Segment

Integrate data collection and management for user analytics.

Using the Segment API with Trigger.dev

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

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

Use our HTTP endpoint to subscribe to webhooks

Example code using Segment

Below are some working code examples of how you can use Segment with Trigger.dev. These samples are open source and maintained by the community, you can copy and paste them into your own projects.

Get source information from Segment.A job that is triggered by a Segment webhook.

1
import { TriggerClient } from "@trigger.dev/sdk";
2
import crypto from "crypto";
3
// Create an HTTP Endpoint, with the Segment details
4
const segment = client.defineHttpEndpoint({
5
  id: "segment",
6
  source: "segment.com",
7
  icon: "segment",
8
  verify: async (request) => {
9
    const signature = request.headers.get("X-Signature");
10

11
    if (!signature) {
12
      return { success: false, reason: "Missing header" };
13
    }
14

15
    const body = await request.text();
16
    const bodyDigest = crypto
17
      .createHmac("sha1", process.env.SEGMENT_WEBHOOK_SIGNING_SECRET!)
18
      .update(body)
19
      .digest("hex");
20

21
    if (signature !== bodyDigest) {
22
      return { success: false, reason: "Failed sha1 verification" };
23
    }
24

25
    return { success: true };
26
  },
27
});
28

29
client.defineJob({
30
  id: "http-segment",
31
  name: "HTTP Segment",
32
  version: "1.0.0",
33
  enabled: true,
34
  // Create a trigger from the HTTP endpoint
35
  trigger: segment.onRequest(),
36
  run: async (request, io, ctx) => {
37
    const body = await request.json();
38
    await io.logger.info(`Body`, body);
39
  },
40
});