YouTube

Upload videos, manage your playlists and subscribers.

Using the YouTube API with Trigger.dev

You can use Trigger.dev with any existing Node SDK or even just using fetch. Using io.runTask makes your YouTube 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 YouTube

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

Search for a YouTube video A job that is triggered by a YouTube webhook.

1
import { TriggerClient } from "@trigger.dev/sdk";
2
import { createHmac } from "crypto";
3
import { XMLParser } from "fast-xml-parser";
4
// Docs: https://developers.google.com/youtube/v3/guides/push_notifications
5
// Go to https://pubsubhubbub.appspot.com/subscribe and enter the following details:
6
// callback URL is endpoint URL
7
// Topic URL is https://www.youtube.com/xml/feeds/videos.xml?channel_id=CHANNEL_ID (replace CHANNEL_ID with your channel ID)
8
// Select Verify Type as Synchronous
9
// Select mode as subscribe
10
// For Hmac secret and Verify Token, enter the same value. This is the secret that will be used to verify the request.
11
// Get endpoint URL and Secret from the `trigger.dev` dashboard
12
// Set the YOUTUBE_SIGNING_SECRET (Secret) in the .env file.
13

14
// Create an HTTP Endpoint, with the YouTube details
15
export const youtube = client.defineHttpEndpoint({
16
  id: "youtube.com",
17
  title: "YouTube",
18
  source: "youtube.com",
19
  icon: "youtube",
20
  respondWith: {
21
    // Don't trigger runs if they match this filter
22
    skipTriggeringRuns: true,
23
    filter: {
24
      query: {
25
        "hub.mode": [{ $endsWith: "subscribe" }],
26
      },
27
    },
28
    handler: async (request, verify) => {
29
      const searchParams = new URL(request.url).searchParams;
30

31
      if (
32
        searchParams.get("hub.verify_token") !==
33
        process.env.YOUTUBE_SIGNING_SECRET
34
      ) {
35
        return new Response("Unauthorized", { status: 401 });
36
      }
37
      return new Response(searchParams.get("hub.challenge") ?? "OK", {
38
        status: 200,
39
      });
40
    },
41
  },
42
  verify: async (request) => {
43
    const signature = request.headers.get("x-hub-signature");
44

45
    if (!signature) {
46
      return { success: false, reason: "Missing header" };
47
    }
48

49
    const secret = process.env.YOUTUBE_SIGNING_SECRET;
50

51
    if (!secret) {
52
      return { success: false, reason: "Missing secret" };
53
    }
54

55
    const [algorithm, hash] = signature.split("=");
56
    const body = await request.text();
57
    const digest = createHmac(algorithm, secret).update(body).digest("hex");
58

59
    if (hash !== digest) {
60
      return { success: false, reason: "Failed sha1 verification" };
61
    }
62

63
    return { success: true };
64
  },
65
});
66

67
client.defineJob({
68
  id: "http-youtube",
69
  name: "HTTP YouTube",
70
  version: "1.0.0",
71
  enabled: true,
72
  // Create a trigger from the HTTP endpoint
73
  trigger: youtube.onRequest(),
74
  run: async (request, io, ctx) => {
75
    const body = await request.text();
76
    const parser = new XMLParser();
77
    const jObj = parser.parse(body);
78
    await io.logger.info(`Body`, jObj);
79
  },
80
});