From cd94ecde1963423bec7c29a5878c05403c253bc4 Mon Sep 17 00:00:00 2001 From: Jedrzej Stuczynski Date: Mon, 9 Dec 2019 13:59:22 +0000 Subject: [PATCH] Passing entire processing data struct for dealing with sphinx packets --- src/node/mod.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/node/mod.rs b/src/node/mod.rs index 5e62658fe8..796973ca03 100644 --- a/src/node/mod.rs +++ b/src/node/mod.rs @@ -61,9 +61,9 @@ struct PacketProcessor { } impl PacketProcessor { - pub fn process_sphinx_data_packet<'a>(packet_data: &[u8], secret_key: Scalar) -> Result, MixProcessingError> { + pub fn process_sphinx_data_packet<'a>(packet_data: &[u8], processing_data: ProcessingData) -> Result, MixProcessingError> { let packet = SphinxPacket::from_bytes(packet_data.to_vec())?; - let (next_packet, next_hop_address, delay) = match packet.process(secret_key) { + let (next_packet, next_hop_address, delay) = match packet.process(processing_data.secret_key) { ProcessedPacket::ProcessedPacketForwardHop(packet, address, delay) => (packet, address, delay), _ => return Err(MixProcessingError::ReceivedFinalHopError), }; @@ -131,7 +131,7 @@ impl MixNode{ return; } Ok(_) => { - let fwd_data = PacketProcessor::process_sphinx_data_packet(buf.as_ref(), processing_data.secret_key).unwrap(); + let fwd_data = PacketProcessor::process_sphinx_data_packet(buf.as_ref(), processing_data).unwrap(); PacketProcessor::wait_and_forward(fwd_data).await; } Err(e) => {