t/tetratto
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: stats page "active user streams"

Browse source
This commit is contained in:
trisua 2025-05-02 20:54:48 -04:00
parent 07f5ebf8e7
commit 11b01b1b82
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
crates/app/src/routes/api/v1/auth/profile.rs
View file

@ -524,14 +524,14 @@ pub async fn handle_socket(socket: WebSocket, db: DataManager, user_id: String,
} }
}); });
db.2.incr("atto.active_connections:user".to_string()).await; db.2.incr("atto.active_connections:users".to_string()).await;
tokio::select! { tokio::select! {
_ = (&mut recv_task) => redis_task.abort(), _ = (&mut recv_task) => redis_task.abort(),
_ = (&mut redis_task) => recv_task.abort() _ = (&mut redis_task) => recv_task.abort()
} }
heartbeat_task.abort(); // kill heartbeat_task.abort(); // kill
db.2.decr("atto.active_connections:user".to_string()).await; db.2.decr("atto.active_connections:users".to_string()).await;
tracing::info!("socket terminate"); tracing::info!("socket terminate");
} }