From 7ca00e4ab9a51fad2b1faa6df7f1db52e92b9f80 Mon Sep 17 00:00:00 2001 From: timedout Date: Wed, 17 Jun 2026 21:27:34 +0100 Subject: [PATCH] chore: Drop unused param from handle_outlier_pdu --- src/service/rooms/event_handler/fetch_and_handle_outliers.rs | 1 - src/service/rooms/event_handler/fetch_prev.rs | 2 +- src/service/rooms/event_handler/fetch_state.rs | 2 -- src/service/rooms/event_handler/handle_incoming_pdu.rs | 2 +- src/service/rooms/event_handler/handle_outlier_pdu.rs | 1 - 5 files changed, 2 insertions(+), 6 deletions(-) diff --git a/src/service/rooms/event_handler/fetch_and_handle_outliers.rs b/src/service/rooms/event_handler/fetch_and_handle_outliers.rs index 03e351464..c55159f35 100644 --- a/src/service/rooms/event_handler/fetch_and_handle_outliers.rs +++ b/src/service/rooms/event_handler/fetch_and_handle_outliers.rs @@ -557,7 +557,6 @@ impl super::Service { &discovered_event_id, room_id, pdu_json, - true, )) .await { diff --git a/src/service/rooms/event_handler/fetch_prev.rs b/src/service/rooms/event_handler/fetch_prev.rs index 2e95f39ab..d8e77cf7c 100644 --- a/src/service/rooms/event_handler/fetch_prev.rs +++ b/src/service/rooms/event_handler/fetch_prev.rs @@ -104,7 +104,7 @@ impl super::Service { let obj = mapped.get(event_id).cloned().unwrap(); let persist_start = Instant::now(); match self - .handle_outlier_pdu(origin, create_event, event_id, room_id, obj, false) + .handle_outlier_pdu(origin, create_event, event_id, room_id, obj) .await { | Ok((pdu, val)) if pdu.origin_server_ts() >= first_ts_in_room => { diff --git a/src/service/rooms/event_handler/fetch_state.rs b/src/service/rooms/event_handler/fetch_state.rs index 22f8c6acd..dbd0b75d6 100644 --- a/src/service/rooms/event_handler/fetch_state.rs +++ b/src/service/rooms/event_handler/fetch_state.rs @@ -331,7 +331,6 @@ impl super::Service { &incoming_event_id, &incoming_room_id, incoming_event_json, - true, ) .await .inspect_err(|e| { @@ -368,7 +367,6 @@ impl super::Service { &incoming_event_id, &incoming_room_id, incoming_event_json, - true, ) .await .inspect_err(|e| { diff --git a/src/service/rooms/event_handler/handle_incoming_pdu.rs b/src/service/rooms/event_handler/handle_incoming_pdu.rs index 019ef5f89..e0b1d383e 100644 --- a/src/service/rooms/event_handler/handle_incoming_pdu.rs +++ b/src/service/rooms/event_handler/handle_incoming_pdu.rs @@ -222,7 +222,7 @@ pub async fn handle_incoming_pdu<'a>( }} let (incoming_pdu, val) = self - .handle_outlier_pdu(origin, create_event, event_id, room_id, value, false) + .handle_outlier_pdu(origin, create_event, event_id, room_id, value) .await?; // 8. if not timeline event: stop diff --git a/src/service/rooms/event_handler/handle_outlier_pdu.rs b/src/service/rooms/event_handler/handle_outlier_pdu.rs index b9f8f3c10..4d3bbc4d0 100644 --- a/src/service/rooms/event_handler/handle_outlier_pdu.rs +++ b/src/service/rooms/event_handler/handle_outlier_pdu.rs @@ -24,7 +24,6 @@ pub(super) async fn handle_outlier_pdu<'a, Pdu>( event_id: &'a EventId, room_id: &'a RoomId, mut value: CanonicalJsonObject, - _auth_events_known: bool, ) -> Result<(PduEvent, BTreeMap)> where Pdu: Event + Send + Sync,