@@ -17,7 +17,7 @@ use tokio_tungstenite::{
1717 tungstenite:: { self , Message } ,
1818 MaybeTlsStream , WebSocketStream ,
1919} ;
20- use tracing:: { error, info, trace, warn} ;
20+ use tracing:: { debug , error, info, trace, warn} ;
2121use uuid:: Uuid ;
2222
2323use crate :: {
@@ -222,7 +222,22 @@ impl Future for CommitmentRequestProcessor {
222222 warn ! ( ?rpc_url, "websocket connection closed by server" ) ;
223223 return Poll :: Ready ( InterruptReason :: ConnectionClosed ) ;
224224 }
225- Ok ( _) => { } // ignore other message types
225+ Ok ( Message :: Binary ( data) ) => {
226+ debug ! (
227+ ?rpc_url,
228+ bytes_len = data. len( ) ,
229+ "received unexpected binary message"
230+ ) ;
231+ }
232+ Ok ( Message :: Ping ( _) ) => {
233+ trace ! ( ?rpc_url, "received ping message" ) ;
234+ }
235+ Ok ( Message :: Pong ( _) ) => {
236+ trace ! ( ?rpc_url, "received pong message" ) ;
237+ }
238+ Ok ( Message :: Frame ( _) ) => {
239+ debug ! ( ?rpc_url, "received unexpected raw frame" ) ;
240+ }
226241 Err ( e) => {
227242 error ! ( ?e, ?rpc_url, "error reading message from websocket connection" ) ;
228243 }
0 commit comments