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

fix: update getPosts and getSearchPosts to include common headers and add retry logic

Browse Source 
fix: change stream URL in getStream function
This commit is contained in:
Himanshu
2026-04-16 20:04:58 +05:30
parent 93d8acec5e
commit 4256b05d2b
5 changed files with 47 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
providers/showbox/posts.ts
View File

@@ -32,10 +32,17 @@ export const getSearchPosts = async function ({
signal: AbortSignal;
providerContext: ProviderContext;
}): Promise<Post[]> {
const { getBaseUrl, axios, cheerio } = providerContext;
const { getBaseUrl, axios, cheerio, commonHeaders } = providerContext;
const baseUrl = await getBaseUrl("showbox");
const url = `${baseUrl}/search?keyword=${searchQuery}&page=${page}`;
return posts({ url, signal, baseUrl, axios, cheerio });
return posts({
url,
signal,
baseUrl,
axios,
cheerio,
headers: commonHeaders,
});
};
async function posts({
@@ -44,32 +51,46 @@ async function posts({
// baseUrl,
axios,
cheerio,
headers,
}: {
url: string;
signal: AbortSignal;
baseUrl: string;
axios: ProviderContext["axios"];
cheerio: ProviderContext["cheerio"];
headers?: Record<string, string>;
}): Promise<Post[]> {
try {
const res = await axios.get(url, { signal });
const data = res.data;
const $ = cheerio.load(data);
const catalog: Post[] = [];
$(".movie-item,.flw-item").map((i, element) => {
const title = $(element).find(".film-name").text().trim();
const link = $(element).find("a").attr("href");
const image = $(element).find("img").attr("src");
if (title && link && image) {
catalog.push({
title: title,
link: link,
image: image,
});
const maxRetries = 3;
let lastError: unknown;
for (let attempt = 1; attempt <= maxRetries; attempt++) {
try {
const res = await axios.get(url, { signal, headers: headers });
const data = res.data;
console.log(data);
const $ = cheerio.load(data);
const catalog: Post[] = [];
$(".movie-item,.flw-item").map((i, element) => {
const title = $(element).find(".film-name").text().trim();
const link = $(element).find("a").attr("href");
const image = $(element).find("img").attr("src");
console.log(title, link, image);
if (title && link && image) {
catalog.push({
title: title,
link: link,
image: image,
});
}
});
return catalog;
} catch (err) {
lastError = err;
if (signal.aborted || attempt === maxRetries) {
throw err;
}
});
return catalog;
} catch (err) {
return [];
}
}
throw lastError;
}