[wip] Optionally parse sync (address) byte

Cargo.toml

@@ -9,6 +9,7 @@ repository = "https://github.com/tact1m4n3/crsf-rs"
 documentation = "https://docs.rs/crsf"
 
 [dependencies]
+bitflags = "2.5.0"
 crc = "3.2"
 defmt = { version = "0.3.6", optional = true }
 num_enum = { version = "0.7.2", default-features = false }

examples/local_serial.rs

@@ -1,6 +1,6 @@
 use std::{env, io, time::Duration};
 
-use crsf::{Packet, PacketReader};
+use crsf::{Packet, PacketPayload, PacketReader};
 
 fn main() {
     let path = env::args().nth(1).expect("no serial port supplied");
@@ -10,19 +10,19 @@ fn main() {
         .expect("failed to open serial port");
 
     let mut buf = [0; 1024];
-    let mut reader = PacketReader::new();
+    let mut reader = PacketReader::default();
     loop {
         match port.read(buf.as_mut_slice()) {
             Ok(n) => {
                 if n > 0 {
                     let mut remaining = &buf[..n];
                     while let (Some(raw_packet), consumed) = reader.push_bytes(remaining) {
                         match Packet::parse(raw_packet) {
-                            Ok(packet) => match packet {
-                                Packet::LinkStatistics(link_statistics) => {
+                            Ok(packet) => match packet.payload {
+                                PacketPayload::LinkStatistics(link_statistics) => {
                                     println!("{:?}", link_statistics);
                                 }
-                                Packet::RcChannels(channels) => {
+                                PacketPayload::RcChannels(channels) => {
                                     println!("{:?}", channels);
                                 }
                                 _ => {}

src/buffer.rs

@@ -0,0 +1,40 @@
+pub(crate) struct Buf<const C: usize> {
+    buf: [u8; C],
+    len: usize,
+}
+
+impl<const C: usize> Buf<C> {
+    pub(crate) const fn new() -> Self {
+        Self {
+            buf: [0; C],
+            len: 0,
+        }
+    }
+
+    pub(crate) fn len(&self) -> usize {
+        self.len
+    }
+
+    pub(crate) fn push(&mut self, c: u8) -> bool {
+        if let Some(v) = self.buf.get_mut(self.len) {
+            *v = c;
+            self.len += 1;
+            true
+        } else {
+            false
+        }
+    }
+
+    pub(crate) fn push_bytes(&mut self, data: &[u8]) {
+        self.buf[self.len..self.len + data.len()].copy_from_slice(data);
+        self.len += data.len();
+    }
+
+    pub(crate) fn data(&self) -> &[u8; C] {
+        &self.buf
+    }
+
+    pub(crate) fn clear(&mut self) {
+        self.len = 0;
+    }
+}