feat: add getWebstreamerStream function and update getStream to utilize it; bump version to 1.5 in manifest

This commit is contained in:
Himanshu
2025-12-26 16:04:59 +05:30
parent a087f22eb1
commit 86e74f911f
3 changed files with 126 additions and 108 deletions

File diff suppressed because one or more lines are too long

View File

@@ -10,7 +10,7 @@
{ {
"display_name": "MultiStream", "display_name": "MultiStream",
"value": "autoEmbed", "value": "autoEmbed",
"version": "1.4", "version": "1.5",
"icon": "", "icon": "",
"type": "global", "type": "global",
"disabled": false "disabled": false

View File

@@ -21,10 +21,20 @@ export const getStream = async ({
const tmdbId: string | number = const tmdbId: string | number =
payload.tmdbId ?? payload.id ?? payload.tmdId ?? ""; payload.tmdbId ?? payload.id ?? payload.tmdId ?? "";
const imdbId: string = payload.imdbId ?? "";
const season: string = payload.season ?? ""; const season: string = payload.season ?? "";
const episode: string = payload.episode ?? ""; const episode: string = payload.episode ?? "";
const effectiveType: string = payload.type ?? type ?? "movie"; const effectiveType: string = payload.type ?? type ?? "movie";
await getWebstreamerStream(
String(imdbId),
episode,
season,
effectiveType,
streams,
providerContext
);
await getRiveStream( await getRiveStream(
String(tmdbId), String(tmdbId),
episode, episode,
@@ -40,6 +50,47 @@ export const getStream = async ({
} }
}; };
///////// Webstreamer
export async function getWebstreamerStream(
imdbId: string,
episode: string,
season: string,
type: string,
Streams: Stream[],
providerContext: ProviderContext
) {
if (!imdbId || imdbId === "undefined") return;
const url = `https://webstreamr.hayd.uk/{"multi":"on","al":"on","de":"on","es":"on","fr":"on","hi":"on","it":"on","mx":"on","mediaFlowProxyUrl":"","mediaFlowProxyPassword":""}/stream/${type}/${imdbId}${
type === "series" ? `:${season}:${episode}` : ""
}.json`;
console.log("Webstreamer URL: ", encodeURI(url));
try {
const res = await providerContext.axios.get(encodeURI(url), {
timeout: 5000,
headers: providerContext.commonHeaders,
});
res.data?.streams.forEach((source: any) => {
const url = source?.url;
const name = source?.name || "WebStreamer";
// Infer type from URL
const qualityMatch = name?.match(/(\d{3,4})p/);
const quality = qualityMatch
? (qualityMatch[1] as "360" | "480" | "720" | "1080" | "2160")
: undefined;
Streams.push({
server: name,
link: url,
type,
quality,
});
});
} catch (e) {
throw e;
}
}
// // Rive Stream Fetcher
export async function getRiveStream( export async function getRiveStream(
tmdId: string, tmdId: string,
episode: string, episode: string,
@@ -55,15 +106,13 @@ export async function getRiveStream(
const secret = generateSecretKey(tmdId); const secret = generateSecretKey(tmdId);
const servers = [ const servers = [
"flowcast", "flowcast",
"primevids",
"humpy",
"loki",
"asiacloud", "asiacloud",
"humpy",
"primevids",
"shadow", "shadow",
"hindicast", "hindicast",
"animez", "animez",
"aqua", "aqua",
"voyager",
"yggdrasil", "yggdrasil",
"putafilme", "putafilme",
"ophim", "ophim",
@@ -84,7 +133,6 @@ export async function getRiveStream(
try { try {
const res = await providerContext.axios.get(url + server, { const res = await providerContext.axios.get(url + server, {
timeout: 4000, timeout: 4000,
headers: providerContext.commonHeaders,
}); });
const subtitles: TextTracks = []; const subtitles: TextTracks = [];
// if (res.data?.data?.captions) { // if (res.data?.data?.captions) {
@@ -119,108 +167,78 @@ export async function getRiveStream(
} }
function generateSecretKey(id: number | string) { function generateSecretKey(id: number | string) {
// Array of secret key fragments from the provided implementation // Updated array from module 2873 in the provided source
const c = [ const c = [
"oYRu3JJ5g1C", "4Z7lUo",
"TRlWJIJXT", "gwIVSMD",
"RuoyGA0udvsFVXr", "PLmz2elE2v",
"Y4s2LNM4y", "Z4OFV0",
"wHzuSgl0fD", "SZ6RZq6Zc",
"MGLTaSGs", "zhJEFYxrz8",
"rr0rSBIYfwutV7E", "FOm7b0",
"ABJXC9c", "axHS3q4KDq",
"W2BuY0yDB9CcK", "o9zuXQ",
"3yvZP1OJuTM", "4Aebt",
"YDoqbu6zdN0zT", "wgjjWwKKx",
"rnNQ2a5OBaMu", "rY4VIxqSN",
"eSKa1Uy", "kfjbnSo",
"QsIV8J472Xa", "2DyrFA1M",
"cPfTgu27", "YUixDM9B",
"j4mzadQCou9", "JQvgEj0",
"qHLZbLrZQfB", "mcuFx6JIek",
"8U9YP6hrTz4cJNQ", "eoTKe26gL",
"xbAbu4pzFEXz", "qaI9EVO1rB",
"dhuA9zvdw", "0xl33btZL",
"k3A1JGmb", "1fszuAU",
"eVC3z4COdUNvvzA", "a7jnHzst6P",
"dwMmuXnrb", "wQuJkX",
"AqpWzY9I1ZmGPR", "cBNhTJlEOf",
"VGXWUm0JTetmXs", "KNcFWhDvgT",
"gD4sH3CISTanpTs", "XipDGjST",
"d6w8dntV", "PCZJlbHoyt",
"iL6dvSNqEab4kd", "2AYnMZkqd",
"mIB8NFtmPjnX1kM", "HIpJh",
"F4PXdP0Hx3", "KH0C3iztrG",
"5Fijua4Z7C", "W81hjts92",
"wPGnHJrkYa1Tu4P", "rJhAT",
"pjrfBfTf", "NON7LKoMQ",
"vswQDEbM0y64io", "NMdY3nsKzI",
"LAnpQuk6hR2bEWs", "t4En5v",
"kX8orxNnkK", "Qq5cOQ9H",
"mRsZ5fjHbC8YuT", "Y9nwrp",
"JnBr1jr", "VX5FYVfsf",
"2twFGU5PgvDmKdP", "cE5SJG",
"3wCg6zYtHFjy", "x1vj1",
"gaQSJhixHiy1pa8", "HegbLe",
"pE2cXTP0GPX", "zJ3nmt4OA",
"xr0ONW3sOnCRdt", "gt7rxW57dq",
"QZu43flHFsebX", "clIE9b",
"yrvtqRTOnHo", "jyJ9g",
"kvXEs16lgj", "B5jXjMCSx",
"AGwT2zpQVHCMb09", "cOzZBZTV",
"M4BxOh3z2JgC", "FTXGy",
"5hbV7briYC7", "Dfh1q1",
"YfHMsm0", "ny9jqZ2POI",
"jC9PAPfz34Vgc", "X2NnMn",
"ExoJ1tgEXpK", "MBtoyD",
"eD8WPA4Lmsyf4W", "qz4Ilys7wB",
"h7WSlhT7iNOj", "68lbOMye",
"RRP61kk", "3YUJnmxp",
"QtY0f1aN", "1fv5Imona",
"TlatGjcOQjup", "PlfvvXD7mA",
"MfpeEGbjouYSOa", "ZarKfHCaPR",
"Zz0Qh8B0pwUkdRT", "owORnX",
"Y4SkLSQNU", "dQP1YU",
"hOk01KFeEVbNRZx", "dVdkx",
"fyf4H8MXazm3oY", "qgiK0E",
"Z116B9F2p", "cx9wQ",
"GdxNJOnvdz", "5F9bGa",
"kqVNNHfP", "7UjkKrp",
"IO3hhNu", "Yvhrj",
"qDdC9Lcllce", "wYXez5Dg3",
"Et7lLOg", "pG4GMU",
"6ZlQrvfgZu", "MwMAu",
"YXHLeZBF", "rFRD5wlM",
"NH6nAd7y",
"ARsut59gfK6j0v",
"jPE2KXiJjnSsjn",
"qYcG5HOJc3TtxM",
"C2w06YGj5C",
"kHx1pT7",
"2enXfHXw",
"koFHBiR054aizN",
"Uj53XTQ92Ntbq7K",
"QjC5euFYi2AuxWb",
"njLwvdMejA",
"NWMzrwTAVZEb",
"s4sVqC0AyTM5h",
"pu01jeZ6AoH",
"SgiOfwx9qkR",
"grjsLtBNn9eTQg",
"XABTTaYgihZk2mq",
"2vlSCZQc3HT27F4",
"kQZ7VQfEL3TC7P",
"MEzqVne021W",
"BLYPZp2SIO",
"5zDMVoqw4nH",
"t14S9uLuGKX7Lb5",
"4McODHAYTyp",
"EAoxL5UKvMPqjH3",
"hJpAbqp",
"tcj63Wpz",
"hGqEu0LxKkMv46P",
"u2wNvb8ou19N3",
"wUKY6Opi1kH",
]; ];
if (id === undefined) { if (id === undefined) {