mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2026-11-13 04:06:54 +00:00
style: reformat
This commit is contained in:
2 files changed
+19
-4
No files matched your search
@@ -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
|
||||
|
||||
@@ -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);
|
||||
|
||||
Reference in new issue
Block a user