alex/LocalAGI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(ui): Make message status SSE name more specific

Browse Source 
Signed-off-by: Richard Palethorpe <io@richiejp.com>
This commit is contained in:
Richard Palethorpe
2025-04-15 05:11:31 +01:00
parent 70e749b53a
commit 30cf87affe
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
webui/app.go
View File

@@ -370,7 +370,7 @@ func (a *App) Chat(pool *state.AgentPool) func(c *fiber.Ctx) error {
xlog.Error("Error marshaling status message", "error", err) xlog.Error("Error marshaling status message", "error", err)
} else { } else {
manager.Send( manager.Send(
sse.NewMessage(string(statusData)).WithEvent("json_status")) sse.NewMessage(string(statusData)).WithEvent("json_message_status"))
} }
// Process the message asynchronously // 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) xlog.Error("Error marshaling completed status", "error", err)
} else { } else {
manager.Send( manager.Send(
sse.NewMessage(string(completedData)).WithEvent("json_status")) sse.NewMessage(string(completedData)).WithEvent("json_message_status"))
} }
}() }()

4
webui/react-ui/src/hooks/useSSE.js vendored
View File

@@ -63,8 +63,8 @@ export function useSSE(agentName) {
} }
}); });
// Handle 'json_status' event // Handle 'json_message_status' event
eventSource.addEventListener('json_status', (event) => { eventSource.addEventListener('json_message_status', (event) => {
try { try {
const data = JSON.parse(event.data); const data = JSON.parse(event.data);
const timestamp = data.timestamp || new Date().toISOString(); const timestamp = data.timestamp || new Date().toISOString();