From 68757371a0f4bfa7adb746b8770a540cfbfe4ce4 Mon Sep 17 00:00:00 2001
From: Alon Levy <alon@pobox.com>
Date: Fri, 29 Dec 2023 01:28:53 +0200
Subject: [PATCH] parses all packets, pretty fast

---
 thermalcamdecoder/Cargo.toml  |  2 +-
 thermalcamdecoder/src/main.rs | 34 ++++++++++++++++++++++++++++++++--
 2 files changed, 33 insertions(+), 3 deletions(-)

diff --git a/thermalcamdecoder/Cargo.toml b/thermalcamdecoder/Cargo.toml
index 046eca2..a5ecd55 100644
--- a/thermalcamdecoder/Cargo.toml
+++ b/thermalcamdecoder/Cargo.toml
@@ -7,5 +7,5 @@ edition = "2021"
 
 [dependencies]
 anyhow = "1.0.77"
-pcap-parser = "0.14.1"
+pcap-parser = { version = "0.14.1", features = ["data"] }
 pyo3 = "0.20.0"
diff --git a/thermalcamdecoder/src/main.rs b/thermalcamdecoder/src/main.rs
index 2327b47..add8422 100644
--- a/thermalcamdecoder/src/main.rs
+++ b/thermalcamdecoder/src/main.rs
@@ -8,11 +8,40 @@ fn main() -> anyhow::Result<()> {
     let mut cap = PcapNGReader::new(65535, file)?;
     let mut i = 0;
     let mut size = 0;
+    let mut data = vec![];
     loop {
         match cap.next() {
-            Ok((offset, _packet)) => {
+            Ok((offset, packet)) => {
                 i += 1;
                 size += offset;
+                match packet {
+                    PcapBlockOwned::Legacy(block) => {
+                        println!("dunno");
+                    }
+                    PcapBlockOwned::LegacyHeader(block) => {
+                        println!("dunnoheader");
+                    }
+                    PcapBlockOwned::NG(block) => {
+                        if block.is_data_block() {
+                            match block {
+                                Block::EnhancedPacket(ref epb) => {
+                                    if epb.origlen == 6972 {
+                                        // remove udp header
+                                        data.push(epb.data[0x2a..].to_vec());
+                                    }
+                                }
+                                Block::SimplePacket(ref ep) => {
+                                    if ep.origlen == 6972 {
+                                        println!("found one regular");
+                                    }
+                                }
+                                _ => {
+                                    println!("unsupported packet");
+                                }
+                            }
+                        }
+                    }
+                }
                 cap.consume(offset)
             }
             Err(PcapError::Eof) => break,
@@ -25,6 +54,7 @@ fn main() -> anyhow::Result<()> {
             }
         }
     }
-    println!("found {} packets, {} size", i, size);
+    println!("found {} packets, saved {}, {} size", i, data.len(), size);
+    println!("{:+?}", data);
     Ok(())
 }