From a5d70344456762c26f977682e6799ffd0d4d8ec0 Mon Sep 17 00:00:00 2001
From: Yash Prakash Waghmare <yashwaghmare@Yashs-MacBook-Air-2.local>
Date: Wed, 8 Apr 2026 07:34:55 +0530
Subject: [PATCH 1/5] docs(realtime): add MRE demonstrating JSONB filter
 limitation and column-based workaround

---
 README.md                                     |   6 +
 .../realtime-jsonb-filter-mre/.env.example    |   2 +
 examples/realtime-jsonb-filter-mre/README.md  | 127 ++++++++++++++++++
 .../expected-output.txt                       |  28 ++++
 .../realtime-jsonb-filter-mre/migration.sql   |  69 ++++++++++
 .../realtime-jsonb-filter-mre/package.json    |  14 ++
 .../realtime-jsonb-filter-mre/run-demo.mjs    |  66 +++++++++
 .../subscription-client.mjs                   |  57 ++++++++
 mre/supabase-jsonb-filter-fix/.env.example    |   2 +
 mre/supabase-jsonb-filter-fix/migration.sql   |  63 +++++++++
 mre/supabase-jsonb-filter-fix/package.json    |  13 ++
 .../subscription-client.mjs                   |  55 ++++++++
 mre/supabase-jsonb-filter-fix/verify-fix.mjs  |  60 +++++++++
 13 files changed, 562 insertions(+)
 create mode 100644 examples/realtime-jsonb-filter-mre/.env.example
 create mode 100644 examples/realtime-jsonb-filter-mre/README.md
 create mode 100644 examples/realtime-jsonb-filter-mre/expected-output.txt
 create mode 100644 examples/realtime-jsonb-filter-mre/migration.sql
 create mode 100644 examples/realtime-jsonb-filter-mre/package.json
 create mode 100644 examples/realtime-jsonb-filter-mre/run-demo.mjs
 create mode 100644 examples/realtime-jsonb-filter-mre/subscription-client.mjs
 create mode 100644 mre/supabase-jsonb-filter-fix/.env.example
 create mode 100644 mre/supabase-jsonb-filter-fix/migration.sql
 create mode 100644 mre/supabase-jsonb-filter-fix/package.json
 create mode 100644 mre/supabase-jsonb-filter-fix/subscription-client.mjs
 create mode 100644 mre/supabase-jsonb-filter-fix/verify-fix.mjs

diff --git a/README.md b/README.md
index 74d8e3f6f..31ba31263 100644
--- a/README.md
+++ b/README.md
@@ -120,6 +120,12 @@ alter publication supabase_realtime add table test;
 
 You can start playing around with Broadcast, Presence, and Postgres Changes features either with the client libs (e.g. `@supabase/realtime-js`), or use the built in Realtime Inspector on localhost, `http://localhost:4000/inspector/new` (make sure the port is correct for your development environment).
 
+## Examples
+
+- [Realtime JSONB Filter Limitation (MRE)](./examples/realtime-jsonb-filter-mre) – Demonstrates why Realtime filters don't work on JSONB expressions, and shows the recommended dedicated column pattern.
+
+## WebSocket Connection
+
 The WebSocket URL must contain the subdomain, `external_id` of the tenant on the `_realtime.tenants` table, and the token must be signed with the `jwt_secret` that was inserted along with the tenant.
 
 If you're using the default tenant, the URL is `ws://realtime-dev.localhost:4000/socket` (make sure the port is correct for your development environment), and you can use `eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjE3MDMwMjgwODcsInJvbGUiOiJwb3N0Z3JlcyJ9.tz_XJ89gd6bN8MBpCl7afvPrZiBH6RB65iA1FadPT3Y` for the token. The token must have `exp` and `role` (database role) keys.
