|
|
|
@ -205,6 +205,15 @@ class EventsStore(SQLBaseStore): |
|
|
|
|
txn.call_after(self.get_joined_hosts_for_room.invalidate, (event.room_id,)) |
|
|
|
|
txn.call_after(self.get_room_name_and_aliases, event.room_id) |
|
|
|
|
|
|
|
|
|
# Add an entry to the current_state_resets table to record the point |
|
|
|
|
# where we clobbered the current state |
|
|
|
|
stream_order = event.internal_metadata.stream_ordering |
|
|
|
|
self._simple_insert_txn( |
|
|
|
|
txn, |
|
|
|
|
table="current_state_resets", |
|
|
|
|
values={"event_stream_ordering": stream_order} |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
self._simple_delete_txn( |
|
|
|
|
txn, |
|
|
|
|
table="current_state_events", |
|
|
|
|