storme/nexusAI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

code clean up pass

Browse Source
This commit is contained in:
Storme-bit
2026-04-26 05:19:31 -07:00
parent acda21317b
commit 785047a824
8 changed files with 26 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
packages/orchestration-service/src/chat/index.js
View File

@@ -317,10 +317,7 @@ async function chatStream(externalId, userMessage, onChunk, options = {}) {
}
}
console.log("[orchestration] final streamed text length:", fullText.length);
if (fullText.trim()) {
console.log('[chat] tokenCount before save:', tokenCount);
await memory.createEpisode(session.id, userMessage, fullText, tokenCount, session.project_id ?? null);
const allEpisodes = await memory.getRecentEpisodes(session.id, 9999);
triggerSummary(session, allEpisodes);

22
packages/orchestration-service/src/services/summarization.js
View File

@@ -77,12 +77,9 @@ async function maybeSummarize(session, allEpisodes) {
// 1. Sum total tokens for this session
const totalTokens = allEpisodes.reduce((sum, ep) => sum + (ep.token_count || 0), 0);
if (totalTokens < THRESHOLD_TOKENS) return; // under threshold — nothing to do
console.log('[summarization] fetching existing summaries...');
// 2. Fetch existing summaries for session
const summariesRes = await fetch(`${MEMORY_URL}/sessions/${session.id}/summaries`);
console.log('[summarization] memory URL:', MEMORY_URL);
console.log('[summarization] session:', session.id, session.external_id);
console.log('[summarization] summaries fetch status:', summariesRes.status);
if (!summariesRes.ok) return;
const summaries = await summariesRes.json();
@@ -96,19 +93,18 @@ async function maybeSummarize(session, allEpisodes) {
if (newEpisodes.length < MIN_EPISODES_SINCE) return;
}
// 4. Determine episode range string e.g. "1-42"
const ids = allEpisodes.map(ep => ep.id).sort((a,b) => a - b);
const episodeRange = `${ids.at(0)}-${ids.at(-1)}`;
const totalEpisodeTokens = allEpisodes.reduce((sum, ep) => sum + (ep.token_count || 0), 0);
// 4. Determine episodes to summarize
const episodesToSummarize = latest
? allEpisodes.filter(ep => ep.id > lastCoveredId)
: allEpisodes;
// 5. Generate summary — pass existing content if updating
const episodesToSummarize = latest
? allEpisodes.filter(ep => ep.id > lastCoveredId)
: allEpisodes;
// 5. Determine episode range from the episodes actually being summarized
const summarizedIds = episodesToSummarize.map(ep => ep.id).sort((a,b) => a - b);
const episodeRange = `${summarizedIds.at(0)}-${summarizedIds.at(-1)}`;
const totalEpisodeTokens = allEpisodes.reduce((sum, ep) => sum + (ep.token_count || 0), 0);
// add temporarily before the generateSummary call
console.log('[summarization] episodes to summarize:', episodesToSummarize.length);
console.log('[summarization] total chars:', episodesToSummarize.reduce((s, ep) => s + ep.user_message.length + ep.ai_response.length, 0));
const content = await generateSummary(
episodesToSummarize,