diff --git a/examples/realtime-jsonb-filter-mre/.env.example b/examples/realtime-jsonb-filter-mre/.env.example
new file mode 100644
index 000000000..7764385c1
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/.env.example
@@ -0,0 +1,2 @@
+SUPABASE_URL=https://YOUR_PROJECT.supabase.co
+SUPABASE_ANON_KEY=YOUR_ANON_KEY
diff --git a/examples/realtime-jsonb-filter-mre/README.md b/examples/realtime-jsonb-filter-mre/README.md
new file mode 100644
index 000000000..201cc25d8
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/README.md
@@ -0,0 +1,127 @@
+# Supabase Realtime JSONB Filter Limitation (MRE)
+
+## Problem
+
+Supabase Realtime `postgres_changes` filters only support direct column filters (e.g., `column=eq.value`). **JSONB expression filters are NOT supported**.
+
+### Expected Behavior
+When filtering on a JSONB field expression like `data->>organization_id`, events should be delivered to matching subscribers (like PostgREST filters).
+
+### Actual Behavior
+No events are received. The filter is silently ignored or rejected because Realtime does not evaluate SQL expressions.
+
+## Reproduction Steps
+
+1. **Clone and setup:**
+   ```bash
+   npm install
+   cp .env.example .env
+   # Add SUPABASE_URL and SUPABASE_ANON_KEY
+   ```
+
+2. **Apply migration:**
+   - Copy contents of `migration.sql`
+   - Run in your Supabase SQL editor
+
+3. **Run the demo:**
+   ```bash
+   npm start
+   ```
+
+4. **Expected output:**
+   ```
+   [SETUP] Supabase Realtime JSONB Filter MRE
+   [SUBSCRIBED] Ready to receive events
+   [INSERT] Creating job with JSONB data...
+   [WAIT] Waiting 8s for realtime event...
+   [subscription] event received: { ... }
+   [RESULT] ✅ PASS: Realtime event received with direct column filter
+   ```
+
+See [expected-output.txt](expected-output.txt) for full example.
+
+## Root Cause
+
+Realtime does not evaluate or validate SQL expressions in filters. It only supports direct column equality:
+- ✅ Supported: `column_name=eq.value`
+- ❌ Not supported: `data->>'key'=eq.value`
+- ❌ Not supported: `array_col[0]=eq.value`
+
+This is by design because Supabase Realtime filters operate on logical replication (WAL) changes and do not evaluate SQL expressions like JSONB operators. Keeping the filter layer simple and performant is essential for scaling to thousands of concurrent subscriptions.
+
+## Solution: Dedicated Column Pattern
+
+Instead of filtering on JSONB expressions, mirror critical fields into dedicated scalar columns:
+
+1. **Add column** – `organization_id TEXT`
+2. **Backfill** – Extract from JSONB: `data->>'organization_id'`
+3. **Sync with trigger** – Auto-update on INSERT/UPDATE
+4. **Filter on column** – Use `organization_id=eq.value`
+5. **Index** – Add for performance: `CREATE INDEX idx_job_organization_id`
+
+### Files
+
+- **migration.sql** – Creates schema, column, trigger, index, RLS policy
+- **subscription-client.mjs** – Realtime subscription using correct filter
+- **run-demo.mjs** – Demonstrates working filtered subscription
+- **expected-output.txt** – Example successful run
+- **package.json** – Dependencies
+
+## Key Code Changes
+
+### ❌ Broken (JSONB filter)
+```javascript
+.on('postgres_changes', {
+  schema: 'pgboss',
+  table: 'job',
+  filter: 'data->>organization_id=eq.org_123'  // Does NOT work
+})
+```
+
+### ✅ Fixed (direct column filter)
+```javascript
+.on('postgres_changes', {
+  schema: 'pgboss',
+  table: 'job',
+  filter: 'organization_id=eq.org_123'  // Works!
+})
+```
+
+### Database Trigger
+```sql
+create trigger sync_organization_id_trigger
+before insert or update on pgboss.job
+for each row
+execute function sync_organization_id();
+```
+
+The trigger keeps `organization_id` in sync from JSONB on every write.
+
+## Comparison
+
+| Filter Type | PostgREST | Realtime | Reason |
+|---|---|---|---|
+| Direct column | ✅ Works | ✅ Works | Both support basic equality |
+| JSONB operator | ✅ Works | ❌ Fails | Realtime doesn't evaluate SQL expressions |
+| Array access | ✅ Works | ❌ Fails | Requires query evaluation |
+| Function call | ✅ Works | ❌ Fails | Requires query evaluation |
+
+**Why the difference?**
+- **PostgREST**: Query-based API that evaluates full SQL expressions
+- **Realtime**: Stream-based API that applies pattern matching on WAL replication events
+
+## Conclusion
+
+Supabase Realtime is a great real-time sync engine, but it's **not a query engine**. It only supports:
+- Direct column filters
+- Simple comparison operators (eq, neq, gt, gte, lt, lte, like, in)
+- No SQL expressions or functions
+
+For complex filtering on JSONB data, use the **dedicated column pattern** demonstrated here.
+
+## Further Reading
+
+- [Supabase Realtime Docs](https://supabase.com/docs/guides/realtime)
+- [Realtime Filters Documentation](https://supabase.com/docs/guides/realtime#postgres_changes-schema)
+- [PostgREST Filters](https://postgrest.org/en/stable/references/api/tables_views.html#operators)
+
diff --git a/examples/realtime-jsonb-filter-mre/expected-output.txt b/examples/realtime-jsonb-filter-mre/expected-output.txt
new file mode 100644
index 000000000..a3c402d94
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/expected-output.txt
@@ -0,0 +1,28 @@
+[SETUP] Supabase Realtime JSONB Filter MRE
+[SETUP] Realtime filter used: organization_id=eq.org_123
+[subscription] status: SUBSCRIBED
+[SUBSCRIBED] Ready to receive events
+[INSERT] Creating job with JSONB data: { organization_id: "org_123" }
+[INSERT] Row created with ID: 5f8a7f51-c13e-4baa-9ba8-9f0ec7f53d36
+[INSERT] organization_id auto-filled: org_123
+[WAIT] Waiting 8s for realtime event...
+
+[subscription] event received: {
+  "schema": "pgboss",
+  "table": "job",
+  "eventType": "INSERT",
+  "new": {
+    "id": "5f8a7f51-c13e-4baa-9ba8-9f0ec7f53d36",
+    "organization_id": "org_123",
+    "data": { "organization_id": "org_123" },
+    "created_at": "2026-04-08T12:00:00.000000"
+  }
+}
+
+[RESULT] Summary:
+[RESULT] Events received: 1
+
+[RESULT]
+[RESULT] ✅ PASS: Realtime event received with direct column filter
+[RESULT] ✅ PASS: Trigger kept organization_id in sync
+[RESULT]
diff --git a/examples/realtime-jsonb-filter-mre/migration.sql b/examples/realtime-jsonb-filter-mre/migration.sql
new file mode 100644
index 000000000..20fa8f847
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/migration.sql
@@ -0,0 +1,69 @@
+-- Supabase Realtime: JSONB Filter Workaround
+-- ============================================
+-- 
+-- Issue: Realtime postgres_changes filters only support direct column filters
+-- (e.g., col=eq.value), not JSONB expressions (e.g., data->>organization_id=eq.value).
+--
+-- Solution: Keep JSONB column for flexible payloads, add a dedicated scalar column
+-- for filtering, and sync with a database trigger.
+--
+-- This migration adds the necessary schema, backfill, trigger, and index.
+
+create extension if not exists pgcrypto;
+create schema if not exists pgboss;
+
+create table if not exists pgboss.job (
+  id uuid primary key default gen_random_uuid(),
+  data jsonb,
+  created_at timestamp default now()
+);
+
+-- 1) Add dedicated scalar column for Realtime filters
+alter table pgboss.job
+  add column if not exists organization_id text;
+
+-- 2) Backfill existing rows from JSONB payload
+update pgboss.job
+set organization_id = data->>'organization_id'
+where organization_id is distinct from data->>'organization_id';
+
+-- 3) Keep scalar column in sync with JSONB on INSERT/UPDATE
+create or replace function sync_organization_id()
+returns trigger as $$
+begin
+  new.organization_id := new.data->>'organization_id';
+  return new;
+end;
+$$ language plpgsql;
+
+drop trigger if exists sync_organization_id_trigger on pgboss.job;
+create trigger sync_organization_id_trigger
+before insert or update on pgboss.job
+for each row
+execute function sync_organization_id();
+
+-- 4) Index for efficient organization-scoped queries and Realtime filtering
+create index if not exists idx_job_organization_id on pgboss.job (organization_id);
+
+-- 5) Realtime + RLS setup (for testing/demo)
+alter table pgboss.job enable row level security;
+
+do $$
+begin
+  if not exists (
+    select 1
+    from pg_policies
+    where schemaname = 'pgboss'
+      and tablename = 'job'
+      and policyname = 'allow_all_for_testing'
+  ) then
+    create policy allow_all_for_testing
+      on pgboss.job
+      for all
+      to anon, authenticated
+      using (true)
+      with check (true);
+  end if;
+end $$;
+
+alter publication supabase_realtime add table pgboss.job;
diff --git a/examples/realtime-jsonb-filter-mre/package.json b/examples/realtime-jsonb-filter-mre/package.json
new file mode 100644
index 000000000..f327c2dd0
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/package.json
@@ -0,0 +1,14 @@
+{
+  "name": "realtime-jsonb-filter-mre",
+  "version": "1.0.0",
+  "private": true,
+  "type": "module",
+  "description": "Minimal reproducible example: Supabase Realtime does not support JSONB filters",
+  "scripts": {
+    "start": "node run-demo.mjs"
+  },
+  "dependencies": {
+    "@supabase/supabase-js": "^2.49.8",
+    "dotenv": "^16.4.5"
+  }
+}
diff --git a/examples/realtime-jsonb-filter-mre/run-demo.mjs b/examples/realtime-jsonb-filter-mre/run-demo.mjs
new file mode 100644
index 000000000..a2e8c6946
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/run-demo.mjs
@@ -0,0 +1,66 @@
+import { subscribeToJobsByOrganization, supabase, waitForSubscribed } from './subscription-client.mjs'
+
+const ORG_ID = 'org_123'
+const WAIT_MS = 8000
+const pause = (ms) => new Promise((r) => setTimeout(r, ms))
+
+async function main() {
+  console.log('[SETUP] Supabase Realtime JSONB Filter MRE')
+  console.log(`[SETUP] Realtime filter used: organization_id=eq.${ORG_ID}`)
+
+  let eventsReceived = 0
+
+  const channel = subscribeToJobsByOrganization(ORG_ID, () => {
+    eventsReceived += 1
+  })
+
+  await waitForSubscribed(channel, 'subscription')
+  console.log('[SUBSCRIBED] Ready to receive events')
+
+  console.log('[INSERT] Creating job with JSONB data: { organization_id: "org_123" }')
+  const { data: insertedRows, error: insertError } = await supabase
+    .schema('pgboss')
+    .from('job')
+    .insert({ data: { organization_id: ORG_ID } })
+    .select('id, data, organization_id, created_at')
+
+  if (insertError) throw new Error(`[ERROR] Insert failed: ${insertError.message}`)
+
+  const inserted = insertedRows?.[0]
+  console.log(`[INSERT] Row created with ID: ${inserted.id}`)
+  console.log(`[INSERT] organization_id auto-filled: ${inserted.organization_id}`)
+
+  if (!inserted || inserted.organization_id !== ORG_ID) {
+    throw new Error(
+      `[ERROR] Trigger sync failed: expected ${ORG_ID}, got ${inserted?.organization_id ?? 'null'}`
+    )
+  }
+
+  console.log(`[WAIT] Waiting ${WAIT_MS / 1000}s for realtime event...`)
+  await pause(WAIT_MS)
+
+  console.log('')
+  console.log('[RESULT] Summary:')
+  console.log(`[RESULT] Events received: ${eventsReceived}`)
+
+  if (eventsReceived < 1) {
+    console.log('[RESULT]')
+    console.log('[RESULT] ❌ FAIL: No realtime event received')
+    console.log('[RESULT]')
+    console.log('[RESULT] This proves: JSONB filter would NOT work (data->>organization_id)')
+    console.log('[RESULT] But direct column filter DOES work (organization_id)')
+    throw new Error('Expected 1+ event but received none')
+  }
+
+  console.log('[RESULT]')
+  console.log('[RESULT] ✅ PASS: Realtime event received with direct column filter')
+  console.log('[RESULT] ✅ PASS: Trigger kept organization_id in sync')
+  console.log('[RESULT]')
+
+  await supabase.removeChannel(channel)
+}
+
+main().catch((err) => {
+  console.error('[ERROR]', err.message)
+  process.exit(1)
+})
diff --git a/examples/realtime-jsonb-filter-mre/subscription-client.mjs b/examples/realtime-jsonb-filter-mre/subscription-client.mjs
new file mode 100644
index 000000000..fb9a7c28a
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/subscription-client.mjs
@@ -0,0 +1,57 @@
+import 'dotenv/config'
+import { createClient } from '@supabase/supabase-js'
+
+const supabaseUrl = process.env.SUPABASE_URL
+const supabaseAnonKey = process.env.SUPABASE_ANON_KEY
+
+if (!supabaseUrl || !supabaseAnonKey) {
+  throw new Error('Missing SUPABASE_URL or SUPABASE_ANON_KEY')
+}
+
+export const supabase = createClient(supabaseUrl, supabaseAnonKey)
+
+/**
+ * Subscribe to jobs by organization using Realtime filters.
+ *
+ * Note: Realtime does not support JSONB expression filters like `data->>organization_id=eq.value`.
+ * We use a dedicated scalar `organization_id` column instead, kept in sync via database trigger.
+ */
+export function subscribeToJobsByOrganization(organizationId, onPayload) {
+  const filter = `organization_id=eq.${organizationId}`
+
+  const channel = supabase
+    .channel(`jobs-org-${organizationId}`)
+    .on(
+      'postgres_changes',
+      {
+        event: '*',
+        schema: 'pgboss',
+        table: 'job',
+        filter
+      },
+      (payload) => {
+        console.log('[subscription] event received:', JSON.stringify(payload, null, 2))
+        onPayload?.(payload)
+      }
+    )
+
+  return channel
+}
+
+export function waitForSubscribed(channel, label = 'channel') {
+  return new Promise((resolve, reject) => {
+    const timeout = setTimeout(() => reject(new Error(`${label} subscribe timeout`)), 15000)
+
+    channel.subscribe((status) => {
+      console.log(`[${label}] status:`, status)
+      if (status === 'SUBSCRIBED') {
+        clearTimeout(timeout)
+        resolve()
+      }
+      if (status === 'CHANNEL_ERROR' || status === 'TIMED_OUT' || status === 'CLOSED') {
+        clearTimeout(timeout)
+        reject(new Error(`${label} failed with status ${status}`))
+      }
+    })
+  })
+}
diff --git a/mre/supabase-jsonb-filter-fix/.env.example b/mre/supabase-jsonb-filter-fix/.env.example
new file mode 100644
index 000000000..30e705f4c
--- /dev/null
+++ b/mre/supabase-jsonb-filter-fix/.env.example
@@ -0,0 +1,2 @@
+SUPABASE_URL=https://YOUR_PROJECT_REF.supabase.co
+SUPABASE_ANON_KEY=YOUR_ANON_KEY
diff --git a/mre/supabase-jsonb-filter-fix/migration.sql b/mre/supabase-jsonb-filter-fix/migration.sql
new file mode 100644
index 000000000..feb4428cd
--- /dev/null
+++ b/mre/supabase-jsonb-filter-fix/migration.sql
@@ -0,0 +1,63 @@
+-- Fix for Supabase Realtime JSONB filtering limitation.
+-- Realtime postgres_changes filters only support direct column filters (column=op.value).
+-- JSONB expressions like data->>organization_id are not supported in the filter.
+-- We keep JSONB `data` for flexibility and add a dedicated scalar column for filtering/indexing.
+
+create extension if not exists pgcrypto;
+create schema if not exists pgboss;
+
+create table if not exists pgboss.job (
+  id uuid primary key default gen_random_uuid(),
+  data jsonb,
+  created_at timestamp default now()
+);
+
+-- 1) Add dedicated filterable column
+alter table pgboss.job
+  add column if not exists organization_id text;
+
+-- 2) Backfill existing rows from JSONB payload
+update pgboss.job
+set organization_id = data->>'organization_id'
+where organization_id is distinct from data->>'organization_id';
+
+-- 3) Keep organization_id in sync from JSONB on writes
+create or replace function sync_organization_id()
+returns trigger as $$
+begin
+  new.organization_id := new.data->>'organization_id';
+  return new;
+end;
+$$ language plpgsql;
+
+drop trigger if exists sync_organization_id_trigger on pgboss.job;
+create trigger sync_organization_id_trigger
+before insert or update on pgboss.job
+for each row
+execute function sync_organization_id();
+
+-- 4) Index for fast organization-scoped queries/realtime filtering
+create index if not exists idx_job_organization_id on pgboss.job (organization_id);
+
+-- Realtime + permissive RLS for testing/demo
+alter table pgboss.job enable row level security;
+
+do $$
+begin
+  if not exists (
+    select 1
+    from pg_policies
+    where schemaname = 'pgboss'
+      and tablename = 'job'
+      and policyname = 'allow_all_for_testing'
+  ) then
+    create policy allow_all_for_testing
+      on pgboss.job
+      for all
+      to anon, authenticated
+      using (true)
+      with check (true);
+  end if;
+end $$;
+
+alter publication supabase_realtime add table pgboss.job;
diff --git a/mre/supabase-jsonb-filter-fix/package.json b/mre/supabase-jsonb-filter-fix/package.json
new file mode 100644
index 000000000..83452ca74
--- /dev/null
+++ b/mre/supabase-jsonb-filter-fix/package.json
@@ -0,0 +1,13 @@
+{
+  "name": "supabase-realtime-jsonb-filter-fix",
+  "version": "1.0.0",
+  "private": true,
+  "type": "module",
+  "scripts": {
+    "start": "node verify-fix.mjs"
+  },
+  "dependencies": {
+    "@supabase/supabase-js": "^2.49.8",
+    "dotenv": "^16.4.5"
+  }
+}
diff --git a/mre/supabase-jsonb-filter-fix/subscription-client.mjs b/mre/supabase-jsonb-filter-fix/subscription-client.mjs
new file mode 100644
index 000000000..53f153163
--- /dev/null
+++ b/mre/supabase-jsonb-filter-fix/subscription-client.mjs
@@ -0,0 +1,55 @@
+import 'dotenv/config'
+import { createClient } from '@supabase/supabase-js'
+
+const supabaseUrl = process.env.SUPABASE_URL
+const supabaseAnonKey = process.env.SUPABASE_ANON_KEY
+
+if (!supabaseUrl || !supabaseAnonKey) {
+  throw new Error('Missing SUPABASE_URL or SUPABASE_ANON_KEY')
+}
+
+export const supabase = createClient(supabaseUrl, supabaseAnonKey)
+
+/**
+ * Supabase Realtime does not support JSONB expression filters (e.g. data->>organization_id).
+ * Use a dedicated scalar column instead and filter by direct equality.
+ */
+export function subscribeToJobsByOrganization(organizationId, onPayload) {
+  const filter = `organization_id=eq.${organizationId}`
+
+  const channel = supabase
+    .channel(`jobs-org-${organizationId}`)
+    .on(
+      'postgres_changes',
+      {
+        event: '*',
+        schema: 'pgboss',
+        table: 'job',
+        filter
+      },
+      (payload) => {
+        console.log('[subscription] event received:', JSON.stringify(payload, null, 2))
+        onPayload?.(payload)
+      }
+    )
+
+  return channel
+}
+
+export function waitForSubscribed(channel, label = 'channel') {
+  return new Promise((resolve, reject) => {
+    const timeout = setTimeout(() => reject(new Error(`${label} subscribe timeout`)), 15000)
+
+    channel.subscribe((status) => {
+      console.log(`[${label}] status:`, status)
+      if (status === 'SUBSCRIBED') {
+        clearTimeout(timeout)
+        resolve()
+      }
+      if (status === 'CHANNEL_ERROR' || status === 'TIMED_OUT' || status === 'CLOSED') {
+        clearTimeout(timeout)
+        reject(new Error(`${label} failed with status ${status}`))
+      }
+    })
+  })
+}
diff --git a/mre/supabase-jsonb-filter-fix/verify-fix.mjs b/mre/supabase-jsonb-filter-fix/verify-fix.mjs
new file mode 100644
index 000000000..87c1bcd82
--- /dev/null
+++ b/mre/supabase-jsonb-filter-fix/verify-fix.mjs
@@ -0,0 +1,60 @@
+import { subscribeToJobsByOrganization, supabase, waitForSubscribed } from './subscription-client.mjs'
+
+// Realtime filters work on direct columns, not JSONB path expressions.
+// We insert JSONB data and rely on the DB trigger to mirror organization_id to a scalar column.
+const ORG_ID = 'org_123'
+const WAIT_MS = 8000
+const pause = (ms) => new Promise((r) => setTimeout(r, ms))
+
+async function main() {
+  console.log('--- Verify Supabase Realtime JSONB filter fix ---')
+  console.log(`Filter used: organization_id=eq.${ORG_ID}`)
+
+  let eventsReceived = 0
+
+  const channel = subscribeToJobsByOrganization(ORG_ID, () => {
+    eventsReceived += 1
+  })
+
+  await waitForSubscribed(channel, 'jobs subscription')
+
+  // Insert JSONB-only organization_id. Trigger should auto-populate scalar organization_id.
+  const { data: insertedRows, error: insertError } = await supabase
+    .schema('pgboss')
+    .from('job')
+    .insert({ data: { organization_id: ORG_ID } })
+    .select('id, data, organization_id, created_at')
+
+  if (insertError) throw new Error(`Insert failed: ${insertError.message}`)
+
+  const inserted = insertedRows?.[0]
+  console.log('\nInserted row:')
+  console.log(JSON.stringify(inserted, null, 2))
+
+  if (!inserted || inserted.organization_id !== ORG_ID) {
+    throw new Error(
+      `organization_id sync failed: expected ${ORG_ID}, got ${inserted?.organization_id ?? 'null'}`
+    )
+  }
+
+  console.log('\n✅ organization_id auto-fill check passed')
+
+  console.log(`\nWaiting ${WAIT_MS / 1000}s for realtime event...`)
+  await pause(WAIT_MS)
+
+  console.log('\nResult summary:')
+  console.log(`- Realtime events received: ${eventsReceived}`)
+
+  if (eventsReceived < 1) {
+    throw new Error('No realtime event received for organization_id filtered subscription')
+  }
+
+  console.log('✅ Realtime filtered subscription works')
+
+  await supabase.removeChannel(channel)
+}
+
+main().catch((err) => {
+  console.error('\nFailure:', err.message)
+  process.exit(1)
+})

