Method CreateIssue

backend/store/issue.go:154–217

CreateIssue creates a new issue.

(ctx context.Context, create *IssueMessage)

// CreateIssue creates a new issue.
func (s *Store) CreateIssue(ctx context.Context, create *IssueMessage) (*IssueMessage, error) {
	create.Status = storepb.Issue_OPEN
	if create.Payload != nil {
		create.Payload.Labels = CanonicalizeIssueLabels(create.Payload.Labels)
	}
	payload, err := protojson.Marshal(create.Payload)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to marshal issue payload")
	}
	tsVector := getTSVector(fmt.Sprintf("%s %s", create.Title, create.Description))

	tx, err := s.GetDB().BeginTx(ctx, nil)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to begin tx")
	}
	defer tx.Rollback()

	nextID, err := nextProjectID(ctx, tx, "issue", create.ProjectID)
	if err != nil {
		return nil, err
	}

	q := qb.Q().Space(`
		INSERT INTO issue (
			id,
			creator,
			project,
			plan_id,
			name,
			status,
			type,
			description,
			payload,
			ts_vector
		)
		VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
		nextID,
		create.CreatorEmail,
		create.ProjectID,
		create.PlanUID,
		create.Title,
		create.Status.String(),
		create.Type.String(),
		create.Description,
		payload,
		tsVector,
	)

	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	if _, err := tx.ExecContext(ctx, query, args...); err != nil {
		return nil, err
	}

	if err := tx.Commit(); err != nil {