Add back the replication requester.

synapse/replication/http/membership.py

@@ -18,6 +18,7 @@
 from twisted.web.server import Request
 
 from synapse.http.servlet import parse_json_object_from_request
+from synapse.http.site import SynapseRequest
 from synapse.replication.http._base import ReplicationEndpoint
 from synapse.types import JsonDict, Requester, UserID
 from synapse.util.distributor import user_left_room
@@ -78,13 +79,16 @@ async def _serialize_payload(  # type: ignore
         }
 
     async def _handle_request(  # type: ignore
-        self, request: Request, room_id: str, user_id: str
+        self, request: SynapseRequest, room_id: str, user_id: str
     ) -> Tuple[int, JsonDict]:
         content = parse_json_object_from_request(request)
 
         remote_room_hosts = content["remote_room_hosts"]
         event_content = content["content"]
 
+        requester = Requester.deserialize(self.store, content["requester"])
+        request.requester = requester
+
         logger.info("remote_join: %s into room: %s", user_id, room_id)
 
         event_id, stream_id = await self.federation_handler.do_invite_join(
@@ -143,14 +147,15 @@ async def _serialize_payload(  # type: ignore
         }
 
     async def _handle_request(  # type: ignore
-        self, request: Request, invite_event_id: str
+        self, request: SynapseRequest, invite_event_id: str
     ) -> Tuple[int, JsonDict]:
         content = parse_json_object_from_request(request)
 
         txn_id = content["txn_id"]
         event_content = content["content"]
 
         requester = Requester.deserialize(self.store, content["requester"])
+        request.requester = requester
 
         # hopefully we're now on the master, so this won't recurse!
         event_id, stream_id = await self.member_handler.remote_reject_invite(