fix: Convert snapshot version to number in JS

kindredgroup · Sep 13, 2023 · c2f0166 · c2f0166
1 parent 7de322d
commit c2f0166
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/cohort_banking_initiator_js/src/banking-app.ts b/cohort_banking_initiator_js/src/banking-app.ts
@@ -192,7 +192,7 @@ export class BankingApp {
             }
 
             // Quickly grab the snapshot to check whether safepoint condition is satisfied. Any row can be used for that.
-            const snapshot = result.rows[0].snapshot
+            const snapshot = Number(result.rows[0].snapshot)
             if (snapshot < request.safepoint) {
                 // safepoint condition
                 return 2

diff --git a/cohort_banking_replicator_js/src/database.ts b/cohort_banking_replicator_js/src/database.ts
@@ -50,7 +50,8 @@ export class Database {
 
             logger.warn("Database.getSnapshot(): %d", version)
 
-            return version
+            return Number(version)
+
         } finally {
             cnn?.release()
             const metric = new MetricsSet()

diff --git a/packages/talos_cohort_replicator/src/services/statemap_queue_service.rs b/packages/talos_cohort_replicator/src/services/statemap_queue_service.rs
@@ -49,7 +49,7 @@ where
     let mut statemap_installer_queue = StatemapInstallerQueue::default();
 
     //Gets snapshot initial version from db.
-    statemap_installer_queue.update_snapshot(snapshot_api.get_snapshot().await.unwrap_or(0));
+    statemap_installer_queue.update_snapshot(snapshot_api.get_snapshot().await.unwrap());
 
     // let mut last_item_send_for_install = 0;