From 955914250a543d7a3bfad435e137854950ac8460 Mon Sep 17 00:00:00 2001 From: maddalax Date: Tue, 5 Nov 2024 14:40:03 -0600 Subject: [PATCH] cleanup --- examples/chat/sse/handler.go | 1 - examples/ws-example/pages/ws/metrics.go | 18 ++++++++++++------ .../websocket/internal/wsutil/handler.go | 1 - .../websocket/internal/wsutil/manager.go | 2 -- extensions/websocket/ws/handler.go | 2 -- 5 files changed, 12 insertions(+), 12 deletions(-) diff --git a/examples/chat/sse/handler.go b/examples/chat/sse/handler.go index b4f8000..cb39bfc 100644 --- a/examples/chat/sse/handler.go +++ b/examples/chat/sse/handler.go @@ -50,7 +50,6 @@ func Handle() http.HandlerFunc { defer manager.Disconnect(sessionId) defer func() { - fmt.Printf("empting channels\n") for len(writer) > 0 { <-writer } diff --git a/examples/ws-example/pages/ws/metrics.go b/examples/ws-example/pages/ws/metrics.go index ba58ea6..529401e 100644 --- a/examples/ws-example/pages/ws/metrics.go +++ b/examples/ws-example/pages/ws/metrics.go @@ -75,12 +75,18 @@ func List(metrics ws.Metrics) *h.Element { h.IterMap(metrics.Manager.SocketsPerRoom, func(key string, value []string) *h.Element { return ListBlock( fmt.Sprintf("Sockets In Room - %s", key), - h.Div( - h.List(value, func(item string, index int) *h.Element { - return h.Div( - h.Pf("%s", item), - ) - }), + h.IfElse( + len(value) > 100, + h.Div( + h.Pf("%d total sockets", len(value)), + ), + h.Div( + h.List(value, func(item string, index int) *h.Element { + return h.Div( + h.Pf("%s", item), + ) + }), + ), ), ) }), diff --git a/extensions/websocket/internal/wsutil/handler.go b/extensions/websocket/internal/wsutil/handler.go index efa7ece..1096dd5 100644 --- a/extensions/websocket/internal/wsutil/handler.go +++ b/extensions/websocket/internal/wsutil/handler.go @@ -61,7 +61,6 @@ func WsHttpHandler(opts *ws2.ExtensionOpts) http.HandlerFunc { defer wg.Done() defer func() { - fmt.Printf("empting channels\n") for len(writer) > 0 { <-writer } diff --git a/extensions/websocket/internal/wsutil/manager.go b/extensions/websocket/internal/wsutil/manager.go index 905d1de..d274fe1 100644 --- a/extensions/websocket/internal/wsutil/manager.go +++ b/extensions/websocket/internal/wsutil/manager.go @@ -243,8 +243,6 @@ func (manager *SocketManager) Add(roomId string, id string, writer WriterChan, d RoomId: s.RoomId, Payload: map[string]any{}, }) - - fmt.Printf("User %s connected to %s\n", id, roomId) } func (manager *SocketManager) OnClose(id string) { diff --git a/extensions/websocket/ws/handler.go b/extensions/websocket/ws/handler.go index a4de0e0..72cdff8 100644 --- a/extensions/websocket/ws/handler.go +++ b/extensions/websocket/ws/handler.go @@ -4,7 +4,6 @@ import ( "fmt" "github.com/maddalax/htmgo/extensions/websocket/internal/wsutil" "github.com/maddalax/htmgo/framework/session" - "log/slog" "sync" ) @@ -79,7 +78,6 @@ func (h *MessageHandler) OnDomElementRemoved(handlerId string) { } func (h *MessageHandler) OnSocketDisconnected(event wsutil.SocketEvent) { - slog.Info("ws-extension: socket disconnected", slog.String("socketId", event.SessionId)) sessionId := session.Id(event.SessionId) hashes, ok := sessionIdToHashes.Load(sessionId) if ok {