chore: add verify-gen-types task and update database types with timestamp fields

- Introduced verify-gen-types to ensure database types are up-to-date
- Updated database types to include created_at, started_at, completed_at, failed_at, queued_at
fields
- Modified relevant type definitions for consistency and completeness

Author: jumski

pkgs/core/project.json

@@ -176,6 +176,7 @@
     },
     "test:vitest": {
       "executor": "@nx/vite:test",
+      "dependsOn": ["build", "verify-gen-types"],
       "outputs": ["{workspaceRoot}/coverage/{projectRoot}"],
       "options": {
         "passWithNoTests": true,
@@ -208,6 +209,25 @@
         "parallel": false
       },
       "cache": true
+    },
+    "verify-gen-types": {
+      "executor": "nx:run-commands",
+      "dependsOn": ["verify-migrations"],
+      "inputs": ["migrations", "databaseTypes"],
+      "outputs": ["{projectRoot}/.nx-inputs/verify-gen-types.txt"],
+      "options": {
+        "cwd": "{projectRoot}",
+        "commands": [
+          "mkdir -p .nx-inputs",
+          "echo 'Verifying database types are up-to-date...'",
+          "cp src/database-types.ts .nx-inputs/database-types.ts.backup",
+          "supabase gen types --local --schema pgflow --schema pgmq > .nx-inputs/database-types.ts.new",
+          "diff .nx-inputs/database-types.ts.backup .nx-inputs/database-types.ts.new > .nx-inputs/verify-gen-types.txt 2>&1 || (echo 'ERROR: Database types are out of date! Run \"nx gen-types core\" to update them.' && exit 1)",
+          "echo 'Database types are up-to-date' > .nx-inputs/verify-gen-types.txt"
+        ],
+        "parallel": false
+      },
+      "cache": true
     }
   }
 }

pkgs/core/src/database-types.ts

