diff options
author | Erik Johnston <erik@matrix.org> | 2018-03-01 15:21:11 +0000 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2018-03-13 18:26:06 +0000 |
commit | 9dce73ded3c237ead3a55f29c6dcf3f10ad18972 (patch) | |
tree | 54211389095601e926effe0395d2eece13f0ce57 /synapse | |
parent | Add is_blocked to worker store (diff) | |
download | synapse-erikj/room_member_worker.tar.xz |
Register membership/state servlets in event_creator github/erikj/room_member_worker erikj/room_member_worker
Diffstat (limited to 'synapse')
-rw-r--r-- | synapse/app/event_creator.py | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/synapse/app/event_creator.py b/synapse/app/event_creator.py index eb593c5278..8d24f7b4aa 100644 --- a/synapse/app/event_creator.py +++ b/synapse/app/event_creator.py @@ -31,14 +31,20 @@ from synapse.replication.slave.storage.account_data import SlavedAccountDataStor from synapse.replication.slave.storage.appservice import SlavedApplicationServiceStore from synapse.replication.slave.storage.client_ips import SlavedClientIpStore from synapse.replication.slave.storage.devices import SlavedDeviceStore +from synapse.replication.slave.storage.directory import DirectoryStore from synapse.replication.slave.storage.events import SlavedEventStore +from synapse.replication.slave.storage.profile import SlavedProfileStore from synapse.replication.slave.storage.push_rule import SlavedPushRuleStore from synapse.replication.slave.storage.pushers import SlavedPusherStore from synapse.replication.slave.storage.receipts import SlavedReceiptsStore from synapse.replication.slave.storage.registration import SlavedRegistrationStore from synapse.replication.slave.storage.room import RoomStore +from synapse.replication.slave.storage.transactions import TransactionStore from synapse.replication.tcp.client import ReplicationClientHandler -from synapse.rest.client.v1.room import RoomSendEventRestServlet +from synapse.rest.client.v1.room import ( + RoomSendEventRestServlet, RoomMembershipRestServlet, RoomStateEventRestServlet, + JoinRoomAliasServlet, +) from synapse.server import HomeServer from synapse.storage.engines import create_engine from synapse.util.httpresourcetree import create_resource_tree @@ -52,6 +58,9 @@ logger = logging.getLogger("synapse.app.event_creator") class EventCreatorSlavedStore( + TransactionStore, + DirectoryStore, + SlavedProfileStore, SlavedAccountDataStore, SlavedPusherStore, SlavedReceiptsStore, @@ -85,6 +94,9 @@ class EventCreatorServer(HomeServer): elif name == "client": resource = JsonResource(self, canonical_json=False) RoomSendEventRestServlet(self).register(resource) + RoomMembershipRestServlet(self).register(resource) + RoomStateEventRestServlet(self).register(resource) + JoinRoomAliasServlet(self).register(resource) resources.update({ "/_matrix/client/r0": resource, "/_matrix/client/unstable": resource, |