send project creation event

Signed-off-by: Miguel Martinez <miguel@chainloop.dev>

Author: migmartri

app/controlplane/pkg/biz/workflow.go

@@ -155,6 +155,15 @@ func (uc *WorkflowUseCase) Create(ctx context.Context, opts *WorkflowCreateOpts)
 		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)
+	}
+
+	existingProject, err := uc.projectRepo.FindProjectByOrgIDAndName(ctx, orgUUID, opts.Project)
+	projectAlreadyExists := err == nil && existingProject != nil
+
 	wf, err := uc.wfRepo.Create(ctx, opts)
 	if err != nil {
 		if IsErrAlreadyExists(err) {
@@ -166,43 +175,44 @@ func (uc *WorkflowUseCase) Create(ctx context.Context, opts *WorkflowCreateOpts)
 
 	// Set project admin if a new project has been created
 	if opts.Owner != nil {
-		orgUUID, err := uuid.Parse(opts.OrgID)
-		if err != nil {
-			return nil, fmt.Errorf("failed to parse org ID %q: %w", opts.OrgID, err)
-		}
 		if err = uc.membershipUC.SetProjectOwner(ctx, orgUUID, wf.ProjectID, *opts.Owner); err != nil {
 			return nil, fmt.Errorf("failed to set project owner: %w", err)
 		}
 	}
 
-	orgUUID, err := uuid.Parse(opts.OrgID)
-	if err != nil {
-		uc.logger.Warn("failed to parse org id", "err", err)
-	} else {
-		// Dispatch events to the audit log regarding the workflow
-		uc.auditorUC.Dispatch(ctx, &events.WorkflowCreated{
-			WorkflowBase: &events.WorkflowBase{
-				WorkflowID:   &wf.ID,
-				WorkflowName: wf.Name,
-				ProjectName:  opts.Project,
+	// Dispatch audit event for project creation if a new project was created
+	if !projectAlreadyExists {
+		uc.auditorUC.Dispatch(ctx, &events.ProjectCreated{
+			ProjectBase: &events.ProjectBase{
+				ProjectID:   &wf.ProjectID,
+				ProjectName: opts.Project,
 			},
-			WorkflowContractID:   &wf.ContractID,
-			WorkflowContractName: wf.ContractName,
-			WorkflowDescription:  &opts.Description,
-			Team:                 &opts.Team,
-			Public:               opts.Public,
 		}, &orgUUID)
+	}
 
-		// Dispatch events to the audit log regarding the contract
-		uc.auditorUC.Dispatch(ctx, &events.WorkflowContractAttached{
-			WorkflowContractBase: &events.WorkflowContractBase{
-				WorkflowContractID:   &wf.ContractID,
-				WorkflowContractName: wf.ContractName,
-			},
+	// Dispatch events to the audit log regarding the workflow
+	uc.auditorUC.Dispatch(ctx, &events.WorkflowCreated{
+		WorkflowBase: &events.WorkflowBase{
 			WorkflowID:   &wf.ID,
 			WorkflowName: wf.Name,
-		}, &orgUUID)
-	}
+			ProjectName:  opts.Project,
+		},
+		WorkflowContractID:   &wf.ContractID,
+		WorkflowContractName: wf.ContractName,
+		WorkflowDescription:  &opts.Description,
+		Team:                 &opts.Team,
+		Public:               opts.Public,
+	}, &orgUUID)
+
+	// Dispatch events to the audit log regarding the contract
+	uc.auditorUC.Dispatch(ctx, &events.WorkflowContractAttached{
+		WorkflowContractBase: &events.WorkflowContractBase{
+			WorkflowContractID:   &wf.ContractID,
+			WorkflowContractName: wf.ContractName,
+		},
+		WorkflowID:   &wf.ID,
+		WorkflowName: wf.Name,
+	}, &orgUUID)
 
 	return wf, nil
 }