Mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2026-05-26 20:49:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: Revert leaked changes to leave.rs

Browse Source
This commit is contained in:
timedout
2026-02-14 14:17:23 +00:00
parent c9d9ed0a90
commit 5ad653ab86
1 changed files with 2 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/api/client/membership/leave.rs
+2 -38
View File
@@ -2,7 +2,7 @@ use std::collections::HashSet;
use axum::extract::State; use axum::extract::State;
use conduwuit::{ use conduwuit::{
Err, Pdu, Result, debug, debug_info, debug_warn, err, error, Err, Pdu, Result, debug_info, debug_warn, err,
matrix::{event::gen_event_id, pdu::PduBuilder}, matrix::{event::gen_event_id, pdu::PduBuilder},
utils::{self, FutureBoolExt, future::ReadyEqExt}, utils::{self, FutureBoolExt, future::ReadyEqExt},
warn, warn,
@@ -33,43 +33,7 @@ pub(crate) async fn leave_room_route(
State(services): State<crate::State>, State(services): State<crate::State>,
body: Ruma<leave_room::v3::Request>, body: Ruma<leave_room::v3::Request>,
) -> Result<leave_room::v3::Response> { ) -> Result<leave_room::v3::Response> {
let user = body.sender_user(); leave_room(&services, body.sender_user(), &body.room_id, body.reason.clone())
if services.users.is_suspended(user).await? {
return Err!(Request(UserSuspended("You cannot perform this action while suspended.")));
}
let room_id = body.room_id.clone();
if services
.rooms
.state_cache
.server_in_room(services.globals.server_name(), &room_id)
.await && !services.config.auto_join_rooms.is_empty()
{
debug!(room_id = %room_id, user_id = %user, "checking if user can leave local room");
for room in &services.config.auto_join_rooms {
let sn = room.server_name();
if sn.is_none_or(|_| sn.is_some_and(|n| n == services.globals.server_name())) {
// Only resolve the ID or aliases of local rooms, since federated lookups are
// slow
match services.rooms.alias.resolve(room).await {
| Err(e) => {
error!("Failed to resolve auto-join room {room}: {e}");
},
| Ok(resolved_room_id) =>
if resolved_room_id == room_id {
warn!(
room_id = %room_id,
user_id = %user,
"Refusing to let user leave auto-join room"
);
return Err!(Request(Forbidden(
"You cannot leave rooms you were automatically joined to"
)));
},
}
}
}
}
leave_room(&services, user, &room_id, body.reason.clone())
.boxed() .boxed()
.await .await
.map(|()| leave_room::v3::Response::new()) .map(|()| leave_room::v3::Response::new())