Method Update

app/controlplane/pkg/data/workflow.go:229–264

(ctx context.Context, id uuid.UUID, opts *biz.WorkflowUpdateOpts)

}

func (r *WorkflowRepo) Update(ctx context.Context, id uuid.UUID, opts *biz.WorkflowUpdateOpts) (*biz.Workflow, error) {
	ctx, span := otelx.Start(ctx, workflowRepoTracer, "WorkflowRepo.Update")
	defer span.End()

	if opts == nil {
		opts = &biz.WorkflowUpdateOpts{}
	}

	req := r.data.DB.Workflow.UpdateOneID(id).
		SetNillableTeam(opts.Team).
		SetNillablePublic(opts.Public).
		SetNillableDescription(opts.Description).
		SetUpdatedAt(time.Now())

	// Update the contract if provided
	if opts.ContractID != nil {
		contractUUID, err := uuid.Parse(*opts.ContractID)
		if err != nil {
			return nil, err
		}
		req = req.SetContractID(contractUUID)
	}

	wf, err := req.Save(ctx)

	if err != nil {
		if ent.IsConstraintError(err) {
			return nil, biz.NewErrAlreadyExists(err)
		}

		return nil, fmt.Errorf("failed to update workflow: %w", err)
	}

	// Reload the object to include the relations
	return r.FindByID(ctx, wf.ID)
}

func (r *WorkflowRepo) List(ctx context.Context, orgID uuid.UUID, filter *biz.WorkflowListOpts, pagination *pagination.OffsetPaginationOpts) ([]*biz.Workflow, int, error) {
	ctx, span := otelx.Start(ctx, workflowRepoTracer, "WorkflowRepo.List")