ember/continuwuity
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

fix: make dropped PDU warning less useless

Browse source
This commit is contained in:
31a05b9c 2026-02-26 09:21:01 +00:00 • committed by Ellis Git
parent 6fe3b1563c
commit 8dd4b71e0e
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/service/rooms/event_handler/handle_incoming_pdu.rs
View file

@ -134,7 +134,7 @@ pub async fn handle_incoming_pdu<'a>(
); );
return Err!(Request(TooLarge("PDU is too large"))); return Err!(Request(TooLarge("PDU is too large")));
} }
trace!("processing incoming pdu from {origin} for room {room_id} with event id {event_id}"); trace!("processing incoming PDU from {origin} for room {room_id} with event id {event_id}");
// 1.1 Check we even know about the room // 1.1 Check we even know about the room
let meta_exists = self.services.metadata.exists(room_id).map(Ok); let meta_exists = self.services.metadata.exists(room_id).map(Ok);
@ -164,7 +164,7 @@ pub async fn handle_incoming_pdu<'a>(
sender_acl_check.map(|o| o.unwrap_or(Ok(()))), sender_acl_check.map(|o| o.unwrap_or(Ok(()))),
) )
.await .await
.inspect_err(|e| debug_error!("failed to handle incoming PDU: {e}"))?; .inspect_err(|e| debug_error!(%origin, "failed to handle incoming PDU {event_id}: {e}"))?;
if is_disabled { if is_disabled {
return Err!(Request(Forbidden("Federation of this room is disabled by this server."))); return Err!(Request(Forbidden("Federation of this room is disabled by this server.")));
@ -195,6 +195,7 @@ pub async fn handle_incoming_pdu<'a>(
} }
info!( info!(
%origin, %origin,
%room_id,
"Dropping inbound PDU for room we aren't participating in" "Dropping inbound PDU for room we aren't participating in"
); );
return Err!(Request(NotFound("This server is not participating in that room."))); return Err!(Request(NotFound("This server is not participating in that room.")));