Merge pull request iotaledger#398 from iotaledger/feat/unsynced-nodes…

…-getter

feat: add method to get unsynced nodes

iota-client/src/builder.rs

@@ -205,6 +205,7 @@ impl ClientBuilder {
             let sync_ = sync.clone();
             let network_info_ = network_info.clone();
             let (sync_kill_sender, sync_kill_receiver) = channel(1);
+            let nodes = nodes.clone();
             let runtime = std::thread::spawn(move || {
                 let runtime = Runtime::new().unwrap();
                 runtime.block_on(Client::sync_nodes(&sync_, &nodes, &network_info_));
@@ -222,7 +223,7 @@ impl ClientBuilder {
             .expect("failed to init node syncing process");
             (Some(runtime), sync, Some(sync_kill_sender), network_info)
         } else {
-            (None, Arc::new(RwLock::new(nodes)), None, network_info)
+            (None, Arc::new(RwLock::new(nodes.clone())), None, network_info)
         };
 
         let mut api_timeout = HashMap::new();
@@ -271,6 +272,7 @@ impl ClientBuilder {
 
         let client = Client {
             runtime,
+            nodes,
             sync,
             sync_kill_sender: sync_kill_sender.map(Arc::new),
             #[cfg(feature = "mqtt")]

iota-client/src/client.rs

@@ -357,6 +357,8 @@ impl HttpClient {
 pub struct Client {
     #[allow(dead_code)]
     pub(crate) runtime: Option<Runtime>,
+    /// Node pool.
+    pub(crate) nodes: HashSet<Url>,
     /// Node pool of synced IOTA nodes
     pub(crate) sync: Arc<RwLock<HashSet<Url>>>,
     /// Flag to stop the node syncing
@@ -548,6 +550,12 @@ impl Client {
         self.network_info.read().await.local_pow
     }
 
+    /// returns the unsynced nodes.
+    pub async fn unsynced_nodes(&self) -> HashSet<&Url> {
+        let synced = self.sync.read().await;
+        self.nodes.iter().filter(|node| !synced.contains(node)).collect()
+    }
+
     ///////////////////////////////////////////////////////////////////////
     // MQTT API
     //////////////////////////////////////////////////////////////////////