diff --git a/packages/orchestration-service/src/chat/index.js b/packages/orchestration-service/src/chat/index.js index 64d6dca..a90661d 100644 --- a/packages/orchestration-service/src/chat/index.js +++ b/packages/orchestration-service/src/chat/index.js @@ -105,19 +105,20 @@ async function chat(externalId, userMessage, options = {}) { let projectSessionIds = null; if (session.project_id) { try { - console.log('[orchestration] Resolving isolation for project:', session.project_id); const project = await memory.getProject(session.project_id); - console.log('[orchestration] Project resolved:', project); - if (project?.isolated === 1) { + if (project) { const projectSessions = await memory.getProjectSessions(session.project_id); - console.log('[orchestration] Project sessions:', projectSessions); projectSessionIds = projectSessions.map(s => s.id); + if (project.isolated === 1) { + console.log(`[orchestration] Isolated project — restricting to ${projectSessionIds.length} sessions`); + } else { + console.log(`[orchestration] Non-isolated project — expanding search to ${projectSessionIds.length} sessions`); + } } } catch (err) { - console.warn('[orchestration] Failed to resolve isolation context:', err.message); + console.warn('[orchestration] Failed to resolve project context:', err.message); } } - // 2. Fetch recent episodes for context const recentEpisodes = await memory.getRecentEpisodes( session.id, @@ -181,16 +182,18 @@ console.log('[orchestration] chatStream entry'); let projectSessionIds = null; if (session.project_id) { try { - console.log('[orchestration] Resolving isolation for project:', session.project_id); const project = await memory.getProject(session.project_id); - console.log('[orchestration] Project resolved:', project); - if (project?.isolated === 1) { + if (project) { const projectSessions = await memory.getProjectSessions(session.project_id); - console.log('[orchestration] Project sessions:', projectSessions); projectSessionIds = projectSessions.map(s => s.id); + if (project.isolated === 1) { + console.log(`[orchestration] Isolated project — restricting to ${projectSessionIds.length} sessions`); + } else { + console.log(`[orchestration] Non-isolated project — expanding search to ${projectSessionIds.length} sessions`); + } } } catch (err) { - console.warn('[orchestration] Failed to resolve isolation context:', err.message); + console.warn('[orchestration] Failed to resolve project context:', err.message); } }