feat: demo - prepare final deployment

Author: jumski

apps/demo/supabase/config.toml

@@ -348,17 +348,6 @@ s3_access_key = "env(S3_ACCESS_KEY)"
 # Configures AWS_SECRET_ACCESS_KEY for S3 bucket
 s3_secret_key = "env(S3_SECRET_KEY)"
 
-[functions.test_flow_worker]
-enabled = true
-verify_jwt = false
-import_map = "./functions/test_flow_worker/deno.json"
-# Uncomment to specify a custom file path to the entrypoint.
-# Supported file extensions are: .ts, .js, .mjs, .jsx, .tsx
-entrypoint = "./functions/test_flow_worker/index.ts"
-# Specifies static files to be bundled with the function. Supports glob patterns.
-# For example, if you want to serve static HTML pages in your function:
-# static_files = [ "./functions/test_flow_worker/*.html" ]
-
 [functions.article_flow_worker]
 enabled = true
 verify_jwt = false

apps/demo/supabase/functions/test_flow_worker/.npmrc

@@ -7,7 +7,9 @@ GRANT SELECT ON pgflow.flows TO anon;
 GRANT SELECT ON pgflow.runs TO anon;
 GRANT SELECT ON pgflow.steps TO anon;
 GRANT SELECT ON pgflow.step_states TO anon;
+GRANT SELECT ON pgflow.step_tasks TO anon;
 GRANT SELECT ON pgflow.deps TO anon;
+GRANT SELECT ON pgflow.workers TO anon;
 
 -- Enable real-time for anon role
 ALTER PUBLICATION supabase_realtime ADD TABLE pgflow.runs;

apps/demo/supabase/functions/test_flow_worker/deno.json

@@ -0,0 +1,32 @@
+-- Cleanup any orphaned pgmq queues from incomplete resets
+-- This ensures a clean slate before flow migrations run
+
+DO $$
+DECLARE
+  queue_record RECORD;
+BEGIN
+  -- Drop any existing queues that might be orphaned
+  -- This handles the case where DROP EXTENSION pgmq didn't cascade properly
+  FOR queue_record IN
+    SELECT queue_name
+    FROM pgmq.list_queues()
+  LOOP
+    -- Use pgmq's built-in drop function to safely remove the queue
+    PERFORM pgmq.drop_queue(queue_record.queue_name);
+
+    RAISE NOTICE 'Dropped orphaned queue: %', queue_record.queue_name;
+  END LOOP;
+
+  -- Also drop any orphaned sequences that might exist without tables
+  FOR queue_record IN
+    SELECT sequence_name
+    FROM information_schema.sequences
+    WHERE sequence_schema = 'pgmq'
+      AND sequence_name LIKE 'q_%_msg_id_seq'
+  LOOP
+    EXECUTE format('DROP SEQUENCE IF EXISTS pgmq.%I CASCADE', queue_record.sequence_name);
+
+    RAISE NOTICE 'Dropped orphaned sequence: %', queue_record.sequence_name;
+  END LOOP;
+
+END $$;