mirror of
https://github.com/Inside4ndroid/TMDB-Embed-API.git
synced 2026-10-22 17:45:11 +00:00
removed the need for language map an display full language label.
This commit is contained in:
@@ -0,0 +1,121 @@
|
||||
import fetch from 'node-fetch';
|
||||
import { languageMap } from '../utils/languages.js';
|
||||
|
||||
export async function getEmbedSu(tmdb_id, s, e) {
|
||||
const DOMAIN = "https://embed.su";
|
||||
const headers = {
|
||||
'User-Agent': "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36",
|
||||
'Referer': DOMAIN,
|
||||
'Origin': DOMAIN,
|
||||
};
|
||||
|
||||
try {
|
||||
const urlSearch = s && e ? `${DOMAIN}/embed/tv/${tmdb_id}/${s}/${e}` : `${DOMAIN}/embed/movie/${tmdb_id}`;
|
||||
const htmlSearch = await fetch(urlSearch, { method: 'GET', headers });
|
||||
const textSearch = await htmlSearch.text();
|
||||
|
||||
const hashEncodeMatch = textSearch.match(/JSON\.parse\(atob\(\`([^\`]+)/i);
|
||||
const hashEncode = hashEncodeMatch ? hashEncodeMatch[1] : "";
|
||||
|
||||
if (!hashEncode) return;
|
||||
|
||||
const hashDecode = JSON.parse(await stringAtob(hashEncode));
|
||||
const mEncrypt = hashDecode.hash;
|
||||
if (!mEncrypt) return;
|
||||
|
||||
const firstDecode = (await stringAtob(mEncrypt)).split(".").map(item => item.split("").reverse().join(""));
|
||||
const secondDecode = JSON.parse(await stringAtob(firstDecode.join("").split("").reverse().join("")));
|
||||
|
||||
if (!secondDecode || secondDecode.length === 0) return;
|
||||
|
||||
const sources = [];
|
||||
const subtitles = [];
|
||||
|
||||
for (const item of secondDecode) {
|
||||
const urlDirect = `${DOMAIN}/api/e/${item.hash}`;
|
||||
const dataDirect = await requestGet(urlDirect, {
|
||||
"Referer": DOMAIN,
|
||||
"User-Agent": headers['User-Agent'],
|
||||
"Origin": DOMAIN
|
||||
});
|
||||
|
||||
if (!dataDirect.source) continue;
|
||||
|
||||
const tracks = dataDirect.subtitles.map(sub => ({
|
||||
url: sub.file,
|
||||
lang: sub.label.split('-')[0].trim()
|
||||
})).filter(track => track.lang);
|
||||
|
||||
const requestDirectSize = await fetch(dataDirect.source, { headers, method: "GET" });
|
||||
const parseRequest = await requestDirectSize.text();
|
||||
|
||||
const patternSize = parseRequest.split('\n').filter(item => item.includes('/proxy/'));
|
||||
|
||||
const directQuality = patternSize.map(patternItem => {
|
||||
const sizeQuality = getSizeQuality(patternItem);
|
||||
let dURL = `${DOMAIN}${patternItem}`;
|
||||
dURL = dURL.replace("embed.su/api/proxy/viper/", "").replace(".png", ".m3u8");
|
||||
return { file: dURL, type: 'hls', quality: `${sizeQuality}p`, lang: 'en' };
|
||||
});
|
||||
|
||||
if (!directQuality.length) continue;
|
||||
|
||||
sources.push({
|
||||
provider: "EmbedSu",
|
||||
files: directQuality,
|
||||
headers: {
|
||||
"Referer": DOMAIN,
|
||||
"User-Agent": headers['User-Agent'],
|
||||
"Origin": DOMAIN
|
||||
}
|
||||
});
|
||||
|
||||
subtitles.push(...tracks);
|
||||
}
|
||||
|
||||
return {
|
||||
sources,
|
||||
subtitles
|
||||
};
|
||||
} catch (e) {
|
||||
return { provider: "EmbedSu", sources: [], subtitles: [] };
|
||||
}
|
||||
}
|
||||
|
||||
function getSizeQuality(url) {
|
||||
const parts = url.split('/');
|
||||
const base64Part = parts[parts.length - 2];
|
||||
const decodedPart = atob(base64Part);
|
||||
const sizeQuality = Number(decodedPart) || 1080;
|
||||
return sizeQuality;
|
||||
}
|
||||
|
||||
async function stringAtob(input) {
|
||||
const chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=';
|
||||
let str = input.replace(/=+$/, '');
|
||||
let output = '';
|
||||
|
||||
if (str.length % 4 === 1) {
|
||||
throw new Error("'atob' failed: The string to be decoded is not correctly encoded.");
|
||||
}
|
||||
|
||||
for (let bc = 0, bs = 0, buffer, i = 0; buffer = str.charAt(i++); ~buffer && (bs = bc % 4 ? bs * 64 + buffer : buffer, bc++ % 4) ? output += String.fromCharCode(255 & bs >> (-2 * bc & 6)) : 0) {
|
||||
buffer = chars.indexOf(buffer);
|
||||
}
|
||||
|
||||
return output;
|
||||
}
|
||||
|
||||
async function requestGet(url, headers = {}) {
|
||||
try {
|
||||
const response = await fetch(url, { method: 'GET', headers });
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error(`HTTP error! status: ${response.status}`);
|
||||
}
|
||||
|
||||
return await response.json();
|
||||
} catch (error) {
|
||||
return "";
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user