feat: io

domo_lib/Cargo.lock

@@ -19,14 +19,14 @@ dependencies = [
 
 [[package]]
 name = "domo_lib"
-version = "0.3.0"
+version = "0.3.1"
 dependencies = [
  "domo_proto",
 ]
 
 [[package]]
 name = "domo_proto"
-version = "1.0.2"
+version = "1.0.3"
 dependencies = [
  "crc32fast",
  "rand",

domo_lib/src/io.rs

@@ -0,0 +1,21 @@
+use std::io;
+use std::io::Read;
+use domo_proto::packet::{Packet, PACKET_HEADER_SIZE};
+
+pub fn try_read_packet(read_handle: &mut dyn Read) -> io::Result<Packet> {
+    let mut header = [0_u8; PACKET_HEADER_SIZE];
+    read_handle.read(header.as_mut_slice())?;
+    if header[0] != 1 {
+        return Err(io::Error::new(io::ErrorKind::InvalidData, "Invalid version"));
+    }
+    let mut body = vec![];
+    body.reserve(u16::from_be_bytes([header[0x12], header[0x13]]) as usize);
+    read_handle.read_exact(&mut body)?;
+
+    Packet::try_from({
+        let mut data = vec![];
+        data.extend(header);
+        data.extend(body);
+        data
+    })
+}

domo_lib/src/lib.rs

@@ -1,4 +1,6 @@
 /// Node abstraction
 pub mod node;
 /// State
-pub mod state;
+pub mod state;
+/// IO
+pub mod io;