From ddca71fc26bb25f77a650056e5ee44ca108dbcd2 Mon Sep 17 00:00:00 2001
From: darkfi <darkfi@darkfi>
Date: Fri, 9 Aug 2024 08:48:26 +0200
Subject: [PATCH] wallet: chatview, flush db after every insert

---
 bin/darkwallet/src/ui/chatview.rs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/bin/darkwallet/src/ui/chatview.rs b/bin/darkwallet/src/ui/chatview.rs
index ed10a4ce9..9d07b2459 100644
--- a/bin/darkwallet/src/ui/chatview.rs
+++ b/bin/darkwallet/src/ui/chatview.rs
@@ -636,7 +636,7 @@ impl ChatView {
         }
     }
 
-    fn add_line_to_db(&self,
+    async fn add_line_to_db(&self,
         timest: Timestamp,
         message_id: &MessageId,
         nick: &str,
@@ -660,6 +660,7 @@ impl ChatView {
         msg.encode(&mut val).unwrap();
 
         self.tree.insert(&key, val).unwrap();
+        let _ = self.tree.flush_async().await;
         true
     }
     async fn handle_insert_line(
@@ -671,7 +672,7 @@ impl ChatView {
     ) {
         debug!(target: "ui::chatview", "handle_insert_line({timest}, {message_id:?}, {nick}, {text})");
 
-        if !self.add_line_to_db(timest, &message_id, &nick, &text) {
+        if !self.add_line_to_db(timest, &message_id, &nick, &text).await {
             // Already exists so bail
             debug!(target: "ui::chatview", "duplicate msg so bailing");
             return