wallet: chatview add_line_to_db() called by handle_insert_line()

bin/darkwallet/insert_line.py

@@ -14,10 +14,10 @@ def send(timest, nick, msg):
     api.call_method(node_id, "insert_line", arg_data)
 
 #for i in range(28):
-for i in range(27):
-    send(1722944640000 + i, "hhi12", "hello 123")
-    time.sleep(0.1)
-time.sleep(0.5)
-send(1722944641015, "john", "hpqjyzzxxdhio")
-time.sleep(1)
+#for i in range(27):
+#    send(1722944640000 + i, "hhi12", "hello 123")
+#    time.sleep(0.1)
+#time.sleep(0.5)
+#send(1722944641015, "john", "hpqjyzzxxdhio")
+#time.sleep(1)
 send(1722944642015, "clr", "hello1234ppjjh")

bin/darkwallet/src/ui/chatview.rs

@@ -628,6 +628,32 @@ impl ChatView {
         }
     }
 
+    fn add_line_to_db(&self,
+        timest: Timestamp,
+        message_id: &MessageId,
+        nick: &str,
+        text: &str,
+    ) -> bool {
+        let timest = timest.to_be_bytes();
+        assert_eq!(timest.len(), 8);
+        let mut key = [0u8; 8 + 32];
+        key[..8].clone_from_slice(&timest);
+        key[8..].clone_from_slice(message_id);
+
+        // When does this return Err?
+        let contains_key = self.tree.contains_key(&key);
+        if contains_key.is_err() || contains_key.unwrap() {
+            // Already exists
+            return false
+        }
+
+        let msg = ChatMsg { nick: nick.to_string(), text: text.to_string() };
+        let mut val = vec![];
+        msg.encode(&mut val).unwrap();
+
+        self.tree.insert(&key, val).unwrap();
+        true
+    }
     async fn handle_insert_line(
         &self,
         timest: Timestamp,
@@ -637,6 +663,12 @@ 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) {
+            // Already exists so bail
+            debug!(target: "ui::chatview", "duplicate msg so bailing");
+            return
+        }
+
         let chatmsg = ChatMsg { nick, text };
 
         let dt = Local.timestamp_opt(timest as i64, 0).unwrap();