summary refs log tree commit diff
path: root/synapse/api/streams
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2014-08-18 11:06:59 +0100
committerErik Johnston <erik@matrix.org>2014-08-18 11:06:59 +0100
commit291010f100f20ef56b731ae51341abdc4d4a7835 (patch)
tree173c4c891c71b55021fa316487b5ed63999b0cc8 /synapse/api/streams
parentWe don't need to do a json.loads here (diff)
downloadsynapse-291010f100f20ef56b731ae51341abdc4d4a7835.tar.xz
Not all event streams returns SynapseEvents
Diffstat (limited to 'synapse/api/streams')
-rw-r--r--synapse/api/streams/event.py6
1 files changed, 5 insertions, 1 deletions
diff --git a/synapse/api/streams/event.py b/synapse/api/streams/event.py
index 895a96b5b9..414b05be30 100644
--- a/synapse/api/streams/event.py
+++ b/synapse/api/streams/event.py
@@ -18,6 +18,7 @@
 from twisted.internet import defer
 
 from synapse.api.errors import EventStreamError
+from synapse.api.events import SynapseEvent
 from synapse.api.events.room import (
     RoomMemberEvent, MessageEvent, FeedbackEvent, RoomTopicEvent
 )
@@ -160,7 +161,10 @@ class EventStream(PaginationStream):
                 self.user_id, from_pkey, to_pkey, limit
             )
 
-            chunk += [e.get_dict() for e in event_chunk]
+            chunk.extend([
+                e.get_dict() if isinstance(e, SynapseEvent) else e
+                for e in event_chunk
+            ])
             next_ver.append(str(max_pkey))
 
         defer.returnValue((chunk, EventStream.SEPARATOR.join(next_ver)))