diff --git a/src/api/client/membership/knock.rs b/src/api/client/membership/knock.rs index fab6e2936..a29d80929 100644 --- a/src/api/client/membership/knock.rs +++ b/src/api/client/membership/knock.rs @@ -458,7 +458,11 @@ async fn knock_room_helper_local( .await?; info!("Appending room knock event locally"); - services.rooms.timeline.progress_extremities(&parsed_knock_pdu).await?; + services + .rooms + .timeline + .progress_extremities(&parsed_knock_pdu) + .await?; services .rooms .timeline @@ -655,7 +659,11 @@ async fn knock_room_helper_remote( .await?; info!("Appending room knock event locally"); - services.rooms.timeline.progress_extremities(&parsed_knock_pdu).await?; + services + .rooms + .timeline + .progress_extremities(&parsed_knock_pdu) + .await?; services .rooms .timeline diff --git a/src/service/rooms/membership/mod.rs b/src/service/rooms/membership/mod.rs index c993e18ae..67aee9ada 100644 --- a/src/service/rooms/membership/mod.rs +++ b/src/service/rooms/membership/mod.rs @@ -668,7 +668,10 @@ impl Service { // We append to state before appending the pdu, so we don't have a // moment in time with the pdu without it's state. This is okay // because append_pdu can't fail. - self.services.timeline.progress_extremities(&parsed_join_pdu).await?; + self.services + .timeline + .progress_extremities(&parsed_join_pdu) + .await?; let statehash_after_join = self .services .state @@ -701,7 +704,11 @@ impl Service { info!("Replacing local forward extremities"); self.services .state - .replace_forward_extremities(room_id, once(parsed_join_pdu.event_id()), &state_lock) + .replace_forward_extremities( + room_id, + once(parsed_join_pdu.event_id()), + &state_lock, + ) .await; } drop(cork);