fix(node/web): state machine time drifting from actual time

Author: binier

.github/workflows/ci.yaml

@@ -116,7 +116,7 @@ jobs:
          rustup default nightly
          rustup component add rustfmt rust-src
          rustup target add wasm32-unknown-unknown
-         cargo install -f wasm-bindgen-cli --version 0.2.93
+         cargo install -f wasm-bindgen-cli --version 0.2.95
 
      - name: Setup Rust Cache
        uses: Swatinem/rust-cache@v2

Cargo.lock

@@ -48,7 +48,7 @@ poly-commitment = {git = "https://github.com/openmina/proof-systems", rev = "2fd
 libp2p = { git = "https://github.com/openmina/rust-libp2p", rev = "5c44c7d9", default-features = false }
 vrf = { path = "vrf" }
 openmina-node-account = { path = "node/account" }
-redux = { git = "https://github.com/openmina/redux-rs.git", rev = "75d4d1d9", features = ["serde"] }
+redux = { git = "https://github.com/openmina/redux-rs.git", rev = "bf0726e5", features = ["serde"] }
 serde = "1.0.190"
 serde_json = "1.0.107"
 serde_with = { version = "3.7.0", features = ["hex"] }

Cargo.toml

@@ -44,6 +44,7 @@ export class WebNodeService {
         tap((webnode: any) => {
           console.log('----------------WEBNODE----------------');
           console.log(webnode);
+          (window as any)["webnode"] = webnode;
           this.webnode$.next(webnode);
         }),
         switchMap(() => this.webnode$.asObservable()),

frontend/src/app/core/services/web-node.service.ts

@@ -38,6 +38,7 @@ pub enum SnarkPoolAction {
     },
     #[action_event(level = trace)]
     P2pSendAll,
+    #[action_event(level = trace)]
     P2pSend {
         peer_id: PeerId,
     },

node/src/snark_pool/snark_pool_actions.rs

@@ -207,10 +207,6 @@ impl NodeBuilder {
             anyhow::anyhow!("transaction verifier index not set on the node builder!")
         })?;
 
-        let initial_time = self
-            .custom_initial_time
-            .unwrap_or_else(redux::Timestamp::global_now);
-
         let transition_frontier = TransitionFrontierConfig::new(self.genesis_config);
 
         let protocol_constants = transition_frontier.genesis.protocol_constants()?;
@@ -235,9 +231,7 @@ impl NodeBuilder {
                 enabled_channels: ChannelId::iter_all().collect(),
                 peer_discovery: !self.p2p_no_discovery,
                 meshsub: P2pMeshsubConfig {
-                    initial_time: initial_time
-                        .checked_sub(redux::Timestamp::ZERO)
-                        .unwrap_or_default(),
+                    initial_time: Duration::ZERO,
                     ..Default::default()
                 },
                 timeouts: P2pTimeouts::default(),
@@ -268,6 +262,10 @@ impl NodeBuilder {
         }
 
         let service = service.build()?;
+
+        let initial_time = self
+            .custom_initial_time
+            .unwrap_or_else(redux::Timestamp::global_now);
         let state = node::State::new(node_config, &consensus_consts, initial_time);
 
         Ok(Node::new(self.rng_seed, state, service, None))