diff --git a/synapse/handlers/room.py b/synapse/handlers/room.py
index 68e2c75a48..799221c198 100644
--- a/synapse/handlers/room.py
+++ b/synapse/handlers/room.py
@@ -1013,7 +1013,7 @@ class RoomEventSource(object):
limit=limit,
)
else:
- room_events = yield self.store.get_room_changes_for_user(
+ room_events = yield self.store.get_membership_changes_for_user(
user.to_string(), from_key, to_key
)
diff --git a/synapse/handlers/sync.py b/synapse/handlers/sync.py
index 8d8d10da33..dc686db541 100644
--- a/synapse/handlers/sync.py
+++ b/synapse/handlers/sync.py
@@ -479,7 +479,7 @@ class SyncHandler(BaseHandler):
)
# Get a list of membership change events that have happened.
- rooms_changed = yield self.store.get_room_changes_for_user(
+ rooms_changed = yield self.store.get_membership_changes_for_user(
user_id, since_token.room_key, now_token.room_key
)
diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py
index bcae3d718e..338a9d40d5 100644
--- a/synapse/storage/stream.py
+++ b/synapse/storage/stream.py
@@ -243,7 +243,7 @@ class StreamStore(SQLBaseStore):
defer.returnValue((ret, key))
@defer.inlineCallbacks
- def get_room_changes_for_user(self, user_id, from_key, to_key):
+ def get_membership_changes_for_user(self, user_id, from_key, to_key):
if from_key is not None:
from_id = RoomStreamToken.parse_stream_token(from_key).stream
else:
@@ -285,7 +285,7 @@ class StreamStore(SQLBaseStore):
return rows
- rows = yield self.runInteraction("get_room_changes_for_user", f)
+ rows = yield self.runInteraction("get_membership_changes_for_user", f)
ret = yield self._get_events(
[r["event_id"] for r in rows],
|