cleanup
This commit is contained in:
parent
cdaceb856c
commit
955914250a
5 changed files with 12 additions and 12 deletions
|
|
@ -50,7 +50,6 @@ func Handle() http.HandlerFunc {
|
||||||
defer manager.Disconnect(sessionId)
|
defer manager.Disconnect(sessionId)
|
||||||
|
|
||||||
defer func() {
|
defer func() {
|
||||||
fmt.Printf("empting channels\n")
|
|
||||||
for len(writer) > 0 {
|
for len(writer) > 0 {
|
||||||
<-writer
|
<-writer
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -75,12 +75,18 @@ func List(metrics ws.Metrics) *h.Element {
|
||||||
h.IterMap(metrics.Manager.SocketsPerRoom, func(key string, value []string) *h.Element {
|
h.IterMap(metrics.Manager.SocketsPerRoom, func(key string, value []string) *h.Element {
|
||||||
return ListBlock(
|
return ListBlock(
|
||||||
fmt.Sprintf("Sockets In Room - %s", key),
|
fmt.Sprintf("Sockets In Room - %s", key),
|
||||||
h.Div(
|
h.IfElse(
|
||||||
h.List(value, func(item string, index int) *h.Element {
|
len(value) > 100,
|
||||||
return h.Div(
|
h.Div(
|
||||||
h.Pf("%s", item),
|
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),
|
||||||
|
)
|
||||||
|
}),
|
||||||
|
),
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
}),
|
}),
|
||||||
|
|
|
||||||
|
|
@ -61,7 +61,6 @@ func WsHttpHandler(opts *ws2.ExtensionOpts) http.HandlerFunc {
|
||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
|
|
||||||
defer func() {
|
defer func() {
|
||||||
fmt.Printf("empting channels\n")
|
|
||||||
for len(writer) > 0 {
|
for len(writer) > 0 {
|
||||||
<-writer
|
<-writer
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -243,8 +243,6 @@ func (manager *SocketManager) Add(roomId string, id string, writer WriterChan, d
|
||||||
RoomId: s.RoomId,
|
RoomId: s.RoomId,
|
||||||
Payload: map[string]any{},
|
Payload: map[string]any{},
|
||||||
})
|
})
|
||||||
|
|
||||||
fmt.Printf("User %s connected to %s\n", id, roomId)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (manager *SocketManager) OnClose(id string) {
|
func (manager *SocketManager) OnClose(id string) {
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/maddalax/htmgo/extensions/websocket/internal/wsutil"
|
"github.com/maddalax/htmgo/extensions/websocket/internal/wsutil"
|
||||||
"github.com/maddalax/htmgo/framework/session"
|
"github.com/maddalax/htmgo/framework/session"
|
||||||
"log/slog"
|
|
||||||
"sync"
|
"sync"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
@ -79,7 +78,6 @@ func (h *MessageHandler) OnDomElementRemoved(handlerId string) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *MessageHandler) OnSocketDisconnected(event wsutil.SocketEvent) {
|
func (h *MessageHandler) OnSocketDisconnected(event wsutil.SocketEvent) {
|
||||||
slog.Info("ws-extension: socket disconnected", slog.String("socketId", event.SessionId))
|
|
||||||
sessionId := session.Id(event.SessionId)
|
sessionId := session.Id(event.SessionId)
|
||||||
hashes, ok := sessionIdToHashes.Load(sessionId)
|
hashes, ok := sessionIdToHashes.Load(sessionId)
|
||||||
if ok {
|
if ok {
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue