restart websocket at first missing keepalive

whisperfish · Nov 19, 2024 · e73644b · e73644b
1 parent 9502d4c
commit e73644b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/websocket/mod.rs b/src/websocket/mod.rs
@@ -201,7 +201,7 @@ impl SignalWebSocketProcess {
             futures::select! {
                 _ = ka_interval.tick().fuse() => {
                     use prost::Message;
-                    if self.outgoing_keep_alive_set.len() > 6 {
+                    if self.outgoing_keep_alive_set.len() > 0 {
                         tracing::warn!("Websocket will be closed due to failed keepalives.");
                         if let Err(e) = self.ws.close(reqwest_websocket::CloseCode::Away, None).await {
                             tracing::debug!("Could not close WebSocket: {:?}", e);