diff options
author | Patrick Cloke <patrickc@matrix.org> | 2023-09-13 14:27:16 -0400 |
---|---|---|
committer | Patrick Cloke <patrickc@matrix.org> | 2023-09-13 14:35:46 -0400 |
commit | 8bb700e9ac897cfcb07de7ff438a208c7a23f569 (patch) | |
tree | 8d012687463ad70d3afecdfb82ac73590fa2874c /synapse/replication/http/send_event.py | |
parent | Working version. (diff) | |
parent | Remove a reference cycle in background process (#16314) (diff) | |
download | synapse-8bb700e9ac897cfcb07de7ff438a208c7a23f569.tar.xz |
Merge remote-tracking branch 'origin/develop' into clokep/psycopg3
Diffstat (limited to 'synapse/replication/http/send_event.py')
-rw-r--r-- | synapse/replication/http/send_event.py | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/synapse/replication/http/send_event.py b/synapse/replication/http/send_event.py index 4215a1c1bc..27ad914075 100644 --- a/synapse/replication/http/send_event.py +++ b/synapse/replication/http/send_event.py @@ -21,7 +21,6 @@ from synapse.api.room_versions import KNOWN_ROOM_VERSIONS from synapse.events import EventBase, make_event_from_dict from synapse.events.snapshot import EventContext from synapse.http.server import HttpServer -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.metrics import Measure @@ -114,11 +113,9 @@ class ReplicationSendEventRestServlet(ReplicationEndpoint): return payload async def _handle_request( # type: ignore[override] - self, request: Request, event_id: str + self, request: Request, content: JsonDict, event_id: str ) -> Tuple[int, JsonDict]: with Measure(self.clock, "repl_send_event_parse"): - content = parse_json_object_from_request(request) - event_dict = content["event"] room_ver = KNOWN_ROOM_VERSIONS[content["room_version"]] internal_metadata = content["internal_metadata"] |