mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-26 19:47:05 +03:00
Code Issues Projects Releases Packages Wiki Activity

Fix exceptions so that the event stream works. Presence like events are turned off currently.

Browse source
This commit is contained in:
Erik Johnston 2014-08-26 19:18:11 +01:00
parent 93cff1668c
commit c1cf0b334e
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
synapse/streams/events.py
View file

@ -20,7 +20,7 @@ from synapse.types import StreamToken
class RoomEventSource(object): class RoomEventSource(object):
SIGNAL_NAME = "EventStreamSourceSignal" SIGNAL_NAME = "RoomEventSource"
def __init__(self, hs): def __init__(self, hs):
self.store = hs.get_datastore() self.store = hs.get_datastore()
@ -74,6 +74,8 @@ class RoomEventSource(object):
class PresenceStreamSource(object): class PresenceStreamSource(object):
SIGNAL_NAME = "PresenceStreamSource"
def __init__(self, hs): def __init__(self, hs):
self.hs = hs self.hs = hs
self.clock = hs.get_clock() self.clock = hs.get_clock()
@ -105,7 +107,7 @@ class PresenceStreamSource(object):
return (([], end_token)) return (([], end_token))
def get_keys_for_user(self, user): def get_keys_for_user(self, user):
raise NotImplementedError("get_keys_for_user") return defer.succeed([])
def get_current_token_part(self): def get_current_token_part(self):
presence = self.hs.get_handlers().presence_handler presence = self.hs.get_handlers().presence_handler