chore(OMN-14974): vendor delegation reconcile migration

docker/migrations/forward/nodes/node_projection_delegation/0009a_delegation_events_legacy_schema_reconcile.sql

@@ -0,0 +1,125 @@
+-- OMN-14974: reconcile warm delegation_events tables created before the
+-- contract-driven projection schema. This migration intentionally sorts after
+-- the base/metrics migrations and before views that require model_name.
+
+ALTER TABLE delegation_events
+    ADD COLUMN IF NOT EXISTS model_name TEXT NOT NULL DEFAULT '',
+    ADD COLUMN IF NOT EXISTS llm_call_id TEXT,
+    ADD COLUMN IF NOT EXISTS prompt_text TEXT,
+    ADD COLUMN IF NOT EXISTS response_text TEXT,
+    ADD COLUMN IF NOT EXISTS tokens_to_compliance INT NOT NULL DEFAULT 0,
+    ADD COLUMN IF NOT EXISTS compliance_attempts INT NOT NULL DEFAULT 1,
+    ADD COLUMN IF NOT EXISTS quality_gates_checked_jsonb JSONB,
+    ADD COLUMN IF NOT EXISTS quality_gates_failed_jsonb JSONB;
+
+-- Old tables required callers to provide id explicitly, while every current
+-- projection writer relies on the canonical UUID default.
+ALTER TABLE delegation_events
+    ALTER COLUMN id SET DEFAULT gen_random_uuid();
+
+-- Legacy installations stored gate labels directly in the
+-- quality_gates_checked/failed JSONB columns. Current handlers store integer
+-- counts there and preserve the labels in the *_jsonb evidence columns.
+DO $reconcile_checked$
+DECLARE
+    current_type TEXT;
+BEGIN
+    SELECT data_type
+      INTO current_type
+      FROM information_schema.columns
+     WHERE table_schema = current_schema()
+       AND table_name = 'delegation_events'
+       AND column_name = 'quality_gates_checked';
+
+    IF current_type IS NULL THEN
+        ALTER TABLE delegation_events
+            ADD COLUMN quality_gates_checked INTEGER NOT NULL DEFAULT 0;
+    ELSIF current_type = 'jsonb' THEN
+        UPDATE delegation_events
+           SET quality_gates_checked_jsonb =
+               COALESCE(quality_gates_checked_jsonb, quality_gates_checked)
+         WHERE quality_gates_checked IS NOT NULL;
+
+        ALTER TABLE delegation_events
+            ALTER COLUMN quality_gates_checked DROP DEFAULT;
+        EXECUTE $sql$
+            ALTER TABLE delegation_events
+                ALTER COLUMN quality_gates_checked TYPE INTEGER
+                USING (
+                    CASE
+                        WHEN quality_gates_checked IS NULL THEN 0
+                        WHEN jsonb_typeof(quality_gates_checked) = 'array'
+                            THEN jsonb_array_length(quality_gates_checked)
+                        WHEN jsonb_typeof(quality_gates_checked) = 'number'
+                             AND (quality_gates_checked #>> '{}') ~ '^[0-9]+$'
+                            THEN (quality_gates_checked #>> '{}')::INTEGER
+                        ELSE 0
+                    END
+                )
+        $sql$;
+    ELSIF current_type <> 'integer' THEN
+        RAISE EXCEPTION
+            'delegation_events.quality_gates_checked has unsupported type %',
+            current_type;
+    END IF;
+
+    UPDATE delegation_events
+       SET quality_gates_checked = 0
+     WHERE quality_gates_checked IS NULL;
+    ALTER TABLE delegation_events
+        ALTER COLUMN quality_gates_checked SET DEFAULT 0,
+        ALTER COLUMN quality_gates_checked SET NOT NULL;
+END
+$reconcile_checked$;
+
+DO $reconcile_failed$
+DECLARE
+    current_type TEXT;
+BEGIN
+    SELECT data_type
+      INTO current_type
+      FROM information_schema.columns
+     WHERE table_schema = current_schema()
+       AND table_name = 'delegation_events'
+       AND column_name = 'quality_gates_failed';
+
+    IF current_type IS NULL THEN
+        ALTER TABLE delegation_events
+            ADD COLUMN quality_gates_failed INTEGER NOT NULL DEFAULT 0;
+    ELSIF current_type = 'jsonb' THEN
+        UPDATE delegation_events
+           SET quality_gates_failed_jsonb =
+               COALESCE(quality_gates_failed_jsonb, quality_gates_failed)
+         WHERE quality_gates_failed IS NOT NULL;
+
+        ALTER TABLE delegation_events
+            ALTER COLUMN quality_gates_failed DROP DEFAULT;
+        EXECUTE $sql$
+            ALTER TABLE delegation_events
+                ALTER COLUMN quality_gates_failed TYPE INTEGER
+                USING (
+                    CASE
+                        WHEN quality_gates_failed IS NULL THEN 0
+                        WHEN jsonb_typeof(quality_gates_failed) = 'array'
+                            THEN jsonb_array_length(quality_gates_failed)
+                        WHEN jsonb_typeof(quality_gates_failed) = 'number'
+                             AND (quality_gates_failed #>> '{}') ~ '^[0-9]+$'
+                            THEN (quality_gates_failed #>> '{}')::INTEGER
+                        ELSE 0
+                    END
+                )
+        $sql$;
+    ELSIF current_type <> 'integer' THEN
+        RAISE EXCEPTION
+            'delegation_events.quality_gates_failed has unsupported type %',
+            current_type;
+    END IF;
+
+    UPDATE delegation_events
+       SET quality_gates_failed = 0
+     WHERE quality_gates_failed IS NULL;
+    ALTER TABLE delegation_events
+        ALTER COLUMN quality_gates_failed SET DEFAULT 0,
+        ALTER COLUMN quality_gates_failed SET NOT NULL;
+END
+$reconcile_failed$;