mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2026-11-13 04:06:54 +00:00
fix: Correctly remove extremities after creating a new event
This commit is contained in:
3 files changed
+4
No files matched your search
@@ -458,6 +458,7 @@ 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
|
||||
@@ -654,6 +655,7 @@ 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
|
||||
|
||||
@@ -668,6 +668,7 @@ 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?;
|
||||
let statehash_after_join = self
|
||||
.services
|
||||
.state
|
||||
|
||||
@@ -111,6 +111,7 @@ impl super::Service {
|
||||
// because append_pdu can't fail.
|
||||
trace!("Appending {} state for room {room_id}", pdu.event_id());
|
||||
let statehashid = self.services.state.append_to_state(&pdu, &room_id).await?;
|
||||
self.progress_extremities(&pdu).await?;
|
||||
trace!("State hash ID for {room_id}: {statehashid:?}");
|
||||
|
||||
trace!("Generating raw ID for PDU {}", pdu.event_id());
|
||||
|
||||
Reference in new issue
Block a user