diff --git a/host/src/engine.rs b/host/src/engine.rs old mode 100755 new mode 100644 index 08ca87f..d1ebd19 --- a/host/src/engine.rs +++ b/host/src/engine.rs @@ -309,12 +309,6 @@ impl HandshakeEngine { ) || registration || first_msg.get_data(DataType::PublicKeys).is_some() || claimed_client_id.is_some_and(|client_id| client_id != 0); - tracing::info!( - claimed_client_id = ?claimed_client_id, - registration, - authentication_requested, - "classified MTP opening authentication mode" - ); if authentication_requested { let attempt = crate::config::AuthenticationAttempt { peer_network_identity: _authentication_context.peer_network_identity.clone(), @@ -572,7 +566,6 @@ impl HandshakeEngine { } // Unknown or zero ID: fall back to guest - tracing::info!("allocating MTP guest identity"); let guest_id_lease = match self.assign_guest_id().await { Ok(lease) => lease, Err(error) => { @@ -581,7 +574,6 @@ impl HandshakeEngine { } }; let guest_id = guest_id_lease.id; - tracing::info!(guest_id, "allocated MTP guest identity"); send_accepted_generic(sender, &negotiated, tm, Some(guest_id)) .await .map_err(AcceptError::Send)?; diff --git a/transport/src/generic_connection.rs b/transport/src/generic_connection.rs index a7a32de..830fb40 100644 --- a/transport/src/generic_connection.rs +++ b/transport/src/generic_connection.rs @@ -9,7 +9,7 @@ use crate::{ connection::{DecodeRejectionCounters, RuntimePolicy, classify_decode_error}, framing::{RetryClassifier, write_frame}, }; -use mtp_codec::{CommunicationValue, DataType, DecodeLimits, TypeMap}; +use mtp_codec::{CommunicationValue, DecodeLimits, TypeMap}; use mtp_common::CommunicationError; use std::sync::Arc; use std::sync::atomic::{AtomicU64, Ordering}; @@ -67,15 +67,6 @@ impl GenericSender { if self.connection.close_reason().is_some() { return Err(CommunicationError::StreamClosed); } - if let Some(version) = value.get_str(DataType::Version) { - tracing::debug!( - message_type = ?value.get_type(), - version, - connected = ?value.get_data(DataType::Connected), - client_id = ?value.get_data(DataType::Id), - "sending MTP handshake response frame" - ); - } match self.policy.send_mode { crate::SendMode::SingleStreamPerMessage => { let mut stream = self.open().await?; diff --git a/wasm/src/client/authentication.rs b/wasm/src/client/authentication.rs index 73bfc9f..df7989e 100644 --- a/wasm/src/client/authentication.rs +++ b/wasm/src/client/authentication.rs @@ -99,19 +99,10 @@ impl WasmClient { return Err(js_error(message)); } - let missing_version = || { - js_error(format!( - "host omitted a valid negotiated protocol version (response_type={:?}, connected={:?}, frame_len={})", - outcome.get_type(), - outcome.get_data(DataType::Connected), - outcome_bytes.len(), - )) - }; - let negotiated_version = match outcome.get_data(DataType::Version) { Some(DataValue::Str(version)) => mtp_codec::Version::parse(version) - .ok_or_else(|| missing_version())?, - _ => return Err(missing_version()), + .ok_or_else(|| js_error("host omitted a valid negotiated protocol version"))?, + _ => return Err(js_error("host omitted a valid negotiated protocol version")), }; if negotiated_version != PROTOCOL_VERSION { return Err(js_error(