diff options
| author | Mark Haines <mjark@negativecurvature.net> | 2016-03-16 11:26:22 +0000 |
|---|---|---|
| committer | Mark Haines <mjark@negativecurvature.net> | 2016-03-16 11:26:22 +0000 |
| commit | add89a03a68c9b4471546945389235184e640726 (patch) | |
| tree | bab9829607686f8b03dce2f542716ac8b418f31e /synapse/rest | |
| parent | Merge pull request #648 from matrix-org/rav/password_reset (diff) | |
| parent | Add a comment to offer a hint to an explanation for why we have a unique cons... (diff) | |
| download | synapse-add89a03a68c9b4471546945389235184e640726.tar.xz | |
Merge pull request #647 from matrix-org/markjh/pushers_stream
Add replication stream for pushers
Diffstat (limited to 'synapse/rest')
| -rw-r--r-- | synapse/rest/client/v1/pusher.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/rest/client/v1/pusher.py b/synapse/rest/client/v1/pusher.py index ee029b4f77..9881f068c3 100644 --- a/synapse/rest/client/v1/pusher.py +++ b/synapse/rest/client/v1/pusher.py @@ -29,6 +29,10 @@ logger = logging.getLogger(__name__) class PusherRestServlet(ClientV1RestServlet): PATTERNS = client_path_patterns("/pushers/set$") + def __init__(self, hs): + super(PusherRestServlet, self).__init__(hs) + self.notifier = hs.get_notifier() + @defer.inlineCallbacks def on_POST(self, request): requester = yield self.auth.get_user_by_req(request) @@ -87,6 +91,8 @@ class PusherRestServlet(ClientV1RestServlet): raise SynapseError(400, "Config Error: " + pce.message, errcode=Codes.MISSING_PARAM) + self.notifier.on_new_replication_data() + defer.returnValue((200, {})) def on_OPTIONS(self, _): |