Supabase

1
import { SupabaseManagement, Supabase } from "@trigger.dev/supabase";
2
import { Stripe } from "@trigger.dev/stripe";
3
import { TriggerClient } from "@trigger.dev/sdk";
4
export const stripe = new Stripe({
5
  id: "stripe",
6
  apiKey: process.env.STRIPE_API_KEY!,
7
});
8

9
const supabase = new Supabase({
10
  id: "supabase",
11
  supabaseUrl: process.env.SUPABASE_PUBLIC_URL!,
12
  supabaseKey: process.env.SUPABASE_SERVICE_ROLE_KEY!,
13
});
14

15
// Use OAuth to authenticate with Supabase Management API
16
const supabaseManagement = new SupabaseManagement({
17
  id: "supabase-management",
18
});
19

20
// Update a Supabase table when a Stripe account is updated
21
client.defineJob({
22
  id: "supabase-stripe-update-database",
23
  name: "Supabase: update database when Stripe account is updated",
24
  version: "1.0.0",
25
  integrations: {
26
    stripe,
27
    supabase,
28
  },
29
  trigger: stripe.onAccountUpdated({ connect: true }),
30
  run: async (payload, io, ctx) => {
31
    const stripeAccountId = payload.id;
32
    const { payouts_enabled, charges_enabled, details_submitted } = payload;
33

34
    const updatedAt = new Date().toISOString();
35

36
    await io.supabase.runTask("update-stripe-account", async (database) => {
37
      const { data, error } = await database
38
        .from("accounts")
39
        .update({
40
          payouts_enabled,
41
          charges_enabled,
42
          details_submitted,
43
          updated_at: updatedAt,
44
        })
45
        .eq("stripe_account_id", stripeAccountId);
46

47
      if (error) throw error;
48

49
      return data;
50
    });
51
  },
52
});