From 11f34920e73f3cd2365cc6ca3c4fffe9de37b9a6 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Tue, 30 Jul 2024 12:46:21 +0100 Subject: [PATCH] Refactor to make LIVE non-static value --- synapse/handlers/sliding_sync.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/synapse/handlers/sliding_sync.py b/synapse/handlers/sliding_sync.py index 73414dbf69..6ddc8ff87b 100644 --- a/synapse/handlers/sliding_sync.py +++ b/synapse/handlers/sliding_sync.py @@ -2237,6 +2237,10 @@ class HaveSentRoom: status: HaveSentRoomFlag last_token: Optional[RoomStreamToken] + @staticmethod + def live() -> "HaveSentRoom": + return HaveSentRoom(HaveSentRoomFlag.LIVE, None) + @staticmethod def previously(last_token: RoomStreamToken) -> "HaveSentRoom": """Constructor for `PREVIOUSLY` flag.""" @@ -2244,7 +2248,6 @@ class HaveSentRoom: HAVE_SENT_ROOM_NEVER = HaveSentRoom(HaveSentRoomFlag.NEVER, None) -HAVE_SENT_ROOM_LIVE = HaveSentRoom(HaveSentRoomFlag.LIVE, None) @attr.s(auto_attribs=True) @@ -2339,7 +2342,7 @@ class SlidingSyncConnectionStore: # end we can treat this as a noop. have_updated = False for room_id in sent_room_ids: - new_room_statuses[room_id] = HAVE_SENT_ROOM_LIVE + new_room_statuses[room_id] = HaveSentRoom.live() have_updated = True # Whether we add/update the entries for unsent rooms depends on the