logos-co
/
nomos-node
mirror of
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test(blend): add MockBlendMessage::payload function to get payload without unpacking (#967)

This commit is contained in:
Youngjoon Lee 2024-12-20 20:36:34 +09:00 committed by GitHub
parent 0b3b298e4c
commit 9001b44079
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
nomos-blend/message/src/mock/mod.rs
View File

@ -75,17 +75,7 @@ impl BlendMessage for MockBlendMessage {
// If this is the last layer // If this is the last layer
if message[NODE_ID_SIZE..NODE_ID_SIZE * 2] == DUMMY_NODE_ID { if message[NODE_ID_SIZE..NODE_ID_SIZE * 2] == DUMMY_NODE_ID {
let padded_payload = &message[NODE_ID_SIZE * MAX_LAYERS..]; return Ok((Self::payload(message)?, true));
// remove the payload padding
match padded_payload
.iter()
.rposition(|&x| x == PAYLOAD_PADDING_SEPARATOR)
{
Some(pos) => {
return Ok((padded_payload[0..pos].to_vec(), true));
}
_ => return Err(Error::InvalidBlendMessage),
}
} }
let mut new_message: Vec<u8> = Vec::with_capacity(MESSAGE_SIZE); let mut new_message: Vec<u8> = Vec::with_capacity(MESSAGE_SIZE);
@ -96,6 +86,20 @@ impl BlendMessage for MockBlendMessage {
} }
} }
impl MockBlendMessage {
pub fn payload(message: &[u8]) -> Result<Vec<u8>, Error> {
let padded_payload = &message[NODE_ID_SIZE * MAX_LAYERS..];
// remove the payload padding
match padded_payload
.iter()
.rposition(|&x| x == PAYLOAD_PADDING_SEPARATOR)
{
Some(pos) => Ok(padded_payload[0..pos].to_vec()),
_ => Err(Error::InvalidBlendMessage),
}
}
}
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use super::*; use super::*;
@ -106,16 +110,19 @@ mod tests {
let payload = [7; 10]; let payload = [7; 10];
let message = MockBlendMessage::build_message(&payload, &node_ids).unwrap(); let message = MockBlendMessage::build_message(&payload, &node_ids).unwrap();
assert_eq!(message.len(), MESSAGE_SIZE); assert_eq!(message.len(), MESSAGE_SIZE);
assert_eq!(MockBlendMessage::payload(&message).unwrap(), payload);
let (message, is_fully_unwrapped) = let (message, is_fully_unwrapped) =
MockBlendMessage::unwrap_message(&message, &node_ids[0]).unwrap(); MockBlendMessage::unwrap_message(&message, &node_ids[0]).unwrap();
assert!(!is_fully_unwrapped); assert!(!is_fully_unwrapped);
assert_eq!(message.len(), MESSAGE_SIZE); assert_eq!(message.len(), MESSAGE_SIZE);
assert_eq!(MockBlendMessage::payload(&message).unwrap(), payload);
let (message, is_fully_unwrapped) = let (message, is_fully_unwrapped) =
MockBlendMessage::unwrap_message(&message, &node_ids[1]).unwrap(); MockBlendMessage::unwrap_message(&message, &node_ids[1]).unwrap();
assert!(!is_fully_unwrapped); assert!(!is_fully_unwrapped);
assert_eq!(message.len(), MESSAGE_SIZE); assert_eq!(message.len(), MESSAGE_SIZE);
assert_eq!(MockBlendMessage::payload(&message).unwrap(), payload);
let (unwrapped_payload, is_fully_unwrapped) = let (unwrapped_payload, is_fully_unwrapped) =
MockBlendMessage::unwrap_message(&message, &node_ids[2]).unwrap(); MockBlendMessage::unwrap_message(&message, &node_ids[2]).unwrap();