feat: post checks to PR commit for dry run results

apps/workspace-engine/pkg/db/queries/deployment_plan.sql

@@ -62,3 +62,38 @@ WHERE id = $1;
 UPDATE deployment_plan
 SET completed_at = NOW()
 WHERE id = $1;
+
+-- name: GetTargetContextByResultID :one
+SELECT
+  t.id AS target_id,
+  t.plan_id,
+  dp.deployment_id,
+  dp.workspace_id,
+  dp.version_tag,
+  dp.version_metadata,
+  w.slug AS workspace_slug,
+  e.name AS environment_name,
+  res.name AS resource_name
+FROM deployment_plan_target_result r
+JOIN deployment_plan_target t ON t.id = r.target_id
+JOIN deployment_plan dp ON dp.id = t.plan_id
+JOIN workspace w ON w.id = dp.workspace_id
+JOIN environment e ON e.id = t.environment_id
+JOIN resource res ON res.id = t.resource_id
+WHERE r.id = $1;
+
+-- name: ListDeploymentPlanTargetResultsByTargetID :many
+SELECT
+  r.id,
+  r.target_id,
+  r.dispatch_context,
+  r.status,
+  r.has_changes,
+  r.current,
+  r.proposed,
+  r.message,
+  r.started_at,
+  r.completed_at
+FROM deployment_plan_target_result r
+WHERE r.target_id = $1
+ORDER BY r.started_at;

apps/workspace-engine/svc/controllers/deploymentplanresult/controller.go

@@ -95,6 +95,10 @@ func (c *Controller) Process(ctx context.Context, item reconcile.Item) (reconcil
 			return reconcile.Result{}, fmt.Errorf("mark result unsupported: %w", updateErr)
 		}
 
+		if checkErr := MaybeUpdateTargetCheck(ctx, c.getter, resultID); checkErr != nil {
+			span.RecordError(checkErr)
+		}
+
 		return reconcile.Result{}, nil
 	}
 
@@ -119,6 +123,10 @@ func (c *Controller) Process(ctx context.Context, item reconcile.Item) (reconcil
 			)
 		}
 
+		if checkErr := MaybeUpdateTargetCheck(ctx, c.getter, resultID); checkErr != nil {
+			span.RecordError(checkErr)
+		}
+
 		return reconcile.Result{}, nil
 	}
 
@@ -169,6 +177,10 @@ func (c *Controller) Process(ctx context.Context, item reconcile.Item) (reconcil
 		return reconcile.Result{}, fmt.Errorf("save completed result: %w", err)
 	}
 
+	if checkErr := MaybeUpdateTargetCheck(ctx, c.getter, resultID); checkErr != nil {
+		span.RecordError(checkErr)
+	}
+
 	return reconcile.Result{}, nil
 }
 

apps/workspace-engine/svc/controllers/deploymentplanresult/controller_test.go

@@ -53,6 +53,20 @@ func (m *mockGetter) GetDeploymentPlanTargetResult(
 	return m.result, m.err
 }
 
+func (m *mockGetter) GetTargetContextByResultID(
+	_ context.Context,
+	_ uuid.UUID,
+) (db.GetTargetContextByResultIDRow, error) {
+	return db.GetTargetContextByResultIDRow{}, nil
+}
+
+func (m *mockGetter) ListDeploymentPlanTargetResultsByTargetID(
+	_ context.Context,
+	_ uuid.UUID,
+) ([]db.ListDeploymentPlanTargetResultsByTargetIDRow, error) {
+	return nil, nil
+}
+
 type completedCall struct {
 	ID     uuid.UUID
 	Status db.DeploymentPlanTargetStatus

apps/workspace-engine/svc/controllers/deploymentplanresult/getters.go

@@ -13,4 +13,14 @@ type Getter interface {
 		ctx context.Context,
 		id uuid.UUID,
 	) (db.DeploymentPlanTargetResult, error)
+
+	GetTargetContextByResultID(
+		ctx context.Context,
+		resultID uuid.UUID,
+	) (db.GetTargetContextByResultIDRow, error)
+
+	ListDeploymentPlanTargetResultsByTargetID(
+		ctx context.Context,
+		targetID uuid.UUID,
+	) ([]db.ListDeploymentPlanTargetResultsByTargetIDRow, error)
 }

apps/workspace-engine/svc/controllers/deploymentplanresult/getters_postgres.go

@@ -20,6 +20,20 @@ func (g *PostgresGetter) GetDeploymentPlanTargetResult(
 	return db.GetQueries(ctx).GetDeploymentPlanTargetResult(ctx, id)
 }
 
+func (g *PostgresGetter) GetTargetContextByResultID(
+	ctx context.Context,
+	resultID uuid.UUID,
+) (db.GetTargetContextByResultIDRow, error) {
+	return db.GetQueries(ctx).GetTargetContextByResultID(ctx, resultID)
+}
+
+func (g *PostgresGetter) ListDeploymentPlanTargetResultsByTargetID(
+	ctx context.Context,
+	targetID uuid.UUID,
+) ([]db.ListDeploymentPlanTargetResultsByTargetIDRow, error) {
+	return db.GetQueries(ctx).ListDeploymentPlanTargetResultsByTargetID(ctx, targetID)
+}
+
 func newRegistry() *jobagents.Registry {
 	registry := jobagents.NewRegistry(nil, nil)
 	registry.Register(