X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Ftypes.rs;h=f38a3760b316897b78729d4e96aa865c122b8969;hb=529c6666501812eb7b23778f02b6a61940634c88;hp=f530bd41a112e41e082079e20fce4f19295c3877;hpb=ae2225c925e537bc8f701886385d9450fe6a94a1;p=rapid-gossip-sync-server

diff --git a/src/types.rs b/src/types.rs
index f530bd4..f38a376 100644
--- a/src/types.rs
+++ b/src/types.rs
@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
 use lightning::sign::KeysManager;
-use lightning::ln::msgs::{ChannelAnnouncement, ChannelUpdate};
+use lightning::ln::msgs::{ChannelAnnouncement, ChannelUpdate, NodeAnnouncement};
 use lightning::ln::peer_handler::{ErroringMessageHandler, IgnoringMessageHandler, PeerManager};
 use lightning::util::logger::{Logger, Record};
 use crate::config;
@@ -14,8 +14,10 @@ pub(crate) type GossipPeerManager<L> = Arc<PeerManager<lightning_net_tokio::Sock
 
 #[derive(Debug)]
 pub(crate) enum GossipMessage {
-	ChannelAnnouncement(ChannelAnnouncement),
-	ChannelUpdate(ChannelUpdate),
+	NodeAnnouncement(NodeAnnouncement, Option<u32>),
+	// the second element is an optional override for the seen value
+	ChannelAnnouncement(ChannelAnnouncement, Option<u32>),
+	ChannelUpdate(ChannelUpdate, Option<u32>),
 }
 
 #[derive(Clone, Copy)]
@@ -28,7 +30,7 @@ impl RGSSLogger {
 }
 
 impl Logger for RGSSLogger {
-	fn log(&self, record: &Record) {
+	fn log(&self, record: Record) {
 		let threshold = config::log_level();
 		if record.level < threshold {
 			return;
@@ -83,7 +85,7 @@ pub mod tests {
 	}
 
 	impl Logger for TestLogger {
-		fn log(&self, record: &Record) {
+		fn log(&self, record: Record) {
 			*self.lines.lock().unwrap().entry((record.module_path.to_string(), format!("{}", record.args))).or_insert(0) += 1;
 			println!("{:<5} {} [{} : {}, {}] {}", record.level.to_string(), self.id, record.module_path, record.file, record.line, record.args);
 		}