GRIN/nym
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Passing entire processing data struct for dealing with sphinx packets

Browse Source
This commit is contained in:
Jedrzej Stuczynski
2019-12-09 13:59:22 +00:00
parent 0b4f10cfe6
commit cd94ecde19
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/node/mod.rs
+3 -3
View File
@@ -61,9 +61,9 @@ struct PacketProcessor {
}
impl PacketProcessor {
pub fn process_sphinx_data_packet<'a>(packet_data: &[u8], secret_key: Scalar) -> Result<ForwardingData<'a>, MixProcessingError> {
pub fn process_sphinx_data_packet<'a>(packet_data: &[u8], processing_data: ProcessingData) -> Result<ForwardingData<'a>, 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) => {