(feat/webrtc-sniffer): add filter parameter

Author: vlad9486

tools/webrtc-sniffer/src/bin/sniffer.rs

@@ -14,26 +14,30 @@ struct Cli {
         help = "name of the interface, use `auto` to determine automatically"
     )]
     interface: Option<String>,
+
     #[arg(
         long,
         help = "if `interface` is set, the packets will be written to the `pcap` file, \
                 otherwise the file will be a source of packets"
     )]
     path: PathBuf,
 
+    #[arg(long, help = "bpf filter, example: \"udp and not port 443\"")]
+    filter: Option<String>,
+
     /// Peer secret key
     #[arg(long, short = 's', env = "OPENMINA_P2P_SEC_KEY")]
-    pub p2p_secret_key: Option<SecretKey>,
+    p2p_secret_key: Option<SecretKey>,
 
     // warning, this overrides `OPENMINA_P2P_SEC_KEY`
     /// Compatibility with OCaml Mina node
     #[arg(long)]
-    pub libp2p_keypair: Option<String>,
+    libp2p_keypair: Option<String>,
 
     // warning, this overrides `OPENMINA_P2P_SEC_KEY`
     /// Compatibility with OCaml Mina node
     #[arg(env = "MINA_LIBP2P_PASS")]
-    pub libp2p_password: Option<String>,
+    libp2p_password: Option<String>,
 }
 
 fn init_logger_std() -> Box<dyn log::Log> {
@@ -51,6 +55,7 @@ fn main() {
     let Cli {
         interface,
         path,
+        filter,
         p2p_secret_key,
         libp2p_keypair,
         libp2p_password,
@@ -106,7 +111,7 @@ fn main() {
             let res = Ok(()).and_then(|()| {
                 let mut capture = Capture::from_device(device)?.open()?;
                 capture
-                    .filter("udp and not port 443", true)
+                    .filter(&filter.unwrap_or_default(), true)
                     .expect("Failed to apply filter");
                 let savefile = capture.savefile(&path)?;
 

tools/webrtc-sniffer/src/lib.rs

@@ -13,11 +13,7 @@ pub fn run<T: Activated + ?Sized>(
 
     for item in net::UdpIter::new(capture, file) {
         let (src, dst, data) = item?;
-        log::info!(
-            "{src} -> {dst}: {} {}",
-            data.len(),
-            hex::encode(&data[..data.len().min(12)])
-        );
+        log::info!("{src} -> {dst}: {} {}", data.len(), hex::encode(data));
     }
 
     Ok(())