async def METHOD_NAME(  # type: ignore[override]
    self, request: Request, content: JsonDict, event_id: str
) -> Tuple[int, JsonDict]:
    with Measure(self.clock, "repl_send_event_parse"):
        event_dict = content["event"]
        room_ver = KNOWN_ROOM_VERSIONS[content["room_version"]]
        internal_metadata = content["internal_metadata"]
        rejected_reason = content["rejected_reason"]
        event = make_event_from_dict(
            event_dict, room_ver, internal_metadata, rejected_reason
        )
        event.internal_metadata.outlier = content["outlier"]
        requester = Requester.deserialize(self.store, content["requester"])
        context = EventContext.deserialize(
            self._storage_controllers, content["context"]
        )
        ratelimit = content["ratelimit"]
        extra_users = [UserID.from_string(u) for u in content["extra_users"]]
    logger.info(
        "Got event to send with ID: %s into room: %s", event.event_id, event.room_id
    )
    event = await self.event_creation_handler.persist_and_notify_client_events(
        requester, [(event, context)], ratelimit=ratelimit, extra_users=extra_users
    )
    return (
        200,
        {
            "stream_id": event.internal_metadata.stream_ordering,
            "event_id": event.event_id,
        },
    )