fix(sync-engine): use schema-scoped enum checks in migrations

Fix enum existence checks to be schema-scoped by joining pg_type
with pg_namespace. Previously, if an enum with the same name existed
in the public schema, the migration would skip creating it in the
stripe schema, causing table creation to fail.

Affected migrations:
- 0003_prices.sql (pricing_type, pricing_tiers)
- 0004_subscriptions.sql (subscription_status)
- 0005_invoices.sql (invoice_status)
- 0024_subscription_schedules.sql (subscription_schedule_status)

Closes #191

Author: cescox

packages/sync-engine/src/database/migrations/0003_prices.sql

@@ -1,12 +1,19 @@
 DO $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'pricing_type') THEN
+    IF NOT EXISTS (
+        SELECT 1 FROM pg_type t
+        JOIN pg_namespace n ON t.typnamespace = n.oid
+        WHERE t.typname = 'pricing_type' AND n.nspname = 'stripe'
+    ) THEN
         create type "stripe"."pricing_type" as enum ('one_time', 'recurring');
     END IF;
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'pricing_tiers') THEN
-      create type "stripe"."pricing_tiers" as enum ('graduated', 'volume');
+    IF NOT EXISTS (
+        SELECT 1 FROM pg_type t
+        JOIN pg_namespace n ON t.typnamespace = n.oid
+        WHERE t.typname = 'pricing_tiers' AND n.nspname = 'stripe'
+    ) THEN
+        create type "stripe"."pricing_tiers" as enum ('graduated', 'volume');
     END IF;
-    --more types here...
 END
 $$;
 

packages/sync-engine/src/database/migrations/0004_subscriptions.sql

@@ -1,7 +1,11 @@
 
 DO $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'subscription_status') THEN
+    IF NOT EXISTS (
+        SELECT 1 FROM pg_type t
+        JOIN pg_namespace n ON t.typnamespace = n.oid
+        WHERE t.typname = 'subscription_status' AND n.nspname = 'stripe'
+    ) THEN
         create type "stripe"."subscription_status" as enum (
           'trialing',
           'active',

packages/sync-engine/src/database/migrations/0005_invoices.sql

@@ -1,7 +1,11 @@
 
 DO $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'invoice_status') THEN
+    IF NOT EXISTS (
+        SELECT 1 FROM pg_type t
+        JOIN pg_namespace n ON t.typnamespace = n.oid
+        WHERE t.typname = 'invoice_status' AND n.nspname = 'stripe'
+    ) THEN
         create type "stripe"."invoice_status" as enum ('draft', 'open', 'paid', 'uncollectible', 'void');
     END IF;
 END

packages/sync-engine/src/database/migrations/0012_add_updated_at.sql

@@ -8,8 +8,6 @@ begin
 end;
 $$;
 
-alter function set_updated_at() owner to postgres;
-
 alter table stripe.subscriptions
     add updated_at timestamptz default timezone('utc'::text, now()) not null;
 

packages/sync-engine/src/database/migrations/0024_subscription_schedules.sql

@@ -1,6 +1,10 @@
-do $$
+DO $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'subscription_schedule_status') THEN
+    IF NOT EXISTS (
+        SELECT 1 FROM pg_type t
+        JOIN pg_namespace n ON t.typnamespace = n.oid
+        WHERE t.typname = 'subscription_schedule_status' AND n.nspname = 'stripe'
+    ) THEN
         create type "stripe"."subscription_schedule_status" as enum ('not_started', 'active', 'completed', 'released', 'canceled');
     END IF;
 END