Method BatchUpdateIssuesStatus

backend/api/v1/issue_service.go:1113–1187

BatchUpdateIssuesStatus batch updates issues status.

(ctx context.Context, req *connect.Request[v1pb.BatchUpdateIssuesStatusRequest])

// BatchUpdateIssuesStatus batch updates issues status.
func (s *IssueService) BatchUpdateIssuesStatus(ctx context.Context, req *connect.Request[v1pb.BatchUpdateIssuesStatusRequest]) (*connect.Response[v1pb.BatchUpdateIssuesStatusResponse], error) {
	user, ok := GetUserFromContext(ctx)
	if !ok {
		return nil, connect.NewError(connect.CodeInternal, errors.Errorf("user not found"))
	}

	if len(req.Msg.Issues) == 0 {
		return connect.NewResponse(&v1pb.BatchUpdateIssuesStatusResponse{}), nil
	}

	newStatus, err := convertToAPIIssueStatus(req.Msg.Status)
	if err != nil {
		return nil, connect.NewError(connect.CodeInvalidArgument, errors.Errorf("failed to convert to issue status, err: %v", err))
	}

	// Parse issue names and validate all issues belong to the same project.
	var projectID string
	issueUIDs := make([]int64, 0, len(req.Msg.Issues))
	for i, issueName := range req.Msg.Issues {
		issueProjectID, issueUID, err := common.GetProjectIDIssueUID(issueName)
		if err != nil {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Errorf("invalid issue name %q: %v", issueName, err))
		}

		// Ensure all issues belong to the same project.
		if i == 0 {
			projectID = issueProjectID
		} else if issueProjectID != projectID {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Errorf("all issues must belong to the same project, found %q and %q", projectID, issueProjectID))
		}

		issueUIDs = append(issueUIDs, issueUID)
	}

	// Get project early for webhooks.
	project, err := s.store.GetProject(ctx, &store.FindProjectMessage{Workspace: common.GetWorkspaceIDFromContext(ctx), ResourceID: &projectID})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Errorf("failed to get project: %v", err))
	}
	if project == nil {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("project %q not found", projectID))
	}

	// Batch update issue statuses. This validates project membership, DONE status, and returns old statuses.
	oldIssueStatuses, err := s.store.BatchUpdateIssueStatuses(ctx, projectID, issueUIDs, newStatus)
	if err != nil {
		if common.ErrorCode(err) == common.Invalid {
			return nil, connect.NewError(connect.CodeFailedPrecondition, err)
		}
		return nil, connect.NewError(connect.CodeInternal, errors.Errorf("failed to batch update issues, err: %v", err))
	}

	// Batch create issue comments.
	issueComments := make([]*store.IssueCommentMessage, 0, len(issueUIDs))
	for _, issueUID := range issueUIDs {
		issueComments = append(issueComments, &store.IssueCommentMessage{
			ProjectID: projectID,
			IssueUID:  issueUID,