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

feat: broadcast ble_scan messages to dashboard every 5s

Browse source 
Add a 5-second ticker in the dashboard hub that broadcasts BLE device
list updates as typed 'ble_scan' messages when devices are present.
The BroadcastBLEScan method and frontend handler already existed but
were never wired up to a periodic timer.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
jedarden 2026-04-07 07:23:30 -04:00
parent a1d96522bf
commit 32c92f2027
1 changed files with 27 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
mothership/internal/dashboard/hub.go
View file

@ -156,9 +156,9 @@ func (h *Hub) SetZoneState(state ZoneStateProvider) {
}
// Run starts the hub's main loop.
// The 10 Hz delta tick replaces the old 5 s state / 500 ms presence /
// 5 s BLE periodic broadcasts. System health (60 s) is kept as a
// separate low-frequency broadcast.
// The 10 Hz delta tick replaces the old 5 s state / 500 ms presence broadcasts.
// BLE scan results are broadcast every 5 s as a separate typed message.
// System health (60 s) is kept as a separate low-frequency broadcast.
func (h *Hub) Run() {
// 10 Hz snapshot/delta tick
deltaTicker := time.NewTicker(100 * time.Millisecond)
@ -168,6 +168,10 @@ func (h *Hub) Run() {
healthTicker := time.NewTicker(60 * time.Second)
defer healthTicker.Stop()
// BLE scan broadcast ticker (5 seconds)
bleScanTicker := time.NewTicker(5 * time.Second)
defer bleScanTicker.Stop()
for {
select {
case client := <-h.register:
@ -216,6 +220,9 @@ func (h *Hub) Run() {
case <-healthTicker.C:
h.broadcastSystemHealth()
case <-bleScanTicker.C:
h.broadcastBLEScan()
}
}
}
@ -690,6 +697,23 @@ func (h *Hub) broadcastSystemHealth() {
)
}
// broadcastBLEScan broadcasts the current BLE device list to all dashboard clients.
// Called every 5 seconds when devices are present.
func (h *Hub) broadcastBLEScan() {
h.mu.RLock()
ble := h.bleState
clientCount := len(h.clients)
h.mu.RUnlock()
if ble == nil || clientCount == 0 {
return
}
if devices := ble.GetCurrentDevices(); len(devices) > 0 {
h.BroadcastBLEScan(devices)
}
}
// BroadcastFleetChange broadcasts a fleet change event to all dashboard clients.
// This implements the fleet.FleetChangeBroadcaster interface.
func (h *Hub) BroadcastFleetChange(event fleet.FleetChangeEvent) {