diff --git a/nym-ip-packet-client/src/connect.rs b/nym-ip-packet-client/src/connect.rs index 3c80882edb..b49d87daa5 100644 --- a/nym-ip-packet-client/src/connect.rs +++ b/nym-ip-packet-client/src/connect.rs @@ -207,7 +207,9 @@ fn maybe_wrap_stream_frame(stream_id: u64, sequence_num: u32, payload: Vec) fn ipr_response_from_reconstructed_message( msg: &nym_sdk::mixnet::ReconstructedMessage, ) -> std::result::Result { - let payload = crate::lp_stream::unwrap_ipr_payload_from_reconstructed(msg); + let warn_on_unexpected = crate::lp_stream::current_requires_sphinx_stream_transport(); + let payload = + crate::lp_stream::maybe_unwrap_lp_stream_payload(&msg.message, warn_on_unexpected); IpPacketResponse::from_bytes(payload) } diff --git a/nym-ip-packet-client/src/lp_stream.rs b/nym-ip-packet-client/src/lp_stream.rs index 262c65ebcb..736d55f378 100644 --- a/nym-ip-packet-client/src/lp_stream.rs +++ b/nym-ip-packet-client/src/lp_stream.rs @@ -50,10 +50,6 @@ pub fn maybe_unwrap_lp_stream_payload_from_reconstructed(message: &Reconstructed maybe_unwrap_lp_stream_payload(&message.message, false) } -pub fn unwrap_ipr_payload_from_reconstructed(message: &ReconstructedMessage) -> &[u8] { - maybe_unwrap_lp_stream_payload(&message.message, current_requires_sphinx_stream_transport()) -} - pub fn encode_stream_frame(stream_id: u64, sequence_num: u32, payload: Vec) -> Vec { let attrs = SphinxStreamFrameAttributes { stream_id,