diff options
author | Mark Haines <mark.haines@matrix.org> | 2015-10-29 19:58:51 +0000 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2015-10-29 19:58:51 +0000 |
commit | 5cf22f0596fa142fe81bb9c8705d445131487a68 (patch) | |
tree | d84426c15a1564d24066338347d8526bb3548a64 /synapse/handlers/sync.py | |
parent | Make search API honour limit set in filter (diff) | |
download | synapse-5cf22f0596fa142fe81bb9c8705d445131487a68.tar.xz |
Don't mark newly joined room timelines as limited in an incremental sync
Diffstat (limited to '')
-rw-r--r-- | synapse/handlers/sync.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/synapse/handlers/sync.py b/synapse/handlers/sync.py index 8601f22179..04f2d46d15 100644 --- a/synapse/handlers/sync.py +++ b/synapse/handlers/sync.py @@ -387,7 +387,7 @@ class SyncHandler(BaseHandler): else: prev_batch = now_token - state = yield self.check_joined_room( + state, limited = yield self.check_joined_room( sync_config, room_id, state ) @@ -396,7 +396,7 @@ class SyncHandler(BaseHandler): timeline=TimelineBatch( events=recents, prev_batch=prev_batch, - limited=False, + limited=limited, ), state=state, ephemeral=typing_by_room.get(room_id, []) @@ -627,6 +627,7 @@ class SyncHandler(BaseHandler): @defer.inlineCallbacks def check_joined_room(self, sync_config, room_id, state_delta): joined = False + limited = False for event in state_delta: if ( event.type == EventTypes.Member @@ -638,5 +639,6 @@ class SyncHandler(BaseHandler): if joined: res = yield self.state_handler.get_current_state(room_id) state_delta = res.values() + limited = True - defer.returnValue(state_delta) + defer.returnValue((state_delta, limited)) |