diff --git a/src/api/client/room/upgrade.rs b/src/api/client/room/upgrade.rs index 1d4a623f1..38a594fcc 100644 --- a/src/api/client/room/upgrade.rs +++ b/src/api/client/room/upgrade.rs @@ -305,8 +305,8 @@ pub(crate) async fn upgrade_room_route( return Err!(Request(Forbidden("Upgrading the admin room this way is not allowed."))); } - // 1. Check that the user has permission to send m.room.tombstone events in - // the room. + // 1. Check that the user has permission to send m.room.tombstone events in the + // room. let old_room_state_lock = services.rooms.state.mutex.lock(body.room_id.as_str()).await; // Check tombstone permission by attempting to create (but not send) the @@ -556,8 +556,8 @@ pub(crate) async fn upgrade_room_route( )?; } - // 5. Send a `m.room.tombstone` event to the old room to indicate that it is - // not intended to be used any further. + // 5. Send a `m.room.tombstone` event to the old room to indicate that it is not + // intended to be used any further. debug!(target=?body.room_id, "Sending tombstone to old room"); services .rooms @@ -598,8 +598,7 @@ pub(crate) async fn upgrade_room_route( power_levels.events_default = new_level; power_levels.invite = new_level; - // 6. Modify the power levels in the old room to prevent sending of events - // and + // 6. Modify the power levels in the old room to prevent sending of events and // inviting new users // Spec dictates that this is allowed to fail. debug!(target=?body.room_id, ?new_level, "Raising power level in old room to lock it"); diff --git a/src/api/client/sync/v3/left.rs b/src/api/client/sync/v3/left.rs index d5d453da1..2e6776284 100644 --- a/src/api/client/sync/v3/left.rs +++ b/src/api/client/sync/v3/left.rs @@ -74,8 +74,8 @@ pub(super) async fn load_left_room( // return early if: // - this is an initial sync and the room filter doesn't include leaves, or - // - this is an incremental sync, and we've already synced the leave, and - // the room filter doesn't include leaves + // - this is an incremental sync, and we've already synced the leave, and the + // room filter doesn't include leaves if last_sync_end_count.is_none_or(|last_sync_end_count| last_sync_end_count >= left_count) && !filter.room.include_leave { diff --git a/src/core/matrix/state_res/event_auth.rs b/src/core/matrix/state_res/event_auth.rs index 79408beb9..5bd5f8f0e 100644 --- a/src/core/matrix/state_res/event_auth.rs +++ b/src/core/matrix/state_res/event_auth.rs @@ -763,8 +763,8 @@ where Ok(match target_membership { | MembershipState::Join => { trace!("starting target_membership=join check"); - // 1. If the only previous event is an m.room.create and the - // state_key is the creator, + // 1. If the only previous event is an m.room.create and the state_key is the + // creator, // allow let mut prev_events = current_event.prev_events(); @@ -1052,8 +1052,8 @@ where allow }, | MembershipState::Knock if room_version.authorization.knocking => { - // 1. If the `join_rule` is anything other than `knock` or - // `knock_restricted`, reject. + // 1. If the `join_rule` is anything other than `knock` or `knock_restricted`, + // reject. if !matches!(join_rules, JoinRule::KnockRestricted(_) | JoinRule::Knock) { warn!( "Join rule is not set to knock or knock_restricted, knocking is not allowed" @@ -1062,8 +1062,8 @@ where } else if matches!(join_rules, JoinRule::KnockRestricted(_)) && !room_version.authorization.knock_restricted_join_rule { - // 2. If the `join_rule` is `knock_restricted`, but the room - // does not support `knock_restricted`, reject. + // 2. If the `join_rule` is `knock_restricted`, but the room does not support + // `knock_restricted`, reject. warn!( "Join rule is set to knock_restricted but room version does not support \ knock_restricted, knocking is not allowed" @@ -1081,8 +1081,8 @@ where sender_membership, MembershipState::Ban | MembershipState::Invite | MembershipState::Join ) { - // 4. If the `sender`'s current membership is not `ban`, - // `invite`, or `join`, allow. + // 4. If the `sender`'s current membership is not `ban`, `invite`, or `join`, + // allow. // 5. Otherwise, reject. warn!( ?target_user_membership_event_id, @@ -1175,12 +1175,11 @@ fn check_power_levels( } // - If any of the keys users_default, events_default, state_default, ban, - // redact, kick, or invite in content are present and not an integer, - // reject. - // - If either of the keys events or notifications in content are present - // and not a dictionary with values that are integers, reject. - // - If users key in content is not a dictionary with keys that are valid - // user IDs with values that are integers, reject. + // redact, kick, or invite in content are present and not an integer, reject. + // - If either of the keys events or notifications in content are present and + // not a dictionary with values that are integers, reject. + // - If users key in content is not a dictionary with keys that are valid user + // IDs with values that are integers, reject. let user_content: RoomPowerLevelsEventContent = deserialize_power_levels(power_event.content().get(), room_version)?; diff --git a/src/service/rooms/event_handler/handle_outlier_pdu.rs b/src/service/rooms/event_handler/handle_outlier_pdu.rs index ee81a0c04..4c2cd2d54 100644 --- a/src/service/rooms/event_handler/handle_outlier_pdu.rs +++ b/src/service/rooms/event_handler/handle_outlier_pdu.rs @@ -161,8 +161,8 @@ impl super::Service { } } - // 4. Reject "due to auth events" if the event doesn't pass auth based - // on the claimed auth events + // 4. Reject "due to auth events" if the event doesn't pass auth based on the + // claimed auth events debug!("Checking based on auth events"); let mut auth_events_by_key: HashMap<_, _> = HashMap::with_capacity(auth_events.len()); // Build map of auth events