Resend

1
import { TriggerClient, TriggerContext, eventTrigger } from "@trigger.dev/sdk";
2
import {
3
  FirstEmail,
4
  MonthLaterEmail,
5
  SecondEmail,
6
  ThirdEmail,
7
} from "./mocks/reactEmails";
8
import { Resend } from "@trigger.dev/resend";
9
import { z } from "zod";
10
const resend = new Resend({
11
  id: "resend",
12
  apiKey: process.env.RESEND_API_KEY!,
13
});
14

15
// This job sends a drip campaign using Resend
16
client.defineJob({
17
  id: "resend-drip-campaign",
18
  name: "Resend: email drip campaign",
19
  version: "1.0.0",
20
  trigger: eventTrigger({
21
    name: "send.drip.campaign",
22
    schema: z.object({
23
      to: z.string(),
24
      // The 'from' email address must be a verified domain in your Resend account.
25
      from: z.string(),
26
      name: z.string(),
27
    }),
28
  }),
29
  integrations: {
30
    resend,
31
  },
32
  run: async (payload, io, ctx) => {
33
    const email1 = {
34
      text: `Hi there, welcome to our community! This is the first email we send you to help you get started.`,
35
    };
36

37
    // Email 1, triggered by an event
38
    await io.resend.sendEmail("email-1", {
39
      to: payload.to,
40
      from: payload.from,
41
      subject: `Thanks for joining Acme Inc`,
42
      text: email1.text,
43
      react: <FirstEmail name={payload.name} text={email1.text} />,
44
    });
45

46
    await io.wait("wait-1-day", delay(60 * 60 * 24 * 1, ctx));
47

48
    const email2 = {
49
      text: `Hi there, welcome to our community! This is the second email we send you to help you get started.`,
50
    };
51

52
    // Email 2, triggered after a day
53
    await io.resend.sendEmail("email-2", {
54
      to: payload.to,
55
      from: payload.from,
56
      subject: `Here are some tips to get started`,
57
      text: email2.text,
58
      react: <SecondEmail name={payload.name} text={email2.text} />,
59
    });
60

61
    await io.wait("wait-4-days", delay(60 * 60 * 24 * 4, ctx));
62

63
    const email3 = {
64
      text: `Hi there, welcome to our community! This is the third email we send you to help you get started.`,
65
    };
66

67
    // Email 3, triggered after 5 days
68
    await io.resend.sendEmail("email-3", {
69
      to: payload.to,
70
      from: payload.from,
71
      subject: `Do you have any questions?`,
72
      text: email3.text,
73
      react: <ThirdEmail name={payload.name} text={email3.text} />,
74
    });
75

76
    await io.wait("wait-26-days", delay(60 * 60 * 24 * 26, ctx));
77

78
    const email4 = {
79
      text: `This is the fourth email designed to re-engage your users after a month.`,
80
    };
81

82
    // Email 4, triggered after 30 days
83
    await io.resend.sendEmail("email-4", {
84
      to: payload.to,
85
      from: payload.from,
86
      subject: `How are you getting on with Acme Inc.?`,
87
      text: email4.text,
88
      react: <MonthLaterEmail name={payload.name} text={email4.text} />,
89
    });
90
  },
91
});
92

93
function delay(seconds: number, context: TriggerContext) {
94
  if (context.environment.type === "DEVELOPMENT" || context.run.isTest) {
95
    return 10;
96
  }
97
  return seconds;
98
}