diff --git a/src/extractor/FileLions.ts b/src/extractor/FileLions.ts index f944e19..b9d84c7 100644 --- a/src/extractor/FileLions.ts +++ b/src/extractor/FileLions.ts @@ -80,7 +80,7 @@ export class FileLions extends Extractor { ttl: this.ttl, meta: { ...meta, - height: await guessHeightFromPlaylist(ctx, this.fetcher, playlistUrl, { headers: { Referer: url.href } }), + height: await guessHeightFromPlaylist(ctx, this.fetcher, playlistUrl, { headers: { Referer: url.href }, queueLimit: 4 }), ...(sizeMatch && { bytes: bytes.parse(sizeMatch[1] as string) as number, }), diff --git a/src/extractor/Streamtape.ts b/src/extractor/Streamtape.ts index 8d25d18..0f95171 100644 --- a/src/extractor/Streamtape.ts +++ b/src/extractor/Streamtape.ts @@ -40,7 +40,7 @@ export class Streamtape extends Extractor { meta: { ...meta, title, - bytes: await guessSizeFromMp4(ctx, this.fetcher, mp4Url), + bytes: await guessSizeFromMp4(ctx, this.fetcher, mp4Url, { queueLimit: 4 }), }, }, ]; diff --git a/src/extractor/Uqload.ts b/src/extractor/Uqload.ts index 120e4dc..8404b81 100644 --- a/src/extractor/Uqload.ts +++ b/src/extractor/Uqload.ts @@ -46,7 +46,7 @@ export class Uqload extends Extractor { meta: { ...meta, title, - bytes: await guessSizeFromMp4(ctx, this.fetcher, mp4Url, { headers: { Referer: url.href } }), + bytes: await guessSizeFromMp4(ctx, this.fetcher, mp4Url, { headers: { Referer: url.href }, queueLimit: 4 }), ...(heightMatch && { height: parseInt(heightMatch[1] as string), }), diff --git a/src/extractor/VixSrc.ts b/src/extractor/VixSrc.ts index 1e299e6..d192867 100644 --- a/src/extractor/VixSrc.ts +++ b/src/extractor/VixSrc.ts @@ -20,7 +20,7 @@ export class VixSrc extends Extractor { protected async extractInternal(ctx: Context, url: URL, meta: Meta): Promise { const playlistUrl = await buildMediaFlowProxyExtractorStreamUrl(ctx, this.fetcher, 'VixCloud', url); - const countryCodes = await this.determineCountryCodesFromPlaylist(ctx, playlistUrl, { headers: { Referer: url.href } }); + const countryCodes = await this.determineCountryCodesFromPlaylist(ctx, playlistUrl, { headers: { Referer: url.href }, queueLimit: 4 }); if (!hasMultiEnabled(ctx.config) && !countryCodes.some(countryCode => countryCode in ctx.config)) { return []; @@ -35,7 +35,7 @@ export class VixSrc extends Extractor { ttl: this.ttl, meta: { countryCodes, - height: await guessHeightFromPlaylist(ctx, this.fetcher, playlistUrl, { headers: { Referer: url.href } }), + height: await guessHeightFromPlaylist(ctx, this.fetcher, playlistUrl, { headers: { Referer: url.href }, queueLimit: 4 }), }, }, ]; diff --git a/src/utils/media-flow-proxy.ts b/src/utils/media-flow-proxy.ts index ce5bb2c..0f1c18f 100644 --- a/src/utils/media-flow-proxy.ts +++ b/src/utils/media-flow-proxy.ts @@ -35,7 +35,7 @@ export const buildMediaFlowProxyExtractorRedirectUrl = (ctx: Context, host: stri export const buildMediaFlowProxyExtractorStreamUrl = async (ctx: Context, fetcher: Fetcher, host: string, url: URL, headers: Record = {}): Promise => { const mediaFlowProxyUrl = buildMediaFlowProxyExtractorUrl(ctx, host, url, headers); - const extractResult: ExtractResult = await fetcher.json(ctx, mediaFlowProxyUrl); + const extractResult: ExtractResult = await fetcher.json(ctx, mediaFlowProxyUrl, { queueLimit: 4 }); const streamUrl = new URL(extractResult.mediaflow_proxy_url);