diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2023-05-09 07:23:27 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-05-09 07:23:27 -0400 |
| commit | 2bfe3f0b8193b62a92975b1f89f6b2e0eb643091 (patch) | |
| tree | fec8d0bebeedd6664d6bea9759c9064a2a481845 /synapse/handlers | |
| parent | Bump hiredis from 2.2.2 to 2.2.3 (#15552) (diff) | |
| download | synapse-2bfe3f0b8193b62a92975b1f89f6b2e0eb643091.tar.xz | |
Use account data constants in more places. (#15554)
Diffstat (limited to 'synapse/handlers')
| -rw-r--r-- | synapse/handlers/read_marker.py | 5 | ||||
| -rw-r--r-- | synapse/handlers/sync.py | 12 |
2 files changed, 9 insertions, 8 deletions
diff --git a/synapse/handlers/read_marker.py b/synapse/handlers/read_marker.py index 05122fd5a6..6d35e61880 100644 --- a/synapse/handlers/read_marker.py +++ b/synapse/handlers/read_marker.py @@ -15,6 +15,7 @@ import logging from typing import TYPE_CHECKING +from synapse.api.constants import ReceiptTypes from synapse.util.async_helpers import Linearizer if TYPE_CHECKING: @@ -42,7 +43,7 @@ class ReadMarkerHandler: async with self.read_marker_linearizer.queue((room_id, user_id)): existing_read_marker = await self.store.get_account_data_for_room_and_type( - user_id, room_id, "m.fully_read" + user_id, room_id, ReceiptTypes.FULLY_READ ) should_update = True @@ -56,5 +57,5 @@ class ReadMarkerHandler: if should_update: content = {"event_id": event_id} await self.account_data_handler.add_account_data_to_room( - user_id, room_id, "m.fully_read", content + user_id, room_id, ReceiptTypes.FULLY_READ, content ) diff --git a/synapse/handlers/sync.py b/synapse/handlers/sync.py index 64d298408d..cc05b0afa0 100644 --- a/synapse/handlers/sync.py +++ b/synapse/handlers/sync.py @@ -1777,18 +1777,18 @@ class SyncHandler: if push_rules_changed: global_account_data = dict(global_account_data) - global_account_data["m.push_rules"] = await self.push_rules_for_user( - sync_config.user - ) + global_account_data[ + AccountDataTypes.PUSH_RULES + ] = await self.push_rules_for_user(sync_config.user) else: all_global_account_data = await self.store.get_global_account_data_for_user( user_id ) global_account_data = dict(all_global_account_data) - global_account_data["m.push_rules"] = await self.push_rules_for_user( - sync_config.user - ) + global_account_data[ + AccountDataTypes.PUSH_RULES + ] = await self.push_rules_for_user(sync_config.user) account_data_for_user = ( await sync_config.filter_collection.filter_global_account_data( |