diff options
author | Erik Johnston <erikj@jki.re> | 2017-04-12 10:21:42 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-04-12 10:21:42 +0100 |
commit | bf9060156a18a747adb23589d124370d378d38a0 (patch) | |
tree | dcab6af4131b8c3a61620225bb537cb594ed815c /synapse/replication/pusher_resource.py | |
parent | Merge pull request #2118 from matrix-org/erikj/no_devices (diff) | |
parent | Remove last reference to worker_replication_url (diff) | |
download | synapse-bf9060156a18a747adb23589d124370d378d38a0.tar.xz |
Merge pull request #2117 from matrix-org/erikj/remove_http_replication
Remove HTTP replication APIs
Diffstat (limited to 'synapse/replication/pusher_resource.py')
-rw-r--r-- | synapse/replication/pusher_resource.py | 54 |
1 files changed, 0 insertions, 54 deletions
diff --git a/synapse/replication/pusher_resource.py b/synapse/replication/pusher_resource.py deleted file mode 100644 index 9b01ab3c13..0000000000 --- a/synapse/replication/pusher_resource.py +++ /dev/null @@ -1,54 +0,0 @@ -# Copyright 2016 OpenMarket Ltd -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -from synapse.http.server import respond_with_json_bytes, request_handler -from synapse.http.servlet import parse_json_object_from_request - -from twisted.web.resource import Resource -from twisted.web.server import NOT_DONE_YET -from twisted.internet import defer - - -class PusherResource(Resource): - """ - HTTP endpoint for deleting rejected pushers - """ - - def __init__(self, hs): - Resource.__init__(self) # Resource is old-style, so no super() - - self.version_string = hs.version_string - self.store = hs.get_datastore() - self.notifier = hs.get_notifier() - self.clock = hs.get_clock() - - def render_POST(self, request): - self._async_render_POST(request) - return NOT_DONE_YET - - @request_handler() - @defer.inlineCallbacks - def _async_render_POST(self, request): - content = parse_json_object_from_request(request) - - for remove in content["remove"]: - yield self.store.delete_pusher_by_app_id_pushkey_user_id( - remove["app_id"], - remove["push_key"], - remove["user_id"], - ) - - self.notifier.on_new_replication_data() - - respond_with_json_bytes(request, 200, "{}") |