Function ConvertPlanVcs

backend/plugins/bamboo/tasks/plan_commit_convertor.go:41–86

(taskCtx plugin.SubTaskContext)

}

func ConvertPlanVcs(taskCtx plugin.SubTaskContext) errors.Error {
	db := taskCtx.GetDal()
	logger := taskCtx.GetLogger()
	rawDataSubTaskArgs, data := CreateRawDataSubTaskArgs(taskCtx, RAW_PLAN_BUILD_TABLE)
	cursor, err := db.Cursor(
		dal.From(&models.BambooPlanBuildVcsRevision{}),
		dal.Join(`left join _tool_bamboo_plan_builds on _tool_bamboo_plan_builds.plan_build_key = _tool_bamboo_plan_build_commits.plan_build_key`),
		dal.Where("_tool_bamboo_plan_build_commits.connection_id = ? and _tool_bamboo_plan_builds.plan_key = ?", data.Options.ConnectionId, data.Options.PlanKey))
	if err != nil {
		return err
	}
	defer cursor.Close()

	planBuildIdGen := didgen.NewDomainIdGenerator(&models.BambooPlanBuild{})
	repoMap := data.Options.GetRepoIdMap()
	converter, err := api.NewDataConverter(api.DataConverterArgs{
		InputRowType:       reflect.TypeOf(models.BambooPlanBuildVcsRevision{}),
		Input:              cursor,
		RawDataSubTaskArgs: *rawDataSubTaskArgs,
		Convert: func(inputRow interface{}) ([]interface{}, errors.Error) {
			line := inputRow.(*models.BambooPlanBuildVcsRevision)
			domainPlanVcs := &devops.CiCDPipelineCommit{
				PipelineId:   planBuildIdGen.Generate(data.Options.ConnectionId, line.PlanBuildKey),
				CommitSha:    line.VcsRevisionKey,
				DisplayTitle: line.DisplayTitle,
				Url:          line.Url,
			}
			domainPlanVcs.RepoId = repoMap[line.RepositoryId]
			fakeRepoUrl, err := generateFakeRepoUrl(data.ApiClient.GetEndpoint(), line.RepositoryId)
			if err != nil {
				logger.Warn(err, "generate fake repo url, endpoint: %s, repo id: %d", data.ApiClient.GetEndpoint(), line.RepositoryId)
			} else {
				domainPlanVcs.RepoUrl = fakeRepoUrl
			}
			return []interface{}{
				domainPlanVcs,
			}, nil
		},
	})

	if err != nil {
		return err
	}

	return converter.Execute()
}