feat: add project events

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

Author: migmartri

app/controlplane/pkg/biz/auditor.go

@@ -73,12 +73,14 @@ func (uc *AuditorUseCase) Dispatch(ctx context.Context, entry auditor.LogEntry,
 
 	payload, err := auditor.GenerateAuditEvent(entry, opts...)
 	if err != nil {
+		uc.log.Error("failed to generate audit event", "error", err)
 		sentry.CaptureException(fmt.Errorf("failed to generate audit event: %w", err))
 		return
 	}
 
 	// Send event to event bus
 	if err := uc.publisher.Publish(payload); err != nil {
+		uc.log.Error("failed to publish event", "error", err)
 		sentry.CaptureException(fmt.Errorf("failed to publish event: %w", err))
 	}
 }

app/controlplane/pkg/biz/projectversion.go

@@ -38,6 +38,7 @@ type ProjectVersion struct {
 	CreatedAt *time.Time
 	// ReleasedAt is the time when the version was released.
 	ReleasedAt *time.Time
+	ProjectID  uuid.UUID
 }
 
 type ProjectVersionRepo interface {

app/controlplane/pkg/biz/workflow.go

@@ -161,6 +161,8 @@ func (uc *WorkflowUseCase) Create(ctx context.Context, opts *WorkflowCreateOpts)
 		return nil, fmt.Errorf("failed to parse org ID %q: %w", opts.OrgID, err)
 	}
 
+	existingProject, _ := uc.projectRepo.FindProjectByOrgIDAndName(ctx, orgUUID, opts.Project)
+
 	wf, err := uc.wfRepo.Create(ctx, opts)
 	if err != nil {
 		if IsErrAlreadyExists(err) {
@@ -177,11 +179,6 @@ func (uc *WorkflowUseCase) Create(ctx context.Context, opts *WorkflowCreateOpts)
 		}
 	}
 
-	existingProject, err := uc.projectRepo.FindProjectByOrgIDAndName(ctx, orgUUID, opts.Project)
-	if err != nil {
-		return nil, fmt.Errorf("failed to find project: %w", err)
-	}
-
 	// Dispatch audit event for project creation if a new project was created
 	if existingProject == nil {
 		uc.auditorUC.Dispatch(ctx, &events.ProjectCreated{

app/controlplane/pkg/biz/workflowrun.go

@@ -1,5 +1,5 @@
 //
-// Copyright 2024 The Chainloop Authors.
+// Copyright 2024-2025 The Chainloop Authors.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -80,6 +80,7 @@ const (
 
 type WorkflowRunRepoCreateResult struct {
 	Run            *WorkflowRun
+	Project        *Project
 	VersionCreated bool
 }
 
@@ -247,16 +248,16 @@ func (uc *WorkflowRunUseCase) Create(ctx context.Context, opts *WorkflowRunCreat
 	}
 
 	// Dispatch audit event for project version creation if a new version was created
-	if result.VersionCreated && result.Run != nil && result.Run.Workflow != nil && uc.auditorUC != nil {
+	if result.VersionCreated && uc.auditorUC != nil && result.Project != nil {
 		uc.auditorUC.Dispatch(ctx, &events.ProjectVersionCreated{
 			ProjectBase: &events.ProjectBase{
-				ProjectID:   &result.Run.Workflow.ProjectID,
-				ProjectName: result.Run.Workflow.Project,
+				ProjectID:   &result.Project.ID,
+				ProjectName: result.Project.Name,
 			},
 			VersionID:  &result.Run.ProjectVersion.ID,
 			Version:    result.Run.ProjectVersion.Version,
 			Prerelease: result.Run.ProjectVersion.Prerelease,
-		}, &result.Run.Workflow.OrgID)
+		}, &result.Project.OrgID)
 	}
 
 	return result.Run, nil

app/controlplane/pkg/data/projectversion.go

@@ -126,6 +126,7 @@ func entProjectVersionToBiz(v *ent.ProjectVersion) *biz.ProjectVersion {
 		TotalWorkflowRuns: v.WorkflowRunCount,
 		CreatedAt:         toTimePtr(v.CreatedAt),
 		ReleasedAt:        toTimePtr(v.ReleasedAt),
+		ProjectID:         v.ProjectID,
 	}
 
 	return pv

app/controlplane/pkg/data/workflowrun.go

@@ -26,6 +26,7 @@ import (
 	"github.com/chainloop-dev/chainloop/app/controlplane/pkg/data/ent"
 	"github.com/chainloop-dev/chainloop/app/controlplane/pkg/data/ent/attestation"
 	"github.com/chainloop-dev/chainloop/app/controlplane/pkg/data/ent/predicate"
+	"github.com/chainloop-dev/chainloop/app/controlplane/pkg/data/ent/project"
 	"github.com/chainloop-dev/chainloop/app/controlplane/pkg/data/ent/projectversion"
 	"github.com/chainloop-dev/chainloop/app/controlplane/pkg/data/ent/workflow"
 	"github.com/chainloop-dev/chainloop/app/controlplane/pkg/data/ent/workflowrun"
@@ -124,9 +125,15 @@ func (r *WorkflowRunRepo) Create(ctx context.Context, opts *biz.WorkflowRunRepoC
 		return nil, fmt.Errorf("reloading project version: %w", err)
 	}
 
+	project, err := r.data.DB.Project.Query().Where(project.ID(wf.ProjectID)).First(ctx)
+	if err != nil {
+		return nil, fmt.Errorf("reloading project: %w", err)
+	}
+
 	run.ProjectVersion = entProjectVersionToBiz(version)
 
 	return &biz.WorkflowRunRepoCreateResult{
+		Project:        entProjectToBiz(project),
 		Run:            run,
 		VersionCreated: versionCreated,
 	}, nil