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

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

Browse Source 
This reverts commit ef46918fec.
This commit is contained in:
Himanshu
2026-02-03 21:42:43 +05:30
parent ef46918fec
commit 8c91327af1
220 changed files with 1300 additions and 771 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
providers/hdhub4u/stream.ts
View File

@@ -1,4 +1,5 @@
import { ProviderContext } from "../types";
import { hubcloudExtractor } from "../extractors/hubcloud";
export async function getStream({
link,
@@ -10,13 +11,7 @@ export async function getStream({
signal: AbortSignal;
providerContext: ProviderContext;
}) {
const {
axios,
cheerio,
extractors,
commonHeaders: headers,
} = providerContext;
const { hubcloudExtracter } = extractors;
const { axios, cheerio, commonHeaders: headers } = providerContext;
let hubdriveLink = "";
if (link.includes("hubdrive")) {
const hubdriveRes = await axios.get(link, { headers, signal });
@@ -39,23 +34,36 @@ export async function getStream({
redirectLinkText.match(
/href="(https:\/\/hubcloud\.[^\/]+\/drive\/[^"]+)"/,
)[1];
console.log("hubdriveLink", hubdriveLink);
if (hubdriveLink.includes("hubdrive")) {
const hubdriveRes = await axios.get(hubdriveLink, { headers, signal });
const hubdriveText = hubdriveRes.data;
const $$ = cheerio.load(hubdriveText);
hubdriveLink =
$$(".btn.btn-primary.btn-user.btn-success1.m-1").attr("href") ||
hubdriveLink;
$$(".btn.btn-primary.btn-user").attr("href") || hubdriveLink;
}
console.log("hubdriveLink2", hubdriveLink);
}
const hubdriveLinkRes = await axios.get(hubdriveLink, { headers, signal });
const hubcloudText = hubdriveLinkRes.data;
const hubcloudLink =
hubcloudText.match(
/<META HTTP-EQUIV="refresh" content="0; url=([^"]+)">/i,
)?.[1] || hubdriveLink;
let hubcloudLink = hubdriveLink;
try {
return await hubcloudExtracter(hubcloudLink, signal);
const hubdriveLinkRes = await axios.get(hubdriveLink, { headers, signal });
const hubcloudText = hubdriveLinkRes.data;
hubcloudLink =
hubcloudText.match(
/<META HTTP-EQUIV="refresh" content="0; url=([^"]+)">/i,
)?.[1] || hubdriveLink;
} catch (error: any) {
console.log("Error fetching hubdrive link:", error?.message);
}
console.log("hubcloudLink", hubcloudLink);
try {
return await hubcloudExtractor(
hubcloudLink,
signal,
axios,
cheerio,
headers,
);
} catch (error: any) {
console.log("hd hub 4 getStream error: ", error);
return [];