From a3b90bf19a008c6cce2b0a04029c99ef42692148 Mon Sep 17 00:00:00 2001
From: WebStreamr <210764791+webstreamr@users.noreply.github.com>
Date: Tue, 7 Oct 2025 20:37:42 +0000
Subject: [PATCH] chore: increase MFP related timeouts

---
 src/utils/media-flow-proxy.ts | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git a/src/utils/media-flow-proxy.ts b/src/utils/media-flow-proxy.ts
index 88de639..fa538f6 100644
--- a/src/utils/media-flow-proxy.ts
+++ b/src/utils/media-flow-proxy.ts
@@ -1,5 +1,5 @@
 import { Context } from '../types';
-import { CustomRequestInit, Fetcher } from './Fetcher';
+import { Fetcher } from './Fetcher';
 
 interface ExtractResult {
   destination_url: string;
@@ -8,11 +8,6 @@ interface ExtractResult {
   query_params: Record<string, string>;
 }
 
-const MEDIAFLOW_DEFAULT_INIT: CustomRequestInit = {
-  queueLimit: 4,
-  queueTimeout: 10000,
-};
-
 export const supportsMediaFlowProxy = (ctx: Context): boolean => !!ctx.config['mediaFlowProxyUrl'];
 
 const buildMediaFlowProxyExtractorUrl = (ctx: Context, host: string, url: URL, headers: Record<string, string>): URL => {
@@ -40,7 +35,7 @@ export const buildMediaFlowProxyExtractorRedirectUrl = (ctx: Context, host: stri
 export const buildMediaFlowProxyExtractorStreamUrl = async (ctx: Context, fetcher: Fetcher, host: string, url: URL, headers: Record<string, string>): Promise<URL> => {
   const mediaFlowProxyUrl = buildMediaFlowProxyExtractorUrl(ctx, host, url, headers);
 
-  const extractResult: ExtractResult = await fetcher.json(ctx, mediaFlowProxyUrl, MEDIAFLOW_DEFAULT_INIT);
+  const extractResult: ExtractResult = await fetcher.json(ctx, mediaFlowProxyUrl, { queueLimit: 4, queueTimeout: 10000, timeout: 20000 });
 
   const streamUrl = new URL(extractResult.mediaflow_proxy_url);