Add log messages to onvif_rs::discovery

Author: DmitrySamoylov

.gitignore

@@ -1,4 +1,5 @@
 /target
 **/*.rs.bk
 Cargo.lock
-.idea
+.idea
+.env

Cargo.toml

@@ -29,3 +29,5 @@ xsd-types = { git = "https://github.com/lumeohq/xsd-parser-rs", rev = "05cd3be1"
 
 [dev-dependencies]
 assert_approx_eq = "1.1.0"
+dotenv = "0.15.0"
+env_logger = "0.7.1"

examples/camera_datetime.rs

@@ -3,6 +3,9 @@ use onvif_rs::{schema, soap};
 
 #[tokio::main]
 async fn main() {
+    dotenv::dotenv().ok();
+    env_logger::init();
+
     let uri = match std::env::args().skip(1).next() {
         Some(arg) => arg,
         None => {

examples/camera_get_stream_uri.rs

@@ -3,6 +3,9 @@ use onvif_rs::{schema, soap};
 
 #[tokio::main]
 async fn main() {
+    dotenv::dotenv().ok();
+    env_logger::init();
+
     let uri = match std::env::args().skip(1).next() {
         Some(arg) => arg,
         None => {

examples/camera_set_hostname.rs

@@ -10,6 +10,9 @@ struct Opts {
 
 #[tokio::main]
 async fn main() {
+    dotenv::dotenv().ok();
+    env_logger::init();
+
     let opts = Opts::parse();
 
     let mut client = soap::client::Client::new(

examples/discovery.rs

@@ -3,6 +3,9 @@ use onvif_rs::discovery;
 
 #[tokio::main]
 async fn main() {
+    dotenv::dotenv().ok();
+    env_logger::init();
+
     use futures::stream::StreamExt;
     const MAX_CONCURRENT_JUMPERS: usize = 100;
 

src/discovery/mod.rs

@@ -69,6 +69,8 @@ pub async fn discover(duration: std::time::Duration) -> Result<StringStream, Err
     let probe = build_probe();
     let probe_xml = yaserde::ser::to_string(&probe).map_err(Error::Internal)?;
 
+    debug!("Probe XML: {}", probe_xml);
+
     let socket = (|| async {
         const LOCAL_IPV4_ADDR: Ipv4Addr = Ipv4Addr::UNSPECIFIED;
         const LOCAL_PORT: u16 = 0;
@@ -96,9 +98,10 @@ pub async fn discover(duration: std::time::Duration) -> Result<StringStream, Err
         // Make an async stream of XML's
         futures::stream::unfold(socket, |s| async { Some((recv_string(&s).await, s)) })
             .filter_map(|string| async move { string.ok() })
-            .filter_map(
-                |xml| async move { yaserde::de::from_str::<probe_matches::Envelope>(&xml).ok() },
-            )
+            .filter_map(|xml| async move {
+                debug!("Probe match XML: {}", xml);
+                yaserde::de::from_str::<probe_matches::Envelope>(&xml).ok()
+            })
             .filter(move |envelope| {
                 futures::future::ready(envelope.header.relates_to == probe.header.message_id)
             })
@@ -151,7 +154,11 @@ where
     .filter(|addr| check_addr(addr.clone()))
     .take(1);
 
-    Box::pin(stream).next().await
+    let addr = Box::pin(stream).next().await;
+
+    debug!("Responding addr: {:?}", addr);
+
+    addr
 }
 
 fn build_probe() -> probe::Envelope {