diff --git a/packages/chat-client/src/api/orchestration.js b/packages/chat-client/src/api/orchestration.js index 065f590..60a9ee3 100644 --- a/packages/chat-client/src/api/orchestration.js +++ b/packages/chat-client/src/api/orchestration.js @@ -66,7 +66,7 @@ export function streamMessage(sessionId, message, model, { onChunk, onDone, onEr try { const data = JSON.parse(raw); if (data.text) onChunk(data.text); - if (data.done) onDone({ model, tokenCount: data.tokenCount ?? 0 }); + if (data.done) onDone({ model: data.model ?? model, tokenCount: data.tokenCount ?? 0 }); if (data.error) onError(new Error(data.error)); } catch { // malformed JSON — skip diff --git a/packages/memory-service/src/episodic/index.js b/packages/memory-service/src/episodic/index.js index d498d7a..b38255b 100644 --- a/packages/memory-service/src/episodic/index.js +++ b/packages/memory-service/src/episodic/index.js @@ -91,7 +91,7 @@ async function createEpisode(sessionId, userMessage, aiResponse, tokenCount = nu function getEpisode(id) { const db = getDB(); const stmt = db.prepare(`SELECT * FROM episodes WHERE id = ?`); - return parseEpisode(stmt.get(id)); + return parseRow(stmt.get(id)); } // Retrieves episodes for a given session, ordered by creation time descending, with pagination diff --git a/packages/nexusAI.zip b/packages/nexusAI.zip new file mode 100644 index 0000000..fbace66 Binary files /dev/null and b/packages/nexusAI.zip differ diff --git a/packages/orchestration-service/src/chat/index.js b/packages/orchestration-service/src/chat/index.js index d947de4..0bc8526 100644 --- a/packages/orchestration-service/src/chat/index.js +++ b/packages/orchestration-service/src/chat/index.js @@ -142,9 +142,10 @@ async function chatStream(externalId, userMessage, onChunk, options = {} ) { } // 6. Write Complete episode to memory - memory.createEpisode(session.id, userMessage, fullText, tokenCount) - .catch(err => console.error('[orchestration] Failed to save streamed episode:', err.message)) - + if(fullText && fullText.trim()){ + memory.createEpisode(session.id, userMessage, fullText, tokenCount) + .catch(err => console.error('[orchestration] Failed to save streamed episode:', err.message)) + } return {model, tokenCount}; }