Add initial persistance to Maker & Taker data stores

nobu-maeda · Jan 2, 2024 · cd462f4 · cd462f4
1 parent bcd694a
commit cd462f4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/src/maker/data.rs b/src/maker/data.rs
@@ -85,13 +85,14 @@ impl MakerActorData {
         let store = Arc::new(RwLock::new(store));
         let (persist_tx, task_handle) =
             Self::setup_persistance(store.clone(), trade_uuid, &dir_path);
-
-        Self {
+        let data = Self {
             persist_tx,
             trade_uuid,
             store,
             task_handle,
-        }
+        };
+        data.queue_persistance();
+        data
     }
 
     pub(crate) async fn restore(data_path: impl AsRef<Path>) -> Result<(Uuid, Self), N3xbError> {

diff --git a/src/taker/data.rs b/src/taker/data.rs
@@ -70,13 +70,14 @@ impl TakerActorData {
         let store = Arc::new(RwLock::new(store));
         let (persist_tx, task_handle) =
             Self::setup_persistance(store.clone(), trade_uuid, &dir_path);
-
-        Self {
+        let data = Self {
             persist_tx,
             trade_uuid,
             store,
             task_handle,
-        }
+        };
+        data.queue_persistance();
+        data
     }
 
     pub(crate) async fn restore(data_path: impl AsRef<Path>) -> Result<(Uuid, Self), N3xbError> {