diff options
| author | Andrej Shadura <andrewsh@debian.org> | 2022-06-19 15:20:00 +0200 |
|---|---|---|
| committer | Andrej Shadura <andrewsh@debian.org> | 2022-06-19 15:21:39 +0200 |
| commit | 734a8e556ce00029d9d7ab0fed73336d24fa91f3 (patch) | |
| tree | b277733532b1b141d534133a4715a2fe765ab533 /synapse/replication/http/send_event.py | |
| parent | 7a966d08c8403bcff00ac636d977097602501a69 (diff) | |
| parent | 6dc64c92c6991f09910f3e6db368e6eeb4b1981e (diff) | |
Update upstream source from tag 'upstream/1.61.0'
Update to upstream version '1.61.0'
with Debian dir 5b9bb60cc861cbccd0027b7db7acf826071dc6a0
Diffstat (limited to 'synapse/replication/http/send_event.py')
| -rw-r--r-- | synapse/replication/http/send_event.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/synapse/replication/http/send_event.py b/synapse/replication/http/send_event.py index ce781768..c2b2588e 100644 --- a/synapse/replication/http/send_event.py +++ b/synapse/replication/http/send_event.py @@ -70,7 +70,7 @@ class ReplicationSendEventRestServlet(ReplicationEndpoint): self.event_creation_handler = hs.get_event_creation_handler() self.store = hs.get_datastores().main - self.storage = hs.get_storage() + self._storage_controllers = hs.get_storage_controllers() self.clock = hs.get_clock() @staticmethod @@ -127,7 +127,9 @@ class ReplicationSendEventRestServlet(ReplicationEndpoint): event.internal_metadata.outlier = content["outlier"] requester = Requester.deserialize(self.store, content["requester"]) - context = EventContext.deserialize(self.storage, content["context"]) + context = EventContext.deserialize( + self._storage_controllers, content["context"] + ) ratelimit = content["ratelimit"] extra_users = [UserID.from_string(u) for u in content["extra_users"]] |