Skip to content
Snippets Groups Projects
Commit 1ee62859 authored by Erik Johnston's avatar Erik Johnston
Browse files

Fix check

parent 68e1a872
No related branches found
No related tags found
No related merge requests found
...@@ -565,13 +565,12 @@ class SyncHandler(object): ...@@ -565,13 +565,12 @@ class SyncHandler(object):
if sync_result_builder.since_token is not None: if sync_result_builder.since_token is not None:
since_stream_id = int(sync_result_builder.since_token.to_device_key) since_stream_id = int(sync_result_builder.since_token.to_device_key)
if since_stream_id: if since_stream_id != int(now_token.to_device_key):
logger.debug("Deleting messages up to %d", since_stream_id) logger.debug("Deleting messages up to %d", since_stream_id)
yield self.store.delete_messages_for_device( yield self.store.delete_messages_for_device(
user_id, device_id, since_stream_id user_id, device_id, since_stream_id
) )
if since_stream_id and since_stream_id == int(now_token.to_device_key):
logger.debug("Getting messages up to %d", now_token.to_device_key) logger.debug("Getting messages up to %d", now_token.to_device_key)
messages, stream_id = yield self.store.get_new_messages_for_device( messages, stream_id = yield self.store.get_new_messages_for_device(
user_id, device_id, now_token.to_device_key user_id, device_id, now_token.to_device_key
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment