Change names to embedsu, add correct quality parsing and change routes, parse subtitle languages and format them in ISO 639-1:2002 standard

This commit is contained in:
An0n-00
2025-02-15 14:58:26 +01:00
parent 8c07b87676
commit ef59e4bf68
7 changed files with 396 additions and 187 deletions
+123
View File
@@ -0,0 +1,123 @@
import fetch from 'node-fetch';
import { languageMap } from './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) {
if (item.name.toLowerCase() !== "viper") continue;
const urlDirect = `${DOMAIN}/api/e/${item.hash}`;
const dataDirect = await requestGet(urlDirect, {
"Referer": DOMAIN,
"User-Agent": headers['User-Agent'],
"Accept": "*/*"
});
if (!dataDirect.source) continue;
const tracks = dataDirect.subtitles.map(sub => ({
url: sub.file,
lang: languageMap[sub.label.split(' ')[0]] || sub.label
})).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 "";
}
}
+126
View File
@@ -0,0 +1,126 @@
export const languageMap = {
"Abkhazian": "ab",
"Afar": "aa",
"Afrikaans": "af",
"Albanian": "sq",
"Amharic": "am",
"Arabic": "ar",
"Aragonese": "an",
"Armenian": "hy",
"Assamese": "as",
"Aymara": "ay",
"Azerbaijani": "az",
"Bashkir": "ba",
"Basque": "eu",
"Bengali": "bn",
"Bihari": "bh",
"Bislama": "bi",
"Bosnian": "bs",
"Breton": "br",
"Bulgarian": "bg",
"Burmese": "my",
"Catalan": "ca",
"Chinese": "zh",
"Chuvash": "cv",
"Cornish": "kw",
"Corsican": "co",
"Croatian": "hr",
"Czech": "cs",
"Danish": "da",
"Dutch": "nl",
"Dzongkha": "dz",
"English": "en",
"Esperanto": "eo",
"Estonian": "et",
"Ewe": "ee",
"Fijian": "fj",
"Finnish": "fi",
"French": "fr",
"Georgian": "ka",
"German": "de",
"Greek": "el",
"Guaraní": "gn",
"Gujarati": "gu",
"Haitian Creole": "ht",
"Hausa": "ha",
"Hawaiian": "haw",
"Hebrew": "he",
"Hindi": "hi",
"Hmong": "hmn",
"Hungarian": "hu",
"Icelandic": "is",
"Igbo": "ig",
"Indonesian": "id",
"Interlingua": "ia",
"Irish": "ga",
"Italian": "it",
"Japanese": "ja",
"Javanese": "jv",
"Kannada": "kn",
"Kazakh": "kk",
"Khmer": "km",
"Kinyarwanda": "rw",
"Korean": "ko",
"Kurdish": "ku",
"Kyrgyz": "ky",
"Lao": "lo",
"Latin": "la",
"Latvian": "lv",
"Lingala": "ln",
"Lithuanian": "lt",
"Luxembourgish": "lb",
"Macedonian": "mk",
"Malagasy": "mg",
"Malay": "ms",
"Malayalam": "ml",
"Maltese": "mt",
"Maori": "mi",
"Marathi": "mr",
"Mongolian": "mn",
"Nepali": "ne",
"Norwegian": "no",
"Occitan": "oc",
"Oromo": "om",
"Pashto": "ps",
"Persian": "fa",
"Polish": "pl",
"Portuguese": "pt",
"Quechua": "qu",
"Romanian": "ro",
"Russian": "ru",
"Samoan": "sm",
"Sanskrit": "sa",
"Scots Gaelic": "gd",
"Serbian": "sr",
"Sesotho": "st",
"Shona": "sn",
"Sindhi": "sd",
"Sinhalese": "si",
"Slovak": "sk",
"Slovenian": "sl",
"Somali": "so",
"Spanish": "es",
"Sundanese": "su",
"Swahili": "sw",
"Swedish": "sv",
"Tajik": "tg",
"Tamil": "ta",
"Tatar": "tt",
"Telugu": "te",
"Thai": "th",
"Tigrinya": "ti",
"Turkish": "tr",
"Turkmen": "tk",
"Ukrainian": "uk",
"Urdu": "ur",
"Uzbek": "uz",
"Vietnamese": "vi",
"Volapük": "vo",
"Walloon": "wa",
"Welsh": "cy",
"Wolof": "wo",
"Xhosa": "xh",
"Yiddish": "yi",
"Yoruba": "yo",
"Zulu": "zu"
};
-174
View File
@@ -1,174 +0,0 @@
export async function getvidsrc(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 {
let urlSearch = '';
if(s && e){
urlSearch = `${DOMAIN}/embed/tv/${tmdb_id}/${s}/${e}`;
} else {
urlSearch = `${DOMAIN}/embed/movie/${tmdb_id}`;
}
const htmlSearch = await fetch(urlSearch, {
method: 'GET',
headers: 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 string_atob(hashEncode));
const mEncrypt = hashDecode.hash;
if (!mEncrypt) {
return;
}
const firstDecode = (await string_atob(mEncrypt)).split(".").map(item => item.split("").reverse().join(""));
const secondDecode = JSON.parse(await string_atob(firstDecode.join("").split("").reverse().join("")));
if (!secondDecode || secondDecode.length == 0) {
return;
}
for (let i = 0; i < secondDecode.length; i++) {
const item = secondDecode[i];
if (item.name.toLowerCase() != "viper") {
continue;
}
const urlDirect = `${DOMAIN}/api/e/${item.hash}`;
const dataDirect = await request_get(urlDirect, {
"Referer": "https://embed.su/",
"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",
"Accept": "*/*"
}, false);
if (!dataDirect.source) {
continue;
}
const tracks = [];
try {
for (let j = 0; j < dataDirect.subtitles.length; j++) {
const itemTrack = dataDirect.subtitles[j];
const labelMatch = itemTrack.label.match(/^([A-z]+)/i);
const label = labelMatch ? labelMatch[1] : "";
if (!label) {
continue;
}
tracks.push({
url: itemTrack.file,
lang: label
});
}
} catch (etrack) { }
const requestDirectSize = await fetch(dataDirect.source, {
headers: {
"Referer": `${DOMAIN}`,
"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",
"Accept": "*/*"
},
method: "GET",
});
const parseRequest = await requestDirectSize.text();
const patternSize = [];
const parseDirectSize = parseRequest.split('\n');
for (let k = 0; k < parseDirectSize.length; k++) {
const item = parseDirectSize[k];
if (item.indexOf('/proxy/') == -1) {
continue;
}
patternSize.push(item);
}
const directQuality = [];
for (let l = 0; l < patternSize.length; l++) {
const patternItem = patternSize[l];
const sizeQualityMatch = patternItem.match(/\/([0-9]+)\//i);
const sizeQuality = sizeQualityMatch ? Number(sizeQualityMatch[1]) : 1080;
let dURL = `${DOMAIN}${patternItem}`;
dURL = dURL.replace("embed.su/api/proxy/viper/", "");
dURL = dURL.replace(".png", ".m3u8");
directQuality.push({
url: dURL,
quality: sizeQuality.toString(),
isM3U8: true
});
}
if (!directQuality.length) {
continue;
}
directQuality.sort((a, b) => b.quality - a.quality);
const results = {
headers: {
"Referer": "https://embed.su/",
"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",
"Accept": "*/*"
},
sources: directQuality,
subtitles: tracks
};
return results;
}
} catch (e) {
const results = {
headers: {},
sources: '',
subtitles: ''
};
return results;
}
}
async function string_atob(input) {
var chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=';
var str = input.replace(/=+$/, '');
var output = '';
if (str.length % 4 == 1) {
throw new Error("'atob' failed: The string to be decoded is not correctly encoded.");
}
for (var bc = 0, bs = 0, buffer = void 0, 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 request_get(url, headers = {}) {
try {
headers = headers || {};
const response = await fetch(url, {
method: 'GET',
headers: headers,
});
if (!response.ok) {
throw new Error(`HTTP error! status: ${response.status}`);
}
const data = await response.json();
return data;
} catch (error) {
return "";
}
}