X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fdownloader.rs;h=ac11ec7091739f62290274c9637af2910b3484e4;hb=160a68310fcfa9f9428de20387470925d08fa6c6;hp=9256100b581748100147d523fbe9f1a9ae0cee0b;hpb=56a58f214905c8329fb768da6a969d43d0ad7ebe;p=rapid-gossip-sync-server diff --git a/src/downloader.rs b/src/downloader.rs index 9256100..ac11ec7 100644 --- a/src/downloader.rs +++ b/src/downloader.rs @@ -1,10 +1,10 @@ use std::sync::{Arc, RwLock}; use bitcoin::secp256k1::PublicKey; +use lightning::events::{MessageSendEvent, MessageSendEventsProvider}; use lightning::ln::features::{InitFeatures, NodeFeatures}; use lightning::ln::msgs::{ChannelAnnouncement, ChannelUpdate, Init, LightningError, NodeAnnouncement, QueryChannelRange, QueryShortChannelIds, ReplyChannelRange, ReplyShortChannelIdsEnd, RoutingMessageHandler}; use lightning::routing::gossip::{NetworkGraph, NodeId, P2PGossipSync}; -use lightning::util::events::{MessageSendEvent, MessageSendEventsProvider}; use tokio::sync::mpsc; use tokio::sync::mpsc::error::TrySendError; @@ -88,7 +88,7 @@ impl MessageSendEventsProvider for GossipRouter { let gossip_evs = self.outbound_gossiper.get_and_clear_pending_msg_events(); for ev in gossip_evs { match ev { - MessageSendEvent::BroadcastChannelAnnouncement { msg, update_msg: None } => { + MessageSendEvent::BroadcastChannelAnnouncement { msg, .. } => { self.new_channel_announcement(msg); }, MessageSendEvent::BroadcastNodeAnnouncement { .. } => {},