Function read_frame

nodedb/tests/native_protocol.rs:234–246

Read a length-prefixed frame from the stream. Returns `None` on EOF.

(stream: &mut TcpStream)

/// Read a length-prefixed frame from the stream.
/// Returns `None` on EOF.
async fn read_frame(stream: &mut TcpStream) -> Option<Vec<u8>> {
    let mut len_buf = [0u8; FRAME_HEADER_LEN];
    match stream.read_exact(&mut len_buf).await {
        Ok(_) => {}
        Err(e) if e.kind() == std::io::ErrorKind::UnexpectedEof => return None,
        Err(e) if e.kind() == std::io::ErrorKind::ConnectionReset => return None,
        Err(e) => panic!("read_frame error: {e}"),
    }
    let payload_len = u32::from_be_bytes(len_buf) as usize;
    let mut payload = vec![0u8; payload_len];
    stream.read_exact(&mut payload).await.expect("read payload");
    Some(payload)
}

// ─── Tests ──────────────────────────────────────────────────────────────────