From 5fed095b00d6fa937cd221b3c9ae20d3faf5e010 Mon Sep 17 00:00:00 2001
From: Yash Prakash Waghmare <yashwaghmare@Yashs-MacBook-Air-2.local>
Date: Wed, 8 Apr 2026 08:27:24 +0530
Subject: [PATCH 2/5] fix(realtime): add MRE for JSONB filter limitation

---
 examples/realtime-jsonb-filter-mre/README.md  |  18 ++
 .../expected-output.txt                       |   3 +
 .../realtime-jsonb-filter-mre/migration.sql   |  70 ++++---
 .../package-lock.json                         | 174 ++++++++++++++++++
 .../realtime-jsonb-filter-mre/run-demo.mjs    |  79 +++++++-
 5 files changed, 305 insertions(+), 39 deletions(-)
 create mode 100644 examples/realtime-jsonb-filter-mre/package-lock.json

diff --git a/examples/realtime-jsonb-filter-mre/README.md b/examples/realtime-jsonb-filter-mre/README.md
index 201cc25d8..fa7f806d7 100644
--- a/examples/realtime-jsonb-filter-mre/README.md
+++ b/examples/realtime-jsonb-filter-mre/README.md
@@ -10,6 +10,24 @@ When filtering on a JSONB field expression like `data->>organization_id`, events
 ### Actual Behavior
 No events are received. The filter is silently ignored or rejected because Realtime does not evaluate SQL expressions.
 
