From d1866a4fda76ffe4c8e88b7efee346c0ebdfd9bc Mon Sep 17 00:00:00 2001
From: ntr <ntr@smokestack.io>
Date: Fri, 18 Oct 2019 17:21:01 +1100
Subject: [PATCH] only send chat clear after a msg

---
 server/src/events.rs | 8 ++++++++
 server/src/rpc.rs    | 7 -------
 2 files changed, 8 insertions(+), 7 deletions(-)

diff --git a/server/src/events.rs b/server/src/events.rs
index df53a60f..294cfb03 100644
--- a/server/src/events.rs
+++ b/server/src/events.rs
@@ -1,4 +1,6 @@
 use std::collections::{HashMap, HashSet};
+use std::thread::{spawn, sleep};
+use std::time;
 
 // Db Commons
 use uuid::Uuid;
@@ -314,6 +316,12 @@ impl Events {
                     }
 
                     c.chat = Some((instance, msg));
+
+                    let events_tx = self.tx.clone();
+                    spawn(move || {
+                        sleep(time::Duration::from_secs(3));
+                        events_tx.send(Event::ChatClear(id, instance)).unwrap();
+                    });
                 }
 
                 // now collect all listeners of this instance
diff --git a/server/src/rpc.rs b/server/src/rpc.rs
index 2dfb9589..3194c1d4 100644
--- a/server/src/rpc.rs
+++ b/server/src/rpc.rs
@@ -179,13 +179,6 @@ impl Connection {
                             return Err(err_msg("invalid chat index"));
                         }
 
-                        let events_tx = self.events.clone();
-                        let id = self.id;
-                        spawn(move || {
-                            sleep(time::Duration::from_secs(3));
-                            events_tx.send(Event::ChatClear(id, instance_id)).unwrap();
-                        });
-
                         Ok(RpcMessage::Processing(()))
                     },
                     _ => {