Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-21 12:17:44 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fix get_max_topological_token to never return None

Browse Source
This commit is contained in:
Erik Johnston 2019-05-21 15:21:38 +01:00
parent 04d53794d6
commit 7b0e804a4a
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
synapse/storage/stream.py
View File

@ -592,8 +592,18 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
) )
def get_max_topological_token(self, room_id, stream_key): def get_max_topological_token(self, room_id, stream_key):
"""Get the max topological token in a room that before given stream
ordering.
Args:
room_id (str)
stream_key (int)
Returns:
Deferred[int]
"""
sql = ( sql = (
"SELECT max(topological_ordering) FROM events" "SELECT coalesce(max(topological_ordering), 0) FROM events"
" WHERE room_id = ? AND stream_ordering < ?" " WHERE room_id = ? AND stream_ordering < ?"
) )
return self._execute( return self._execute(