Method Create

app/controlplane/pkg/biz/workflow.go:143–258

(ctx context.Context, opts *WorkflowCreateOpts)

}

func (uc *WorkflowUseCase) Create(ctx context.Context, opts *WorkflowCreateOpts) (*Workflow, error) {
	ctx, span := otelx.Start(ctx, workflowTracer, "WorkflowUseCase.Create")
	defer span.End()

	if opts.Name == "" {
		return nil, errors.New("workflow name is required")
	}
	if opts.Project == "" {
		return nil, errors.New("project name is required")
	}
	if opts.OrgID == "" {
		return nil, errors.New("organization ID is required")
	}

	contractName := fmt.Sprintf("%s-%s", opts.Project, opts.Name)

	defaultContract, err := createDefaultContract(contractName)
	if err != nil {
		return nil, fmt.Errorf("failed to create default contract: %w", err)
	}
	opts.DetectedContract = defaultContract

	// Take the raw contract bytes and identify the format and validate it
	if opts.ContractBytes != nil {
		detectedContract, err := identifyUnMarshalAndValidateRawContract(opts.ContractBytes)
		if err != nil {
			return nil, fmt.Errorf("failed to load contract: %w", err)
		}

		opts.DetectedContract = detectedContract
	}

	// validate format of the name and the project
	if err := ValidateIsDNS1123(opts.Name); err != nil {
		return nil, NewErrValidation(err)
	}

	if err := ValidateIsDNS1123(opts.Project); err != nil {
		return nil, NewErrValidation(err)
	}

	// Check if the project already exists to determine if we need to emit a ProjectCreated event
	orgUUID, err := uuid.Parse(opts.OrgID)
	if err != nil {
		return nil, fmt.Errorf("failed to parse org ID %q: %w", opts.OrgID, err)
	}

	// Check if implicit creation is prevented by organization settings
	if opts.ImplicitCreation {
		org, err := uc.orgRepo.FindByID(ctx, orgUUID)
		if err != nil {
			return nil, fmt.Errorf("failed to find organization: %w", err)
		}
		if org == nil {
			return nil, NewErrNotFound("organization")
		}

		if org.PreventImplicitWorkflowCreation {