diff options
author | Mark Haines <mark.haines@matrix.org> | 2015-01-13 14:43:26 +0000 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2015-01-13 14:43:26 +0000 |
commit | fda63064fc21881c8aabbfef36916b3b00af5299 (patch) | |
tree | 97a197da8e3f8d9939d253ba11bdded15122c306 | |
parent | Fix stream token ordering (diff) | |
download | synapse-fda63064fc21881c8aabbfef36916b3b00af5299.tar.xz |
get_room_events isn't called anywhere
-rw-r--r-- | synapse/storage/stream.py | 30 |
1 files changed, 0 insertions, 30 deletions
diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py index 563c8e3bbb..8ac2adab05 100644 --- a/synapse/storage/stream.py +++ b/synapse/storage/stream.py @@ -128,36 +128,6 @@ class _StreamToken(namedtuple("_StreamToken", "topological stream")): class StreamStore(SQLBaseStore): @log_function - def get_room_events(self, user_id, from_key, to_key, room_id, limit=0, - direction='f', with_feedback=False): - # We deal with events request in two different ways depending on if - # this looks like an /events request or a pagination request. - is_events = ( - direction == 'f' - and user_id - and is_stream_token(from_key) - and to_key and is_stream_token(to_key) - ) - - if is_events: - return self.get_room_events_stream( - user_id=user_id, - from_key=from_key, - to_key=to_key, - room_id=room_id, - limit=limit, - with_feedback=with_feedback, - ) - else: - return self.paginate_room_events( - from_key=from_key, - to_key=to_key, - room_id=room_id, - limit=limit, - with_feedback=with_feedback, - ) - - @log_function def get_room_events_stream(self, user_id, from_key, to_key, room_id, limit=0, with_feedback=False): # TODO (erikj): Handle compressed feedback |