feat(data): Adds latest_run and updated_at fields to workflow model

app/controlplane/pkg/data/ent/migrate/migrations/20241112093035.sql

@@ -0,0 +1,16 @@
+-- Modify "workflows" table
+ALTER TABLE "workflows" ADD COLUMN "updated_at" timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP, ADD COLUMN "latest_run" uuid NULL, ADD CONSTRAINT "workflows_workflow_runs_latest_workflow_run" FOREIGN KEY ("latest_run") REFERENCES "workflow_runs" ("id") ON UPDATE NO ACTION ON DELETE SET NULL;
+
+-- This query modifies all existing Workflows to have the latest_run set to the most recent run
+WITH ranked_runs AS (
+    SELECT wr.*,
+           ROW_NUMBER() OVER (PARTITION BY wr.workflow_workflowruns ORDER BY wr.created_at DESC) AS run_rank
+    FROM workflow_runs wr
+             JOIN workflows w ON wr.workflow_workflowruns = w.id
+)
+UPDATE workflows w
+SET latest_run = rr.id,
+    updated_at = CURRENT_TIMESTAMP
+FROM ranked_runs rr
+WHERE rr.run_rank = 1
+  AND w.id = rr.workflow_workflowruns;

app/controlplane/pkg/data/ent/migrate/migrations/atlas.sum

@@ -1,4 +1,4 @@
-h1:1T7gv7Lcd8qIpPZUQuXQm5N3/NMypjjLzgzI//wb0jE=
+h1:pHdF6up5OQHLlGTE7H4+pns0dc5ISfZKp0NHKCa6R1M=
 20230706165452_init-schema.sql h1:VvqbNFEQnCvUVyj2iDYVQQxDM0+sSXqocpt/5H64k8M=
 20230710111950-cas-backend.sql h1:A8iBuSzZIEbdsv9ipBtscZQuaBp3V5/VMw7eZH6GX+g=
 20230712094107-cas-backends-workflow-runs.sql h1:a5rzxpVGyd56nLRSsKrmCFc9sebg65RWzLghKHh5xvI=
@@ -60,3 +60,4 @@ h1:1T7gv7Lcd8qIpPZUQuXQm5N3/NMypjjLzgzI//wb0jE=
 20241104110642.sql h1:zy1jgVPvHklL1o6EtgK104u1juXGxZMPIJfBzAPX9H8=
 20241104122145.sql h1:Y8P3QxXUtM/zOmHIl+3H9j5RQWZtknCiZPgj1HgrbOQ=
 20241107213854.sql h1:QqJSP0a0U1VMeYWmcXphUvJaF5SE22i99vRWJGUcGOU=
+20241112093035.sql h1:ccnLSbDjlsVXu7nB30bnR/iIN4MexNi8gI+XkQtVTpA=

app/controlplane/pkg/data/ent/migrate/schema.go

@@ -410,12 +410,14 @@ var (
 		{Name: "team", Type: field.TypeString, Nullable: true},
 		{Name: "runs_count", Type: field.TypeInt, Default: 0},
 		{Name: "created_at", Type: field.TypeTime, Default: "CURRENT_TIMESTAMP"},
+		{Name: "updated_at", Type: field.TypeTime, Default: "CURRENT_TIMESTAMP"},
 		{Name: "deleted_at", Type: field.TypeTime, Nullable: true},
 		{Name: "public", Type: field.TypeBool, Default: false},
 		{Name: "description", Type: field.TypeString, Nullable: true},
 		{Name: "organization_id", Type: field.TypeUUID},
 		{Name: "project_id", Type: field.TypeUUID},
 		{Name: "workflow_contract", Type: field.TypeUUID},
+		{Name: "latest_run", Type: field.TypeUUID, Nullable: true},
 	}
 	// WorkflowsTable holds the schema information for the "workflows" table.
 	WorkflowsTable = &schema.Table{
@@ -425,36 +427,42 @@ var (
 		ForeignKeys: []*schema.ForeignKey{
 			{
 				Symbol:     "workflows_organizations_workflows",
-				Columns:    []*schema.Column{WorkflowsColumns[9]},
+				Columns:    []*schema.Column{WorkflowsColumns[10]},
 				RefColumns: []*schema.Column{OrganizationsColumns[0]},
 				OnDelete:   schema.Cascade,
 			},
 			{
 				Symbol:     "workflows_projects_workflows",
-				Columns:    []*schema.Column{WorkflowsColumns[10]},
+				Columns:    []*schema.Column{WorkflowsColumns[11]},
 				RefColumns: []*schema.Column{ProjectsColumns[0]},
 				OnDelete:   schema.NoAction,
 			},
 			{
 				Symbol:     "workflows_workflow_contracts_contract",
-				Columns:    []*schema.Column{WorkflowsColumns[11]},
+				Columns:    []*schema.Column{WorkflowsColumns[12]},
 				RefColumns: []*schema.Column{WorkflowContractsColumns[0]},
 				OnDelete:   schema.NoAction,
 			},
+			{
+				Symbol:     "workflows_workflow_runs_latest_workflow_run",
+				Columns:    []*schema.Column{WorkflowsColumns[13]},
+				RefColumns: []*schema.Column{WorkflowRunsColumns[0]},
+				OnDelete:   schema.SetNull,
+			},
 		},
 		Indexes: []*schema.Index{
 			{
 				Name:    "workflow_name_organization_id_project_id",
 				Unique:  true,
-				Columns: []*schema.Column{WorkflowsColumns[1], WorkflowsColumns[9], WorkflowsColumns[10]},
+				Columns: []*schema.Column{WorkflowsColumns[1], WorkflowsColumns[10], WorkflowsColumns[11]},
 				Annotation: &entsql.IndexAnnotation{
 					Where: "deleted_at IS NULL",
 				},
 			},
 			{
 				Name:    "workflow_organization_id_id",
 				Unique:  true,
-				Columns: []*schema.Column{WorkflowsColumns[9], WorkflowsColumns[0]},
+				Columns: []*schema.Column{WorkflowsColumns[10], WorkflowsColumns[0]},
 				Annotation: &entsql.IndexAnnotation{
 					Where: "deleted_at IS NULL",
 				},
@@ -715,6 +723,7 @@ func init() {
 	WorkflowsTable.ForeignKeys[0].RefTable = OrganizationsTable
 	WorkflowsTable.ForeignKeys[1].RefTable = ProjectsTable
 	WorkflowsTable.ForeignKeys[2].RefTable = WorkflowContractsTable
+	WorkflowsTable.ForeignKeys[3].RefTable = WorkflowRunsTable
 	WorkflowContractsTable.ForeignKeys[0].RefTable = OrganizationsTable
 	WorkflowContractVersionsTable.ForeignKeys[0].RefTable = WorkflowContractsTable
 	WorkflowRunsTable.ForeignKeys[0].RefTable = ProjectVersionsTable