Added repeating discovery call

chipp · Aug 17, 2024 · 03592b8 · 03592b8
1 parent b53df9b
commit 03592b8
Show file tree

Hide file tree

Showing 4 changed files with 37 additions and 4 deletions.
diff --git a/Makefile b/Makefile
@@ -139,7 +139,7 @@ test_isabel_libs_arm64:
 		--load
 
 run_elisheba: RUST_LOG = elisheba=debug,sonoff=debug,info
-run_elisheba: KEYS = $(shell op read "op://private/elisheba devices/notesPlain")
+run_elisheba: KEYS = 10020750eb=$(shell op read "op://private/elisheba devices/10020750eb"),1002074ed2=$(shell op read "op://private/elisheba devices/1002074ed2")
 run_elisheba: MQTT_ADDRESS = mqtt://localhost:1883
 run_elisheba: MQTT_USER = elisheba
 run_elisheba: MQTT_PASS = 123mqtt

diff --git a/bin/elisheba/src/main.rs b/bin/elisheba/src/main.rs
@@ -10,7 +10,7 @@ use transport::state::StateUpdate;
 use transport::{connect_mqtt, Topic};
 
 use futures_util::StreamExt;
-use log::{error, info, trace};
+use log::{debug, error, info, trace};
 use paho_mqtt::{AsyncClient as MqClient, MessageBuilder, QOS_1};
 use tokio::signal::unix::{signal, SignalKind};
 use tokio::{task, time};

diff --git a/lib/sonoff/src/client.rs b/lib/sonoff/src/client.rs
@@ -220,18 +220,26 @@ impl Client {
         let host = host.ok_or(Error::MissingHostname)?;
         let host = host.to_string();
 
+        debug!("got host {host}");
+
         let mut manager = self.manager.lock().await;
 
         let result = if let Some(device) = manager.devices.get_mut(&host) {
+            debug!("host exists {host}");
+
             if let Some(ipv4) = ipv4 {
+                debug!("updating ipv4 {ipv4}");
                 device.addr.set_ip(ipv4);
             }
 
             if let Some(port) = port {
+                debug!("updating port {port}");
                 device.addr.set_port(port);
             }
 
             if let Some(mut info) = info {
+                debug!("updating meta {info:?}");
+
                 let key = self
                     .keys
                     .get(&device.id)
@@ -243,6 +251,8 @@ impl Client {
 
             HandleResult::UpdatedDevice(host, device.clone())
         } else {
+            debug!("new host {host}");
+
             let service = service.ok_or(Error::MissingService)?;
             if service != "_ewelink._tcp.local" {
                 return Ok(HandleResult::Ignored("Unknown service"));

diff --git a/lib/sonoff/src/client/discovery.rs b/lib/sonoff/src/client/discovery.rs
@@ -48,8 +48,23 @@ impl Client {
                             break;
                         }
 
-                        info!("{} left to discover", ids.len());
-                        info!("{} left to resolve", hosts.len());
+                        info!(
+                            "{} left to discover: [{}]",
+                            ids.len(),
+                            ids.iter()
+                                .map(|s| s.as_str())
+                                .collect::<Vec<_>>()
+                                .join(", ")
+                        );
+                        info!(
+                            "{} left to resolve: [{}]",
+                            hosts.len(),
+                            hosts
+                                .iter()
+                                .map(|s| s.as_str())
+                                .collect::<Vec<_>>()
+                                .join(", ")
+                        );
 
                         last_update = Instant::now();
                     }
@@ -60,10 +75,18 @@ impl Client {
                     if last_update.elapsed().as_secs() > 2 {
                         for host in hosts.iter() {
                             debug!("query device again: {}", host);
+
                             let query = create_query_packet(&host);
                             socket.send_to(&query, MDNS_ADDR).await?;
                         }
 
+                        if !ids.is_empty() {
+                            debug!("discover devices again");
+
+                            let discover = create_discovery_packet(SERVICE);
+                            socket.send_to(&discover, MDNS_ADDR).await?;
+                        }
+
                         last_update = Instant::now();
                     }
                 }