summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
Diffstat (limited to 'examples')
-rwxr-xr-xexamples/custom_stanzas/custom_stanza_provider.py19
-rwxr-xr-xexamples/custom_stanzas/custom_stanza_user.py12
2 files changed, 17 insertions, 14 deletions
diff --git a/examples/custom_stanzas/custom_stanza_provider.py b/examples/custom_stanzas/custom_stanza_provider.py
index 9927c449..bca4a904 100755
--- a/examples/custom_stanzas/custom_stanza_provider.py
+++ b/examples/custom_stanzas/custom_stanza_provider.py
@@ -50,7 +50,7 @@ class ActionBot(slixmpp.ClientXMPP):
register_stanza_plugin(Iq, Action)
- def start(self, event):
+ async def start(self, event):
"""
Process the session_start event.
@@ -73,7 +73,7 @@ class ActionBot(slixmpp.ClientXMPP):
"""
self.event('custom_action', iq)
- def _handle_action_event(self, iq):
+ async def _handle_action_event(self, iq):
"""
Respond to the custom action event.
"""
@@ -82,17 +82,20 @@ class ActionBot(slixmpp.ClientXMPP):
if method == 'is_prime' and param == '2':
print("got message: %s" % iq)
- iq.reply()
- iq['action']['status'] = 'done'
- iq.send()
+ rep = iq.reply()
+ rep['action']['status'] = 'done'
+ await rep.send()
elif method == 'bye':
print("got message: %s" % iq)
+ rep = iq.reply()
+ rep['action']['status'] = 'done'
+ await rep.send()
self.disconnect()
else:
print("got message: %s" % iq)
- iq.reply()
- iq['action']['status'] = 'error'
- iq.send()
+ rep = iq.reply()
+ rep['action']['status'] = 'error'
+ await rep.send()
if __name__ == '__main__':
# Setup the command line arguments.
diff --git a/examples/custom_stanzas/custom_stanza_user.py b/examples/custom_stanzas/custom_stanza_user.py
index c5630584..4119aa97 100755
--- a/examples/custom_stanzas/custom_stanza_user.py
+++ b/examples/custom_stanzas/custom_stanza_user.py
@@ -43,7 +43,7 @@ class ActionUserBot(slixmpp.ClientXMPP):
register_stanza_plugin(Iq, Action)
- def start(self, event):
+ async def start(self, event):
"""
Process the session_start event.
@@ -57,11 +57,11 @@ class ActionUserBot(slixmpp.ClientXMPP):
data.
"""
self.send_presence()
- self.get_roster()
+ await self.get_roster()
- self.send_custom_iq()
+ await self.send_custom_iq()
- def send_custom_iq(self):
+ async def send_custom_iq(self):
"""Create and send two custom actions.
If the first action was successful, then send
@@ -74,14 +74,14 @@ class ActionUserBot(slixmpp.ClientXMPP):
iq['action']['param'] = '2'
try:
- resp = iq.send()
+ resp = await iq.send()
if resp['action']['status'] == 'done':
#sending bye
iq2 = self.Iq()
iq2['to'] = self.action_provider
iq2['type'] = 'set'
iq2['action']['method'] = 'bye'
- iq2.send(block=False)
+ await iq2.send()
self.disconnect()
except XMPPError: