Automate expectations creation

Add backend automation to create and lifecycle manage expectations
for jobs and operations when due/start times are set, update, or backfilled.
Include triggers, functions, and backfill logic to ensure expectations
exist and evolve, tying into the new monitoring UI and navigation.

X-Lovable-Edit-ID: edt-1e548683-890c-40da-a83e-75f850928ae5

Author: lovable-dev[bot]

supabase/migrations/20251220215802_8032dd7d-b721-42f6-bff3-0c7dab1c97a8.sql

@@ -0,0 +1,18 @@
+
+-- First drop and recreate the constraint
+ALTER TABLE expectations DROP CONSTRAINT IF EXISTS expectations_source_check;
+
+ALTER TABLE expectations ADD CONSTRAINT expectations_source_check 
+CHECK (source = ANY (ARRAY[
+  'erp_sync'::text, 
+  'manual'::text, 
+  'scheduler'::text, 
+  'auto_replan'::text, 
+  'system'::text,
+  'backfill'::text,
+  'job_creation'::text,
+  'job_update'::text,
+  'operation_creation'::text,
+  'operation_update'::text,
+  'due_date_change'::text
+]));

supabase/migrations/20251220215859_3d5dd345-3910-47a1-ae2c-8b080878eb09.sql

@@ -0,0 +1,49 @@
+
+-- Operation trigger using correct column name (operation_name)
+CREATE OR REPLACE FUNCTION public.auto_create_operation_expectation()
+RETURNS TRIGGER
+LANGUAGE plpgsql
+SECURITY DEFINER
+SET search_path = public
+AS $$
+DECLARE
+  v_existing_id uuid;
+BEGIN
+  IF NEW.planned_end IS NOT NULL AND NEW.status NOT IN ('completed') THEN
+    SELECT id INTO v_existing_id
+    FROM expectations
+    WHERE entity_type = 'operation' AND entity_id = NEW.id 
+      AND expectation_type = 'completion_time' AND superseded_by IS NULL;
+    
+    IF v_existing_id IS NULL THEN
+      INSERT INTO expectations (tenant_id, entity_type, entity_id, expectation_type,
+        belief_statement, expected_value, expected_at, source, context)
+      VALUES (NEW.tenant_id, 'operation', NEW.id, 'completion_time',
+        format('Operation %s should complete by %s', NEW.operation_name, to_char(NEW.planned_end, 'YYYY-MM-DD HH24:MI')),
+        jsonb_build_object('status', 'completed', 'operation_name', NEW.operation_name),
+        NEW.planned_end,
+        CASE WHEN TG_OP = 'INSERT' THEN 'operation_creation' ELSE 'operation_update' END,
+        jsonb_build_object('operation_id', NEW.id, 'operation_name', NEW.operation_name));
+    END IF;
+  END IF;
+  RETURN NEW;
+END;
+$$;
+
+DROP TRIGGER IF EXISTS auto_create_operation_expectation_trigger ON operations;
+CREATE TRIGGER auto_create_operation_expectation_trigger
+  AFTER INSERT OR UPDATE OF planned_start, planned_end, status ON operations
+  FOR EACH ROW EXECUTE FUNCTION auto_create_operation_expectation();
+
+-- Backfill operation expectations
+INSERT INTO expectations (tenant_id, entity_type, entity_id, expectation_type,
+  belief_statement, expected_value, expected_at, source, context)
+SELECT o.tenant_id, 'operation', o.id, 'completion_time',
+  format('Operation %s should complete by %s', o.operation_name, to_char(o.planned_end, 'YYYY-MM-DD HH24:MI')),
+  jsonb_build_object('status', 'completed', 'operation_name', o.operation_name),
+  o.planned_end, 'backfill',
+  jsonb_build_object('operation_id', o.id, 'operation_name', o.operation_name, 'backfilled_at', now())
+FROM operations o
+WHERE o.planned_end IS NOT NULL AND o.status NOT IN ('completed')
+  AND NOT EXISTS (SELECT 1 FROM expectations e WHERE e.entity_id = o.id 
+    AND e.entity_type = 'operation' AND e.expectation_type = 'completion_time');

supabase/migrations/20251220215925_ee08a59e-7ab5-4899-99bd-8f23e4a0c6e1.sql

@@ -0,0 +1,12 @@
+
+-- Backfill job expectations
+INSERT INTO expectations (tenant_id, entity_type, entity_id, expectation_type,
+  belief_statement, expected_value, expected_at, source, context)
+SELECT j.tenant_id, 'job', j.id, 'completion_time',
+  format('Job %s should be completed by %s', j.job_number, to_char(j.due_date, 'YYYY-MM-DD HH24:MI')),
+  jsonb_build_object('status', 'completed', 'job_number', j.job_number, 'customer', j.customer),
+  j.due_date, 'backfill',
+  jsonb_build_object('job_id', j.id, 'job_number', j.job_number, 'customer', j.customer)
+FROM jobs j
+WHERE j.due_date IS NOT NULL AND j.deleted_at IS NULL AND j.status NOT IN ('completed')
+  AND NOT EXISTS (SELECT 1 FROM expectations e WHERE e.entity_id = j.id AND e.entity_type = 'job');