diff --git a/src/backend/providers/2embed.ts b/src/backend/providers/2embed.ts new file mode 100644 index 00000000..48056020 --- /dev/null +++ b/src/backend/providers/2embed.ts @@ -0,0 +1,251 @@ +import Base64 from "crypto-js/enc-base64"; +import Utf8 from "crypto-js/enc-utf8"; + +import { proxiedFetch, rawProxiedFetch } from "../helpers/fetch"; +import { registerProvider } from "../helpers/register"; +import { + MWCaptionType, + MWStreamQuality, + MWStreamType, +} from "../helpers/streams"; +import { MWMediaType } from "../metadata/types"; + +const twoEmbedBase = "https://www.2embed.to"; + +async function fetchCaptchaToken(recaptchaKey: string) { + const domainHash = Base64.stringify(Utf8.parse(twoEmbedBase)).replace( + /=/g, + "." + ); + + const recaptchaRender = await proxiedFetch( + `https://www.google.com/recaptcha/api.js?render=${recaptchaKey}` + ); + + const vToken = recaptchaRender.substring( + recaptchaRender.indexOf("/releases/") + 10, + recaptchaRender.indexOf("/recaptcha__en.js") + ); + + const recaptchaAnchor = await proxiedFetch( + `https://www.google.com/recaptcha/api2/anchor?ar=1&hl=en&size=invisible&cb=flicklax&k=${recaptchaKey}&co=${domainHash}&v=${vToken}` + ); + + const cToken = new DOMParser() + .parseFromString(recaptchaAnchor, "text/html") + .getElementById("recaptcha-token") + ?.getAttribute("value"); + + if (!cToken) throw new Error("Unable to find cToken"); + + const payload = { + v: vToken, + reason: "q", + k: recaptchaKey, + c: cToken, + sa: "", + co: twoEmbedBase, + }; + + const tokenData = await proxiedFetch( + `https://www.google.com/recaptcha/api2/reload?${new URLSearchParams( + payload + ).toString()}`, + { + headers: { referer: "https://www.google.com/recaptcha/api2/" }, + method: "POST", + } + ); + + const token = tokenData.match('rresp","(.+?)"'); + return token ? token[1] : null; +} + +interface IEmbedRes { + link: string; + sources: []; + tracks: []; + type: string; +} + +interface IStreamData { + status: string; + message: string; + type: string; + token: string; + result: + | { + Original: { + label: string; + file: string; + url: string; + }; + } + | { + label: string; + size: number; + url: string; + }[]; +} + +interface ISubtitles { + url: string; + lang: string; +} + +async function fetchStream(sourceId: string, captchaToken: string) { + const embedRes = await proxiedFetch( + `${twoEmbedBase}/ajax/embed/play?id=${sourceId}&_token=${captchaToken}`, + { + headers: { + Referer: twoEmbedBase, + }, + } + ); + + // Link format: https://rabbitstream.net/embed-4/{data-id}?z= + const rabbitStreamUrl = new URL(embedRes.link); + + const dataPath = rabbitStreamUrl.pathname.split("/"); + const dataId = dataPath[dataPath.length - 1]; + + // https://rabbitstream.net/embed/m-download/{data-id} + const download = await proxiedFetch( + `${rabbitStreamUrl.origin}/embed/m-download/${dataId}`, + { + headers: { + referer: twoEmbedBase, + }, + } + ); + + const downloadPage = new DOMParser().parseFromString(download, "text/html"); + + const streamlareEl = Array.from( + downloadPage.querySelectorAll(".dls-brand") + ).find((el) => el.textContent?.trim() === "Streamlare"); + if (!streamlareEl) throw new Error("Unable to find streamlare element"); + + const streamlareUrl = + streamlareEl.nextElementSibling?.querySelector("a")?.href; + if (!streamlareUrl) throw new Error("Unable to parse streamlare url"); + + const subtitles: ISubtitles[] = []; + const subtitlesDropdown = downloadPage.querySelectorAll( + "#user_menu .dropdown-item" + ); + subtitlesDropdown.forEach((item) => { + const url = item.getAttribute("href"); + const lang = item.textContent?.trim().replace("Download", "").trim(); + if (url && lang) subtitles.push({ url, lang }); + }); + + const streamlare = await proxiedFetch(streamlareUrl); + + const streamlarePage = new DOMParser().parseFromString( + streamlare, + "text/html" + ); + + const csrfToken = streamlarePage + .querySelector("head > meta:nth-child(3)") + ?.getAttribute("content"); + + if (!csrfToken) throw new Error("Unable to find CSRF token"); + + const videoId = streamlareUrl.match("/[ve]/([^?#&/]+)")?.[1]; + if (!videoId) throw new Error("Unable to get streamlare video id"); + + const streamRes = await proxiedFetch( + `${new URL(streamlareUrl).origin}/api/video/download/get`, + { + method: "POST", + body: JSON.stringify({ + id: videoId, + }), + headers: { + "X-Requested-With": "XMLHttpRequest", + "X-CSRF-Token": csrfToken, + }, + } + ); + + if (streamRes.message !== "OK") throw new Error("Unable to fetch stream"); + + const streamData = Array.isArray(streamRes.result) + ? streamRes.result[0] + : streamRes.result.Original; + if (!streamData) throw new Error("Unable to get stream data"); + + const followStream = await rawProxiedFetch(streamData.url, { + method: "HEAD", + referrer: new URL(streamlareUrl).origin, + }); + + const finalStreamUrl = followStream.headers.get("X-Final-Destination"); + return { url: finalStreamUrl, subtitles }; +} + +registerProvider({ + id: "2embed", + displayName: "2Embed", + rank: 125, + type: [MWMediaType.MOVIE, MWMediaType.SERIES], + async scrape({ media, episode, progress }) { + let embedUrl = `${twoEmbedBase}/embed/tmdb/movie?id=${media.tmdbId}`; + + if (media.meta.type === MWMediaType.SERIES) { + const seasonNumber = media.meta.seasonData.number; + const episodeNumber = media.meta.seasonData.episodes.find( + (e) => e.id === episode + )?.number; + + embedUrl = `${twoEmbedBase}/embed/tmdb/tv?id=${media.tmdbId}&s=${seasonNumber}&e=${episodeNumber}`; + } + + const embed = await proxiedFetch(embedUrl); + progress(20); + + const embedPage = new DOMParser().parseFromString(embed, "text/html"); + + const pageServerItems = Array.from( + embedPage.querySelectorAll(".item-server") + ); + const pageStreamItem = pageServerItems.find((item) => + item.textContent?.includes("Vidcloud") + ); + + const sourceId = pageStreamItem + ? pageStreamItem.getAttribute("data-id") + : null; + if (!sourceId) throw new Error("Unable to get source id"); + + const siteKey = embedPage + .querySelector("body") + ?.getAttribute("data-recaptcha-key"); + if (!siteKey) throw new Error("Unable to get site key"); + + const captchaToken = await fetchCaptchaToken(siteKey); + if (!captchaToken) throw new Error("Unable to fetch captcha token"); + progress(35); + + const stream = await fetchStream(sourceId, captchaToken); + if (!stream.url) throw new Error("Unable to find stream url"); + + return { + embeds: [], + stream: { + streamUrl: stream.url, + quality: MWStreamQuality.QUNKNOWN, + type: MWStreamType.MP4, + captions: stream.subtitles.map((sub) => { + return { + langIso: sub.lang, + url: `https://cc.2cdns.com${new URL(sub.url).pathname}`, + type: MWCaptionType.VTT, + }; + }), + }, + }; + }, +});