diff --git a/internal/web/job/node_heartbeat_job.go b/internal/web/job/node_heartbeat_job.go index c8c14b419..bb37d7cf7 100644 --- a/internal/web/job/node_heartbeat_job.go +++ b/internal/web/job/node_heartbeat_job.go @@ -63,7 +63,7 @@ func (j *NodeHeartbeatJob) Run() { if !websocket.HasClients() { return } - updated, err := j.nodeService.GetNodeTree() + updated, err := j.nodeService.GetNodeTreeView() if err != nil { logger.Warning("node heartbeat: load nodes for broadcast failed:", err) return diff --git a/internal/web/websocket/notifier.go b/internal/web/websocket/notifier.go index 897047e5d..7b5eff898 100644 --- a/internal/web/websocket/notifier.go +++ b/internal/web/websocket/notifier.go @@ -63,9 +63,6 @@ func BroadcastInbounds(inbounds any) { } } -// BroadcastNodes broadcasts the fresh node list to all connected clients. -// Pushed by NodeHeartbeatJob at the end of each 10s tick so the Nodes page -// reflects status / latency / cpu / mem updates without polling. func BroadcastNodes(nodes any) { if hub := GetHub(); hub != nil { hub.Broadcast(MessageTypeNodes, nodes)