shishantbiswas/vega-providers
1
0
Fork 0
mirror of https://github.com/vega-org/vega-providers.git synced 2026-04-17 15:41:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "feat: add extractors bundled in file refactor stream handling in multiple providers"

Browse Source 
This reverts commit 13d41f9da6.
This commit is contained in:
Himanshu
2026-02-02 23:44:25 +05:30
parent 13d41f9da6
commit ef46918fec
220 changed files with 771 additions and 1300 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
providers/katmovies/stream.ts
View File

@@ -1,10 +1,8 @@
import { Stream, ProviderContext } from "../types";
import { hubcloudExtractor } from "../extractors/hubcloud";
import { gdflixExtractor } from "../extractors/gdflix";
async function extractKmhdLink(
katlink: string,
providerContext: ProviderContext,
providerContext: ProviderContext
) {
const { axios } = providerContext;
const res = await axios.get(katlink, {
@@ -15,7 +13,7 @@ async function extractKmhdLink(
const data = res.data;
const hubDriveRes = data.match(/hubdrive_res:\s*"([^"]+)"/)[1];
const hubDriveLink = data.match(
/hubdrive_res\s*:\s*{[^}]*?link\s*:\s*"([^"]+)"/,
/hubdrive_res\s*:\s*{[^}]*?link\s*:\s*"([^"]+)"/
)[1];
return hubDriveLink + hubDriveRes;
}
@@ -29,22 +27,17 @@ export const getStream = async function ({
signal: AbortSignal;
providerContext: ProviderContext;
}): Promise<Stream[]> {
const { axios, cheerio, commonHeaders } = providerContext;
const { axios, cheerio, extractors } = providerContext;
const { hubcloudExtracter, gdFlixExtracter } = extractors;
const streamLinks: Stream[] = [];
console.log("katGetStream", link);
try {
if (link.includes("gdflix")) {
return await gdflixExtractor(link, signal, axios, cheerio, commonHeaders);
return await gdFlixExtracter(link, signal);
}
if (link.includes("kmhd")) {
const hubcloudLink = await extractKmhdLink(link, providerContext);
return await hubcloudExtractor(
hubcloudLink,
signal,
axios,
cheerio,
commonHeaders,
);
return await hubcloudExtracter(hubcloudLink, signal);
}
if (link.includes("gdflix")) {
// resume link
@@ -101,13 +94,7 @@ export const getStream = async function ({
}
return streamLinks;
}
const stereams = await hubcloudExtractor(
link,
signal,
axios,
cheerio,
commonHeaders,
);
const stereams = await hubcloudExtracter(link, signal);
return stereams;
} catch (error: any) {
console.log("katgetStream error: ", error);