+## Setup Required
+
+Before running the demo, you MUST apply the database migration.
+
+Steps:
+1. Open Supabase dashboard
+2. Confirm the project URL matches the `[DEBUG] SUPABASE_URL` printed by the demo
+3. Go to SQL Editor
+4. Copy contents of migration.sql
+5. Run it
+6. Go to Project Settings → API → Exposed schemas and add `pgboss`
+
+If not applied, you will see:
+
+```text
+[ERROR] Database schema not found
+```
+
 ## Reproduction Steps
 
 1. **Clone and setup:**
diff --git a/examples/realtime-jsonb-filter-mre/expected-output.txt b/examples/realtime-jsonb-filter-mre/expected-output.txt
index a3c402d94..dd9faf984 100644
--- a/examples/realtime-jsonb-filter-mre/expected-output.txt
+++ b/examples/realtime-jsonb-filter-mre/expected-output.txt
@@ -1,3 +1,6 @@
+NOTE:
+This output assumes migration.sql has already been applied.
+
 [SETUP] Supabase Realtime JSONB Filter MRE
 [SETUP] Realtime filter used: organization_id=eq.org_123
 [subscription] status: SUBSCRIBED
diff --git a/examples/realtime-jsonb-filter-mre/migration.sql b/examples/realtime-jsonb-filter-mre/migration.sql
index 20fa8f847..2d7836774 100644
--- a/examples/realtime-jsonb-filter-mre/migration.sql
+++ b/examples/realtime-jsonb-filter-mre/migration.sql
@@ -1,34 +1,29 @@
--- Supabase Realtime: JSONB Filter Workaround
 -- ============================================
