diff --git a/assets/style.css b/assets/style.css index 613e333..db799d7 100644 --- a/assets/style.css +++ b/assets/style.css @@ -1,7 +1,6 @@ body{ background-color: #0C1616FF; color: #8896b2; - max-width: 1000px; min-width: 0px; margin: 2em auto !important; margin-left: auto; diff --git a/assets/style.css.gz b/assets/style.css.gz index e4b3e9f..5f04e9a 100644 Binary files a/assets/style.css.gz and b/assets/style.css.gz differ diff --git a/broker/sse.go b/broker/sse.go index 1946bb4..116c23f 100644 --- a/broker/sse.go +++ b/broker/sse.go @@ -91,7 +91,9 @@ func (broker *Broker) ServeHTTP(w http.ResponseWriter, r *http.Request) { // Listen for new notifications and redistribute them to clients func (broker *Broker) Listen() { + slog.Info("Broker listener started") for { + slog.Info("Broker waiting for event") select { case s := <-broker.newClients: // A new client has connected. @@ -104,16 +106,21 @@ func (broker *Broker) Listen() { delete(broker.clients, s) slog.Info("Client removed", "clients listening", len(broker.clients)) case event := <-broker.Notifier: + slog.Info("Received new event", "event", event.EventName, "payload", event.Payload) // We got a new event from the outside! // Send event to all connected clients + slog.Info("Broadcasting event to clients", "client_count", len(broker.clients)) for clientMessageChan := range broker.clients { + slog.Info("Sending event to client", "client", clientMessageChan) select { case clientMessageChan <- event: + slog.Info("Successfully sent event to client", "client", clientMessageChan) case <-time.After(patience): delete(broker.clients, clientMessageChan) - slog.Info("Client was removed", "clients listening", len(broker.clients)) + slog.Warn("Client timed out, removed", "client", clientMessageChan, "clients listening", len(broker.clients)) } } + slog.Info("Finished broadcasting event") } } } diff --git a/components/room.html b/components/room.html index 1caabbd..e3dd763 100644 --- a/components/room.html +++ b/components/room.html @@ -49,6 +49,15 @@ {{template "teamlist" .Room.RedTeam}}