@@ -65,21 +65,21 @@ func (p *Proxy) handleWebSocket(w http.ResponseWriter, r *http.Request, s *sessi
6565 upstream := true
6666 err := p .stream (ctx , topic , inConn , targetConn , upstream )
6767 if err := targetConn .WriteMessage (websocket .CloseMessage , websocket .FormatCloseMessage (websocket .CloseNormalClosure , "client closed" )); err != nil {
68- p .logger .Warn ( fmt . Sprintf ( "failed to send close connection %s" , getPrefix ( upstream )) , slog .Any ("error" , err ))
68+ p .logger .Debug ( "mGate proxy unable to send close message to websocket server" , slog .Any ("error" , err ))
6969 }
7070 if err := targetConn .Close (); err != nil {
71- p .logger .Warn ( " failed to send close connection to websocket server" , slog .Any ("error" , err ))
71+ p .logger .Debug ( "mGate proxy failed to close websocket connection with server" , slog .Any ("error" , err ))
7272 }
7373 return err
7474 })
7575 g .Go (func () error {
7676 upstream := false
7777 err := p .stream (ctx , topic , targetConn , inConn , upstream )
7878 if err := inConn .WriteMessage (websocket .CloseMessage , websocket .FormatCloseMessage (websocket .CloseNormalClosure , "client closed" )); err != nil {
79- p .logger .Warn ( fmt . Sprintf ( "failed to send close connection %s" , getPrefix ( upstream )) , slog .Any ("error" , err ))
79+ p .logger .Debug ( "mGate proxy unable to send close message to websocket client" , slog .Any ("error" , err ))
8080 }
8181 if err := inConn .Close (); err != nil {
82- p .logger .Warn ( " failed to send close connection to client" , slog .Any ("error" , err ))
82+ p .logger .Debug ( "mGate proxy failed to close websocket connection with client" , slog .Any ("error" , err ))
8383 }
8484 return err
8585 })
0 commit comments