From 78144d02135072681237eae8bd5b11bf8fc3f991 Mon Sep 17 00:00:00 2001 From: Viren070 Date: Fri, 27 Jun 2025 17:00:24 +0100 Subject: [PATCH] fix: apply filters and precomputation to streams after each group fetch --- packages/core/src/streams/fetcher.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/core/src/streams/fetcher.ts b/packages/core/src/streams/fetcher.ts index 7c0e481a..240339b1 100644 --- a/packages/core/src/streams/fetcher.ts +++ b/packages/core/src/streams/fetcher.ts @@ -132,13 +132,13 @@ ${errorStreams.length > 0 ? ` ❌ Errors : ${errorStreams.map((s) => ` const finalStreams = results.flatMap((r) => r.success ? r.streams : [] ) as ParsedStream[]; - // const filteredStreams = await this.filter.filter(finalStreams, type, id); - // await this.precompute.precompute(filteredStreams); + const filteredStreams = await this.filter.filter(finalStreams, type, id); + await this.precompute.precompute(filteredStreams); const groupTime = Date.now() - groupStart; return { // results, totalTime: groupTime, - streams: finalStreams, + streams: filteredStreams, }; };