Slack

1
import { TriggerClient, cronTrigger } from "@trigger.dev/sdk";
2
import { SendGrid } from "@trigger.dev/sendgrid";
3
import { Slack } from "@trigger.dev/slack";
4
import { weeklySummaryDb } from "./mocks/db";
5
import { weeklySummaryEmail } from "./mocks/emails";
6
const sendgrid = new SendGrid({
7
  id: "sendgrid",
8
  apiKey: process.env.SENDGRID_API_KEY!,
9
});
10

11
const slack = new Slack({ id: "slack" });
12

13
// This Job sends a weekly summary email to users who have
14
// summariesEnabled = true, and then posts the total numbers to Slack.
15
client.defineJob({
16
  id: "weekly-user-activity-summary",
17
  name: "Weekly user activity summary",
18
  version: "1.0.0",
19
  integrations: { sendgrid, slack },
20
  trigger: cronTrigger({
21
    // Send every Friday at 4pm
22
    cron: "0 16 * * 5",
23
  }),
24
  run: async (payload, io, ctx) => {
25
    const users = await weeklySummaryDb.getUsers();
26

27
    let sentCount = 0;
28
    let notSentCount = 0;
29

30
    for (const user of users) {
31
      if (user.summariesEnabled) {
32
        await io.sendgrid.sendEmail(`Weekly summary for ${user.id}`, {
33
          to: user.email,
34
          // The 'from' email must be a verified domain in your SendGrid account.
35
          from: "[email protected]",
36
          subject: "Your weekly summary",
37
          html: weeklySummaryEmail(user),
38
        });
39
        sentCount++;
40
      } else {
41
        notSentCount++;
42
      }
43
    }
44

45
    await io.slack.postMessage("Notify team", {
46
      text: `Weekly summary sent to ${sentCount} users and not sent to ${notSentCount} users`,
47
      // This has to be a channel ID, not a channel name
48
      channel: "YOUR_CHANNEL_ID",
49
    });
50
  },
51
});