agents-orchestrator/agent-orchestrator
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore(electrobun): add detailed RPC message listener debug logging

Browse source
This commit is contained in:
Hibryda 2026-03-26 02:43:18 +01:00
parent 5315dc6176
commit 5ac80a4d00
1 changed files with 14 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

15
ui-electrobun/src/mainview/agent-store.svelte.ts
View file

@ -196,6 +196,15 @@ function ensureListeners() {
listenersRegistered = true; listenersRegistered = true;
console.log('[agent-store] Registering RPC listeners'); console.log('[agent-store] Registering RPC listeners');
// DEBUG: Test if addMessageListener actually works
console.log('[agent-store] typeof addMessageListener:', typeof appRpc.addMessageListener);
appRpc.addMessageListener('agent.status', (payload: unknown) => {
console.log('[agent-store] *** RECEIVED agent.status ***', payload);
});
appRpc.addMessageListener('agent.cost', (payload: unknown) => {
console.log('[agent-store] *** RECEIVED agent.cost ***', payload);
});
// agent.message — raw messages from sidecar, converted to display format // agent.message — raw messages from sidecar, converted to display format
appRpc.addMessageListener('agent.message', (payload: { appRpc.addMessageListener('agent.message', (payload: {
sessionId: string; sessionId: string;
@ -207,8 +216,12 @@ function ensureListeners() {
timestamp: number; timestamp: number;
}>; }>;
}) => { }) => {
console.log('[agent-store] *** RECEIVED agent.message ***', payload.sessionId, payload.messages?.length, 'msgs');
const session = sessions[payload.sessionId]; const session = sessions[payload.sessionId];
if (!session) return; if (!session) {
console.warn('[agent-store] No session found for', payload.sessionId);
return;
}
const converted: AgentMessage[] = []; const converted: AgentMessage[] = [];
for (const raw of payload.messages) { for (const raw of payload.messages) {