pomodoro/GoTomato
3
0
Fork 0
Code Issues Pull requests Releases 15 Activity

add more log output

Browse source
This commit is contained in:
Sebastian Mark 2024-11-20 20:21:22 +01:00
parent 2ddc1ef9e4
commit c63ef3c12a
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
internal/websocket/broadcast.go
View file

@ -32,7 +32,7 @@ func SendPermanentBroadCastMessage() {
// Remove unresponsive client // Remove unresponsive client
client.Conn.Close() client.Conn.Close()
delete(Clients, client.Conn.LocalAddr()) delete(Clients, client.Conn.LocalAddr())
helper.Logger.Info("Client timed out", "host", client.RealIP, "clients", len(Clients)) helper.Logger.Info("Client timed out", "lastPong", client.LastPong, "host", client.RealIP, "clients", len(Clients))
} }
} }
<-tick.C <-tick.C

2
pkg/models/client.go
View file

@ -25,7 +25,7 @@ type WebsocketClient struct {
// Sends a message to the websocket. // Sends a message to the websocket.
// Automatically locks and unlocks the client mutex, to ensure that only one goroutine can write at a time. // Automatically locks and unlocks the client mutex, to ensure that only one goroutine can write at a time.
func (c *WebsocketClient) SendMessage(messageType int, data []byte) error { func (c *WebsocketClient) SendMessage(messageType int, data []byte) error {
c.Conn.SetPongHandler(func(appData string) error { c.Conn.SetPongHandler(func(s string) error {
c.LastPong = time.Now() c.LastPong = time.Now()
return nil return nil
}) })