mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2026-11-13 12:16:54 +00:00
chore: Drop unused param from handle_outlier_pdu
This commit is contained in:
5 files changed
+2
-6
No files matched your search
@@ -557,7 +557,6 @@ impl super::Service {
|
||||
&discovered_event_id,
|
||||
room_id,
|
||||
pdu_json,
|
||||
true,
|
||||
))
|
||||
.await
|
||||
{
|
||||
|
||||
@@ -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 => {
|
||||
|
||||
@@ -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| {
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -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<String, CanonicalJsonValue>)>
|
||||
where
|
||||
Pdu: Event + Send + Sync,
|
||||
|
||||
Reference in new issue
Block a user