diff --git a/openflare_relay/internal/wsclient/client.go b/openflare_relay/internal/wsclient/client.go index 5733c597..4b7e1f55 100644 --- a/openflare_relay/internal/wsclient/client.go +++ b/openflare_relay/internal/wsclient/client.go @@ -95,6 +95,7 @@ func (conn *Connection) SendPing() error { return errors.New("relay ws connection is nil") } slog.Debug("relay ws sending ping") + _ = conn.conn.SetWriteDeadline(time.Now().Add(5 * time.Second)) return websocket.JSON.Send(conn.conn, service.WSMessage{ Type: "ping", }) @@ -105,6 +106,7 @@ func (conn *Connection) SendPong() error { return errors.New("relay ws connection is nil") } slog.Debug("relay ws sending pong") + _ = conn.conn.SetWriteDeadline(time.Now().Add(5 * time.Second)) return websocket.JSON.Send(conn.conn, service.WSMessage{ Type: "pong", }) diff --git a/openflared/internal/wsclient/client.go b/openflared/internal/wsclient/client.go index fd5d53de..0a2477de 100644 --- a/openflared/internal/wsclient/client.go +++ b/openflared/internal/wsclient/client.go @@ -95,6 +95,7 @@ func (conn *Connection) SendPong() error { return errors.New("flared ws connection is nil") } slog.Debug("flared ws sending pong") + _ = conn.conn.SetWriteDeadline(time.Now().Add(5 * time.Second)) return websocket.JSON.Send(conn.conn, service.WSMessage{ Type: "pong", })