|
@@ -67,7 +67,7 @@ from synapse.replication.http.devices import ReplicationUserDevicesResyncRestSer
|
|
|
from synapse.replication.http.federation import (
|
|
|
ReplicationCleanRoomRestServlet,
|
|
|
ReplicationFederationSendEventsRestServlet,
|
|
|
- ReplicationStoreRoomOnInviteRestServlet,
|
|
|
+ ReplicationStoreRoomOnOutlierMembershipRestServlet,
|
|
|
)
|
|
|
from synapse.state import StateResolutionStore
|
|
|
from synapse.storage.databases.main.events_worker import EventRedactBehaviour
|
|
@@ -152,12 +152,14 @@ class FederationHandler(BaseHandler):
|
|
|
self._user_device_resync = ReplicationUserDevicesResyncRestServlet.make_client(
|
|
|
hs
|
|
|
)
|
|
|
- self._maybe_store_room_on_invite = ReplicationStoreRoomOnInviteRestServlet.make_client(
|
|
|
+ self._maybe_store_room_on_outlier_membership = ReplicationStoreRoomOnOutlierMembershipRestServlet.make_client(
|
|
|
hs
|
|
|
)
|
|
|
else:
|
|
|
self._device_list_updater = hs.get_device_handler().device_list_updater
|
|
|
- self._maybe_store_room_on_invite = self.store.maybe_store_room_on_invite
|
|
|
+ self._maybe_store_room_on_outlier_membership = (
|
|
|
+ self.store.maybe_store_room_on_outlier_membership
|
|
|
+ )
|
|
|
|
|
|
# When joining a room we need to queue any events for that room up.
|
|
|
# For each room, a list of (pdu, origin) tuples.
|
|
@@ -1617,7 +1619,7 @@ class FederationHandler(BaseHandler):
|
|
|
# keep a record of the room version, if we don't yet know it.
|
|
|
# (this may get overwritten if we later get a different room version in a
|
|
|
# join dance).
|
|
|
- await self._maybe_store_room_on_invite(
|
|
|
+ await self._maybe_store_room_on_outlier_membership(
|
|
|
room_id=event.room_id, room_version=room_version
|
|
|
)
|
|
|
|