@@ -11,16 +11,19 @@ export type Database = {
     Tables: {
       deps: {
         Row: {
+          created_at: string
           dep_slug: string
           flow_slug: string
           step_slug: string
         }
         Insert: {
+          created_at?: string
           dep_slug: string
           flow_slug: string
           step_slug: string
         }
         Update: {
+          created_at?: string
           dep_slug?: string
           flow_slug?: string
           step_slug?: string
@@ -51,18 +54,21 @@ export type Database = {
       }
       flows: {
         Row: {
+          created_at: string
           flow_slug: string
           opt_base_delay: number
           opt_max_attempts: number
           opt_timeout: number
         }
         Insert: {
+          created_at?: string
           flow_slug: string
           opt_base_delay?: number
           opt_max_attempts?: number
           opt_timeout?: number
         }
         Update: {
+          created_at?: string
           flow_slug?: string
           opt_base_delay?: number
           opt_max_attempts?: number
@@ -72,27 +78,36 @@ export type Database = {
       }
       runs: {
         Row: {
+          completed_at: string | null
+          failed_at: string | null
           flow_slug: string
           input: Json
           output: Json | null
           remaining_steps: number
           run_id: string
+          started_at: string
           status: string
         }
         Insert: {
+          completed_at?: string | null
+          failed_at?: string | null
           flow_slug: string
           input: Json
           output?: Json | null
           remaining_steps?: number
           run_id?: string
+          started_at?: string
           status?: string
         }
         Update: {
+          completed_at?: string | null
+          failed_at?: string | null
           flow_slug?: string
           input?: Json
           output?: Json | null
           remaining_steps?: number
           run_id?: string
+          started_at?: string
           status?: string
         }
         Relationships: [
@@ -107,26 +122,38 @@ export type Database = {
       }
       step_states: {
         Row: {
+          completed_at: string | null
+          created_at: string
+          failed_at: string | null
           flow_slug: string
           remaining_deps: number
           remaining_tasks: number
           run_id: string
+          started_at: string | null
           status: string
           step_slug: string
         }
         Insert: {
+          completed_at?: string | null
+          created_at?: string
+          failed_at?: string | null
           flow_slug: string
           remaining_deps?: number
           remaining_tasks?: number
           run_id: string
+          started_at?: string | null
           status?: string
           step_slug: string
         }
         Update: {
+          completed_at?: string | null
+          created_at?: string
+          failed_at?: string | null
           flow_slug?: string
           remaining_deps?: number
           remaining_tasks?: number
           run_id?: string
+          started_at?: string | null
           status?: string
           step_slug?: string
         }
@@ -157,32 +184,41 @@ export type Database = {
       step_tasks: {
         Row: {
           attempts_count: number
+          completed_at: string | null
           error_message: string | null
+          failed_at: string | null
           flow_slug: string
           message_id: number | null
           output: Json | null
+          queued_at: string
           run_id: string
           status: string
           step_slug: string
           task_index: number
         }
         Insert: {
           attempts_count?: number
+          completed_at?: string | null
           error_message?: string | null
+          failed_at?: string | null
           flow_slug: string
           message_id?: number | null
           output?: Json | null
+          queued_at?: string
           run_id: string
           status?: string
           step_slug: string
           task_index?: number
         }
         Update: {
           attempts_count?: number
+          completed_at?: string | null
           error_message?: string | null
+          failed_at?: string | null
           flow_slug?: string
           message_id?: number | null
           output?: Json | null
+          queued_at?: string
           run_id?: string
           status?: string
           step_slug?: string
@@ -214,29 +250,35 @@ export type Database = {
       }
       steps: {
         Row: {
+          created_at: string
           deps_count: number
           flow_slug: string
           opt_base_delay: number | null
           opt_max_attempts: number | null
           opt_timeout: number | null
+          step_index: number
           step_slug: string
           step_type: string
         }
         Insert: {
+          created_at?: string
           deps_count?: number
           flow_slug: string
           opt_base_delay?: number | null
           opt_max_attempts?: number | null
           opt_timeout?: number | null
+          step_index?: number
           step_slug: string
           step_type?: string
         }
         Update: {
+          created_at?: string
           deps_count?: number
           flow_slug?: string
           opt_base_delay?: number | null
           opt_max_attempts?: number | null
           opt_timeout?: number | null
+          step_index?: number
           step_slug?: string
           step_type?: string
         }
@@ -300,11 +342,13 @@ export type Database = {
               timeout?: number
             }
         Returns: {
+          created_at: string
           deps_count: number
           flow_slug: string
           opt_base_delay: number | null
           opt_max_attempts: number | null
           opt_timeout: number | null
+          step_index: number
           step_slug: string
           step_type: string
         }
@@ -322,10 +366,13 @@ export type Database = {
         }
         Returns: {
           attempts_count: number
+          completed_at: string | null
           error_message: string | null
+          failed_at: string | null
           flow_slug: string
           message_id: number | null
           output: Json | null
+          queued_at: string
           run_id: string
           status: string
           step_slug: string
@@ -340,6 +387,7 @@ export type Database = {
           timeout?: number
         }
         Returns: {
+          created_at: string
           flow_slug: string
           opt_base_delay: number
           opt_max_attempts: number
@@ -355,10 +403,13 @@ export type Database = {
         }
         Returns: {
           attempts_count: number
+          completed_at: string | null
           error_message: string | null
+          failed_at: string | null
           flow_slug: string
           message_id: number | null
           output: Json | null
+          queued_at: string
           run_id: string
           status: string
           step_slug: string
@@ -397,11 +448,14 @@ export type Database = {
       start_flow: {
         Args: { flow_slug: string; input: Json }
         Returns: {
+          completed_at: string | null
+          failed_at: string | null
           flow_slug: string
           input: Json
           output: Json | null
           remaining_steps: number
           run_id: string
+          started_at: string
           status: string
         }[]
       }