feat(drift-analysis): add total projects errored to analysis run

Author: fernandonogueira

migrations/V20260116005454__add_total_projects_errored.sql

@@ -0,0 +1,2 @@
+ALTER TABLE drift_analysis_run
+    ADD COLUMN total_projects_errored INT NOT NULL DEFAULT 0;

migrations/V20260116010023__backfill_total_projects_errored.sql

@@ -0,0 +1,6 @@
+-- Backfill total_projects_errored from existing project data
+UPDATE drift_analysis_run dar
+SET total_projects_errored = (SELECT COUNT(*)
+                              FROM drift_analysis_project dap
+                              WHERE dap.drift_analysis_run_id = dar.uuid
+                                AND dap.succeeded = false);

pkg/model/dto/analysis_run.go

@@ -7,6 +7,7 @@ type DriftAnalysisRunDTO struct {
 	RepositoryId         int64     `json:"repository_id"`
 	TotalProjects        int32     `json:"total_projects"`
 	TotalProjectsDrifted int32     `json:"total_projects_drifted"`
+	TotalProjectsErrored int32     `json:"total_projects_errored"`
 	DurationMillis       int64     `json:"duration_millis"`
 	CreatedAt            time.Time `json:"created_at"`
 	UpdatedAt            time.Time `json:"updated_at"`

pkg/repository/queries/drift_analysis.sql

@@ -1,6 +1,6 @@
 -- name: CreateDriftAnalysisRun :one
-INSERT INTO drift_analysis_run (uuid, repository_id, total_projects, total_projects_drifted, analysis_duration_millis)
-VALUES (@uuid, @repository_id, @total_projects, @total_projects_drifted, @analysis_duration_millis)
+INSERT INTO drift_analysis_run (uuid, repository_id, total_projects, total_projects_drifted, total_projects_errored, analysis_duration_millis)
+VALUES (@uuid, @repository_id, @total_projects, @total_projects_drifted, @total_projects_errored, @analysis_duration_millis)
 RETURNING *;
 
 -- name: CreateDriftAnalysisProject :one

pkg/repository/queries/drift_analysis.sql.go

@@ -93,13 +93,26 @@ func (d *DriftStateHandler) HandleUpdate(c *fiber.Ctx) error {
 
 	log.Debugf("Received drift state update: %v", state)
 
+	// Use sent value or calculate errored count from project results as fallback
+	var totalErrored int32
+	if state.TotalErrored != nil {
+		totalErrored = *state.TotalErrored
+	} else {
+		for _, project := range state.ProjectResults {
+			if !project.Succeeded {
+				totalErrored++
+			}
+		}
+	}
+
 	var runUUID uuid.UUID
 	err = d.driftAnalysisRepository.WithTx(c.Context(), func(ctx context.Context) error {
 		params := queries.CreateDriftAnalysisRunParams{
 			Uuid:                   uuid.New(),
 			RepositoryID:           repo.ID,
 			TotalProjects:          state.TotalProjects,
 			TotalProjectsDrifted:   state.TotalDrifted,
+			TotalProjectsErrored:   totalErrored,
 			AnalysisDurationMillis: state.Duration.Milliseconds(),
 		}
 

pkg/repository/queries/models.go

@@ -46,6 +46,7 @@ type DriftProjectResult struct {
 type DriftDetectionResult struct {
 	ProjectResults []DriftProjectResult `json:"project_results"`
 	TotalDrifted   int32                `json:"total_drifted"`
+	TotalErrored   *int32               `json:"total_errored,omitempty"`
 	TotalProjects  int32                `json:"total_projects"`
 	TotalChecked   int32                `json:"total_checked"`
 	Duration       time.Duration        `json:"duration"`

pkg/usecase/drift_stream/api.go

@@ -11,6 +11,7 @@ func ToDriftAnalysisRunDTO(run queries.DriftAnalysisRun) dto.DriftAnalysisRunDTO
 		RepositoryId:         run.RepositoryID,
 		TotalProjects:        run.TotalProjects,
 		TotalProjectsDrifted: run.TotalProjectsDrifted,
+		TotalProjectsErrored: run.TotalProjectsErrored,
 		DurationMillis:       run.AnalysisDurationMillis,
 		CreatedAt:            run.CreatedAt,
 		UpdatedAt:            run.UpdatedAt,