diff options
| author | Erik Johnston <erik@matrix.org> | 2021-01-18 15:47:59 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-01-18 15:47:59 +0000 |
| commit | 6633a4015a7b4ba60f87c5e6f979a9c9d8f9d8fe (patch) | |
| tree | 6e111e6f153f80e324f69f418e33fff396c19773 /synapse/handlers/read_marker.py | |
| parent | Enforce all replication HTTP clients calls use kwargs (#9144) (diff) | |
| download | synapse-6633a4015a7b4ba60f87c5e6f979a9c9d8f9d8fe.tar.xz | |
Allow moving account data and receipts streams off master (#9104)
Diffstat (limited to 'synapse/handlers/read_marker.py')
| -rw-r--r-- | synapse/handlers/read_marker.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/synapse/handlers/read_marker.py b/synapse/handlers/read_marker.py index a7550806e6..6bb2fd936b 100644 --- a/synapse/handlers/read_marker.py +++ b/synapse/handlers/read_marker.py @@ -31,8 +31,8 @@ class ReadMarkerHandler(BaseHandler): super().__init__(hs) self.server_name = hs.config.server_name self.store = hs.get_datastore() + self.account_data_handler = hs.get_account_data_handler() self.read_marker_linearizer = Linearizer(name="read_marker") - self.notifier = hs.get_notifier() async def received_client_read_marker( self, room_id: str, user_id: str, event_id: str @@ -59,7 +59,6 @@ class ReadMarkerHandler(BaseHandler): if should_update: content = {"event_id": event_id} - max_id = await self.store.add_account_data_to_room( + await self.account_data_handler.add_account_data_to_room( user_id, room_id, "m.fully_read", content ) - self.notifier.on_new_event("account_data_key", max_id, users=[user_id]) |