From 4cf08fc6d55dbcc1de551091d14f731265b89fd5 Mon Sep 17 00:00:00 2001
From: WebStreamr <210764791+webstreamr@users.noreply.github.com>
Date: Thu, 15 Jan 2026 14:03:51 +0000
Subject: [PATCH] feat: add fetcher http stats

---
 src/utils/Fetcher.ts | 23 +++++++++++++++++++++--
 1 file changed, 21 insertions(+), 2 deletions(-)

diff --git a/src/utils/Fetcher.ts b/src/utils/Fetcher.ts
index cc12417..e574ac8 100644
--- a/src/utils/Fetcher.ts
+++ b/src/utils/Fetcher.ts
@@ -69,13 +69,18 @@ export class Fetcher {
   private readonly timeoutsCountCache = new Cacheable({ primary: new Keyv({ store: new CacheableMemory({ lruSize: 1024 }) }) });
   private readonly timeoutsCountMutex = new Mutex();
 
+  private readonly httpStatus = new Map<string, Record<number, number>>();
+  private readonly httpStatusMutex = new Mutex();
+
   public constructor(axios: AxiosInstance, logger: winston.Logger) {
     this.axios = axios;
     this.logger = logger;
   }
 
   public stats() {
-    return {};
+    return {
+      httpStatus: Object.fromEntries(this.httpStatus),
+    };
   };
 
   public async fetch(ctx: Context, url: URL, requestConfig?: CustomRequestConfig): Promise<AxiosResponse> {
@@ -194,6 +199,7 @@ export class Fetcher {
         validateStatus: () => true,
       });
     } catch (error) {
+      await this.trackHttpStatus(ctx, url, 0);
       this.logger.info(`Got error ${error} for ${url}`, ctx);
 
       if (error instanceof AxiosError && error.code === 'ECONNABORTED') {
@@ -204,6 +210,7 @@ export class Fetcher {
       throw error;
     }
 
+    await this.trackHttpStatus(ctx, url, response.status);
     this.logger.info(`Got ${response.status} (${response.statusText}) for ${url}`, ctx);
 
     await this.decreaseTimeoutsCount(url);
@@ -268,7 +275,7 @@ export class Fetcher {
     }
 
     if (response.status === 403) {
-      if (ctx.config.mediaFlowProxyUrl && url.href.startsWith(ctx.config.mediaFlowProxyUrl)) {
+      if (ctx.config.mediaFlowProxyUrl && url.href.includes(ctx.config.mediaFlowProxyUrl)) {
         throw new BlockedError(url, BlockedReason.media_flow_proxy_auth, response.headers);
       }
 
@@ -376,4 +383,16 @@ export class Fetcher {
 
     return proxyConfig;
   }
+
+  private async trackHttpStatus(ctx: Context, url: URL, status: number) {
+    if (ctx.config.mediaFlowProxyUrl && url.href.includes(ctx.config.mediaFlowProxyUrl)) {
+      return;
+    }
+
+    await this.httpStatusMutex.runExclusive(() => {
+      const httpStatusCounts = this.httpStatus.get(url.host) ?? {};
+      httpStatusCounts[status] = (httpStatusCounts[status] ?? 0) + 1;
+      this.httpStatus.set(url.host, httpStatusCounts);
+    });
+  }
 }