Method decode

perro_source/api_modules/perro_networking/src/tcp.rs:41–74

(bytes: &[u8])

        out.extend_from_slice(&self.version.to_be_bytes());
        out.extend_from_slice(&(app.len() as u16).to_be_bytes());
        out.extend_from_slice(&(protocol.len() as u16).to_be_bytes());
        out.extend_from_slice(app);
        out.extend_from_slice(protocol);
        Ok(out)
    }

    pub fn decode(bytes: &[u8]) -> NetResult<Self> {
        let min_len = Self::MAGIC.len() + 6;
        if bytes.len() < min_len || !bytes.starts_with(Self::MAGIC) {
            return Err(NetError::new(
                NetErrorKind::Handshake,
                "invalid handshake header",
            ));
        }

        let mut i = Self::MAGIC.len();
        let version = u16::from_be_bytes([bytes[i], bytes[i + 1]]);
        i += 2;
        let app_len = u16::from_be_bytes([bytes[i], bytes[i + 1]]) as usize;
        i += 2;
        let protocol_len = u16::from_be_bytes([bytes[i], bytes[i + 1]]) as usize;
        i += 2;

        if bytes.len() != i + app_len + protocol_len {
            return Err(NetError::new(
                NetErrorKind::Handshake,
                "invalid handshake length",
            ));
        }

        let app = utf8(bytes[i..i + app_len].to_vec())?;
        i += app_len;
        let protocol = utf8(bytes[i..i + protocol_len].to_vec())?;

        Ok(Self {
            app,
            protocol,