use super::*;
impl<N: Network> FromBytes for Execution<N> {
fn read_le<R: Read>(mut reader: R) -> IoResult<Self> {
let version = u16::read_le(&mut reader)?;
if version != 0 {
return Err(error("Invalid execution version"));
}
let edition = u16::read_le(&mut reader)?;
let num_transitions = u16::read_le(&mut reader)?;
if num_transitions == 0 {
warn!("Execution (from 'read_le') has no transitions");
return Err(error("Execution (from 'read_le') has no transitions"));
}
let transitions =
(0..num_transitions).map(|_| Transition::read_le(&mut reader)).collect::<IoResult<Vec<_>>>()?;
Self::from(edition, &transitions).map_err(|e| error(e.to_string()))
}
}
impl<N: Network> ToBytes for Execution<N> {
fn write_le<W: Write>(&self, mut writer: W) -> IoResult<()> {
0u16.write_le(&mut writer)?;
self.edition.write_le(&mut writer)?;
(self.transitions.len() as u16).write_le(&mut writer)?;
self.transitions.write_le(&mut writer)
}
}
#[cfg(test)]
mod tests {
use super::*;
use console::network::Testnet3;
type CurrentNetwork = Testnet3;
#[test]
fn test_bytes() -> Result<()> {
let expected = crate::process::test_helpers::sample_execution();
let expected_bytes = expected.to_bytes_le()?;
assert_eq!(expected, Execution::read_le(&expected_bytes[..])?);
assert!(Execution::<CurrentNetwork>::read_le(&expected_bytes[1..]).is_err());
Ok(())
}
}