Method Update

app/controlplane/pkg/biz/workflow.go:260–312

(ctx context.Context, orgID, workflowID string, opts *WorkflowUpdateOpts)

}

func (uc *WorkflowUseCase) Update(ctx context.Context, orgID, workflowID string, opts *WorkflowUpdateOpts) (*Workflow, error) {
	ctx, span := otelx.Start(ctx, workflowTracer, "WorkflowUseCase.Update")
	defer span.End()

	if opts == nil {
		return nil, NewErrValidationStr("no updates provided")
	}

	orgUUID, err := uuid.Parse(orgID)
	if err != nil {
		return nil, NewErrInvalidUUID(err)
	}

	workflowUUID, err := uuid.Parse(workflowID)
	if err != nil {
		return nil, NewErrInvalidUUID(err)
	}

	// make sure that the workflow is for the provided org
	var preUpdateWorkflow *Workflow
	if preUpdateWorkflow, err = uc.wfRepo.GetOrgScoped(ctx, orgUUID, workflowUUID); err != nil {
		return nil, err
	} else if preUpdateWorkflow == nil {
		return nil, NewErrNotFound("workflow in organization")
	}

	// Double check that the contract exists
	var wfContract *WorkflowContract
	if opts.ContractID != nil {
		if wfContract, err = uc.contractUC.FindByIDInOrg(ctx, orgID, *opts.ContractID); err != nil {
			return nil, err
		} else if wfContract == nil {
			return nil, NewErrNotFound("contract")
		}
	}

	wf, err := uc.wfRepo.Update(ctx, workflowUUID, opts)
	if err != nil {
		if IsErrAlreadyExists(err) {
			return nil, NewErrValidationStr("name already taken")
		}

		return nil, fmt.Errorf("failed to update workflow: %w", err)
	} else if wf == nil {
		return nil, NewErrNotFound("workflow")
	}

	// Dispatch events to the audit log regarding the workflow
	uc.handleWorkflowUpdateEvents(ctx, wf, preUpdateWorkflow, opts, wfContract, orgUUID)

	otelx.RecordError(span, err)
	return wf, err
}

// handleWorkflowUpdateEvents dispatches events to the audit log regarding the workflow
func (uc *WorkflowUseCase) handleWorkflowUpdateEvents(ctx context.Context, wf *Workflow, preUpdateWorkflow *Workflow, opts *WorkflowUpdateOpts, newWfContract *WorkflowContract, orgUUID uuid.UUID) {