Real-time two-way sync between Supabase and BigQuery

import { createClient } from '@stacksync/client'const stacksync = createClient(  process.env.SUPABASE_URL,  process.env.STACKSYNC_API_KEY)export default function Deals() {  const [deals, setDeals] = useState([])  useEffect(() => {    stacksync.from('deals').select('*')      .then(({ data }) => setDeals(data))  }, [])  return <DealList items={deals} />}

import { createClient } from '@stacksync/client'export async function POST(request) {  const stacksync = createClient(    process.env.SUPABASE_URL,    process.env.STACKSYNC_API_KEY  )  const { id, stage } = await request.json()  // writes Supabase, propagates to BigQuery  const { data } = await stacksync    .from('deals')    .update({ stage })    .eq('id', id)  return Response.json(data)}

from stacksync import create_clientstacksync = create_client(    os.environ['SUPABASE_URL'],    os.environ['STACKSYNC_API_KEY'])# one write, both systemsstacksync.table('deals').update(    {'stage': 'won', 'amount': 48000}).eq('id', 'd_10427').execute()for row in stacksync.logs('deals').recent():    print(row['system'], row['latency_ms'])

import { createClient } from '@stacksync/client'Deno.serve(async (req) => {  const stacksync = createClient(    Deno.env.get('SUPABASE_URL'),    Deno.env.get('STACKSYNC_API_KEY')  )  const { record } = await req.json()  await stacksync.from('accounts').upsert({    id: record.id,    owner: record.owner_email  })  return new Response('ok')})

// claude_desktop_config.json{  "mcpServers": {    "stacksync": {      "command": "npx",      "args": ["-y", "@stacksync/mcp"],      "env": {        "STACKSYNC_API_KEY": "sk_live_...",        "SUPABASE_URL": "https://xyz.supabase.co"      }    }  }}// your agent now reads and writes// every connected system of record

-- Supabase stays the source of truthupdate deals   set stage = 'won',       amount = 48000 where id = 'd_10427';-- Stacksync picks up the change via CDC-- and writes it to every mapped systemselect system, object_id, latency_ms, status  from stacksync.write_log where table_name = 'deals' order by created_at desc limit 10;