Tasks

client.defineJob({
  id: "new-user",
  name: "Run when a new user signs up",
  version: "0.0.1",
  trigger: eventTrigger({
    name: "new.user",
    schema: z.object({
      userId: z.string(),
    }),
  }),
  integrations: {
    resend,
  },
  run: async (payload, io, ctx) => {
    // regular code, not a Task
    // the inputs/outputs of this function are not sent to the Trigger.dev platform
    const user = await prisma.user.findUnique({
      where: { id: payload.userId },
      select: { email: true, name: true },
    });
    if (!user) throw new Error(`User not found: ${payload.userId}`);

    // Integration functions are Tasks
    await io.resend.sendEmail("Welcome email", {
      to: user.email,
      from: "[email protected]",
      subject: "Welcome!",
      html: welcomeEmail(user.name),
    });

    // built-in io functions are Tasks
    await io.wait("wait", 60 * 60 * 3); // wait for 3 hours

    // You can wrap your own code in a Task, for retrying, resumability and logging
    const response = await io.runTask(
      "my-task",
      async () => {
        return await longRunningCode(payload.userId);
      },
      { name: "My Task" }
    );

    return response;
  },
});