From 8f1fe118efdfcdbaeb658e1250bf4a6510a28971 Mon Sep 17 00:00:00 2001
From: boqiu <82121246@qq.com>
Date: Wed, 23 Oct 2024 19:00:47 +0800
Subject: [PATCH] handle NewFile in sync servic to write in db

---
 node/sync/src/auto_sync/manager.rs | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/node/sync/src/auto_sync/manager.rs b/node/sync/src/auto_sync/manager.rs
index 68e3da9..51a3da0 100644
--- a/node/sync/src/auto_sync/manager.rs
+++ b/node/sync/src/auto_sync/manager.rs
@@ -53,8 +53,15 @@ impl AutoSyncManager {
         let catched_up = Arc::new(AtomicBool::new(false));
 
         // handle new file
+        let sync_store_cloned = sync_store.clone();
         executor.spawn(
-            Self::handle_new_file(new_file_recv, sync_store.clone()),
+            async move {
+                while let Some(tx_seq) = new_file_recv.recv().await {
+                    if let Err(err) = sync_store_cloned.insert(tx_seq, Queue::Ready).await {
+                        warn!(?err, %tx_seq, "Failed to insert new file to ready queue");
+                    }
+                }
+            },
             "auto_sync_handle_new_file",
         );