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.

    import { TriggerClient } from "@trigger.dev/sdk";
    import { createHmac } from "crypto";
    import { XMLParser } from "fast-xml-parser";
    // Docs: https://developers.google.com/youtube/v3/guides/push_notifications
    // Go to https://pubsubhubbub.appspot.com/subscribe and enter the following details:
    // callback URL is endpoint URL
    // Topic URL is https://www.youtube.com/xml/feeds/videos.xml?channel_id=CHANNEL_ID (replace CHANNEL_ID with your channel ID)
    // Select Verify Type as Synchronous
    // Select mode as subscribe
    // For Hmac secret and Verify Token, enter the same value. This is the secret that will be used to verify the request.
    // Get endpoint URL and Secret from the `trigger.dev` dashboard
    // Set the YOUTUBE_SIGNING_SECRET (Secret) in the .env file.
    // Create an HTTP Endpoint, with the YouTube details
    export const youtube = client.defineHttpEndpoint({
    id: "youtube.com",
    title: "YouTube",
    source: "youtube.com",
    icon: "youtube",
    respondWith: {
    // Don't trigger runs if they match this filter
    skipTriggeringRuns: true,
    filter: {
    query: {
    "hub.mode": [{ $endsWith: "subscribe" }],
    handler: async (request, verify) => {
    const searchParams = new URL(request.url).searchParams;
    if (
    searchParams.get("hub.verify_token") !==
    ) {
    return new Response("Unauthorized", { status: 401 });
    return new Response(searchParams.get("hub.challenge") ?? "OK", {
    status: 200,
    verify: async (request) => {
    const signature = request.headers.get("x-hub-signature");
    if (!signature) {
    return { success: false, reason: "Missing header" };
    const secret = process.env.YOUTUBE_SIGNING_SECRET;
    if (!secret) {
    return { success: false, reason: "Missing secret" };
    const [algorithm, hash] = signature.split("=");
    const body = await request.text();
    const digest = createHmac(algorithm, secret).update(body).digest("hex");
    if (hash !== digest) {
    return { success: false, reason: "Failed sha1 verification" };
    return { success: true };
    id: "http-youtube",
    name: "HTTP YouTube",
    version: "1.0.0",
    enabled: true,
    // Create a trigger from the HTTP endpoint
    trigger: youtube.onRequest(),
    run: async (request, io, ctx) => {
    const body = await request.text();
    const parser = new XMLParser();
    const jObj = parser.parse(body);
    await io.logger.info(`Body`, jObj);