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

style: Reformat

Browse Source
This commit is contained in:
timedout
2026-05-09 20:06:53 +01:00
parent 5d4b7bfea3
commit 3764faeefc
5 changed files with 50 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/admin/debug/commands.rs
+18 -12
View File
@@ -6,24 +6,24 @@ use std::{
};
use conduwuit::{
debug_error, err, info, matrix::{
pdu::{PduEvent, PduId, RawPduId},
Err, Result, debug_error, err, info,
matrix::{
Event,
}, trace,
utils,
pdu::{PduEvent, PduId, RawPduId},
},
trace, utils,
utils::{
stream::{IterStream, ReadyExt},
string::EMPTY,
}, warn,
Err,
Result,
},
warn,
};
use futures::{FutureExt, StreamExt, TryStreamExt};
use lettre::message::Mailbox;
use ruma::{
api::federation::event::get_room_state, events::AnyStateEvent, serde::Raw, CanonicalJsonObject, CanonicalJsonValue,
EventId, OwnedEventId, OwnedRoomId, OwnedRoomOrAliasId, OwnedServerName,
RoomId, RoomVersionId, UInt,
CanonicalJsonObject, CanonicalJsonValue, EventId, OwnedEventId, OwnedRoomId,
OwnedRoomOrAliasId, OwnedServerName, RoomId, RoomVersionId, UInt,
api::federation::event::get_room_state, events::AnyStateEvent, serde::Raw,
};
use service::rooms::{
short::{ShortEventId, ShortRoomId},
@@ -813,7 +813,10 @@ pub(super) async fn force_set_room_state_from_server(
.await;
state.insert(shortstatekey, pdu.event_id.clone());
self.services.rooms.pdu_metadata.clear_pdu_markers(pdu.event_id());
self.services
.rooms
.pdu_metadata
.clear_pdu_markers(pdu.event_id());
}
}
@@ -831,7 +834,10 @@ pub(super) async fn force_set_room_state_from_server(
.rooms
.outlier
.add_pdu_outlier(&event_id, &value);
self.services.rooms.pdu_metadata.clear_pdu_markers(&event_id);
self.services
.rooms
.pdu_metadata
.clear_pdu_markers(&event_id);
}
info!("Resolving new room state");