diff --git a/webui/app.go b/webui/app.go index 91cf899..ad9d362 100644 --- a/webui/app.go +++ b/webui/app.go @@ -370,7 +370,7 @@ func (a *App) Chat(pool *state.AgentPool) func(c *fiber.Ctx) error { xlog.Error("Error marshaling status message", "error", err) } else { manager.Send( - sse.NewMessage(string(statusData)).WithEvent("json_status")) + sse.NewMessage(string(statusData)).WithEvent("json_message_status")) } // Process the message asynchronously @@ -417,7 +417,7 @@ func (a *App) Chat(pool *state.AgentPool) func(c *fiber.Ctx) error { xlog.Error("Error marshaling completed status", "error", err) } else { manager.Send( - sse.NewMessage(string(completedData)).WithEvent("json_status")) + sse.NewMessage(string(completedData)).WithEvent("json_message_status")) } }() diff --git a/webui/react-ui/src/hooks/useSSE.js b/webui/react-ui/src/hooks/useSSE.js index 76409cc..c62c704 100644 --- a/webui/react-ui/src/hooks/useSSE.js +++ b/webui/react-ui/src/hooks/useSSE.js @@ -63,8 +63,8 @@ export function useSSE(agentName) { } }); - // Handle 'json_status' event - eventSource.addEventListener('json_status', (event) => { + // Handle 'json_message_status' event + eventSource.addEventListener('json_message_status', (event) => { try { const data = JSON.parse(event.data); const timestamp = data.timestamp || new Date().toISOString();