Konektor Supabase

import { createClient } from '@supabase/supabase-js';

// Use service role key for server-side operations
const supabase = createClient(
  process.env.SUPABASE_URL,
  process.env.SUPABASE_SERVICE_KEY
);

connectors:
  supabase:
    enabled: true
    url: "${SUPABASE_URL}"
    service_key: "${SUPABASE_SERVICE_KEY}"

    sync:
      users: true
      profiles: true
      events: true
      schedule: "0 */2 * * *"  # Every 2 hours

    tables:
      profiles: "public.profiles"
      orders: "public.orders"

    lists:
      all_users: 10
      active_users: 11
      premium_users: 12

field_mapping:
  # Auth user fields
  email: email
  created_at: SIGNUP_DATE
  last_sign_in_at: LAST_LOGIN_DATE
  email_confirmed_at: EMAIL_VERIFIED_DATE

  # Profile table fields
  first_name: FIRSTNAME
  last_name: LASTNAME
  phone: SMS
  plan: SUBSCRIPTION_PLAN
  company: COMPANY
  avatar_url: AVATAR_URL

import { TajoClient } from '@tajo/sdk';

const tajo = new TajoClient({
  apiKey: process.env.TAJO_API_KEY,
  brevoApiKey: process.env.BREVO_API_KEY
});

await tajo.connectors.connect('supabase', {
  url: process.env.SUPABASE_URL,
  serviceKey: process.env.SUPABASE_SERVICE_KEY
});

import { createClient } from '@supabase/supabase-js';

const supabase = createClient(
  process.env.SUPABASE_URL,
  process.env.SUPABASE_SERVICE_KEY
);

// Paginate through all auth users
let page = 1;
const perPage = 1000;

while (true) {
  const { data: { users }, error } = await supabase.auth.admin.listUsers({
    page,
    perPage
  });

  if (error || !users.length) break;

  for (const user of users) {
    await tajo.contacts.sync({
      email: user.email,
      attributes: {
        SIGNUP_DATE: user.created_at,
        LAST_LOGIN_DATE: user.last_sign_in_at,
        EMAIL_VERIFIED_DATE: user.email_confirmed_at
      },
      listIds: [10]
    });
  }

  if (users.length < perPage) break;
  page++;
}

// Listen for new user signups via Supabase Realtime
const channel = supabase
  .channel('auth-changes')
  .on(
    'postgres_changes',
    {
      event: 'INSERT',
      schema: 'auth',
      table: 'users'
    },
    async (payload) => {
      const newUser = payload.new;

      await tajo.contacts.sync({
        email: newUser.email,
        attributes: {
          SIGNUP_DATE: newUser.created_at
        },
        listIds: [10]
      });
    }
  )
  .subscribe();

// Supabase Database Webhooks forward row events to your endpoint
app.post('/webhooks/supabase', async (req, res) => {
  const { type, table, record, old_record } = req.body;

  if (table === 'profiles' && type === 'UPDATE') {
    await tajo.contacts.update(record.email, {
      attributes: {
        FIRSTNAME: record.first_name,
        LASTNAME: record.last_name,
        SUBSCRIPTION_PLAN: record.plan
      }
    });
  }

  res.status(200).send('OK');
});

connectors:
  supabase:
    debug: true
    log_level: verbose
    log_queries: true
    log_realtime: true