feat: sleep in between introductions

config/default.toml

@@ -41,6 +41,7 @@ wait_before_next_api_call = 2 # in seconds
 #nodes = ["http://localhost:7000"]
 public_url = "http://localhost:7000"
 nodes = []
+wait=1
 
 [repository]
 root = "/tmp/starchart.forgeflux.org"

src/introduce.rs

@@ -18,6 +18,7 @@
 use std::collections::HashSet;
 use std::future::Future;
 
+use actix::clock::sleep;
 use actix_web::web;
 use actix_web::{HttpResponse, Responder};
 use actix_web_codegen_const_routes::get;
@@ -150,7 +151,7 @@ impl Ctx {
                 let shutdown = match rx.try_recv() {
                     // The channel is currently empty
                     Ok(x) => {
-                        log::info!("Received signal from tx");
+                        log::info!("[introducer] Received signal {x}");
                         x
                     }
                     Err(TryRecvError::Empty) => false,
@@ -164,6 +165,11 @@ impl Ctx {
                 }
 
                 let _ = ctx.bootstrap(&db).await;
+                log::info!(
+                    "Waiting for {} until re-introducing",
+                    ctx.settings.introducer.wait
+                );
+                tokio::time::sleep(std::time::Duration::new(ctx.settings.introducer.wait, 0)).await;
             }
         };
 

src/settings.rs

@@ -134,6 +134,7 @@ pub struct Crawler {
 pub struct Introducer {
     pub nodes: Vec<Url>,
     pub public_url: Url,
+    pub wait: u64,
 }
 
 #[derive(Debug, Validate, Clone, PartialEq, Eq, Serialize, Deserialize)]