From d7750ad15f213687e4bc01da235604e7a8606c6a Mon Sep 17 00:00:00 2001 From: Dylan Cant Date: Thu, 19 Jan 2023 11:02:39 -0500 Subject: [PATCH] added comment --- handlers.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/handlers.go b/handlers.go index 25e1ccf..70491b3 100644 --- a/handlers.go +++ b/handlers.go @@ -235,9 +235,14 @@ func (s *Server) handleWebsocket(w http.ResponseWriter, r *http.Request) { if advancedQuerier != nil { advancedQuerier.AfterQuery(events, filter) } + + // this block should not trigger if the SQL query accounts for filter.Limit + // other implementations may be broken, and this ensures the client + // won't be bombarded. if filter.Limit > 0 && len(events) > filter.Limit { events = events[0:filter.Limit] } + for _, event := range events { ws.WriteJSON([]interface{}{"EVENT", id, event}) }