diff options
author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-09-09 12:22:00 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-09-09 12:22:00 -0400 |
commit | 2ea1c682490a19e0e2df069702c1dbe419389fa4 (patch) | |
tree | 5b66ed708eb7d43362782262844e6e56d5d86b75 /synapse/replication/http | |
parent | Fixup pusher pool notifications (#8287) (diff) | |
download | synapse-2ea1c682490a19e0e2df069702c1dbe419389fa4.tar.xz |
Remove some unused distributor signals (#8216)
Removes the `user_joined_room` and stops calling it since there are no observers. Also cleans-up some other unused signals and related code.
Diffstat (limited to 'synapse/replication/http')
-rw-r--r-- | synapse/replication/http/membership.py | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/synapse/replication/http/membership.py b/synapse/replication/http/membership.py index 741329ab5f..08095fdf7d 100644 --- a/synapse/replication/http/membership.py +++ b/synapse/replication/http/membership.py @@ -19,7 +19,7 @@ from typing import TYPE_CHECKING, Optional from synapse.http.servlet import parse_json_object_from_request from synapse.replication.http._base import ReplicationEndpoint from synapse.types import JsonDict, Requester, UserID -from synapse.util.distributor import user_joined_room, user_left_room +from synapse.util.distributor import user_left_room if TYPE_CHECKING: from synapse.server import HomeServer @@ -181,9 +181,9 @@ class ReplicationUserJoinedLeftRoomRestServlet(ReplicationEndpoint): Args: room_id (str) user_id (str) - change (str): Either "joined" or "left" + change (str): "left" """ - assert change in ("joined", "left") + assert change == "left" return {} @@ -192,9 +192,7 @@ class ReplicationUserJoinedLeftRoomRestServlet(ReplicationEndpoint): user = UserID.from_string(user_id) - if change == "joined": - user_joined_room(self.distributor, user, room_id) - elif change == "left": + if change == "left": user_left_room(self.distributor, user, room_id) else: raise Exception("Unrecognized change: %r", change) |