summary refs log tree commit diff
path: root/synapse/handlers
diff options
context:
space:
mode:
authorMark Haines <mark.haines@matrix.org>2015-01-27 20:19:36 +0000
committerMark Haines <mark.haines@matrix.org>2015-01-27 20:19:36 +0000
commite020574d65a994858ac53c45070ae5016090d2f3 (patch)
tree0d759eb3f0883e0341c81f0bc1268ec175d02e11 /synapse/handlers
parentWait for events if the incremental sync is empty and a timeout is given (diff)
downloadsynapse-e020574d65a994858ac53c45070ae5016090d2f3.tar.xz
Fix Formatting
Diffstat (limited to 'synapse/handlers')
-rw-r--r--synapse/handlers/sync.py13
1 files changed, 5 insertions, 8 deletions
diff --git a/synapse/handlers/sync.py b/synapse/handlers/sync.py
index 9f5f73eab6..82a2c6986a 100644
--- a/synapse/handlers/sync.py
+++ b/synapse/handlers/sync.py
@@ -52,10 +52,10 @@ class RoomSyncResult(collections.namedtuple("RoomSyncResult", [
 
 
 class SyncResult(collections.namedtuple("SyncResult", [
-    "next_batch", # Token for the next sync
-    "private_user_data", # List of private events for the user.
-    "public_user_data", # List of public events for all users.
-    "rooms", # RoomSyncResult for each room.
+    "next_batch",  # Token for the next sync
+    "private_user_data",  # List of private events for the user.
+    "public_user_data",  # List of public events for all users.
+    "rooms",  # RoomSyncResult for each room.
 ])):
     __slots__ = []
 
@@ -181,7 +181,6 @@ class SyncHandler(BaseHandler):
             limited=True,
         ))
 
-
     @defer.inlineCallbacks
     def incremental_sync_with_gap(self, sync_config, since_token):
         """ Get the incremental delta needed to bring the client up to
@@ -231,7 +230,6 @@ class SyncHandler(BaseHandler):
             next_batch=now_token,
         ))
 
-
     @defer.inlineCallbacks
     def incremental_sync_with_gap_for_room(self, room_id, sync_config,
                                            since_token, now_token,
@@ -316,7 +314,6 @@ class SyncHandler(BaseHandler):
             state = ()
         defer.returnValue(state)
 
-
     def compute_state_delta(self, since_token, previous_state, current_state):
         """ Works out the differnce in state between the current state and the
         state the client got when it last performed a sync.
@@ -327,7 +324,7 @@ class SyncHandler(BaseHandler):
         # after the previous sync, since we need to include those state
         # updates even if they occured logically before the previous event.
         # TODO(mjark) Check for new redactions in the state events.
-        previous_dict = {event.event_id:event for event in previous_state}
+        previous_dict = {event.event_id: event for event in previous_state}
         state_delta = []
         for event in current_state:
             if event.event_id not in previous_dict: