Method SetWatchEventsBus

internal/server/server.go:848–850

SetWatchEventsBus attaches the watch/nudge notification bus consumed by GET /api/v1/events/stream (TASK-2533). Nil-checked by every producer and by the stream handler, so a server constructed without one (e.g. a test that doesn't exercise watches) still serves every other endpoint.

(bus watchevents.Bus)

// by the stream handler, so a server constructed without one (e.g. a test
// that doesn't exercise watches) still serves every other endpoint.
func (s *Server) SetWatchEventsBus(bus watchevents.Bus) {
	s.watchEvents = bus
}

// SetSessionPresence attaches the live-session registry read by
// GET /api/v1/sessions and written by GET /api/v1/events/stream