feat: election timer

Author: jmininger

Cargo.lock

@@ -10,7 +10,9 @@ axum = { version = "0.6.20", features = ["macros"] }
 axum-macros = "0.4.1"
 clap = "4.4.2"
 color-eyre = "0.6.2"
+rand = "0.8.5"
 reqwest = { version = "0.11.20", features = ["serde_json", "json"] }
 serde = { version = "1.0.188", features = ["serde_derive"] }
 serde_json = "1.0.105"
 tokio = { version = "1.32.0", features = ["full"] }
+tracing = "0.1.40"

Cargo.toml

@@ -0,0 +1,55 @@
+use color_eyre::Result;
+use rand::Rng;
+use tokio::{
+    net::{
+        unix::SocketAddr,
+        TcpListener,
+        TcpSocket,
+        ToSocketAddrs,
+    },
+    select,
+    sync::{
+        mpsc,
+        oneshot,
+    },
+};
+use tracing::warn;
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    Ok(())
+}
+
+async fn start_network(addr: impl ToSocketAddrs) -> Result<()> {
+    let listener = TcpListener::bind(addr).await?;
+
+    while let Ok((sock, addr)) = listener.accept().await {
+        todo!()
+    }
+
+    todo!()
+}
+
+async fn election_timeout(
+    mut msg_alert: mpsc::Receiver<()>,
+    election_trigger: oneshot::Sender<()>,
+) {
+    let mut rng = rand::thread_rng();
+    loop {
+        let rand_timeout = rng.gen_range(150..300);
+        select! {
+            _ = msg_alert.recv() => (),
+            _ = tokio::time::sleep(std::time::Duration::from_millis(rand_timeout)) => break,
+        }
+    }
+    if let Err(_) = election_trigger.send(()) {
+        warn!("Election timeout triggered but failed to send warning via oneshot");
+    }
+}
+
+/*
+ * Who fires the first ever message?
+ * - Broadcast (but each has a retry for failures)
+ * Streams are only initiated on the first dial
+ *
+ */