OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Support streaming peek

erikj/paginate_sync
Erik Johnston 2016-06-22 11:02:27 +01:00
parent 6a101e512f
commit 839088e2e7
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
synapse/handlers/sync.py
View File

@ -779,13 +779,19 @@ class SyncHandler(object):
if include_all_tags and r.room_id in all_tags: if include_all_tags and r.room_id in all_tags:
r.always_include = True r.always_include = True
continue continue
r.full_state = True
r.would_require_resync = True
if r.room_id in include_map: if r.room_id in include_map:
r.always_include = True since = include_map[r.room_id].get("since", None)
r.since_token = since
if not since:
r.always_include = True
r.full_state = True
r.would_require_resync = True
r.events = None r.events = None
r.since_token = None
r.upto_token = now_token r.upto_token = now_token
else:
r.full_state = True
r.would_require_resync = True
elif pagination_config and include_all_tags: elif pagination_config and include_all_tags:
all_tags = yield self.store.get_tags_for_user(user_id) all_tags = yield self.store.get_tags_for_user(user_id)