Resend email sequence

import { task, wait, retry } from "@trigger.dev/sdk";
import { Resend } from "resend";

const resend = new Resend(process.env.RESEND_API_KEY);

export const emailSequence = task({
  id: "email-sequence",
  run: async (payload: { userId: string; email: string; name: string }) => {
    console.log(`Starting email sequence for user ${payload.userId}`);

    // Email 1 — sent immediately
    const firstEmailResult = await retry.onThrow(
      async ({ attempt }) => {
        const { data, error } = await resend.emails.send({
          from: "hello@trigger.dev",
          to: payload.email,
          subject: "Welcome to Trigger.dev",
          html: `<p>Hello ${payload.name},</p><p>Welcome to Trigger.dev</p>`,
        });

        if (error) {
          // Throwing retries only this block, not the whole task
          throw error;
        }

        return data;
      },
      { maxAttempts: 3 }
    );

    // Wait 3 days before sending the next email.
    // The task is fully suspended and uses no resources during this time.
    await wait.for({ days: 3 });

    // Email 2 — sent after 3 days
    const secondEmailResult = await retry.onThrow(
      async ({ attempt }) => {
        const { data, error } = await resend.emails.send({
          from: "hello@trigger.dev",
          to: payload.email,
          subject: "Some tips for you",
          html: `<p>Hello ${payload.name},</p><p>Here are some tips for you…</p>`,
        });

        if (error) {
          throw error;
        }

        return data;
      },
      { maxAttempts: 3 }
    );

    // Add more wait.for + retry.onThrow blocks to extend the sequence
    return { firstEmailResult, secondEmailResult };
  },
});