diff --git a/services/identity/src/websockets/auth.rs b/services/identity/src/websockets/auth.rs --- a/services/identity/src/websockets/auth.rs +++ b/services/identity/src/websockets/auth.rs @@ -51,8 +51,8 @@ let request = Request::new(message); let response = match grpc_client.verify_user_access_token(request).await { Ok(response) => response, - Err(e) => { - error!("Failed to verify user access token: {}", e); + Err(_) => { + error!("Failed to verify user access token"); return Err(WebsocketError::AuthError); } }; @@ -61,13 +61,12 @@ } pub async fn handle_auth_message(message: &str) -> Result<(), WebsocketError> { - error!("Handling auth message: {}", message); let auth_message = serde_json::from_str(message.trim()); let auth_message: AuthMessage = match auth_message { Ok(auth_message) => auth_message, - Err(e) => { - error!("Failed to parse auth message: {}", e); + Err(_) => { + error!("Failed to parse auth message"); return Err(WebsocketError::InvalidMessage); } }; diff --git a/services/identity/src/websockets/mod.rs b/services/identity/src/websockets/mod.rs --- a/services/identity/src/websockets/mod.rs +++ b/services/identity/src/websockets/mod.rs @@ -66,14 +66,13 @@ let addr = self.addr; let future = async move { - tracing::info!( + tracing::debug!( "Incoming HTTP request on WebSocket port: {} {}", req.method(), req.uri().path() ); if hyper_tungstenite::is_upgrade_request(&req) { let (response, websocket) = hyper_tungstenite::upgrade(&mut req, None)?; - debug!("Upgraded WebSocket connection from {}", addr); tokio::spawn(async move { accept_connection(websocket, addr).await; @@ -104,7 +103,7 @@ let addr: SocketAddr = IDENTITY_SERVICE_WEBSOCKET_ADDR.parse()?; let listener = TcpListener::bind(&addr).await.expect("Failed to bind"); - info!("WebSocket Listening on {}", addr); + info!("Listening to WebSocket traffic on {}", addr); let mut http = hyper::server::conn::Http::new(); http.http1_only(true);