ockam_node 0.5.0

Ockam Node implementation crate
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use ockam_core::{Message, Result};

pub(crate) fn message<M: Message>(mut vec: Vec<u8>) -> Result<M> {
    M::decode(&vec).or_else(|_| {
        trace!("Parsing payload without inner length...");

        // This condition means we _may_ be dealing with a payload
        // sent by a non-Rust implementation.  In this case we
        // prepend the length of the mesage to the vector and try
        // again.  I know it's bad, but as long as we don't have
        // properly specified payload encoding this is what will
        // have to do.
        let mut new_v = vec![vec.len() as u8]; // FIXME: does not handle message sizes over 255
        trace!("New message length: {:?}", new_v);

        new_v.append(&mut vec);
        M::decode(&new_v)
    })
}