Upgrade to LDK 0.0.116-alpha1

[rapid-gossip-sync-server] / src / tracking.rs

diff --git a/src/tracking.rs b/src/tracking.rs
index ebe04134a91d43e42d284459404a83a5898008d6..8d2668fcaf08ffde4128fcb6a68bfb8987e26c76 100644 (file)
--- a/src/tracking.rs
+++ b/src/tracking.rs
@@ -11,7 +11,7 @@ use lightning::ln::peer_handler::{
        ErroringMessageHandler, IgnoringMessageHandler, MessageHandler, PeerManager,
 };
 use lightning::routing::gossip::NetworkGraph;
-use lightning::chain::keysinterface::KeysManager;
+use lightning::sign::KeysManager;
 use tokio::sync::mpsc;
 
 use crate::{config, TestLogger};
@@ -39,13 +39,13 @@ pub(crate) async fn download_gossip(persistence_sender: mpsc::Sender<GossipMessa
                chan_handler: ErroringMessageHandler::new(),
                route_handler: Arc::clone(&router),
                onion_message_handler: IgnoringMessageHandler {},
+               custom_message_handler: IgnoringMessageHandler {},
        };
        let peer_handler = Arc::new(PeerManager::new(
                message_handler,
                0xdeadbeef,
                &random_data,
                TestLogger::new(),
-               IgnoringMessageHandler {},
                keys_manager,
        ));
        router.set_pm(Arc::clone(&peer_handler));
@@ -161,9 +161,8 @@ async fn connect_peer(current_peer: (PublicKey, SocketAddr), peer_manager: Gossi
                                        current_peer.1,
                                ).await {
                                        disconnection_future.await;
-                               } else {
-                                       tokio::time::sleep(Duration::from_secs(10)).await;
                                }
+                               tokio::time::sleep(Duration::from_secs(10)).await;
                        }
                });
                true