summary refs log tree commit diff
path: root/synapse/server.py
diff options
context:
space:
mode:
Diffstat (limited to 'synapse/server.py')
-rw-r--r--synapse/server.py12
1 files changed, 7 insertions, 5 deletions
diff --git a/synapse/server.py b/synapse/server.py

index 8e41112530..01bb26557f 100644 --- a/synapse/server.py +++ b/synapse/server.py
@@ -105,7 +105,7 @@ from synapse.server_notices.worker_server_notices_sender import ( WorkerServerNoticesSender, ) from synapse.state import StateHandler, StateResolutionHandler -from synapse.storage import DataStore, DataStores, Storage +from synapse.storage import Databases, DataStore, Storage from synapse.streams.events import EventSources from synapse.util import Clock from synapse.util.distributor import Distributor @@ -178,6 +178,7 @@ class HomeServer(object): "event_builder_factory", "filtering", "http_client_context_factory", + "proxied_http_client", "simple_http_client", "proxied_http_client", "media_repository", @@ -216,6 +217,7 @@ class HomeServer(object): "replication_streamer", "replication_data_handler", "replication_streams", + "password_policy_handler", ] REQUIRED_ON_MASTER_STARTUP = ["user_directory_handler", "stats_handler"] @@ -280,7 +282,7 @@ class HomeServer(object): def setup(self): logger.info("Setting up.") self.start_time = int(self.get_clock().time()) - self.datastores = DataStores(self.DATASTORE_CLASS, self) + self.datastores = Databases(self.DATASTORE_CLASS, self) logger.info("Finished setting up.") def setup_master(self): @@ -579,9 +581,6 @@ class HomeServer(object): def build_event_client_serializer(self): return EventClientSerializer(self) - def build_password_policy_handler(self): - return PasswordPolicyHandler(self) - def build_storage(self) -> Storage: return Storage(self, self.datastores) @@ -594,6 +593,9 @@ class HomeServer(object): def build_replication_streams(self): return {stream.NAME: stream(self) for stream in STREAMS_MAP.values()} + def build_password_policy_handler(self): + return PasswordPolicyHandler(self) + def remove_pusher(self, app_id, push_key, user_id): return self.get_pusherpool().remove_pusher(app_id, push_key, user_id)