The open source Background Jobs framework for TypeScript

1
client.defineJob({
2
  id: "tweet-generator",
3
  name: "Generate tweets from an idea",
4
  version: "0.1.4",
5
  integrations: { openai, twitter },
6
  trigger: eventTrigger({
7
    name: "tweet.idea",
8
    schema: z.object({
9
      idea: z.string(),
10
      scheduledTime: z.date(),
11
    }),
12
  }),
13
  run: async (payload, io, ctx) => {
14
    const generatedTweet = await io.openai.createCompletion("Generate ✨", {
15
      model: "text-davinci-003",
16
      prompt: tweetPrompt(payload.idea),
17
    });
18

19
    await io.wait("Wait 🕘", { date: payload.scheduledTime });
20

21
    await io.twitter.tweet("Tweet 🐥", {
22
      text: generatedTweet,
23
    });
24
  },
25
});
26
// Send the "tweet.idea" event to trigger the tweet-generator job
27
await client.sendEvent("tweet.idea", {
28
  idea: "Write a funny javascript joke",
29
  scheduledTime: new Date(),
30
});

1
client.defineJob({
2
  id: "weekly-user-activity-summary",
3
  name: "Weekly user activity summary",
4
  version: "0.1.4",
5
  integrations: { sendgrid },
6
  trigger: cronTrigger({
7
    cron: "0 16 * * 5",
8
  }),
9
  run: async (payload, io, ctx) => {
10
    const users = await db.users.findMany({ summariesEnabled: true });
11

12
    for (const user of users) {
13
      await io.sendgrid.sendEmail(`Weekly summary for ${user.id}`, {
14
        to: user.email,
15
        from: "[email protected]",
16
        subject: "Your weekly summary",
17
        html: weeklySummaryEmail(user),
18
      });
19
    }
20

21
    await io.slack.postMessage("Notify team", {
22
      text: `Weekly summary sent to ${users.length} users`,
23
      channel: "summaries",
24
    });
25
  },
26
});