import { writable, get } from 'svelte/store' import { streamChat, fetchSessions, fetchMessages, deleteSession as apiDeleteSession } from '$lib/api' import type { ChatEvent, Session, Message } from '$lib/api' export interface PendingApproval { executionId: string action: string target: string destructive: boolean command?: string purpose?: string } export interface ChatMessage { id: string role: 'user' | 'assistant' text: string tools: ToolCallResult[] pendingApprovals: PendingApproval[] } const APPROVAL_RE = /execution\s+([0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12})/i // Deliberately NOT filtered by tool name. There is no fixed set of gated // tools — `run` can execute anything, and any future tool that queues an // approval should surface a card the same way. A prior version hardcoded // `t.name === 'request_execution'`, so approvals raised by the newer `run` // tool were silently invisible in chat: no card, no feedback, nothing to // self-heal, forcing the operator to the Ops page with zero acknowledgement // back in the conversation. Matching on the response shape (not the tool // name) is what makes this robust to new gated tools without another // silent breakage. function extractApprovals(tools: ToolCallResult[]): PendingApproval[] { const out: PendingApproval[] = [] for (const t of tools) { if (t.type !== 'tool_result') continue const text = typeof t.result === 'string' ? t.result : JSON.stringify(t.result ?? '') if (!text.includes('requires approval')) continue const m = text.match(APPROVAL_RE) if (m) { out.push({ executionId: m[1], action: t.args?.action ?? t.args?.purpose ?? t.name ?? 'unknown', target: t.args?.target ?? 'unknown', destructive: /\bDESTRUCTIVE\b/.test(text), command: t.args?.command, purpose: t.args?.purpose }) } } return out } export interface ToolCallResult { type: 'tool_use' | 'tool_result' name: string id?: string args?: any result?: any error?: string } function mid(): string { return crypto.randomUUID() } export const messages = writable([]) export const streaming = writable(false) export const currentSession = writable(null) export const sessions = writable([]) export const sessionMessages = writable([]) export const error = writable(null) let activeController: AbortController | null = null export async function loadSessions() { const list = await fetchSessions() sessions.set(list) } // mergeToolCalls collapses a persisted tool_calls array into one entry per // call id. Nomos persists the tool_use and tool_result as two separate // entries sharing the same id (matching the SSE event pair); Chat.svelte // renders tools in a keyed {#each ... (tool.id)}, which throws on duplicate // keys and silently aborts the whole message list. Live-streamed messages // never hit this because sendMessage() merges tool_result into the existing // tool_use entry in place rather than appending a second one. function mergeToolCalls(raw: ToolCallResult[] | undefined): ToolCallResult[] { const byId = new Map() for (const tc of raw ?? []) { const key = tc.id ?? crypto.randomUUID() const existing = byId.get(key) byId.set(key, existing ? { ...existing, ...tc, id: key } : { ...tc, id: key }) } return Array.from(byId.values()) } function toChatMessages(msgs: Message[]): ChatMessage[] { return msgs.map((m) => { const tools = mergeToolCalls(m.content?.tool_calls) return { id: m.id, role: m.role as 'user' | 'assistant', text: m.content?.text ?? (typeof m.content === 'string' ? m.content : ''), tools, pendingApprovals: extractApprovals(tools) } }) } export async function loadSessionMessages(sessionId: string) { currentSession.set(sessionId) const msgs = await fetchMessages(sessionId) sessionMessages.set(msgs) messages.set(toChatMessages(msgs)) startPolling(sessionId) } // Live visibility for autonomous work: the auto-continuation worker (see // cmd/nomos/continue.go) runs entirely server-side and has no live push — // previously the only way to see its result was to manually reload the // session, so approving a plan and then waiting felt like nothing was // happening even while the agent was actively working. This polls the // session's persisted messages every few seconds and merges in anything new // (an auto-continuation's result, a fresh pending approval it queued, etc.) // so the transcript updates on its own. Only runs between turns — never // while a live streaming turn owns the message list, to avoid clobbering the // in-progress optimistic UI. let pollTimer: ReturnType | null = null let pollingSessionId: string | null = null function startPolling(sessionId: string) { stopPolling() pollingSessionId = sessionId pollTimer = setInterval(async () => { if (get(streaming)) return if (pollingSessionId !== sessionId || get(currentSession) !== sessionId) return const msgs = await fetchMessages(sessionId) if (get(streaming) || pollingSessionId !== sessionId) return // re-check: the fetch itself takes time const current = get(messages) if (msgs.length === current.length) return sessionMessages.set(msgs) messages.set(toChatMessages(msgs)) }, 3000) } export function stopPolling() { if (pollTimer) { clearInterval(pollTimer) pollTimer = null } pollingSessionId = null } export function sendMessage(text: string) { error.set(null) streaming.set(true) const userMsg: ChatMessage = { id: mid(), role: 'user', text, tools: [], pendingApprovals: [] } messages.update((ms) => [...ms, userMsg]) const assistantMsg: ChatMessage = { id: mid(), role: 'assistant', text: '', tools: [], pendingApprovals: [] } messages.update((ms) => [...ms, assistantMsg]) let activeTools: Map = new Map() activeController = streamChat( text, get(currentSession), // continue the active session so the agent keeps context (ev: ChatEvent) => { if (ev.type === 'session') { currentSession.set(ev.data) } else if (ev.type === 'tool_use') { const tr: ToolCallResult = { type: 'tool_use', name: ev.data.name, id: ev.data.id, args: ev.data.args } activeTools.set(ev.data.id, tr) messages.update((ms) => { const last = ms[ms.length - 1] if (last && last.role === 'assistant') { last.tools = [...last.tools, tr] } return [...ms] }) } else if (ev.type === 'tool_result') { const existing = activeTools.get(ev.data.id) if (existing) { const updated: ToolCallResult = { ...existing, type: 'tool_result', result: ev.data.result, error: ev.data.error } activeTools.set(ev.data.id, updated) messages.update((ms) => { const last = ms[ms.length - 1] if (last && last.role === 'assistant') { last.tools = last.tools.map((t) => t.id === ev.data.id ? updated : t ) } return [...ms] }) } } else if (ev.type === 'text_delta') { messages.update((ms) => { const last = ms[ms.length - 1] if (last && last.role === 'assistant') { last.text += ev.data } return [...ms] }) } else if (ev.type === 'text') { // Final authoritative content for the turn; replaces accumulated deltas. messages.update((ms) => { const last = ms[ms.length - 1] if (last && last.role === 'assistant') { last.text = ev.data } return [...ms] }) } else if (ev.type === 'done') { messages.update((ms) => { const last = ms[ms.length - 1] if (last && last.role === 'assistant') { last.pendingApprovals = extractApprovals(last.tools) } return [...ms] }) const sid = ev.data?.session_id ?? ev.session_id currentSession.set(sid) // Start polling for auto-continuation results now that the live turn // is over — this is what makes an approved plan's later steps show up // on their own instead of requiring a manual reload. if (sid) startPolling(sid) } else if (ev.type === 'error') { error.set(ev.data) } }, (err: string) => { error.set(err) }, () => { streaming.set(false) activeController = null loadSessions() } ) } export function newChat() { cancelStream() stopPolling() currentSession.set(null) messages.set([]) error.set(null) } export function cancelStream() { if (activeController) { activeController.abort() activeController = null streaming.set(false) } } export async function deleteSession(sessionId: string) { const ok = await apiDeleteSession(sessionId) if (!ok) return if (get(currentSession) === sessionId) { newChat() } loadSessions() }