--- 
--- Issue: Realtime postgres_changes filters only support direct column filters
--- (e.g., col=eq.value), not JSONB expressions (e.g., data->>organization_id=eq.value).
---
--- Solution: Keep JSONB column for flexible payloads, add a dedicated scalar column
--- for filtering, and sync with a database trigger.
---
--- This migration adds the necessary schema, backfill, trigger, and index.
+-- Supabase Realtime: JSONB Filter Workaround (FIXED)
+-- ============================================
 
+-- Extensions & Schema
 create extension if not exists pgcrypto;
 create schema if not exists pgboss;
 
+-- Table
 create table if not exists pgboss.job (
   id uuid primary key default gen_random_uuid(),
   data jsonb,
   created_at timestamp default now()
 );
 
--- 1) Add dedicated scalar column for Realtime filters
+-- 1) Add scalar column for filtering
 alter table pgboss.job
   add column if not exists organization_id text;
 
--- 2) Backfill existing rows from JSONB payload
+-- 2) Backfill existing rows
 update pgboss.job
 set organization_id = data->>'organization_id'
 where organization_id is distinct from data->>'organization_id';
 
--- 3) Keep scalar column in sync with JSONB on INSERT/UPDATE
-create or replace function sync_organization_id()
+-- 3) Trigger function (schema-safe)
+create or replace function pgboss.sync_organization_id()
 returns trigger as $$
 begin
   new.organization_id := new.data->>'organization_id';
@@ -36,34 +31,51 @@ begin
 end;
 $$ language plpgsql;
 
+-- 4) Trigger
 drop trigger if exists sync_organization_id_trigger on pgboss.job;
+
 create trigger sync_organization_id_trigger
 before insert or update on pgboss.job
 for each row
-execute function sync_organization_id();
+execute function pgboss.sync_organization_id();
 
--- 4) Index for efficient organization-scoped queries and Realtime filtering
-create index if not exists idx_job_organization_id on pgboss.job (organization_id);
+-- 5) Index
+create index if not exists idx_job_organization_id
+on pgboss.job (organization_id);
 
--- 5) Realtime + RLS setup (for testing/demo)
+-- 6) Enable RLS
 alter table pgboss.job enable row level security;
+alter table pgboss.job replica identity full;
+
+-- 7) RLS Policy (IMPORTANT)
+-- Replace with your JWT structure if needed
+drop policy if exists "org based access" on pgboss.job;
+
+create policy "org based access"
+on pgboss.job
+for select
+using (
+  organization_id = auth.jwt() ->> 'organization_id'
+);
+
+-- (Optional: allow inserts if needed)
+drop policy if exists "allow insert" on pgboss.job;
 
+create policy "allow insert"
+on pgboss.job
+for insert
+with check (true);
+
+-- 8) Add to Realtime publication (idempotent)
 do $$
 begin
   if not exists (
     select 1
-    from pg_policies
-    where schemaname = 'pgboss'
+    from pg_publication_tables
+    where pubname = 'supabase_realtime'
+      and schemaname = 'pgboss'
       and tablename = 'job'
-      and policyname = 'allow_all_for_testing'
   ) then
-    create policy allow_all_for_testing
-      on pgboss.job
-      for all
-      to anon, authenticated
-      using (true)
-      with check (true);
+    alter publication supabase_realtime add table pgboss.job;
   end if;
