summary refs log tree commit diff
path: root/synapse/rest/admin/server_notice_servlet.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-10-18 11:53:02 +0200
committerGitHub <noreply@github.com>2019-10-18 11:53:02 +0200
commitd98029ea89ffc19a80a00299c1f2aff06f7b778d (patch)
tree2156796e5e8bef890dc3c7b6c82c8d61423ada8a /synapse/rest/admin/server_notice_servlet.py
parentAdd missing BOOLEAN_COLUMNs to synapse_port_db (#6216) (diff)
parentPort synapse/rest/client/_base.py to async/await (diff)
downloadsynapse-d98029ea89ffc19a80a00299c1f2aff06f7b778d.tar.xz
Merge pull request #6196 from matrix-org/erikj/await
Move rest/admin to use async/await.
Diffstat (limited to 'synapse/rest/admin/server_notice_servlet.py')
-rw-r--r--synapse/rest/admin/server_notice_servlet.py9
1 files changed, 3 insertions, 6 deletions
diff --git a/synapse/rest/admin/server_notice_servlet.py b/synapse/rest/admin/server_notice_servlet.py

index ae2cbe2e0a..6e9a874121 100644 --- a/synapse/rest/admin/server_notice_servlet.py +++ b/synapse/rest/admin/server_notice_servlet.py
@@ -14,8 +14,6 @@ # limitations under the License. import re -from twisted.internet import defer - from synapse.api.constants import EventTypes from synapse.api.errors import SynapseError from synapse.http.servlet import ( @@ -69,9 +67,8 @@ class SendServerNoticeServlet(RestServlet): self.__class__.__name__, ) - @defer.inlineCallbacks - def on_POST(self, request, txn_id=None): - yield assert_requester_is_admin(self.auth, request) + async def on_POST(self, request, txn_id=None): + await assert_requester_is_admin(self.auth, request) body = parse_json_object_from_request(request) assert_params_in_dict(body, ("user_id", "content")) event_type = body.get("type", EventTypes.Message) @@ -85,7 +82,7 @@ class SendServerNoticeServlet(RestServlet): if not self.hs.is_mine_id(user_id): raise SynapseError(400, "Server notices can only be sent to local users") - event = yield self.snm.send_notice( + event = await self.snm.send_notice( user_id=body["user_id"], type=event_type, state_key=state_key,