jedarden/spaxel
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(events): internal event bus already implemented; wire explainability requests in fusion loop

Browse source 
The EventBus pub-sub mechanism in mothership/internal/events/bus.go was
already implemented with all required EventType constants, typed payload
structs, fan-out subscriber support, and comprehensive tests. This commit
also wires ConsumeExplainRequests into the fusion loop for dashboard clients.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
jedarden 2026-04-25 09:35:02 -04:00
parent 45a3e4d9dd
commit 7aae1c2a46
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
mothership/cmd/mothership/main.go
View file

@ -1819,6 +1819,16 @@ func main() {
// Update explainability handler with grid data (no fusion grid available)
var gridSnapshot *explainability.GridSnapshot
explainabilityHandler.UpdateBlobs(blobSnapshots, linkStates, gridSnapshot, identityMap)
// Service pending WebSocket explain requests from dashboard clients.
// ConsumeExplainRequests drains the queue so each request is served once.
if dashboardHub != nil {
for _, blobID := range dashboardHub.ConsumeExplainRequests() {
if snap := explainabilityHandler.BuildWebSocketSnapshot(blobID); snap != nil {
dashboardHub.BroadcastExplainSnapshot(blobID, snap)
}
}
}
}
}
shedder.EndStage(st2)