refactor(l1): discovery service

cmd/ethrex/ethrex.rs

@@ -264,18 +264,15 @@ async fn main() {
             let block_producer_engine = ethrex_dev::block_producer::start_block_producer(url, authrpc_jwtsecret.into(), head_block_hash, max_tries, 1000, ethrex_core::Address::default());
             tracker.spawn(block_producer_engine);
         } else {
-            let networking = ethrex_net::start_network(
+            ethrex_net::start_network(
                 local_p2p_node,
                 tracker.clone(),
-                udp_socket_addr,
-                tcp_socket_addr,
                 bootnodes,
                 signer,
                 peer_table.clone(),
                 store,
             )
-            .into_future();
-            tracker.spawn(networking);
+            .await.expect("Network starts");
             tracker.spawn(ethrex_net::periodically_show_peer_stats(peer_table));
         }
     }

crates/networking/p2p/discv4/helpers.rs

@@ -0,0 +1,29 @@
+use std::time::{Duration, SystemTime, UNIX_EPOCH};
+
+pub fn get_msg_expiration_from_seconds(seconds: u64) -> u64 {
+    (SystemTime::now() + Duration::from_secs(seconds))
+        .duration_since(UNIX_EPOCH)
+        .unwrap_or_default()
+        .as_secs()
+}
+
+pub fn is_msg_expired(expiration: u64) -> bool {
+    // this cast to a signed integer is needed as the rlp decoder doesn't take into account the sign
+    // otherwise if a msg contains a negative expiration, it would pass since as it would wrap around the u64.
+    (expiration as i64) < (current_unix_time() as i64)
+}
+
+pub fn elapsed_time_since(unix_timestamp: u64) -> u64 {
+    let time = SystemTime::UNIX_EPOCH + std::time::Duration::from_secs(unix_timestamp);
+    SystemTime::now()
+        .duration_since(time)
+        .unwrap_or_default()
+        .as_secs()
+}
+
+pub fn current_unix_time() -> u64 {
+    SystemTime::now()
+        .duration_since(UNIX_EPOCH)
+        .unwrap_or_default()
+        .as_secs()
+}