Mercurial > libervia-backend

comparison sat/core/xmpp.py @ 3172:dcebc585c29f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
core: renamed "MessageReceived" trigger to "messageReceived" for consistency.
author Goffi <goffi@goffi.org>
date Tue, 18 Feb 2020 18:13:19 +0100
parents 39d7327583e1
children 343b8076e967
comparison
equal deleted inserted replaced
3171:d073d82d9044 3172:dcebc585c29f
1079 return data 1079 return data
1080 1080
1081 def _onMessageStartWorkflow(self, cont, client, message_elt, post_treat): 1081 def _onMessageStartWorkflow(self, cont, client, message_elt, post_treat):
1082 """Parse message and do post treatments 1082 """Parse message and do post treatments
1083 1083
1084 It is the first callback called after MessageReceived trigger 1084 It is the first callback called after messageReceived trigger
1085 @param cont(bool): workflow will continue only if this is True 1085 @param cont(bool): workflow will continue only if this is True
1086 @param message_elt(domish.Element): message stanza 1086 @param message_elt(domish.Element): message stanza
1087 may have be modified by triggers 1087 may have be modified by triggers
1088 @param post_treat(defer.Deferred): post parsing treatments 1088 @param post_treat(defer.Deferred): post parsing treatments
1089 """ 1089 """
1106 1106
1107 # plugin can add their treatments to this deferred 1107 # plugin can add their treatments to this deferred
1108 post_treat = defer.Deferred() 1108 post_treat = defer.Deferred()
1109 1109
1110 d = self.host.trigger.asyncPoint( 1110 d = self.host.trigger.asyncPoint(
1111 "MessageReceived", client, message_elt, post_treat 1111 "messageReceived", client, message_elt, post_treat
1112 ) 1112 )
1113 1113
1114 d.addCallback(self._onMessageStartWorkflow, client, message_elt, post_treat) 1114 d.addCallback(self._onMessageStartWorkflow, client, message_elt, post_treat)
1115 1115
1116 def skipEmptyMessage(self, data): 1116 def skipEmptyMessage(self, data):