Matrix/synapse
Matrix/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse synced 2024-08-19 12:40:20 +00:00
Code Issues Projects Releases Packages Wiki Activity

Select to_key if to_key else from_key

Browse source 
See https://github.com/element-hq/synapse/pull/17320#discussion_r1646591886
This commit is contained in:
Eric Eastwood 2024-07-01 21:42:11 -05:00
parent e4195875b9
commit 2bd6cba76d
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
synapse/storage/databases/main/stream.py
View file

@ -1827,7 +1827,9 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
and to_key is not None
and to_key.is_before_or_eq(from_key)
):
return [], from_key
# Token selection matches what we do in `_paginate_room_events_txn` if there
# are no rows
return [], to_key if to_key else from_key
# Or vice-versa, if we're looking backwards and our `from_key` is already before
# our `to_key`.
elif (
@ -1835,7 +1837,9 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
and to_key is not None
and from_key.is_before_or_eq(to_key)
):
return [], from_key
# Token selection matches what we do in `_paginate_room_events_txn` if there
# are no rows
return [], to_key if to_key else from_key
rows, token = await self.db_pool.runInteraction(
"paginate_room_events",