summary refs log tree commit diff
path: root/synapse/replication
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2018-03-14 14:15:49 +0000
committerErik Johnston <erik@matrix.org>2018-03-14 14:17:43 +0000
commit62ad701326089ceebbc2683a2e0c9eeeaa734293 (patch)
treed6a68b83874c68f628715cf6589a73eeb24fb30a /synapse/replication
parentSplit RoomMemberWorkerHandler to separate file (diff)
downloadsynapse-62ad701326089ceebbc2683a2e0c9eeeaa734293.tar.xz
s/join/joined/ in notify_user_membership_change
Diffstat (limited to 'synapse/replication')
-rw-r--r--synapse/replication/http/membership.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/replication/http/membership.py b/synapse/replication/http/membership.py
index df16c3b2b4..fcd038a8a2 100644
--- a/synapse/replication/http/membership.py
+++ b/synapse/replication/http/membership.py
@@ -154,7 +154,7 @@ def notify_user_membership_change(client, host, port, user_id, room_id, change):
     Returns:
         Deferred
     """
-    assert change in ("join", "left")
+    assert change in ("joined", "left")
 
     uri = "http://%s:%s/_synapse/replication/user_%s_room" % (host, port, change)
 
@@ -297,7 +297,7 @@ class ReplicationRegister3PIDGuestRestServlet(RestServlet):
 
 
 class ReplicationUserJoinedLeftRoomRestServlet(RestServlet):
-    PATTERNS = [re.compile("^/_synapse/replication/user_(?P<change>join|left)_room$")]
+    PATTERNS = [re.compile("^/_synapse/replication/user_(?P<change>joined|left)_room$")]
 
     def __init__(self, hs):
         super(ReplicationUserJoinedLeftRoomRestServlet, self).__init__()
@@ -317,7 +317,7 @@ class ReplicationUserJoinedLeftRoomRestServlet(RestServlet):
 
         user = UserID.from_string(user_id)
 
-        if change == "join":
+        if change == "joined":
             user_joined_room(self.distributor, user, room_id)
         elif change == "left":
             user_left_room(self.distributor, user, room_id)