pierre/MatrixGW
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

Implement disconnect specific client ID

Browse Source
This commit is contained in:
Pierre HUBERT 2025-02-11 22:03:16 +01:00
parent b8a8e14f3c
commit bb1e412d36
2 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/server/api/ws.rs
View File

@ -64,7 +64,16 @@ pub async fn ws_handler(
}; };
match msg { match msg {
WsMessage::CloseClientSession(_) => todo!(), WsMessage::CloseClientSession(id) => {
if let Some(client) = &auth.client {
if client.id == id {
log::info!(
"closing client session {id:?} of user {:?} as requested", auth.user.user_id
);
break None;
}
}
},
WsMessage::CloseAllUserSessions(userid) => { WsMessage::CloseAllUserSessions(userid) => {
if userid == auth.user.user_id { if userid == auth.user.user_id {
log::info!( log::info!(

5
src/server/web_ui.rs
View File

@ -138,7 +138,10 @@ pub async fn home(
config.clients.retain(|c| c.id != delete_client_id); config.clients.retain(|c| c.id != delete_client_id);
config.save().await?; config.save().await?;
success_message = Some("The client was successfully deleted!".to_string()); success_message = Some("The client was successfully deleted!".to_string());
// TODO : close connections with given id
if let Err(e) = tx.send(WsMessage::CloseClientSession(delete_client_id)) {
log::error!("Failed to send CloseClientSession: {}", e);
}
} }
} }