Test storing node addresses.

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

diff --git a/src/types.rs b/src/types.rs
index 93527a45b837c7368d9bc2842167323ff4c2e397..f38a3760b316897b78729d4e96aa865c122b8969 100644 (file)
--- 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,6 +14,7 @@ pub(crate) type GossipPeerManager<L> = Arc<PeerManager<lightning_net_tokio::Sock
 
 #[derive(Debug)]
 pub(crate) enum GossipMessage {
+       NodeAnnouncement(NodeAnnouncement, Option<u32>),
        // the second element is an optional override for the seen value
        ChannelAnnouncement(ChannelAnnouncement, Option<u32>),
        ChannelUpdate(ChannelUpdate, Option<u32>),
@@ -29,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;
@@ -84,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);
                }