-end $$;
-
-alter publication supabase_realtime add table pgboss.job;
+end $$;
\ No newline at end of file
diff --git a/examples/realtime-jsonb-filter-mre/package-lock.json b/examples/realtime-jsonb-filter-mre/package-lock.json
new file mode 100644
index 000000000..6fb46edd9
--- /dev/null
+++ b/examples/realtime-jsonb-filter-mre/package-lock.json
@@ -0,0 +1,174 @@
+{
+  "name": "realtime-jsonb-filter-mre",
+  "version": "1.0.0",
+  "lockfileVersion": 3,
+  "requires": true,
+  "packages": {
+    "": {
+      "name": "realtime-jsonb-filter-mre",
+      "version": "1.0.0",
+      "dependencies": {
+        "@supabase/supabase-js": "^2.49.8",
+        "dotenv": "^16.4.5"
+      }
+    },
+    "node_modules/@supabase/auth-js": {
+      "version": "2.102.1",
+      "resolved": "https://registry.npmjs.org/@supabase/auth-js/-/auth-js-2.102.1.tgz",
+      "integrity": "sha512-2uH2WB0H98TOGDtaFWhxIcR42Dro/VB7VDZanz/4bVJsqioIue1m3TUqu3xciDm2W9r+1LXQvYNsYbQfWmD+uQ==",
+      "license": "MIT",
+      "dependencies": {
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/functions-js": {
+      "version": "2.102.1",
+      "resolved": "https://registry.npmjs.org/@supabase/functions-js/-/functions-js-2.102.1.tgz",
+      "integrity": "sha512-UcrcKTPnAIo+Yp9Jjq9XXwFbsmgRYY637mwka9ZjmTIWcX/xr1pote4OVvaGQycVY1KTiQgjMvpC0Q0yJhRq3w==",
+      "license": "MIT",
+      "dependencies": {
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/phoenix": {
+      "version": "0.4.0",
+      "resolved": "https://registry.npmjs.org/@supabase/phoenix/-/phoenix-0.4.0.tgz",
+      "integrity": "sha512-RHSx8bHS02xwfHdAbX5Lpbo6PXbgyf7lTaXTlwtFDPwOIw64NnVRwFAXGojHhjtVYI+PEPNSWwkL90f4agN3bw==",
+      "license": "MIT"
+    },
+    "node_modules/@supabase/postgrest-js": {
+      "version": "2.102.1",
+      "resolved": "https://registry.npmjs.org/@supabase/postgrest-js/-/postgrest-js-2.102.1.tgz",
+      "integrity": "sha512-InLvXKAYf8BIqiv9jWOYudWB3rU8A9uMbcip5BQ5sLLNPrbO1Ekkr79OvlhZBgMNSppxVyC7wPPGzLxMcTZhlA==",
+      "license": "MIT",
+      "dependencies": {
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/realtime-js": {
+      "version": "2.102.1",
+      "resolved": "https://registry.npmjs.org/@supabase/realtime-js/-/realtime-js-2.102.1.tgz",
+      "integrity": "sha512-h2fCumib/v6u7XMwSPgxnpfimjX4xCEayUHrxWLC7UurfQjUZJ0pmJDgm6yj80DnUerxuulRghwm5zXYysFG/Q==",
+      "license": "MIT",
+      "dependencies": {
+        "@supabase/phoenix": "^0.4.0",
+        "@types/ws": "^8.18.1",
+        "tslib": "2.8.1",
+        "ws": "^8.18.2"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/storage-js": {
+      "version": "2.102.1",
+      "resolved": "https://registry.npmjs.org/@supabase/storage-js/-/storage-js-2.102.1.tgz",
+      "integrity": "sha512-eCL9T4Xpe40nmKlkUJ7Zq/hk34db1xPiT0WL3Iv5MbJqHuCAe5TxhV8Rjqd6DNZrzjtfYObZtYl9jKJaHrivqw==",
+      "license": "MIT",
+      "dependencies": {
+        "iceberg-js": "^0.8.1",
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/supabase-js": {
+      "version": "2.102.1",
+      "resolved": "https://registry.npmjs.org/@supabase/supabase-js/-/supabase-js-2.102.1.tgz",
+      "integrity": "sha512-bChxPVeLDnYN9M2d/u4fXsvylwSQG5grAl+HN8f+ZD9a9PuVU+Ru+xGmEsk+b9Iz3rJC9ZQnQUJYQ28fApdWYA==",
+      "license": "MIT",
+      "dependencies": {
+        "@supabase/auth-js": "2.102.1",
+        "@supabase/functions-js": "2.102.1",
+        "@supabase/postgrest-js": "2.102.1",
+        "@supabase/realtime-js": "2.102.1",
+        "@supabase/storage-js": "2.102.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@types/node": {
+      "version": "25.5.2",
+      "resolved": "https://registry.npmjs.org/@types/node/-/node-25.5.2.tgz",
+      "integrity": "sha512-tO4ZIRKNC+MDWV4qKVZe3Ql/woTnmHDr5JD8UI5hn2pwBrHEwOEMZK7WlNb5RKB6EoJ02gwmQS9OrjuFnZYdpg==",
+      "license": "MIT",
+      "dependencies": {
+        "undici-types": "~7.18.0"
+      }
+    },
+    "node_modules/@types/ws": {
+      "version": "8.18.1",
+      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.18.1.tgz",
+      "integrity": "sha512-ThVF6DCVhA8kUGy+aazFQ4kXQ7E1Ty7A3ypFOe0IcJV8O/M511G99AW24irKrW56Wt44yG9+ij8FaqoBGkuBXg==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/node": "*"
+      }
+    },
+    "node_modules/dotenv": {
+      "version": "16.6.1",
+      "resolved": "https://registry.npmjs.org/dotenv/-/dotenv-16.6.1.tgz",
+      "integrity": "sha512-uBq4egWHTcTt33a72vpSG0z3HnPuIl6NqYcTrKEg2azoEyl2hpW0zqlxysq2pK9HlDIHyHyakeYaYnSAwd8bow==",
+      "license": "BSD-2-Clause",
+      "engines": {
+        "node": ">=12"
+      },
+      "funding": {
+        "url": "https://dotenvx.com"
+      }
+    },
+    "node_modules/iceberg-js": {
+      "version": "0.8.1",
+      "resolved": "https://registry.npmjs.org/iceberg-js/-/iceberg-js-0.8.1.tgz",
+      "integrity": "sha512-1dhVQZXhcHje7798IVM+xoo/1ZdVfzOMIc8/rgVSijRK38EDqOJoGula9N/8ZI5RD8QTxNQtK/Gozpr+qUqRRA==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/tslib": {
+      "version": "2.8.1",
+      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.8.1.tgz",
+      "integrity": "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w==",
+      "license": "0BSD"
+    },
+    "node_modules/undici-types": {
+      "version": "7.18.2",
+      "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-7.18.2.tgz",
+      "integrity": "sha512-AsuCzffGHJybSaRrmr5eHr81mwJU3kjw6M+uprWvCXiNeN9SOGwQ3Jn8jb8m3Z6izVgknn1R0FTCEAP2QrLY/w==",
+      "license": "MIT"
+    },
+    "node_modules/ws": {
+      "version": "8.20.0",
+      "resolved": "https://registry.npmjs.org/ws/-/ws-8.20.0.tgz",
+      "integrity": "sha512-sAt8BhgNbzCtgGbt2OxmpuryO63ZoDk/sqaB/znQm94T4fCEsy/yV+7CdC1kJhOU9lboAEU7R3kquuycDoibVA==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=10.0.0"
+      },
+      "peerDependencies": {
+        "bufferutil": "^4.0.1",
+        "utf-8-validate": ">=5.0.2"
+      },
+      "peerDependenciesMeta": {
+        "bufferutil": {
+          "optional": true
+        },
+        "utf-8-validate": {
+          "optional": true
+        }
+      }
+    }
+  }
+}
diff --git a/examples/realtime-jsonb-filter-mre/run-demo.mjs b/examples/realtime-jsonb-filter-mre/run-demo.mjs
index a2e8c6946..e9c3d6443 100644
--- a/examples/realtime-jsonb-filter-mre/run-demo.mjs
+++ b/examples/realtime-jsonb-filter-mre/run-demo.mjs
@@ -4,29 +4,83 @@ const ORG_ID = 'org_123'
 const WAIT_MS = 8000
 const pause = (ms) => new Promise((r) => setTimeout(r, ms))
 
+function isSchemaSetupError(error) {
+  const message = String(error?.message ?? error ?? '').toLowerCase()
+  return (
+    message.includes('invalid schema') ||
+    message.includes('schema does not exist') ||
+    message.includes('relation does not exist')
+  )
+}
+
+function printSchemaSetupHelp() {
+  console.log('[ERROR] Database schema not found')
+  console.log('')
+  console.log('This demo requires the pgboss schema and job table, and pgboss must be exposed to the API.')
+  console.log('')
+  console.log('👉 Fix:')
+  console.log('1. Open your Supabase dashboard')
+  console.log('2. Confirm this project URL matches [DEBUG] SUPABASE_URL above')
+  console.log('3. Go to SQL Editor and run migration.sql from this project')
+  console.log('4. Go to Project Settings → API → Exposed schemas, add: pgboss')
+  console.log('5. Re-run: npm start')
+  console.log('')
+  console.log('Quick SQL check:')
+  console.log('select to_regclass(\'pgboss.job\');')
+}
+
 async function main() {
   console.log('[SETUP] Supabase Realtime JSONB Filter MRE')
+  console.log('[DEBUG] SUPABASE_URL =', process.env.SUPABASE_URL)
   console.log(`[SETUP] Realtime filter used: organization_id=eq.${ORG_ID}`)
 
+  let channel
   let eventsReceived = 0
 
-  const channel = subscribeToJobsByOrganization(ORG_ID, () => {
+  // Pre-check setup before subscribing/inserting.
+  const { error: setupCheckError } = await supabase
+    .schema('pgboss')
+    .from('job')
+    .select('id')
+    .limit(1)
+
+  if (setupCheckError) {
+    if (isSchemaSetupError(setupCheckError)) {
+      printSchemaSetupHelp()
+      process.exit(1)
+    }
+
+    throw new Error(`[ERROR] Setup check failed: ${setupCheckError.message}`)
+  }
+
+  channel = subscribeToJobsByOrganization(ORG_ID, () => {
     eventsReceived += 1
   })
 
   await waitForSubscribed(channel, 'subscription')
   console.log('[SUBSCRIBED] Ready to receive events')
 
-  console.log('[INSERT] Creating job with JSONB data: { organization_id: "org_123" }')
-  const { data: insertedRows, error: insertError } = await supabase
-    .schema('pgboss')
-    .from('job')
-    .insert({ data: { organization_id: ORG_ID } })
-    .select('id, data, organization_id, created_at')
+  let inserted
 
-  if (insertError) throw new Error(`[ERROR] Insert failed: ${insertError.message}`)
+  try {
+    console.log('[INSERT] Creating job with JSONB data: { organization_id: "org_123" }')
+    const { data: insertedRows, error: insertError } = await supabase
+      .schema('pgboss')
+      .from('job')
+      .insert({ data: { organization_id: ORG_ID } })
+      .select('id, data, organization_id, created_at')
+
+    if (insertError) throw insertError
+    inserted = insertedRows?.[0]
+  } catch (error) {
+    if (isSchemaSetupError(error)) {
+      printSchemaSetupHelp()
+      process.exit(1)
+    }
+
+    throw new Error(`[ERROR] Insert failed: ${error.message}`)
+  }
 
-  const inserted = insertedRows?.[0]
   console.log(`[INSERT] Row created with ID: ${inserted.id}`)
   console.log(`[INSERT] organization_id auto-filled: ${inserted.organization_id}`)
 
@@ -57,10 +111,15 @@ async function main() {
   console.log('[RESULT] ✅ PASS: Trigger kept organization_id in sync')
   console.log('[RESULT]')
 
-  await supabase.removeChannel(channel)
+  if (channel) await supabase.removeChannel(channel)
 }
 
 main().catch((err) => {
+  if (isSchemaSetupError(err)) {
+    printSchemaSetupHelp()
+    process.exit(1)
+  }
+
   console.error('[ERROR]', err.message)
   process.exit(1)
 })

From d5f5b0b8dfff66c50ecaff2cf194d778a8da542e Mon Sep 17 00:00:00 2001
From: Yash Prakash Waghmare <yashwaghmare@Yashs-MacBook-Air-2.local>
Date: Wed, 8 Apr 2026 08:29:16 +0530
Subject: [PATCH 3/5] fix(realtime): add MRE for JSONB filter limitation

---
 .gitignore                                    |  1 +
 mre/supabase-jsonb-filter-fix/.env.example    |  2 -
 mre/supabase-jsonb-filter-fix/migration.sql   | 63 -------------------
 mre/supabase-jsonb-filter-fix/package.json    | 13 ----
 .../subscription-client.mjs                   | 55 ----------------
 mre/supabase-jsonb-filter-fix/verify-fix.mjs  | 60 ------------------
 6 files changed, 1 insertion(+), 193 deletions(-)
 delete mode 100644 mre/supabase-jsonb-filter-fix/.env.example
 delete mode 100644 mre/supabase-jsonb-filter-fix/migration.sql
 delete mode 100644 mre/supabase-jsonb-filter-fix/package.json
 delete mode 100644 mre/supabase-jsonb-filter-fix/subscription-client.mjs
 delete mode 100644 mre/supabase-jsonb-filter-fix/verify-fix.mjs

diff --git a/.gitignore b/.gitignore
index b4af75d88..8c7cfc3fb 100644
--- a/.gitignore
+++ b/.gitignore
@@ -31,5 +31,6 @@ node_modules
 .supabase
 config/prod.secret.exs
 demo/.env
+examples/realtime-jsonb-filter-mre/.env
 .lexical
 .vscode
diff --git a/mre/supabase-jsonb-filter-fix/.env.example b/mre/supabase-jsonb-filter-fix/.env.example
deleted file mode 100644
index 30e705f4c..000000000
--- a/mre/supabase-jsonb-filter-fix/.env.example
+++ /dev/null
@@ -1,2 +0,0 @@
-SUPABASE_URL=https://YOUR_PROJECT_REF.supabase.co
-SUPABASE_ANON_KEY=YOUR_ANON_KEY
diff --git a/mre/supabase-jsonb-filter-fix/migration.sql b/mre/supabase-jsonb-filter-fix/migration.sql
deleted file mode 100644
index feb4428cd..000000000
--- a/mre/supabase-jsonb-filter-fix/migration.sql
+++ /dev/null
@@ -1,63 +0,0 @@
--- Fix for Supabase Realtime JSONB filtering limitation.
--- Realtime postgres_changes filters only support direct column filters (column=op.value).
--- JSONB expressions like data->>organization_id are not supported in the filter.
--- We keep JSONB `data` for flexibility and add a dedicated scalar column for filtering/indexing.
-
-create extension if not exists pgcrypto;
-create schema if not exists pgboss;
-
-create table if not exists pgboss.job (
-  id uuid primary key default gen_random_uuid(),
-  data jsonb,
-  created_at timestamp default now()
-);
-
--- 1) Add dedicated filterable column
-alter table pgboss.job
-  add column if not exists organization_id text;
-
--- 2) Backfill existing rows from JSONB payload
-update pgboss.job
-set organization_id = data->>'organization_id'
-where organization_id is distinct from data->>'organization_id';
-
--- 3) Keep organization_id in sync from JSONB on writes
-create or replace function sync_organization_id()
-returns trigger as $$
-begin
-  new.organization_id := new.data->>'organization_id';
-  return new;
-end;
-$$ language plpgsql;
-
-drop trigger if exists sync_organization_id_trigger on pgboss.job;
-create trigger sync_organization_id_trigger
-before insert or update on pgboss.job
-for each row
-execute function sync_organization_id();
-
--- 4) Index for fast organization-scoped queries/realtime filtering
-create index if not exists idx_job_organization_id on pgboss.job (organization_id);
-
--- Realtime + permissive RLS for testing/demo
-alter table pgboss.job enable row level security;
-
-do $$
-begin
-  if not exists (
-    select 1
-    from pg_policies
-    where schemaname = 'pgboss'
-      and tablename = 'job'
-      and policyname = 'allow_all_for_testing'
-  ) then
-    create policy allow_all_for_testing
-      on pgboss.job
-      for all
-      to anon, authenticated
-      using (true)
-      with check (true);
-  end if;
-end $$;
-
-alter publication supabase_realtime add table pgboss.job;
diff --git a/mre/supabase-jsonb-filter-fix/package.json b/mre/supabase-jsonb-filter-fix/package.json
deleted file mode 100644
index 83452ca74..000000000
--- a/mre/supabase-jsonb-filter-fix/package.json
+++ /dev/null
@@ -1,13 +0,0 @@
-{
-  "name": "supabase-realtime-jsonb-filter-fix",
-  "version": "1.0.0",
-  "private": true,
-  "type": "module",
-  "scripts": {
-    "start": "node verify-fix.mjs"
-  },
-  "dependencies": {
-    "@supabase/supabase-js": "^2.49.8",
-    "dotenv": "^16.4.5"
-  }
-}
diff --git a/mre/supabase-jsonb-filter-fix/subscription-client.mjs b/mre/supabase-jsonb-filter-fix/subscription-client.mjs
deleted file mode 100644
index 53f153163..000000000
--- a/mre/supabase-jsonb-filter-fix/subscription-client.mjs
+++ /dev/null
@@ -1,55 +0,0 @@
-import 'dotenv/config'
-import { createClient } from '@supabase/supabase-js'
-
-const supabaseUrl = process.env.SUPABASE_URL
-const supabaseAnonKey = process.env.SUPABASE_ANON_KEY
-
-if (!supabaseUrl || !supabaseAnonKey) {
-  throw new Error('Missing SUPABASE_URL or SUPABASE_ANON_KEY')
-}
-
-export const supabase = createClient(supabaseUrl, supabaseAnonKey)
-
-/**
- * Supabase Realtime does not support JSONB expression filters (e.g. data->>organization_id).
- * Use a dedicated scalar column instead and filter by direct equality.
- */
-export function subscribeToJobsByOrganization(organizationId, onPayload) {
-  const filter = `organization_id=eq.${organizationId}`
-
-  const channel = supabase
-    .channel(`jobs-org-${organizationId}`)
-    .on(
-      'postgres_changes',
-      {
-        event: '*',
-        schema: 'pgboss',
-        table: 'job',
-        filter
-      },
-      (payload) => {
-        console.log('[subscription] event received:', JSON.stringify(payload, null, 2))
-        onPayload?.(payload)
-      }
-    )
-
-  return channel
-}
-
-export function waitForSubscribed(channel, label = 'channel') {
-  return new Promise((resolve, reject) => {
-    const timeout = setTimeout(() => reject(new Error(`${label} subscribe timeout`)), 15000)
-
-    channel.subscribe((status) => {
-      console.log(`[${label}] status:`, status)
-      if (status === 'SUBSCRIBED') {
-        clearTimeout(timeout)
-        resolve()
-      }
-      if (status === 'CHANNEL_ERROR' || status === 'TIMED_OUT' || status === 'CLOSED') {
-        clearTimeout(timeout)
-        reject(new Error(`${label} failed with status ${status}`))
-      }
-    })
-  })
-}
diff --git a/mre/supabase-jsonb-filter-fix/verify-fix.mjs b/mre/supabase-jsonb-filter-fix/verify-fix.mjs
deleted file mode 100644
index 87c1bcd82..000000000
--- a/mre/supabase-jsonb-filter-fix/verify-fix.mjs
+++ /dev/null
@@ -1,60 +0,0 @@
-import { subscribeToJobsByOrganization, supabase, waitForSubscribed } from './subscription-client.mjs'
-
-// Realtime filters work on direct columns, not JSONB path expressions.
-// We insert JSONB data and rely on the DB trigger to mirror organization_id to a scalar column.
-const ORG_ID = 'org_123'
-const WAIT_MS = 8000
-const pause = (ms) => new Promise((r) => setTimeout(r, ms))
-
-async function main() {
-  console.log('--- Verify Supabase Realtime JSONB filter fix ---')
-  console.log(`Filter used: organization_id=eq.${ORG_ID}`)
-
-  let eventsReceived = 0
-
-  const channel = subscribeToJobsByOrganization(ORG_ID, () => {
-    eventsReceived += 1
-  })
-
-  await waitForSubscribed(channel, 'jobs subscription')
-
-  // Insert JSONB-only organization_id. Trigger should auto-populate scalar organization_id.
-  const { data: insertedRows, error: insertError } = await supabase
-    .schema('pgboss')
-    .from('job')
-    .insert({ data: { organization_id: ORG_ID } })
-    .select('id, data, organization_id, created_at')
-
-  if (insertError) throw new Error(`Insert failed: ${insertError.message}`)
-
-  const inserted = insertedRows?.[0]
-  console.log('\nInserted row:')
-  console.log(JSON.stringify(inserted, null, 2))
-
-  if (!inserted || inserted.organization_id !== ORG_ID) {
-    throw new Error(
-      `organization_id sync failed: expected ${ORG_ID}, got ${inserted?.organization_id ?? 'null'}`
-    )
-  }
-
-  console.log('\n✅ organization_id auto-fill check passed')
-
-  console.log(`\nWaiting ${WAIT_MS / 1000}s for realtime event...`)
-  await pause(WAIT_MS)
-
-  console.log('\nResult summary:')
-  console.log(`- Realtime events received: ${eventsReceived}`)
-
-  if (eventsReceived < 1) {
-    throw new Error('No realtime event received for organization_id filtered subscription')
-  }
-
-  console.log('✅ Realtime filtered subscription works')
-
-  await supabase.removeChannel(channel)
-}
-
-main().catch((err) => {
-  console.error('\nFailure:', err.message)
-  process.exit(1)
-})

From 5ec3aa18a6ef6d2ef5c04622ecb8b31867052a99 Mon Sep 17 00:00:00 2001
From: Yash Waghmare <waghmareyash07@gmail.com>
Date: Wed, 8 Apr 2026 12:47:10 +0530
Subject: [PATCH 4/5] Update examples/realtime-jsonb-filter-mre/package.json

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
---
 examples/realtime-jsonb-filter-mre/package.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/examples/realtime-jsonb-filter-mre/package.json b/examples/realtime-jsonb-filter-mre/package.json
index f327c2dd0..8a58abb9b 100644
--- a/examples/realtime-jsonb-filter-mre/package.json
+++ b/examples/realtime-jsonb-filter-mre/package.json
@@ -8,7 +8,7 @@
     "start": "node run-demo.mjs"
   },
   "dependencies": {
-    "@supabase/supabase-js": "^2.49.8",
+    "@supabase/supabase-js": "2.49.8",
     "dotenv": "^16.4.5"
   }
 }

From 0740da615229be524eb1c27e2c9d1a8eed02fa0c Mon Sep 17 00:00:00 2001
From: Yash Waghmare <waghmareyash07@gmail.com>
Date: Wed, 8 Apr 2026 12:47:26 +0530
Subject: [PATCH 5/5] Update
 examples/realtime-jsonb-filter-mre/expected-output.txt

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
---
 examples/realtime-jsonb-filter-mre/expected-output.txt | 1 +
 1 file changed, 1 insertion(+)

diff --git a/examples/realtime-jsonb-filter-mre/expected-output.txt b/examples/realtime-jsonb-filter-mre/expected-output.txt
index dd9faf984..3d4b90cc9 100644
--- a/examples/realtime-jsonb-filter-mre/expected-output.txt
+++ b/examples/realtime-jsonb-filter-mre/expected-output.txt
@@ -3,6 +3,7 @@ This output assumes migration.sql has already been applied.
 
 [SETUP] Supabase Realtime JSONB Filter MRE
 [SETUP] Realtime filter used: organization_id=eq.org_123
+[DEBUG] SUPABASE_URL = https://your-project.supabase.co
 [subscription] status: SUBSCRIBED
 [SUBSCRIBED] Ready to receive events
 [INSERT] Creating job with JSONB data: { organization_id: "org_123" }