diff --git a/src/service/rooms/event_handler/upgrade_outlier_pdu.rs b/src/service/rooms/event_handler/upgrade_outlier_pdu.rs index 38fc7c452..c50176743 100644 --- a/src/service/rooms/event_handler/upgrade_outlier_pdu.rs +++ b/src/service/rooms/event_handler/upgrade_outlier_pdu.rs @@ -1,17 +1,17 @@ use std::{borrow::Borrow, collections::BTreeMap, sync::Arc, time::Instant}; use conduwuit::{ - Err, Result, debug, debug_info, debug_warn, err, implement, is_equal_to, - matrix::{Event, EventTypeExt, PduEvent, StateKey, state_res}, - trace, + debug, debug_info, debug_warn, err, implement, is_equal_to, matrix::{state_res, Event, EventTypeExt, PduEvent, StateKey}, trace, utils::{ - IterStream, stream::{BroadbandExt, ReadyExt}, + IterStream, }, warn, + Err, + Result, }; -use futures::{FutureExt, StreamExt, future::ready}; -use ruma::{CanonicalJsonValue, RoomId, ServerName, events::StateEventType}; +use futures::{future::ready, FutureExt, StreamExt}; +use ruma::{events::StateEventType, CanonicalJsonValue, RoomId, ServerName}; use tokio::join; use super::get_room_version_rules; @@ -59,8 +59,7 @@ where // If any of the auth events are rejected, this event is also rejected. for aid in incoming_pdu.auth_events() { if self.services.pdu_metadata.is_event_rejected(aid).await { - // TODO: debug_warn instead of warn - warn!( + debug_warn!( "Rejecting incoming event {} which depends on rejected auth event {aid}", incoming_pdu.event_id() );