single.highest.test.mjs

// =============================[ USING YT-DLX'S DOWNLOAD MACHANISM ]=============================
//
import colors from "colors";
import YouTube from "yt-dlx";
(async () => {
  try {
    await YouTube.default.VideoOnly.Single.Highest({
      stream: false,
      verbose: true,
      useTor: false,
      output: "public/video",
      query: "video-NAME/ID/URL",
    });
  } catch (error) {
    console.error(colors.red(error.message));
  }
})();
//
// =============================[ USING STREAMING TO SAVE THE FILE ]=============================
//
import * as fs from "fs";
(async () => {
  try {
    const result = await YouTube.default.VideoOnly.Single.Highest({
      stream: true,
      verbose: true,
      useTor: false,
      output: "public/video",
      query: "video-NAME/ID/URL",
    });
    if (result && result.filename && result.ffmpeg) {
      result.ffmpeg.pipe(fs.createWriteStream(result.filename), {
        end: true,
      });
    } else {
      console.error(colors.red("@error:"), "ffmpeg or filename not found!");
    }
  } catch (error) {
    console.error(colors.red(error.message));
  }
})();
//
// =============================[ USING STREAMING TO PIPE THE FILE ]=============================
//
import express from "express";
(async () => {
  try {
    const server = express();
    server.get("/video/:query", async (req, res) => {
      try {
        const queryParam = req.params.query;
        const result = await YouTube.default.VideoOnly.Single.Highest({
          stream: true,
          verbose: true,
          useTor: false,
          query: queryParam,
        });
        if (result && result.filename && result.ffmpeg) {
          result.ffmpeg.pipe(res, { end: true });
        } else res.status(404).send("ffmpeg or filename not found!");
      } catch (error) {
        res.status(500).send(error.message);
      }
    });
    server.listen(3000, () => {
      console.log(colors.blue("@server:"), "running on port 3000");
    });
  } catch (error) {
    console.error(colors.red(error.message));
  }
})();
//
// ========================================================================================