From c96aec520dbf18f11455001f1db9b4f068c10528 Mon Sep 17 00:00:00 2001
From: Alex Auvolat <alex@adnab.me>
Date: Thu, 9 Mar 2023 16:49:56 +0100
Subject: persist gossip state to disk

---
 src/main.rs | 39 +++++++++++++++++++++++++++++++++++++--
 1 file changed, 37 insertions(+), 2 deletions(-)

(limited to 'src/main.rs')

diff --git a/src/main.rs b/src/main.rs
index 7b95d4d..04e655c 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -21,6 +21,8 @@ const TIMEOUT: Duration = Duration::from_secs(300);
 /// Interval at which to gossip last_seen info
 const GOSSIP_INTERVAL: Duration = Duration::from_secs(300);
 
+const PERSIST_INTERVAL: Duration = Duration::from_secs(600);
+
 const LAN_BROADCAST_INTERVAL: Duration = Duration::from_secs(60);
 
 const IGD_INTERVAL: Duration = Duration::from_secs(60);
@@ -37,6 +39,8 @@ struct Config {
     /// The secret to use to authenticate nodes between them
     gossip_secret: Option<String>,
     gossip_secret_file: Option<String>,
+    /// The file where to persist known peer addresses
+    persist_file: Option<String>,
 
     /// Enable LAN discovery
     #[serde(default)]
@@ -187,6 +191,14 @@ impl Daemon {
         let (our_pubkey, listen_port, _peers) = wg_dump(&config)?;
         let socket = UdpSocket::bind(SocketAddr::new("0.0.0.0".parse()?, config.gossip_port))?;
         socket.set_broadcast(true)?;
+
+        let gossip = config
+            .persist_file
+            .as_ref()
+            .and_then(|x| std::fs::read(x).ok())
+            .and_then(|x| bincode::deserialize(&x).ok())
+            .unwrap_or_default();
+
         Ok(Daemon {
             config,
             gossip_key,
@@ -195,7 +207,7 @@ impl Daemon {
             socket,
             state: Mutex::new(State {
                 peers: HashMap::new(),
-                gossip: HashMap::new(),
+                gossip,
             }),
         })
     }
@@ -216,6 +228,7 @@ impl Daemon {
         thread::scope(|s| {
             s.spawn(|| self.wg_loop());
             s.spawn(|| self.recv_loop());
+            s.spawn(|| self.persist_loop());
             s.spawn(|| self.lan_broadcast_loop());
             s.spawn(|| self.igd_loop());
         });
@@ -335,6 +348,23 @@ impl Daemon {
         Ok((src, gossip))
     }
 
+    fn persist_loop(&self) {
+        if let Some(file) = &self.config.persist_file {
+            loop {
+                if let Err(e) = self.persist_state(file) {
+                    error!("Could not write persistent state to disk: {}", e);
+                }
+                std::thread::sleep(PERSIST_INTERVAL);
+            }
+        }
+    }
+
+    fn persist_state(&self, file: &str) -> Result<()> {
+        let data = bincode::serialize(&self.state.lock().unwrap().gossip)?;
+        std::fs::write(file, &data)?;
+        Ok(())
+    }
+
     fn lan_broadcast_loop(&self) {
         if self.config.lan_discovery {
             loop {
@@ -603,7 +633,12 @@ impl State {
             if !endpoints.is_empty() {
                 let endpoint = endpoints[i % endpoints.len()].0;
 
-                if self.peers.get(&peer_cfg.pubkey).map(|x| x.endpoint == Some(endpoint)).unwrap_or(false) {
+                if self
+                    .peers
+                    .get(&peer_cfg.pubkey)
+                    .map(|x| x.endpoint == Some(endpoint))
+                    .unwrap_or(false)
+                {
                     // Skip if we are already using that endpoint
                     continue;
                 }
-- 
cgit v1.2.3