diff options
author | Mark Haines <mark.haines@matrix.org> | 2016-03-04 14:44:34 +0000 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2016-03-04 14:44:34 +0000 |
commit | ec7460b4f2da70ae3ea4ddaa4a198d9dd193a045 (patch) | |
tree | 2dddf9f52591a392295bbace7a9494ab423c7cfd /synapse/handlers/message.py | |
parent | Hook up the push rules stream to account_data in /sync (diff) | |
parent | Merge pull request #598 from Rugvip/invite-state (diff) | |
download | synapse-ec7460b4f2da70ae3ea4ddaa4a198d9dd193a045.tar.xz |
Merge branch 'develop' into markjh/pushrule_stream
Diffstat (limited to 'synapse/handlers/message.py')
-rw-r--r-- | synapse/handlers/message.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/synapse/handlers/message.py b/synapse/handlers/message.py index 2fa12c8f2b..e238579164 100644 --- a/synapse/handlers/message.py +++ b/synapse/handlers/message.py @@ -215,7 +215,7 @@ class MessageHandler(BaseHandler): defer.returnValue((event, context)) @defer.inlineCallbacks - def send_nonmember_event(self, event, context, ratelimit=True): + def send_nonmember_event(self, requester, event, context, ratelimit=True): """ Persists and notifies local clients and federation of an event. @@ -241,6 +241,7 @@ class MessageHandler(BaseHandler): defer.returnValue(prev_state) yield self.handle_new_client_event( + requester=requester, event=event, context=context, ratelimit=ratelimit, @@ -268,9 +269,9 @@ class MessageHandler(BaseHandler): @defer.inlineCallbacks def create_and_send_nonmember_event( self, + requester, event_dict, ratelimit=True, - token_id=None, txn_id=None ): """ @@ -280,10 +281,11 @@ class MessageHandler(BaseHandler): """ event, context = yield self.create_event( event_dict, - token_id=token_id, + token_id=requester.access_token_id, txn_id=txn_id ) yield self.send_nonmember_event( + requester, event, context, ratelimit=ratelimit, |