Update framing

Author: bugadani

espflash/src/cli/monitor/mod.rs

@@ -85,14 +85,15 @@ struct FrameDelimiter<'a> {
 }
 
 const FRAME_START: &[u8] = &[0xFF, 0x00];
-const FRAME_END: &[u8] = &[0xFC, 0x00];
+const FRAME_END: &[u8] = &[0x00];
 
-fn search(haystack: &[u8], look_for_end: bool) -> Option<(&[u8], usize)> {
+fn search(haystack: &[u8], look_for_end: bool) -> Option<(&[u8], &[u8])> {
     let needle = if look_for_end { FRAME_END } else { FRAME_START };
+
     haystack
         .windows(needle.len())
-        .position(|window| window == FRAME_START || window == FRAME_END)
-        .map(|pos| (&haystack[pos..][..2], pos))
+        .position(|byte| byte == needle)
+        .map(|pos| (needle, &haystack[..pos]))
 }
 
 impl FrameDelimiter<'_> {
@@ -104,19 +105,22 @@ impl FrameDelimiter<'_> {
 
         self.buffer.extend_from_slice(buffer);
 
-        while let Some((delimiter, pos)) = search(&self.buffer, self.in_frame) {
-            let frame = &self.buffer[..pos];
+        while let Some((delimiter, frame)) = search(&self.buffer, self.in_frame) {
             if delimiter == FRAME_START {
                 process(FrameKind::Raw(frame));
+                self.in_frame = true;
             } else {
                 table.received(frame);
+                // small reliance on rzcobs internals: we need to feed the terminating zero
+                table.received(delimiter);
                 if let Ok(frame) = table.decode() {
                     process(FrameKind::Defmt(frame));
                 } else {
                     log::warn!("Failed to decode defmt frame");
                 }
+                self.in_frame = false;
             }
-            self.buffer.drain(..pos + delimiter.len());
+            self.buffer.drain(..frame.len() + delimiter.len());
         }
     }
 }