diff options
author | Erik Johnston <erik@matrix.org> | 2018-08-24 14:50:03 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2018-08-24 14:50:03 +0100 |
commit | cdd24449eeec12f869ceca233085f957d8dc7d19 (patch) | |
tree | f4f155b138d4504cb6020edba38019f91282936f /synapse/server_notices/resource_limits_server_notices.py | |
parent | Make content of tag an empty object rather than null (diff) | |
download | synapse-cdd24449eeec12f869ceca233085f957d8dc7d19.tar.xz |
Ensure we wake up /sync when we add tag to notice room
Diffstat (limited to 'synapse/server_notices/resource_limits_server_notices.py')
-rw-r--r-- | synapse/server_notices/resource_limits_server_notices.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/synapse/server_notices/resource_limits_server_notices.py b/synapse/server_notices/resource_limits_server_notices.py index 7144dfcbc2..893b9001cd 100644 --- a/synapse/server_notices/resource_limits_server_notices.py +++ b/synapse/server_notices/resource_limits_server_notices.py @@ -46,6 +46,8 @@ class ResourceLimitsServerNotices(object): self._message_handler = hs.get_message_handler() self._state = hs.get_state_handler() + self._notifier = hs.get_notifier() + @defer.inlineCallbacks def maybe_send_server_notice_to_user(self, user_id): """Check if we need to send a notice to this user, this will be true in @@ -152,9 +154,12 @@ class ResourceLimitsServerNotices(object): # tag already present, nothing to do here need_to_set_tag = False if need_to_set_tag: - yield self._store.add_tag_to_room( + max_id = yield self._store.add_tag_to_room( user_id, room_id, SERVER_NOTICE_ROOM_TAG, {} ) + self._notifier.on_new_event( + "account_data_key", max_id, users=[user_id] + ) @defer.inlineCallbacks def _is_room_currently_blocked(self, room_id): |