Signed-off-by: Awiteb <a@4rs.nl>

@@ -94,0 +144,4 @@
+    async fn disconnect_inactive_users(&self) {
+        let now = Utc::now().timestamp();
+        let is_inactive =
+            |u: &SocketUserData| u.pinged_at > u.ponged_at && now - u.pinged_at.timestamp() >= 5;

@@ -94,0 +153,4 @@
+                log::info!("Disconnected from {}, inactive", u.public_key);
+                u.sender.close_channel()
+            });
+        self.write().await.retain(|_, u| !is_inactive(u));

@@ -0,0 +23,4 @@
+
+/// Client websocket event
+#[derive(Deserialize, Clone, Debug)]
+pub struct ClientEvent {

@@ -0,0 +92,4 @@
+    depot: &Depot,
+) -> Result<(), StatusError> {
+    let nonce_cache = depot.nonce_cache();
+    let nonce_limit = *depot.nonce_cache_size();

@@ -0,0 +117,4 @@
+    let (user_ws_sender, mut user_ws_receiver) = ws.split();
+
+    let (sender, receiver) = mpsc::unbounded();
+    let sender = Arc::new(sender);

@@ -0,0 +206,4 @@
+        /// Seconds to wait for pongs, before disconnecting the user
+        const WAIT_FOR_PONGS_SECS: u32 = 10;
+        /// Seconds to sleep between pings (10 minutes)
+        const SLEEP_SECS: u32 = 60 * 10;

@@ -94,0 +129,4 @@
+        let now = Utc::now();
+        self.write().await.par_iter_mut().for_each(|(_, u)| {
+            u.pinged_at = now;
+            let _ = u.sender.unbounded_send(Ok(Message::from(

@@ -0,0 +43,4 @@
+impl ClientEventType {
+    /// Returns event data as json bytes
+    pub fn data(&self) -> Vec<u8> {
+        serde_json::to_vec(&serde_json::to_value(self).expect("can't fail")["data"])

@@ -0,0 +32,4 @@
+/// The cache will remove first 10% nonces if the cache limit is reached.
+pub struct NonceCache {
+    /// The nonce cache hashmap, the key is the nonce and the value is the time
+    cache: HashMap<[u8; 16], i64>,