@@ -21,7 +21,7 @@
- Socket threads:
+ Socket tasks:
{{ (active_users_chats + active_users) * 3 }}
diff --git a/crates/app/src/routes/api/v1/auth/profile.rs b/crates/app/src/routes/api/v1/auth/profile.rs
index 00367bf..1a2c5f0 100644
--- a/crates/app/src/routes/api/v1/auth/profile.rs
+++ b/crates/app/src/routes/api/v1/auth/profile.rs
@@ -507,7 +507,7 @@ pub async fn handle_socket(socket: WebSocket, db: DataManager, user_id: String,
let channel_c = channel.clone();
let heartbeat_task = tokio::spawn(async move {
let mut con = db2c.get_con().await;
- let mut heartbeat = tokio::time::interval(Duration::from_secs(10));
+ let mut heartbeat = tokio::time::interval(Duration::from_secs(30));
loop {
con.publish::<&str, String, ()>(
diff --git a/crates/app/src/routes/api/v1/channels/messages.rs b/crates/app/src/routes/api/v1/channels/messages.rs
index 5d57167..b7b9835 100644
--- a/crates/app/src/routes/api/v1/channels/messages.rs
+++ b/crates/app/src/routes/api/v1/channels/messages.rs
@@ -241,7 +241,7 @@ pub async fn handle_socket(socket: WebSocket, db: DataManager, community_id: Str
let db2c = db.2.clone();
let heartbeat_task = tokio::spawn(async move {
let mut con = db2c.get_con().await;
- let mut heartbeat = tokio::time::interval(Duration::from_secs(10));
+ let mut heartbeat = tokio::time::interval(Duration::from_secs(30));
loop {
con.publish::(