diff --git a/common/mixnode-common/src/packet_processor/error.rs b/common/mixnode-common/src/packet_processor/error.rs index 1349d88fb9..50ae179e37 100644 --- a/common/mixnode-common/src/packet_processor/error.rs +++ b/common/mixnode-common/src/packet_processor/error.rs @@ -13,6 +13,6 @@ pub enum MixProcessingError { #[error("the received packet was set to use the very old and very much deprecated 'VPN' mode")] ReceivedOldTypeVpnPacket, - #[error("failed to process received sphinx packet: {0}")] + #[error("failed to process received Nym packet: {0}")] NymPacketProcessingError(#[from] PacketProcessingError), } diff --git a/mixnode/src/node/listener/connection_handler/mod.rs b/mixnode/src/node/listener/connection_handler/mod.rs index 30373f475c..0b76762667 100644 --- a/mixnode/src/node/listener/connection_handler/mod.rs +++ b/mixnode/src/node/listener/connection_handler/mod.rs @@ -65,7 +65,7 @@ impl ConnectionHandler { // however, if it was a forward hop, we still need to delay it nanos!("handle_received_packet", { self.packet_processor - .node_stats_update_sender + .node_stats_update_sender() .report_received(); match process_received_packet(framed_sphinx_packet, self.packet_processor().inner()) { Err(err) => debug!("We failed to process received sphinx packet - {err}"), diff --git a/mixnode/src/node/listener/connection_handler/packet_processing.rs b/mixnode/src/node/listener/connection_handler/packet_processing.rs index 774683b9e7..9e6742a6b8 100644 --- a/mixnode/src/node/listener/connection_handler/packet_processing.rs +++ b/mixnode/src/node/listener/connection_handler/packet_processing.rs @@ -10,12 +10,12 @@ use nym_sphinx::framing::processing::{process_framed_packet, MixProcessingResult // PacketProcessor contains all data required to correctly unwrap and forward sphinx packets #[derive(Clone)] -pub struct PacketProcessor { +pub(crate) struct PacketProcessor { /// Responsible for performing unwrapping - pub inner_processor: SphinxPacketProcessor, + inner_processor: SphinxPacketProcessor, /// Responsible for updating metrics data - pub node_stats_update_sender: node_statistics::UpdateSender, + node_stats_update_sender: node_statistics::UpdateSender, } impl PacketProcessor { @@ -32,6 +32,10 @@ impl PacketProcessor { pub fn inner(&self) -> &SphinxPacketProcessor { &self.inner_processor } + + pub fn node_stats_update_sender(&self) -> &node_statistics::UpdateSender { + &self.node_stats_update_sender + } } pub fn process_received_packet(