diff options
author | Antonio Russo <aerusso@aerusso.net> | 2023-08-23 23:23:20 -0600 |
---|---|---|
committer | Antonio Russo <aerusso@aerusso.net> | 2023-08-23 23:23:20 -0600 |
commit | 7d14b344339cd9e55ae85d2802fbae1e781d0042 (patch) | |
tree | 56b482d87cb5f15312e036f91d2da714b4103375 /synapse/handlers/read_marker.py | |
parent | 6027905201d37bb95ac4855e5d19abcce0cec062 (diff) |
New upstream version 1.90.0
Diffstat (limited to 'synapse/handlers/read_marker.py')
-rw-r--r-- | synapse/handlers/read_marker.py | 24 |
1 files changed, 17 insertions, 7 deletions
diff --git a/synapse/handlers/read_marker.py b/synapse/handlers/read_marker.py index 05122fd5..df5a4f3e 100644 --- a/synapse/handlers/read_marker.py +++ b/synapse/handlers/read_marker.py @@ -15,6 +15,8 @@ import logging from typing import TYPE_CHECKING +from synapse.api.constants import ReceiptTypes +from synapse.api.errors import SynapseError from synapse.util.async_helpers import Linearizer if TYPE_CHECKING: @@ -25,7 +27,6 @@ logger = logging.getLogger(__name__) class ReadMarkerHandler: def __init__(self, hs: "HomeServer"): - self.server_name = hs.config.server.server_name self.store = hs.get_datastores().main self.account_data_handler = hs.get_account_data_handler() self.read_marker_linearizer = Linearizer(name="read_marker") @@ -42,19 +43,28 @@ class ReadMarkerHandler: async with self.read_marker_linearizer.queue((room_id, user_id)): existing_read_marker = await self.store.get_account_data_for_room_and_type( - user_id, room_id, "m.fully_read" + user_id, room_id, ReceiptTypes.FULLY_READ ) should_update = True + # Get event ordering, this also ensures we know about the event + event_ordering = await self.store.get_event_ordering(event_id) if existing_read_marker: - # Only update if the new marker is ahead in the stream - should_update = await self.store.is_event_after( - event_id, existing_read_marker["event_id"] - ) + try: + old_event_ordering = await self.store.get_event_ordering( + existing_read_marker["event_id"] + ) + except SynapseError: + # Old event no longer exists, assume new is ahead. This may + # happen if the old event was removed due to retention. + pass + else: + # Only update if the new marker is ahead in the stream + should_update = event_ordering > old_event_ordering if should_update: content = {"event_id": event_id} await self.account_data_handler.add_account_data_to_room( - user_id, room_id, "m.fully_read", content + user_id, room_id, ReceiptTypes.FULLY_READ, content ) |