Synchronize with L1 Slot Start Time

Node/src/ethereum_l1/slot_clock.rs

@@ -35,7 +35,7 @@ impl SlotClock {
         self.slots_per_epoch
     }
 
-    fn duration_to_next_slot(&self) -> Result<Duration, Error> {
+    pub fn duration_to_next_slot(&self) -> Result<Duration, Error> {
         let now = SystemTime::now().duration_since(UNIX_EPOCH)?;
         self.duration_to_next_slot_from(now)
     }

Node/src/node/mod.rs

@@ -21,6 +21,7 @@ use tokio::sync::{
     mpsc::{Receiver, Sender},
     Mutex,
 };
+use tokio::time::{sleep, Duration};
 use tracing::info;
 
 pub mod block_proposed_receiver;
@@ -240,9 +241,11 @@ impl Node {
     }
 
     async fn preconfirmation_loop(&mut self) {
-        // TODO syncronize with slot clock
-        let mut interval =
-            tokio::time::interval(std::time::Duration::from_secs(self.l2_slot_duration_sec));
+        // Synchronize with L1 Slot Start Time
+        let duration_to_next_slot = self.ethereum_l1.slot_clock.duration_to_next_slot().unwrap();
+        sleep(duration_to_next_slot).await;
+        // start preconfirmation loop
+        let mut interval = tokio::time::interval(Duration::from_secs(self.l2_slot_duration_sec));
         loop {
             interval.tick().await;