Node.js'da ijtimoiy tarmoq videosini yuklab olish

Node 18'dan beri fetch ichida bor, ya'ni o'rnatiladigan mijoz kutubxonasi yo'q. Nusxa olishga arziydigan qismi — AbortSignal.timeout: usiz sekin manba handlerni platforma o'ldirguncha tirik ushlab turadi.

const API = "https://api.saveapi.org/v1/download";

async function resolve(link) {
  const res = await fetch(API + "?url=" + encodeURIComponent(link), {
    headers: { Authorization: "Bearer sk_live_xxxx" },
    signal: AbortSignal.timeout(30_000),
  });
  return res.json();
}

medias[] postdagi hamma faylni o'z tartibida saqlaydi. TikTok slayd-shousi rasm yozuvlarini va fon musiqasi uchun alohida audio yozuvini beradi, shuning uchun medias[0] ga umid qilmasdan type bo'yicha find() qiling.

const data = await resolve("https://www.tiktok.com/@user/video/123");

if (!data.success) throw new Error(data.error.code);

const video = data.medias.find((m) => m.type === "video");
const images = data.medias.filter((m) => m.type === "image");
const audio = data.medias.find((m) => m.type === "audio");

Agar foydalanuvchilaringiz yuklash tugmasini bossa, faylni xotirada to'plamang va ularni manba CDN'iga yo'naltirmang — havola imzolangan va tez o'chadi. Upstream tanasini o'z javobingizga pipe qiling va Content-Disposition sarlavhasi bilan brauzer uni siz tanlagan nom bilan saqlaydi.

import { Readable } from "node:stream";

app.get("/save", async (req, res) => {
  const data = await resolve(req.query.url);
  if (!data.success) return res.status(400).json(data.error);

  const upstream = await fetch(data.medias[0].url);
  res.setHeader("Content-Type", "video/mp4");
  res.setHeader("Content-Disposition", 'attachment; filename="video.mp4"');
  Readable.fromWeb(upstream.body).pipe(res);
});

Timeout va upstream xatosi ikkinchi urinishga arziydi. Yopiq, topilmagan va qo'llab-quvvatlanmaydigan javoblar esa yakuniy — ularni takrorlash vaqtni, hisoblanadigan xatolarda esa kreditni ham behuda sarflaydi. Qayta uriniladigan kodlarni Set ichida saqlang, qoida bitta joyda tursin.

const RETRY = new Set(["UPSTREAM_TIMEOUT", "UPSTREAM_ERROR"]);

async function withRetry(link) {
  for (let attempt = 0; attempt < 2; attempt++) {
    const data = await resolve(link);
    if (data.success) return data;
    if (!RETRY.has(data.error.code)) throw new Error(data.error.message);
  }
  throw new Error("source unavailable");
}

Har javobda daqiqalik chegara, undan qolgani va qolgan kredit bor. Chegaralanishdan oldin sekinlashish va paket tugayotganida ogohlantirish uchun shuning o'zi yetarli — qo'shimcha so'rovsiz.

const res = await fetch(API + "?url=" + encodeURIComponent(link), { headers });

const perMinute = Number(res.headers.get("X-RateLimit-Limit"));
const left = Number(res.headers.get("X-RateLimit-Remaining"));
const credits = Number(res.headers.get("X-Credits-Remaining"));

Foydalanuvchi ixtiyoriy matn tashlaydigan joyda /v1/detect havola qaysi platformaga tegishli ekanini kreditga tegmasdan aytadi. U rate limitga kiradi, ya'ni bu bepul zond emas, tekshirish qadami.

const check = await fetch(
  "https://api.saveapi.org/v1/detect?url=" + encodeURIComponent(userInput),
  { headers },
);
const { platform } = await check.json();   // kredit sarflanmaydi