X (Twitter)

Schedule, update and delete posts on X.

Using the X (Twitter) API with Trigger.dev

You can use Trigger.dev with any existing Node SDK or even just using fetch. Using io.runTask makes your X (Twitter) background job resumable and appear in our dashboard.

Use io.runTask() and the official SDK or fetch.

Example code using X (Twitter)

Below is a working code example of how you can use X (Twitter) with Trigger.dev. These samples are open source and maintained by the community, you can copy and paste them into your own projects.

1
import { TriggerClient, eventTrigger } from "@trigger.dev/sdk";
2
import z from "zod";
3
import { createHmac } from "crypto";
4
import OAuth from "oauth-1.0a";
5
// Create tokens at
6
// https://developer.twitter.com/en/docs/twitter-api/getting-started/getting-access-to-the-twitter-api
7
const endpointURL = "https://api.twitter.com/2/tweets";
8
const token = {
9
  key: process.env.X_ACCESS_TOKEN!,
10
  secret: process.env.X_ACCESS_TOKEN_SECRET!,
11
};
12

13
// Using OAuth 1.0a
14
const oauth = new OAuth({
15
  consumer: {
16
    key: process.env.X_CONSUMER_KEY!,
17
    secret: process.env.X_CONSUMER_SECRET!,
18
  },
19
  signature_method: "HMAC-SHA1",
20
  hash_function: (baseString: string, key: string) =>
21
    createHmac("sha1", key).update(baseString).digest("base64"),
22
});
23

24
// Create an authorization header
25
const authHeader = oauth.toHeader(
26
  oauth.authorize({ url: endpointURL, method: "POST" }, token)
27
);
28

29
// Create request options
30
const requestOptions: RequestInit = {
31
  method: "POST",
32
  headers: {
33
    Authorization: authHeader["Authorization"],
34
    "user-agent": "v2CreateTweetJS",
35
    "content-type": "application/json",
36
    accept: "application/json",
37
  },
38
};
39

40
client.defineJob({
41
  id: "tweet-x",
42
  name: "Tweet X",
43
  version: "1.0.0",
44
  trigger: eventTrigger({
45
    name: "tweet-x",
46
    schema: z.object({
47
      text: z.string().max(280), // Tweets are limited to 280 characters
48
    }),
49
  }),
50
  run: async (payload, io, ctx) => {
51
    // Wrap an SDK call in io.runTask so it's resumable and displays in logs
52
    await io.runTask(
53
      "Tweet X",
54
      async () => {
55
        // Make request using Fetch API
56
        return await fetch(endpointURL, {
57
          ...requestOptions,
58
          body: JSON.stringify(payload),
59
        }).then((response) => response.json());
60
      },
61

62
      // Add metadata to improve how the task displays in the logs
63
      { name: "Tweet X", icon: "twitter" }
64
    );
65
  },
66
});