Supabase

1
import { SupabaseManagement } from "@trigger.dev/supabase";
2
import { Database } from "./mocks/supabase-types";
3
import { Resend } from "@trigger.dev/resend";
4
import { TriggerClient } from "@trigger.dev/sdk";
5
// Use OAuth to authenticate with Supabase Management API
6
const supabaseManagement = new SupabaseManagement({
7
  id: "supabase-management",
8
});
9

10
const db = supabaseManagement.db<Database>(
11
  // process.env.NEXT_PUBLIC_SUPABASE_URL! // Use if using standard Supabase domain
12
  process.env.SUPABASE_REFERENCE_ID! // Use if using a Supabase custom domain
13
);
14

15
const resend = new Resend({
16
  id: "resend",
17
  apiKey: process.env.RESEND_API_KEY!,
18
});
19

20
// This job triggers when a Supabase user confirms their email address
21
client.defineJob({
22
  id: "welcome-email-campaign",
23
  name: "Welcome Email Campaign",
24
  version: "1.0.0",
25
  trigger: db.onUpdated({
26
    // This job triggers when there is an update in the 'users' table of the 'auth' schema.
27
    // Specifically, it watches for a change in the 'email_confirmed_at' field from null (unconfirmed email)
28
    // to a timestamp (confirmed email).
29
    schema: "auth",
30
    table: "users",
31
    filter: {
32
      old_record: {
33
        email_confirmed_at: [{ $isNull: true }],
34
      },
35
      record: {
36
        email_confirmed_at: [{ $isNull: false }],
37
      },
38
    },
39
  }),
40
  integrations: {
41
    resend,
42
  },
43
  run: async (payload, io, ctx) => {
44
    if (!payload.record.email) {
45
      return;
46
    }
47

48
    const isTestOrDev =
49
      ctx.run.isTest || ctx.environment.type === "DEVELOPMENT";
50

51
    // Only wait for 10 seconds when running as a test or in the development environment
52
    await io.wait("wait-1", isTestOrDev ? 10 : 60 * 60); // 1 hour
53

54
    const email1 = await io.resend.sendEmail("email-1", {
55
      to: payload.record.email,
56
      subject: `Thanks for joining Acme Inc`,
57
      text: `Hi there, welcome to our community! This is the first email we send you to help you get started.`,
58
      from: process.env.RESEND_FROM_EMAIL!,
59
    });
60

61
    await io.wait("wait-2", isTestOrDev ? 10 : 60 * 60 * 12); // 12 hours
62

63
    const email2 = await io.resend.sendEmail("email-2", {
64
      to: payload.record.email,
65
      subject: `Here are some tips to get started`,
66
      text: `Hi there, welcome to our community! This is the second email we send you to help you get started.`,
67
      from: process.env.RESEND_FROM_EMAIL!,
68
    });
69

70
    await io.wait("wait-3", isTestOrDev ? 10 : 60 * 60 * 24); // 24 hours
71

72
    const email3 = await io.resend.sendEmail("email-3", {
73
      to: payload.record.email,
74
      subject: "Do you have any questions?",
75
      text: `Hi there, welcome to our community! This is the third email we send you to help you get started.`,
76
      from: process.env.RESEND_FROM_EMAIL!,
77
    });
78

79
    return {
80
      email1,
81
      email2,
82
      email3,
83
    };
84
  },
85
});