From 732c69f5ca91aa85e678a251a49700c7f3c98d9a Mon Sep 17 00:00:00 2001 From: nexy7574 Date: Sat, 19 Jul 2025 20:47:02 +0100 Subject: [PATCH] fix(policy-server): Avoid unnecessary database lookup --- src/service/rooms/event_handler/call_policyserv.rs | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) diff --git a/src/service/rooms/event_handler/call_policyserv.rs b/src/service/rooms/event_handler/call_policyserv.rs index 804c77eb..e7ae1d0f 100644 --- a/src/service/rooms/event_handler/call_policyserv.rs +++ b/src/service/rooms/event_handler/call_policyserv.rs @@ -26,20 +26,11 @@ pub async fn policyserv_check(&self, pdu: &PduEvent, room_id: &RoomId) -> Result return Ok(()); }, }; - // TODO: dont do *this* - let pdu_json = self.services.timeline.get_pdu_json(pdu.event_id()).await?; let outgoing = self .services .sending - .convert_to_outgoing_federation_event(pdu_json) + .convert_to_outgoing_federation_event(pdu.to_canonical_object()) .await; - // let s = match serde_json::to_string(outgoing.as_ref()) { - // | Ok(s) => s, - // | Err(e) => { - // warn!("Failed to convert pdu {} to outgoing federation event: {e}", - // pdu.event_id()); return Err!(Request(InvalidParam("Failed to convert PDU - // to outgoing event."))); }, - // }; debug!("Checking pdu {outgoing:?} for spam with policy server {via} for room {room_id}"); let response = self .services