Method createRevisions

backend/api/v1/revision_service.go:167–274

(
	ctx context.Context,
	parent string,
	revisions []*v1pb.Revision,
	database *store.DatabaseMessage,
)

}

func (s *RevisionService) createRevisions(
	ctx context.Context,
	parent string,
	revisions []*v1pb.Revision,
	database *store.DatabaseMessage,
) ([]*v1pb.Revision, error) {
	var sheetSha256s []string
	for _, revisionReq := range revisions {
		if revisionReq == nil {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Errorf("request.Revision is not set"))
		}
		// Validate the version format.
		if _, err := model.NewVersion(revisionReq.Version); err != nil {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Wrapf(err, "failed to parse version %q", revisionReq.Version))
		}

		_, sha, err := common.GetProjectResourceIDSheetSha256(revisionReq.Sheet)
		if err != nil {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Wrapf(err, "failed to get sheet from %v", revisionReq.Sheet))
		}
		sheetSha256s = append(sheetSha256s, sha)
	}

	exist, err := s.store.HasSheets(ctx, sheetSha256s...)
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Errorf("failed to check sheets: %v", err))
	}
	if !exist {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("some sheets are not found"))
	}

	var createdRevisions []*v1pb.Revision
	for i, revision := range revisions {
		if revision.TaskRun != "" {
			projectID, planID, stageID, taskID, taskRunID, err := common.GetProjectIDPlanIDStageIDTaskIDTaskRunID(revision.TaskRun)
			if err != nil {
				return nil, connect.NewError(connect.CodeInvalidArgument, errors.Errorf("failed to get taskRun from %q", revision.TaskRun))
			}
			taskRun, err := s.store.GetTaskRunV1(ctx, &store.FindTaskRunMessage{
				Workspace: common.GetWorkspaceIDFromContext(ctx),
				ProjectID: projectID,
				UID:       &taskRunID,
			})
			if err != nil {
				return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to get taskRun"))
			}
			if taskRun == nil {
				return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("taskRun %q not found", revision.TaskRun))
			}
			if taskRun.ProjectID != projectID ||
				taskRun.PlanUID != planID ||
				taskRun.Environment != formatEnvironmentFromStageID(stageID) ||
				taskRun.TaskUID != taskID {
				return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("taskRun %q not found", revision.TaskRun))
			}
		}

		if revision.Type == v1pb.Revision_TYPE_UNSPECIFIED {