From 2fc372815f9136a10fcf72a4e197f28bd58c756b Mon Sep 17 00:00:00 2001 From: Storme-bit Date: Sun, 19 Apr 2026 18:05:00 -0700 Subject: [PATCH] fixed summary creation --- .../orchestration-service/src/services/summarization.js | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/packages/orchestration-service/src/services/summarization.js b/packages/orchestration-service/src/services/summarization.js index 54a1118..d65f25c 100644 --- a/packages/orchestration-service/src/services/summarization.js +++ b/packages/orchestration-service/src/services/summarization.js @@ -59,11 +59,8 @@ async function generateSummary(episodes, existingSummary = null) { } async function maybeSummarize(session, allEpisodes) { - console.log('[summarization] MEMORY_URL:', MEMORY_URL) - console.log('[summarization] EXTRACTION_URL:', EXTRACTION_URL); // 1. Sum total tokens for this session const totalTokens = allEpisodes.reduce((sum, ep) => sum + (ep.token_count || 0), 0); - console.log('[summarization] totalTokens:', totalTokens, 'threshold:', THRESHOLD_TOKENS); if (totalTokens < THRESHOLD_TOKENS) return; // under threshold — nothing to do console.log('[summarization] fetching existing summaries...'); // 2. Fetch existing summaries for session @@ -73,11 +70,11 @@ async function maybeSummarize(session, allEpisodes) { const summaries = await summariesRes.json(); const latest = summaries.at(-1) ?? null; - + const lastCoveredId = latest + ? parseInt(latest.episode_range?.split('-').at(-1)) || 0 + : 0; // 3. Guard — don't re-summarize until MIN_EPISODES_SINCE new episodes have accumulated if (latest) { - const lastEpisodeRange = latest.episode_range ?? '0'; - const lastCoveredId = parseInt(lastEpisodeRange.split('-').at(-1)) || 0; const newEpisodes = allEpisodes.filter(ep => ep.id > lastCoveredId); if (newEpisodes.length < MIN_EPISODES_SINCE) return; }