Function EnrichOptions

backend/plugins/bitbucket_server/impl/impl.go:219–268

(taskCtx plugin.TaskContext,
	op *tasks.BitbucketServerOptions,
	apiClient *helper.ApiClient)

}

func EnrichOptions(taskCtx plugin.TaskContext,
	op *tasks.BitbucketServerOptions,
	apiClient *helper.ApiClient) errors.Error {
	var repo models.BitbucketServerRepo
	// validate the op and set name=owner/repo if this is from advanced mode or bpV100
	err := tasks.ValidateTaskOptions(op)
	if err != nil {
		return err
	}
	logger := taskCtx.GetLogger()
	err = taskCtx.GetDal().First(&repo, dal.Where(
		"connection_id = ? AND bitbucket_id = ?",
		op.ConnectionId, op.FullName))
	if err == nil {
		if op.ScopeConfigId == 0 {
			op.ScopeConfigId = repo.ScopeConfigId
		}
	} else {
		if taskCtx.GetDal().IsErrorNotFound(err) && op.FullName != "" {
			var repo *models.BitbucketServerApiRepo
			repo, err = tasks.GetApiRepo(op, apiClient)
			if err != nil {
				return err
			}
			logger.Debug(fmt.Sprintf("Current repo: %s", repo.Slug))
			scope := repo.ConvertApiScope().(*models.BitbucketServerRepo)
			scope.ConnectionId = op.ConnectionId
			err = taskCtx.GetDal().CreateIfNotExist(scope)
			if err != nil {
				return err
			}
		} else {
			return errors.Default.Wrap(err, fmt.Sprintf("fail to find repo %s", op.FullName))
		}
	}
	// Set scope config if it's nil, this has lower priority
	if op.BitbucketServerScopeConfig == nil && op.ScopeConfigId != 0 {
		var scopeConfig models.BitbucketServerScopeConfig
		db := taskCtx.GetDal()
		err = db.First(&scopeConfig, dal.Where("id = ?", repo.ScopeConfigId))
		if err != nil && !db.IsErrorNotFound(err) {
			return errors.BadInput.Wrap(err, "fail to get scopeConfig")
		}
		op.BitbucketServerScopeConfig = &scopeConfig
	}
	if op.BitbucketServerScopeConfig == nil && op.ScopeConfigId == 0 {
		op.BitbucketServerScopeConfig = new(models.BitbucketServerScopeConfig)
	}
	return err
}