Bugfixes

Author: DogLooksGood

core/src/types/transport_params.rs

@@ -218,6 +218,7 @@ pub struct JoinParams {
     pub game_addr: String,
     pub amount: u64,
     pub access_version: u64,
+    pub settle_version: u64,
     pub position: u16,
 }
 

transactor-components/src/synchronizer.rs

@@ -39,7 +39,7 @@ async fn maybe_send_sync(
 
     // Drop duplicated updates
     if access_version <= prev_access_version {
-        println!("Drop this update, {} <= prev {}", access_version, prev_access_version);
+        info!("{} Drop update, this version {} < previous version {}", env.log_prefix, access_version, prev_access_version);
         return (prev_access_version, None);
     }
 
@@ -161,6 +161,24 @@ impl Component<PipelinePorts, GameSynchronizerContext> for GameSynchronizer {
             }
         };
 
+
+        let account = ctx.transport.get_game_account(&ctx.game_addr).await;
+
+        if let Ok(Some(game_account)) = account {
+            let (new_access_version, close_reason) = maybe_send_sync(
+                prev_access_version,
+                game_account,
+                &mut ports,
+                &env
+            ).await;
+
+            if close_reason.is_some() {
+                error!("{} Failed on the initial query, but the subscription is still available", env.log_prefix);
+            } else {
+                prev_access_version = new_access_version;
+            }
+        }
+
         loop {
             select! {
                 event_frame = ports.recv() => {

transport/src/solana/types/params.rs

@@ -170,12 +170,14 @@ impl From<JoinParams> for IxJoinParams {
         let JoinParams {
             amount,
             access_version,
+            settle_version,
             position,
             ..
         } = value;
         Self {
             amount,
             access_version,
+            settle_version,
             position,
         }
     }