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/room_member.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/room_member.py')
| -rw-r--r-- | synapse/handlers/room_member.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/synapse/handlers/room_member.py b/synapse/handlers/room_member.py index cb5a29bc7e..e001e418f9 100644 --- a/synapse/handlers/room_member.py +++ b/synapse/handlers/room_member.py @@ -63,6 +63,7 @@ class RoomMemberHandler(metaclass=abc.ABCMeta): self.registration_handler = hs.get_registration_handler() self.profile_handler = hs.get_profile_handler() self.event_creation_handler = hs.get_event_creation_handler() + self.account_data_handler = hs.get_account_data_handler() self.member_linearizer = Linearizer(name="member") @@ -253,7 +254,7 @@ class RoomMemberHandler(metaclass=abc.ABCMeta): direct_rooms[key].append(new_room_id) # Save back to user's m.direct account data - await self.store.add_account_data_for_user( + await self.account_data_handler.add_account_data_for_user( user_id, AccountDataTypes.DIRECT, direct_rooms ) break @@ -263,7 +264,9 @@ class RoomMemberHandler(metaclass=abc.ABCMeta): # Copy each room tag to the new room for tag, tag_content in room_tags.items(): - await self.store.add_tag_to_room(user_id, new_room_id, tag, tag_content) + await self.account_data_handler.add_tag_to_room( + user_id, new_room_id, tag, tag_content + ) async def update_membership( self, |