Create an example job using the X (Twitter) API and SDK about api-reference HOT 4 CLOSED

import { TriggerClient, eventTrigger } from "@trigger.dev/sdk";
import z from "zod";
import axios from "axios";

const client = new TriggerClient({
  id: "api-reference",
});

client.defineJob({
  id: "tweet-x",
  name: "Tweet X",
  version: "1.0.0",
  trigger: eventTrigger({
    name: "tweet-x",
    schema: z.object({
      text: z.string(),
    }),
  }),
  run: async (payload, io, ctx) => {
    const { text } = payload;

    // Wrap an SDK call in io.runTask so it's resumable and displays in logs
    await io.runTask(
      "Tweet X",
      async () => {
        try {
          await axios.post(
            "https://api.twitter.com/1.1/statuses/update.json",
            {
              status: text,
            },
            {
              headers: {
                Authorization: `Bearer ${process.env.X_BEARER_TOKEN}`,
                "Content-Type": "application/json",
              },
            }
          );
        } catch (e: any) {
          console.log(e.response.data);
        }
      },

      // Add metadata to the task to improve the display in the logs
      { name: "Tweet X", icon: "twitter" }
    );
  },
});

// These lines can be removed if you don't want to use express
import { createExpressServer } from "@trigger.dev/express";
createExpressServer(client);