From 052722eee84c6d51496bace40f51b037c9854e96 Mon Sep 17 00:00:00 2001 From: trisua <tri@swmff.org> Date: Fri, 2 May 2025 20:57:01 -0400 Subject: [PATCH] fix: send socket pings every 30 seconds instead of 10 --- crates/app/src/public/html/mod/stats.html | 4 ++-- crates/app/src/routes/api/v1/auth/profile.rs | 2 +- crates/app/src/routes/api/v1/channels/messages.rs | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/crates/app/src/public/html/mod/stats.html b/crates/app/src/public/html/mod/stats.html index 57e5df4..869c3fc 100644 --- a/crates/app/src/public/html/mod/stats.html +++ b/crates/app/src/public/html/mod/stats.html @@ -1,5 +1,5 @@ {% extends "root.html" %} {% block head %} -<title>Audit log - {{ config.name }}</title> +<title>Server stats - {{ config.name }}</title> {% endblock %} {% block body %} {{ macros::nav() }} <main class="flex flex-col gap-2"> <div class="card-nest w-full"> @@ -21,7 +21,7 @@ </li> <li> - <b>Socket threads:</b> + <b>Socket tasks:</b> <span>{{ (active_users_chats + active_users) * 3 }}</span> </li> </ul> 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::<usize, String, ()>(