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(
|