Manual cleanup of the remaining set([…]) and set((…)).

.gitlab-ci.yml

@@ -1,21 +0,0 @@
-stages:
-  - test
-  - trigger
-
-test:
-  stage: test
-  tags:
-    - docker
-  image: ubuntu:latest
-  script:
-    - apt update
-    - apt install -y python3 cython3 gpg
-    - ./run_tests.py
-
-trigger_poezio:
-  stage: trigger
-  tags:
-    - docker
-  image: appropriate/curl:latest
-  script:
-    - curl --request POST -F token="$SLIXMPP_TRIGGER_TOKEN" -F ref=master https://lab.louiz.org/api/v4/projects/18/trigger/pipeline

.travis.yml

@@ -1,9 +1,10 @@
 language: python
 python:
+  - "2.6"
+  - "2.7"
+  - "3.2"
+  - "3.3"
   - "3.4"
-  - "3.5"
-  - "3.6"
-  - "3.7-dev"
 install:
   - "pip install ."
 script: testall.py

INSTALL

@@ -1,5 +1,5 @@
 Pre-requisites:
-- Python 3.5+
+- Python 3.4
 - Cython 0.22 and libidn, optionally (making JID faster by compiling the stringprep module)
 
 Install:

README.rst

@@ -1,7 +1,7 @@
 Slixmpp
 #########
 
-Slixmpp is an MIT licensed XMPP library for Python 3.5+. It is a fork of
+Slixmpp is an MIT licensed XMPP library for Python 3.4+. It is a fork of
 SleekXMPP.
 
 Slixmpp's goals is to only rewrite the core of the library (the low level
@@ -36,7 +36,7 @@ The Slixmpp Boilerplate
 -------------------------
 Projects using Slixmpp tend to follow a basic pattern for setting up client/component
 connections and configuration. Here is the gist of the boilerplate needed for a Slixmpp
-based project. See the documentation or examples directory for more detailed archetypes for
+based project. See the documetation or examples directory for more detailed archetypes for
 Slixmpp projects::
 
     import logging

docs/conf.py

@@ -12,17 +12,12 @@
 # serve to show the default.
 
 import sys, os
-import datetime
 
 # If extensions (or modules to document with autodoc) are in another directory,
 # add these directories to sys.path here. If the directory is relative to the
 # documentation root, use os.path.abspath to make it absolute, like shown here.
 sys.path.insert(0, os.path.abspath('..'))
 
-# get version automagically from source tree
-from slixmpp.version import __version__ as version
-release = ".".join(version.split(".")[0:2])
-
 # -- General configuration -----------------------------------------------------
 
 # If your documentation needs a minimal Sphinx version, state it here.
@@ -46,18 +41,16 @@ master_doc = 'index'
 
 # General information about the project.
 project = u'Slixmpp'
-year = datetime.datetime.now().year
-copyright = u'{}, Nathan Fritz, Lance Stout'.format(year)
+copyright = u'2011, Nathan Fritz, Lance Stout'
 
 # The version info for the project you're documenting, acts as replacement for
 # |version| and |release|, also used in various other places throughout the
 # built documents.
 #
-# auto imported from code!
 # The short X.Y version.
-# version = '1.4'
+version = '1.1'
 # The full version, including alpha/beta/rc tags.
-# release = '1.4.0'
+release = '1.1'
 
 # The language for content autogenerated by Sphinx. Refer to documentation
 # for a list of supported languages.

docs/differences.rst

@@ -3,8 +3,8 @@
 Differences from SleekXMPP
 ==========================
 
-**Python 3.5+ only**
-    slixmpp will only work on python 3.5 and above.
+**Python 3.4+ only**
+    slixmpp will only work on python 3.4 and above.
 
 **Stanza copies**
     The same stanza object is given through all the handlers; a handler that

docs/getting_started/muc.rst

@@ -1,7 +1,7 @@
 .. _mucbot:
 
 =========================
-Multi-User Chat (MUC) Bot
+Mulit-User Chat (MUC) Bot
 =========================
 
 .. note::

docs/index.rst

@@ -21,7 +21,7 @@ Slixmpp
     which goal is to use asyncio instead of threads to handle networking. See
     :ref:`differences`.
 
-Slixmpp is an :ref:`MIT licensed <license>` XMPP library for Python 3.5+,
+Slixmpp is an :ref:`MIT licensed <license>` XMPP library for Python 3.4+,
 
 Slixmpp's design goals and philosphy are:
 

examples/confirm_answer.py

@@ -15,6 +15,7 @@ from argparse import ArgumentParser
 
 import slixmpp
 from slixmpp.exceptions import XMPPError
+from slixmpp import asyncio
 
 log = logging.getLogger(__name__)
 

examples/confirm_ask.py

@@ -51,17 +51,18 @@ class AskConfirm(slixmpp.ClientXMPP):
             else:
                 self.confirmed.set_result(True)
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         log.info('Sending confirm request %s to %s who wants to access %s using '
                  'method %s...' % (self.id, self.recipient, self.url, self.method))
         try:
-            confirmed = await self['xep_0070'].ask_confirm(self.recipient,
+            confirmed = yield from self['xep_0070'].ask_confirm(self.recipient,
                                                                 id=self.id,
                                                                 url=self.url,
                                                                 method=self.method,
                                                                 message='Plz say yes or no for {method} {url} ({id}).')
             if isinstance(confirmed, slixmpp.Message):
-                confirmed = await self.confirmed
+                confirmed = yield from self.confirmed
             else:
                 confirmed = True
         except IqError:

examples/custom_stanzas/custom_stanza_provider.py

@@ -50,7 +50,7 @@ class ActionBot(slixmpp.ClientXMPP):
 
         register_stanza_plugin(Iq, Action)
 
-    async def start(self, event):
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -73,7 +73,7 @@ class ActionBot(slixmpp.ClientXMPP):
         """
         self.event('custom_action', iq)
 
-    async def _handle_action_event(self, iq):
+    def _handle_action_event(self, iq):
         """
         Respond to the custom action event.
         """
@@ -82,20 +82,17 @@ class ActionBot(slixmpp.ClientXMPP):
 
         if method == 'is_prime' and param == '2':
             print("got message: %s" % iq)
-            rep = iq.reply()
-            rep['action']['status'] = 'done'
-            await rep.send()
+            iq.reply()
+            iq['action']['status'] = 'done'
+            iq.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)
-            rep = iq.reply()
-            rep['action']['status'] = 'error'
-            await rep.send()
+            iq.reply()
+            iq['action']['status'] = 'error'
+            iq.send()
 
 if __name__ == '__main__':
     # Setup the command line arguments.

examples/custom_stanzas/custom_stanza_user.py

@@ -43,7 +43,7 @@ class ActionUserBot(slixmpp.ClientXMPP):
 
         register_stanza_plugin(Iq, Action)
 
-    async def start(self, event):
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -57,11 +57,11 @@ class ActionUserBot(slixmpp.ClientXMPP):
                      data.
         """
         self.send_presence()
-        await self.get_roster()
+        self.get_roster()
 
-        await self.send_custom_iq()
+        self.send_custom_iq()
 
-    async def send_custom_iq(self):
+    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 = await iq.send()
+            resp = iq.send()
             if resp['action']['status'] == 'done':
                 #sending bye
                 iq2 = self.Iq()
                 iq2['to'] = self.action_provider
                 iq2['type'] = 'set'
                 iq2['action']['method'] = 'bye'
-                await iq2.send()
+                iq2.send(block=False)
 
                 self.disconnect()
         except XMPPError:

examples/disco_browser.py

@@ -15,6 +15,7 @@ from argparse import ArgumentParser
 
 import slixmpp
 from slixmpp.exceptions import IqError, IqTimeout
+from slixmpp.xmlstream.asyncio import asyncio
 
 
 class Disco(slixmpp.ClientXMPP):
@@ -53,7 +54,8 @@ class Disco(slixmpp.ClientXMPP):
         # our roster.
         self.add_event_handler("session_start", self.start)
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -75,13 +77,13 @@ class Disco(slixmpp.ClientXMPP):
         try:
             if self.get in self.info_types:
                 # function using the callback parameter.
-                info = await self['xep_0030'].get_info(jid=self.target_jid,
+                info = yield from self['xep_0030'].get_info(jid=self.target_jid,
                                                             node=self.target_node)
             if self.get in self.items_types:
                 # The same applies from above. Listen for the
                 # disco_items event or pass a callback function
                 # if you need to process a non-blocking request.
-                items = await self['xep_0030'].get_items(jid=self.target_jid,
+                items = yield from self['xep_0030'].get_items(jid=self.target_jid,
                                                               node=self.target_node)
             if self.get not in self.info_types and self.get not in self.items_types:
                 logging.error("Invalid disco request type.")

examples/download_avatars.py

@@ -47,7 +47,8 @@ class AvatarDownloader(slixmpp.ClientXMPP):
         self.roster_received.set()
         self.presences_received.clear()
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -64,15 +65,16 @@ class AvatarDownloader(slixmpp.ClientXMPP):
         self.get_roster(callback=self.roster_received_cb)
 
         print('Waiting for presence updates...\n')
-        await self.roster_received.wait()
+        yield from self.roster_received.wait()
         print('Roster received')
-        await self.presences_received.wait()
+        yield from self.presences_received.wait()
         self.disconnect()
 
-    async def on_vcard_avatar(self, pres):
+    @asyncio.coroutine
+    def on_vcard_avatar(self, pres):
         print("Received vCard avatar update from %s" % pres['from'].bare)
         try:
-            result = await self['xep_0054'].get_vcard(pres['from'].bare, cached=True,
+            result = yield from self['xep_0054'].get_vcard(pres['from'].bare, cached=True,
                                                            timeout=5)
         except XMPPError:
             print("Error retrieving avatar for %s" % pres['from'])
@@ -87,13 +89,14 @@ class AvatarDownloader(slixmpp.ClientXMPP):
         with open(filename, 'wb+') as img:
             img.write(avatar['BINVAL'])
 
-    async def on_avatar(self, msg):
+    @asyncio.coroutine
+    def on_avatar(self, msg):
         print("Received avatar update from %s" % msg['from'])
         metadata = msg['pubsub_event']['items']['item']['avatar_metadata']
         for info in metadata['items']:
             if not info['url']:
                 try:
-                    result = await self['xep_0084'].retrieve_avatar(msg['from'].bare, info['id'],
+                    result = yield from self['xep_0084'].retrieve_avatar(msg['from'].bare, info['id'],
                                                                          timeout=5)
                 except XMPPError:
                     print("Error retrieving avatar for %s" % msg['from'])

examples/gtalk_custom_domain.py

@@ -55,8 +55,8 @@ class GTalkBot(slixmpp.ClientXMPP):
             cert.verify('talk.google.com', der_cert)
             logging.debug("CERT: Found GTalk certificate")
         except cert.CertificateError as err:
-            logging.error(err.message)
-            self.disconnect()
+            log.error(err.message)
+            self.disconnect(send_close=False)
 
     def start(self, event):
         """

examples/http_over_xmpp.py

@@ -13,7 +13,7 @@
 
 from slixmpp import ClientXMPP
 
-from argparse import ArgumentParser
+from optparse import OptionParser
 import logging
 import getpass
 
@@ -23,7 +23,7 @@ class HTTPOverXMPPClient(ClientXMPP):
         ClientXMPP.__init__(self, jid, password)
         self.register_plugin('xep_0332')    # HTTP over XMPP Transport
         self.add_event_handler(
-            'session_start', self.session_start
+            'session_start', self.session_start, threaded=True
         )
         self.add_event_handler('http_request', self.http_request_received)
         self.add_event_handler('http_response', self.http_response_received)
@@ -58,40 +58,40 @@ if __name__ == '__main__':
     # ./http_over_xmpp.py -J <jid> -P <pwd> -i <ip> -p <port> [-v]
     #
 
-    parser = ArgumentParser()
+    parser = OptionParser()
 
     # Output verbosity options.
-    parser.add_argument(
+    parser.add_option(
         '-v', '--verbose', help='set logging to DEBUG', action='store_const',
         dest='loglevel', const=logging.DEBUG, default=logging.ERROR
     )
 
     # JID and password options.
-    parser.add_argument('-J', '--jid', dest='jid', help='JID')
-    parser.add_argument('-P', '--password', dest='password', help='Password')
+    parser.add_option('-J', '--jid', dest='jid', help='JID')
+    parser.add_option('-P', '--password', dest='password', help='Password')
 
     # XMPP server ip and port options.
-    parser.add_argument(
+    parser.add_option(
         '-i', '--ipaddr', dest='ipaddr',
         help='IP Address of the XMPP server', default=None
     )
-    parser.add_argument(
+    parser.add_option(
         '-p', '--port', dest='port',
         help='Port of the XMPP server', default=None
     )
 
-    args = parser.parse_args()
+    opts, args = parser.parse_args()
 
     # Setup logging.
-    logging.basicConfig(level=args.loglevel,
+    logging.basicConfig(level=opts.loglevel,
                         format='%(levelname)-8s %(message)s')
 
-    if args.jid is None:
-        args.jid = input('Username: ')
-    if args.password is None:
-        args.password = getpass.getpass('Password: ')
+    if opts.jid is None:
+        opts.jid = input('Username: ')
+    if opts.password is None:
+        opts.password = getpass.getpass('Password: ')
 
-    xmpp = HTTPOverXMPPClient(args.jid, args.password)
+    xmpp = HTTPOverXMPPClient(opts.jid, opts.password)
     xmpp.connect()
     xmpp.process()
 

examples/http_upload.py

@@ -1,96 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2018 Emmanuel Gil Peyrot
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-import logging
-from getpass import getpass
-from argparse import ArgumentParser
-
-import slixmpp
-
-log = logging.getLogger(__name__)
-
-
-class HttpUpload(slixmpp.ClientXMPP):
-
-    """
-    A basic client asking an entity if they confirm the access to an HTTP URL.
-    """
-
-    def __init__(self, jid, password, recipient, filename, domain=None):
-        slixmpp.ClientXMPP.__init__(self, jid, password)
-
-        self.recipient = recipient
-        self.filename = filename
-        self.domain = domain
-
-        self.add_event_handler("session_start", self.start)
-
-    async def start(self, event):
-        log.info('Uploading file %s...', self.filename)
-        def timeout_callback(arg):
-            raise TimeoutError("could not send message in time")
-        url = await self['xep_0363'].upload_file(
-            self.filename, domain=self.domain, timeout=10, timeout_callback=timeout_callback)
-        log.info('Upload success!')
-
-        log.info('Sending file to %s', self.recipient)
-        html = '<body xmlns="http://www.w3.org/1999/xhtml"><a href="%s">%s</a></body>' % (url, url)
-        self.send_message(self.recipient, url, mhtml=html)
-        self.disconnect()
-
-
-if __name__ == '__main__':
-    # Setup the command line arguments.
-    parser = ArgumentParser()
-    parser.add_argument("-q","--quiet", help="set logging to ERROR",
-                        action="store_const",
-                        dest="loglevel",
-                        const=logging.ERROR,
-                        default=logging.INFO)
-    parser.add_argument("-d","--debug", help="set logging to DEBUG",
-                        action="store_const",
-                        dest="loglevel",
-                        const=logging.DEBUG,
-                        default=logging.INFO)
-
-    # JID and password options.
-    parser.add_argument("-j", "--jid", dest="jid",
-                        help="JID to use")
-    parser.add_argument("-p", "--password", dest="password",
-                        help="password to use")
-
-    # Other options.
-    parser.add_argument("-r", "--recipient", required=True,
-                        help="Recipient JID")
-    parser.add_argument("-f", "--file", required=True,
-                        help="File to send")
-    parser.add_argument("--domain",
-                        help="Domain to use for HTTP File Upload (leave out for your own server’s)")
-
-    args = parser.parse_args()
-
-    # Setup logging.
-    logging.basicConfig(level=args.loglevel,
-                        format='%(levelname)-8s %(message)s')
-
-    if args.jid is None:
-        args.jid = input("Username: ")
-    if args.password is None:
-        args.password = getpass("Password: ")
-
-    xmpp = HttpUpload(args.jid, args.password, args.recipient, args.file, args.domain)
-    xmpp.register_plugin('xep_0071')
-    xmpp.register_plugin('xep_0128')
-    xmpp.register_plugin('xep_0363')
-
-    # Connect to the XMPP server and start processing XMPP stanzas.
-    xmpp.connect()
-    xmpp.process(forever=False)

examples/ibb_transfer/ibb_sender.py

@@ -9,6 +9,7 @@
     See the file LICENSE for copying permission.
 """
 
+import asyncio
 import logging
 from getpass import getpass
 from argparse import ArgumentParser
@@ -38,7 +39,8 @@ class IBBSender(slixmpp.ClientXMPP):
         # our roster.
         self.add_event_handler("session_start", self.start)
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -56,13 +58,13 @@ class IBBSender(slixmpp.ClientXMPP):
 
         try:
             # Open the IBB stream in which to write to.
-            stream = await self['xep_0047'].open_stream(self.receiver, use_messages=self.use_messages)
+            stream = yield from self['xep_0047'].open_stream(self.receiver, use_messages=self.use_messages)
 
             # If you want to send in-memory bytes, use stream.sendall() instead.
-            await stream.sendfile(self.file, timeout=10)
+            yield from stream.sendfile(self.file, timeout=10)
 
             # And finally close the stream.
-            await stream.close(timeout=10)
+            yield from stream.close(timeout=10)
         except (IqError, IqTimeout):
             print('File transfer errored')
         else:

examples/mam.py

@@ -1,97 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2017 Mathieu Pasquet
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-import logging
-from getpass import getpass
-from argparse import ArgumentParser
-
-import slixmpp
-from slixmpp.exceptions import XMPPError
-
-log = logging.getLogger(__name__)
-
-
-class MAM(slixmpp.ClientXMPP):
-
-    """
-    A basic client fetching mam archive messages
-    """
-
-    def __init__(self, jid, password, remote_jid, start):
-        slixmpp.ClientXMPP.__init__(self, jid, password)
-        self.remote_jid = remote_jid
-        self.start_date = start
-
-        self.add_event_handler("session_start", self.start)
-
-    async def start(self, *args):
-        """
-        Fetch mam results for the specified JID.
-        Use RSM to paginate the results.
-        """
-        results = self.plugin['xep_0313'].retrieve(jid=self.remote_jid, iterator=True, rsm={'max': 10}, start=self.start_date)
-        page = 1
-        async for rsm in results:
-            print('Page %d' % page)
-            for msg in rsm['mam']['results']:
-                forwarded = msg['mam_result']['forwarded']
-                timestamp = forwarded['delay']['stamp']
-                message = forwarded['stanza']
-                print('[%s] %s: %s' % (timestamp, message['from'], message['body']))
-            page += 1
-        self.disconnect()
-
-if __name__ == '__main__':
-    # Setup the command line arguments.
-    parser = ArgumentParser()
-    parser.add_argument("-q","--quiet", help="set logging to ERROR",
-                        action="store_const",
-                        dest="loglevel",
-                        const=logging.ERROR,
-                        default=logging.INFO)
-    parser.add_argument("-d","--debug", help="set logging to DEBUG",
-                        action="store_const",
-                        dest="loglevel",
-                        const=logging.DEBUG,
-                        default=logging.INFO)
-
-    # JID and password options.
-    parser.add_argument("-j", "--jid", dest="jid",
-                        help="JID to use")
-    parser.add_argument("-p", "--password", dest="password",
-                        help="password to use")
-
-    # Other options
-    parser.add_argument("-r", "--remote-jid", dest="remote_jid",
-                        help="Remote JID")
-    parser.add_argument("--start", help="Start date", default='2017-09-20T12:00:00Z')
-
-    args = parser.parse_args()
-
-    # Setup logging.
-    logging.basicConfig(level=args.loglevel,
-                        format='%(levelname)-8s %(message)s')
-
-    if args.jid is None:
-        args.jid = input("Username: ")
-    if args.password is None:
-        args.password = getpass("Password: ")
-    if args.remote_jid is None:
-        args.remote_jid = input("Remote JID: ")
-    if args.start is None:
-        args.start = input("Start time: ")
-
-    xmpp = MAM(args.jid, args.password, args.remote_jid, args.start)
-    xmpp.register_plugin('xep_0313')
-
-    # Connect to the XMPP server and start processing XMPP stanzas.
-    xmpp.connect()
-    xmpp.process(forever=False)

examples/markup.py

@@ -1,120 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2010  Nathanael C. Fritz
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-import logging
-from getpass import getpass
-from argparse import ArgumentParser
-
-import slixmpp
-from slixmpp.plugins.xep_0394 import stanza as markup_stanza
-
-
-class EchoBot(slixmpp.ClientXMPP):
-
-    """
-    A simple Slixmpp bot that will echo messages it
-    receives, along with a short thank you message.
-    """
-
-    def __init__(self, jid, password):
-        slixmpp.ClientXMPP.__init__(self, jid, password)
-
-        # The session_start event will be triggered when
-        # the bot establishes its connection with the server
-        # and the XML streams are ready for use. We want to
-        # listen for this event so that we we can initialize
-        # our roster.
-        self.add_event_handler("session_start", self.start)
-
-        # The message event is triggered whenever a message
-        # stanza is received. Be aware that that includes
-        # MUC messages and error messages.
-        self.add_event_handler("message", self.message)
-
-    def start(self, event):
-        """
-        Process the session_start event.
-
-        Typical actions for the session_start event are
-        requesting the roster and broadcasting an initial
-        presence stanza.
-
-        Arguments:
-            event -- An empty dictionary. The session_start
-                     event does not provide any additional
-                     data.
-        """
-        self.send_presence()
-        self.get_roster()
-
-    def message(self, msg):
-        """
-        Process incoming message stanzas. Be aware that this also
-        includes MUC messages and error messages. It is usually
-        a good idea to check the messages's type before processing
-        or sending replies.
-
-        Arguments:
-            msg -- The received message stanza. See the documentation
-                   for stanza objects and the Message stanza to see
-                   how it may be used.
-        """
-        body = msg['body']
-        new_body = self['xep_0394'].to_plain_text(body, msg['markup'])
-        xhtml = self['xep_0394'].to_xhtml_im(body, msg['markup'])
-        print('Plain text:', new_body)
-        print('XHTML-IM:', xhtml['body'])
-        message = msg.reply()
-        message['body'] = new_body
-        message['html']['body'] = xhtml['body']
-        self.send(message)
-
-
-if __name__ == '__main__':
-    # Setup the command line arguments.
-    parser = ArgumentParser(description=EchoBot.__doc__)
-
-    # Output verbosity options.
-    parser.add_argument("-q", "--quiet", help="set logging to ERROR",
-                        action="store_const", dest="loglevel",
-                        const=logging.ERROR, default=logging.INFO)
-    parser.add_argument("-d", "--debug", help="set logging to DEBUG",
-                        action="store_const", dest="loglevel",
-                        const=logging.DEBUG, default=logging.INFO)
-
-    # JID and password options.
-    parser.add_argument("-j", "--jid", dest="jid",
-                        help="JID to use")
-    parser.add_argument("-p", "--password", dest="password",
-                        help="password to use")
-
-    args = parser.parse_args()
-
-    # Setup logging.
-    logging.basicConfig(level=args.loglevel,
-                        format='%(levelname)-8s %(message)s')
-
-    if args.jid is None:
-        args.jid = input("Username: ")
-    if args.password is None:
-        args.password = getpass("Password: ")
-
-    # Setup the EchoBot and register plugins. Note that while plugins may
-    # have interdependencies, the order in which you register them does
-    # not matter.
-    xmpp = EchoBot(args.jid, args.password)
-    xmpp.register_plugin('xep_0030') # Service Discovery
-    xmpp.register_plugin('xep_0199') # XMPP Ping
-    xmpp.register_plugin('xep_0394') # Message Markup
-
-    # Connect to the XMPP server and start processing XMPP stanzas.
-    xmpp.connect()
-    xmpp.process()

examples/ping.py

@@ -13,6 +13,7 @@ import logging
 from getpass import getpass
 from argparse import ArgumentParser
 from slixmpp.exceptions import IqError, IqTimeout
+from slixmpp import asyncio
 
 import slixmpp
 
@@ -37,7 +38,8 @@ class PingTest(slixmpp.ClientXMPP):
         # our roster.
         self.add_event_handler("session_start", self.start)
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -54,7 +56,7 @@ class PingTest(slixmpp.ClientXMPP):
         self.get_roster()
 
         try:
-            rtt = await self['xep_0199'].ping(self.pingjid,
+            rtt = yield from self['xep_0199'].ping(self.pingjid,
                                                    timeout=10)
             logging.info("Success! RTT: %s", rtt)
         except IqError as e:

examples/pubsub_client.py

@@ -5,6 +5,7 @@ import logging
 from getpass import getpass
 from argparse import ArgumentParser
 
+import asyncio
 import slixmpp
 from slixmpp.exceptions import XMPPError
 from slixmpp.xmlstream import ET, tostring
@@ -20,7 +21,7 @@ class PubsubClient(slixmpp.ClientXMPP):
         self.register_plugin('xep_0059')
         self.register_plugin('xep_0060')
 
-        self.actions = ['nodes', 'create', 'delete', 'get_configure',
+        self.actions = ['nodes', 'create', 'delete',
                         'publish', 'get', 'retract',
                         'purge', 'subscribe', 'unsubscribe']
 
@@ -31,86 +32,80 @@ class PubsubClient(slixmpp.ClientXMPP):
 
         self.add_event_handler('session_start', self.start)
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         self.get_roster()
         self.send_presence()
 
         try:
-            await getattr(self, self.action)()
+            yield from getattr(self, self.action)()
         except:
-            logging.exception('Could not execute %s:', self.action)
+            logging.error('Could not execute: %s', self.action)
         self.disconnect()
 
-    async def nodes(self):
+    def nodes(self):
         try:
-            result = await self['xep_0060'].get_nodes(self.pubsub_server, self.node)
+            result = yield from self['xep_0060'].get_nodes(self.pubsub_server, self.node)
             for item in result['disco_items']['items']:
                 logging.info('  - %s', str(item))
         except XMPPError as error:
             logging.error('Could not retrieve node list: %s', error.format())
 
-    async def create(self):
+    def create(self):
         try:
-            await self['xep_0060'].create_node(self.pubsub_server, self.node)
+            yield from self['xep_0060'].create_node(self.pubsub_server, self.node)
             logging.info('Created node %s', self.node)
         except XMPPError as error:
             logging.error('Could not create node %s: %s', self.node, error.format())
 
-    async def delete(self):
+    def delete(self):
         try:
-            await self['xep_0060'].delete_node(self.pubsub_server, self.node)
+            yield from self['xep_0060'].delete_node(self.pubsub_server, self.node)
             logging.info('Deleted node %s', self.node)
         except XMPPError as error:
             logging.error('Could not delete node %s: %s', self.node, error.format())
 
-    async def get_configure(self):
-        try:
-            configuration_form = await self['xep_0060'].get_node_config(self.pubsub_server, self.node)
-            logging.info('Configure form received from node %s: %s', self.node, configuration_form['pubsub_owner']['configure']['form'])
-        except XMPPError as error:
-            logging.error('Could not retrieve configure form from node %s: %s', self.node, error.format())
-
-    async def publish(self):
+    def publish(self):
         payload = ET.fromstring("<test xmlns='test'>%s</test>" % self.data)
         try:
-            result = await self['xep_0060'].publish(self.pubsub_server, self.node, payload=payload)
+            result = yield from self['xep_0060'].publish(self.pubsub_server, self.node, payload=payload)
             logging.info('Published at item id: %s', result['pubsub']['publish']['item']['id'])
         except XMPPError as error:
             logging.error('Could not publish to %s: %s', self.node, error.format())
 
-    async def get(self):
+    def get(self):
         try:
-            result = await self['xep_0060'].get_item(self.pubsub_server, self.node, self.data)
+            result = yield from self['xep_0060'].get_item(self.pubsub_server, self.node, self.data)
             for item in result['pubsub']['items']['substanzas']:
                 logging.info('Retrieved item %s: %s', item['id'], tostring(item['payload']))
         except XMPPError as error:
             logging.error('Could not retrieve item %s from node %s: %s', self.data, self.node, error.format())
 
-    async def retract(self):
+    def retract(self):
         try:
-            await self['xep_0060'].retract(self.pubsub_server, self.node, self.data)
+            yield from self['xep_0060'].retract(self.pubsub_server, self.node, self.data)
             logging.info('Retracted item %s from node %s', self.data, self.node)
         except XMPPError as error:
             logging.error('Could not retract item %s from node %s: %s', self.data, self.node, error.format())
 
-    async def purge(self):
+    def purge(self):
         try:
-            await self['xep_0060'].purge(self.pubsub_server, self.node)
+            yield from self['xep_0060'].purge(self.pubsub_server, self.node)
             logging.info('Purged all items from node %s', self.node)
         except XMPPError as error:
             logging.error('Could not purge items from node %s: %s', self.node, error.format())
 
-    async def subscribe(self):
+    def subscribe(self):
         try:
-            iq = await self['xep_0060'].subscribe(self.pubsub_server, self.node)
+            iq = yield from self['xep_0060'].subscribe(self.pubsub_server, self.node)
             subscription = iq['pubsub']['subscription']
             logging.info('Subscribed %s to node %s', subscription['jid'], subscription['node'])
         except XMPPError as error:
             logging.error('Could not subscribe %s to node %s: %s', self.boundjid.bare, self.node, error.format())
 
-    async def unsubscribe(self):
+    def unsubscribe(self):
         try:
-            await self['xep_0060'].unsubscribe(self.pubsub_server, self.node)
+            yield from self['xep_0060'].unsubscribe(self.pubsub_server, self.node)
             logging.info('Unsubscribed %s from node %s', self.boundjid.bare, self.node)
         except XMPPError as error:
             logging.error('Could not unsubscribe %s from node %s: %s', self.boundjid.bare, self.node, error.format())
@@ -123,7 +118,7 @@ if __name__ == '__main__':
     parser = ArgumentParser()
     parser.version = '%%prog 0.1'
     parser.usage = "Usage: %%prog [options] <jid> " + \
-                             'nodes|create|delete|get_configure|purge|subscribe|unsubscribe|publish|retract|get' + \
+                             'nodes|create|delete|purge|subscribe|unsubscribe|publish|retract|get' + \
                              ' [<node> <data>]'
 
     parser.add_argument("-q","--quiet", help="set logging to ERROR",
@@ -144,7 +139,7 @@ if __name__ == '__main__':
                         help="password to use")
 
     parser.add_argument("server")
-    parser.add_argument("action", choices=["nodes", "create", "delete", "get_configure", "purge", "subscribe", "unsubscribe", "publish", "retract", "get"])
+    parser.add_argument("action", choices=["nodes", "create", "delete", "purge", "subscribe", "unsubscribe", "publish", "retract", "get"])
     parser.add_argument("node", nargs='?')
     parser.add_argument("data", nargs='?')
 

examples/register_account.py

@@ -66,7 +66,7 @@ class RegisterBot(slixmpp.ClientXMPP):
         # We're only concerned about registering, so nothing more to do here.
         self.disconnect()
 
-    async def register(self, iq):
+    def register(self, iq):
         """
         Fill out and submit a registration form.
 
@@ -90,7 +90,7 @@ class RegisterBot(slixmpp.ClientXMPP):
         resp['register']['password'] = self.password
 
         try:
-            await resp.send()
+            yield from resp.send()
             logging.info("Account created for %s!" % self.boundjid)
         except IqError as e:
             logging.error("Could not register account: %s" %

examples/roster_browser.py

@@ -38,7 +38,8 @@ class RosterBrowser(slixmpp.ClientXMPP):
         self.received = set()
         self.presences_received = asyncio.Event()
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -56,7 +57,7 @@ class RosterBrowser(slixmpp.ClientXMPP):
             future.set_result(None)
         try:
             self.get_roster(callback=callback)
-            await future
+            yield from future
         except IqError as err:
             print('Error: %s' % err.iq['error']['condition'])
         except IqTimeout:
@@ -65,7 +66,7 @@ class RosterBrowser(slixmpp.ClientXMPP):
 
 
         print('Waiting for presence updates...\n')
-        await asyncio.sleep(10)
+        yield from asyncio.sleep(10)
 
         print('Roster for %s' % self.boundjid.bare)
         groups = self.client_roster.groups()

examples/s5b_transfer/s5b_receiver.py

@@ -9,6 +9,7 @@
     See the file LICENSE for copying permission.
 """
 
+import asyncio
 import logging
 from getpass import getpass
 from argparse import ArgumentParser

examples/s5b_transfer/s5b_sender.py

@@ -9,6 +9,7 @@
     See the file LICENSE for copying permission.
 """
 
+import asyncio
 import logging
 from getpass import getpass
 from argparse import ArgumentParser
@@ -35,7 +36,8 @@ class S5BSender(slixmpp.ClientXMPP):
         # and the XML streams are ready for use.
         self.add_event_handler("session_start", self.start)
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -51,14 +53,14 @@ class S5BSender(slixmpp.ClientXMPP):
 
         try:
             # Open the S5B stream in which to write to.
-            proxy = await self['xep_0065'].handshake(self.receiver)
+            proxy = yield from self['xep_0065'].handshake(self.receiver)
 
             # Send the entire file.
             while True:
                 data = self.file.read(1048576)
                 if not data:
                     break
-                await proxy.write(data)
+                yield from proxy.write(data)
 
             # And finally close the stream.
             proxy.transport.write_eof()

examples/set_avatar.py

@@ -18,6 +18,7 @@ from argparse import ArgumentParser
 
 import slixmpp
 from slixmpp.exceptions import XMPPError
+from slixmpp import asyncio
 
 class AvatarSetter(slixmpp.ClientXMPP):
 
@@ -32,7 +33,8 @@ class AvatarSetter(slixmpp.ClientXMPP):
 
         self.filepath = filepath
 
-    async def start(self, event):
+    @asyncio.coroutine
+    def start(self, event):
         """
         Process the session_start event.
 
@@ -66,20 +68,20 @@ class AvatarSetter(slixmpp.ClientXMPP):
         used_xep84 = False
 
         print('Publish XEP-0084 avatar data')
-        result = await self['xep_0084'].publish_avatar(avatar)
+        result = yield from self['xep_0084'].publish_avatar(avatar)
         if isinstance(result, XMPPError):
             print('Could not publish XEP-0084 avatar')
         else:
             used_xep84 = True
 
         print('Update vCard with avatar')
-        result = await self['xep_0153'].set_avatar(avatar=avatar, mtype=avatar_type)
+        result = yield from self['xep_0153'].set_avatar(avatar=avatar, mtype=avatar_type)
         if isinstance(result, XMPPError):
             print('Could not set vCard avatar')
 
         if used_xep84:
             print('Advertise XEP-0084 avatar metadata')
-            result = await self['xep_0084'].publish_avatar_metadata([
+            result = yield from self['xep_0084'].publish_avatar_metadata([
                 {'id': avatar_id,
                  'type': avatar_type,
                  'bytes': avatar_bytes}

setup.py

@@ -9,7 +9,7 @@
 
 import os
 from pathlib import Path
-from subprocess import call, DEVNULL, check_output, CalledProcessError
+from subprocess import call, DEVNULL
 from tempfile import TemporaryFile
 try:
     from setuptools import setup
@@ -29,40 +29,24 @@ CLASSIFIERS = [
     'Intended Audience :: Developers',
     'License :: OSI Approved :: MIT License',
     'Programming Language :: Python',
-    'Programming Language :: Python :: 3.5',
-    'Programming Language :: Python :: 3.6',
-    'Programming Language :: Python :: 3.7',
-    'Topic :: Internet :: XMPP',
+    'Programming Language :: Python :: 3.4',
     'Topic :: Software Development :: Libraries :: Python Modules',
 ]
 
 packages = [str(mod.parent) for mod in Path('slixmpp').rglob('__init__.py')]
 
-def check_include(library_name, header):
-    command = [os.environ.get('PKG_CONFIG', 'pkg-config'), '--cflags', library_name]
-    try:
-        cflags = check_output(command).decode('utf-8').split()
-    except FileNotFoundError:
-        print('pkg-config not found.')
-        return False
-    except CalledProcessError:
-        # pkg-config already prints the missing libraries on stderr.
-        return False
-    command = [os.environ.get('CC', 'cc')] + cflags + ['-E', '-']
+def check_include(header):
+    command = [os.environ.get('CC', 'cc'), '-E', '-']
     with TemporaryFile('w+') as c_file:
         c_file.write('#include <%s>' % header)
         c_file.seek(0)
         try:
             return call(command, stdin=c_file, stdout=DEVNULL, stderr=DEVNULL) == 0
         except FileNotFoundError:
-            print('%s headers not found.' % library_name)
             return False
 
-HAS_PYTHON_HEADERS = check_include('python3', 'Python.h')
-HAS_STRINGPREP_HEADERS = check_include('libidn', 'stringprep.h')
-
 ext_modules = None
-if HAS_PYTHON_HEADERS and HAS_STRINGPREP_HEADERS:
+if check_include('stringprep.h'):
     try:
         from Cython.Build import cythonize
     except ImportError:
@@ -70,7 +54,7 @@ if HAS_PYTHON_HEADERS and HAS_STRINGPREP_HEADERS:
     else:
         ext_modules = cythonize('slixmpp/stringprep.pyx')
 else:
-    print('Falling back to the slow stringprep module.')
+    print('libidn-dev not found, falling back to the slow stringprep module.')
 
 setup(
     name="slixmpp",
@@ -84,7 +68,7 @@ setup(
     platforms=['any'],
     packages=packages,
     ext_modules=ext_modules,
-    install_requires=['aiodns>=1.0', 'pyasn1', 'pyasn1_modules', 'aiohttp'],
+    install_requires=['aiodns>=1.0', 'pyasn1', 'pyasn1_modules'],
     classifiers=CLASSIFIERS,
     cmdclass={'test': TestCommand}
 )

slixmpp/__init__.py

@@ -6,13 +6,12 @@
     See the file LICENSE for copying permission.
 """
 
+import asyncio
+if hasattr(asyncio, 'sslproto'): # no ssl proto: very old asyncio = no need for this
+    asyncio.sslproto._is_sslproto_available=lambda: False
 import logging
 logging.getLogger(__name__).addHandler(logging.NullHandler())
 
-import asyncio
-# Required for python < 3.7 to use the old ssl implementation
-# and manage to do starttls as an unintended side effect
-asyncio.sslproto._is_sslproto_available = lambda: False
 
 from slixmpp.stanza import Message, Presence, Iq
 from slixmpp.jid import JID, InvalidJID

slixmpp/clientxmpp.py

@@ -15,7 +15,6 @@
 import asyncio
 import logging
 
-from slixmpp.jid import JID
 from slixmpp.stanza import StreamFeatures
 from slixmpp.basexmpp import BaseXMPP
 from slixmpp.exceptions import XMPPError
@@ -109,21 +108,10 @@ class ClientXMPP(BaseXMPP):
                 CoroutineCallback('Stream Features',
                      MatchXPath('{%s}features' % self.stream_ns),
                      self._handle_stream_features))
-        def roster_push_filter(iq):
-            from_ = iq['from']
-            if from_ and from_ != JID('') and from_ != self.boundjid.bare:
-                reply = iq.reply()
-                reply['type'] = 'error'
-                reply['error']['type'] = 'cancel'
-                reply['error']['code'] = 503
-                reply['error']['condition'] = 'service-unavailable'
-                reply.send()
-                return
-            self.event('roster_update', iq)
         self.register_handler(
                 Callback('Roster Update',
                          StanzaPath('iq@type=set/roster'),
-                         roster_push_filter))
+                         lambda iq: self.event('roster_update', iq)))
 
         # Setup default stream features
         self.register_plugin('feature_starttls')
@@ -255,7 +243,7 @@ class ClientXMPP(BaseXMPP):
                 orig_cb(resp)
             callback = wrapped
 
-        return iq.send(callback, timeout, timeout_callback)
+        iq.send(callback, timeout, timeout_callback)
 
     def _reset_connection_state(self, event=None):
         #TODO: Use stream state here
@@ -265,7 +253,8 @@ class ClientXMPP(BaseXMPP):
         self.bindfail = False
         self.features = set()
 
-    async def _handle_stream_features(self, features):
+    @asyncio.coroutine
+    def _handle_stream_features(self, features):
         """Process the received stream features.
 
         :param features: The features stanza.
@@ -274,7 +263,7 @@ class ClientXMPP(BaseXMPP):
             if name in features['features']:
                 handler, restart = self._stream_feature_handlers[name]
                 if asyncio.iscoroutinefunction(handler):
-                    result = await handler(features)
+                    result = yield from handler(features)
                 else:
                     result = handler(features)
                 if result and restart:

slixmpp/features/feature_bind/bind.py

@@ -35,7 +35,8 @@ class FeatureBind(BasePlugin):
         register_stanza_plugin(Iq, stanza.Bind)
         register_stanza_plugin(StreamFeatures, stanza.Bind)
 
-    async def _handle_bind_resource(self, features):
+    @asyncio.coroutine
+    def _handle_bind_resource(self, features):
         """
         Handle requesting a specific resource.
 
@@ -50,7 +51,7 @@ class FeatureBind(BasePlugin):
         if self.xmpp.requested_jid.resource:
             iq['bind']['resource'] = self.xmpp.requested_jid.resource
 
-        await iq.send(callback=self._on_bind_response)
+        yield from iq.send(callback=self._on_bind_response)
 
     def _on_bind_response(self, response):
         self.xmpp.boundjid = JID(response['bind']['jid'])

slixmpp/features/feature_mechanisms/mechanisms.py

@@ -97,7 +97,13 @@ class FeatureMechanisms(BasePlugin):
                 jid = self.xmpp.requested_jid.bare
                 result[value] = creds.get('email', jid)
             elif value == 'channel_binding':
-                result[value] = self.xmpp.socket.get_channel_binding()
+                if hasattr(self.xmpp.socket, 'get_channel_binding'):
+                    result[value] = self.xmpp.socket.get_channel_binding()
+                else:
+                    log.debug("Channel binding not supported.")
+                    log.debug("Use Python 3.3+ for channel binding and " + \
+                              "SCRAM-SHA-1-PLUS support")
+                    result[value] = None
             elif value == 'host':
                 result[value] = creds.get('host', self.xmpp.requested_jid.domain)
             elif value == 'realm':
@@ -116,7 +122,7 @@ class FeatureMechanisms(BasePlugin):
             if value == 'encrypted':
                 if 'starttls' in self.xmpp.features:
                     result[value] = True
-                elif isinstance(self.xmpp.socket, (ssl.SSLSocket, ssl.SSLObject)):
+                elif isinstance(self.xmpp.socket, ssl.SSLSocket):
                     result[value] = True
                 else:
                     result[value] = False

slixmpp/features/feature_session/session.py

@@ -35,22 +35,18 @@ class FeatureSession(BasePlugin):
         register_stanza_plugin(Iq, stanza.Session)
         register_stanza_plugin(StreamFeatures, stanza.Session)
 
-    async def _handle_start_session(self, features):
+    @asyncio.coroutine
+    def _handle_start_session(self, features):
         """
         Handle the start of the session.
 
         Arguments:
             feature -- The stream features element.
         """
-        if features['session']['optional']:
-            self.xmpp.sessionstarted = True
-            self.xmpp.event('session_start')
-            return
-
         iq = self.xmpp.Iq()
         iq['type'] = 'set'
         iq.enable('session')
-        await iq.send(callback=self._on_start_session_response)
+        yield from iq.send(callback=self._on_start_session_response)
 
     def _on_start_session_response(self, response):
         self.xmpp.features.add('session')

slixmpp/features/feature_session/stanza.py

@@ -6,7 +6,7 @@
     See the file LICENSE for copying permission.
 """
 
-from slixmpp.xmlstream import ElementBase, ET
+from slixmpp.xmlstream import ElementBase
 
 
 class Session(ElementBase):
@@ -16,19 +16,5 @@ class Session(ElementBase):
 
     name = 'session'
     namespace = 'urn:ietf:params:xml:ns:xmpp-session'
-    interfaces = {'optional'}
+    interfaces = set()
     plugin_attrib = 'session'
-
-    def get_optional(self):
-        return self.xml.find('{%s}optional' % self.namespace) is not None
-
-    def set_optional(self, value):
-        if value:
-            optional = ET.Element('{%s}optional' % self.namespace)
-            self.xml.append(optional)
-        else:
-            self.del_optional()
-
-    def del_optional(self):
-        optional = self.xml.find('{%s}optional' % self.namespace)
-        self.xml.remove(optional)

slixmpp/features/feature_starttls/starttls.py

@@ -12,7 +12,7 @@ from slixmpp.stanza import StreamFeatures
 from slixmpp.xmlstream import register_stanza_plugin
 from slixmpp.plugins import BasePlugin
 from slixmpp.xmlstream.matcher import MatchXPath
-from slixmpp.xmlstream.handler import CoroutineCallback
+from slixmpp.xmlstream.handler import Callback
 from slixmpp.features.feature_starttls import stanza
 
 
@@ -28,7 +28,7 @@ class FeatureSTARTTLS(BasePlugin):
 
     def plugin_init(self):
         self.xmpp.register_handler(
-                CoroutineCallback('STARTTLS Proceed',
+                Callback('STARTTLS Proceed',
                         MatchXPath(stanza.Proceed.tag_name()),
                         self._handle_starttls_proceed,
                         instream=True))
@@ -58,8 +58,8 @@ class FeatureSTARTTLS(BasePlugin):
             self.xmpp.send(features['starttls'])
             return True
 
-    async def _handle_starttls_proceed(self, proceed):
+    def _handle_starttls_proceed(self, proceed):
         """Restart the XML stream when TLS is accepted."""
         log.debug("Starting TLS")
-        if await self.xmpp.start_tls():
+        if self.xmpp.start_tls():
             self.xmpp.features.add('starttls')

slixmpp/jid.py

@@ -346,10 +346,30 @@ class JID:
     def node(self):
         return self._node
 
+    @property
+    def user(self):
+        return self._node
+
+    @property
+    def local(self):
+        return self._node
+
+    @property
+    def username(self):
+        return self._node
+
     @property
     def domain(self):
         return self._domain
 
+    @property
+    def server(self):
+        return self._domain
+
+    @property
+    def host(self):
+        return self._domain
+
     @property
     def resource(self):
         return self._resource
@@ -362,16 +382,45 @@ class JID:
     def full(self):
         return self._full
 
+    @property
+    def jid(self):
+        return self._full
+
     @node.setter
     def node(self, value):
         self._node = _validate_node(value)
         self._update_bare_full()
 
+    @user.setter
+    def user(self, value):
+        self._node = _validate_node(value)
+        self._update_bare_full()
+
+    @local.setter
+    def local(self, value):
+        self._node = _validate_node(value)
+        self._update_bare_full()
+
+    @username.setter
+    def username(self, value):
+        self._node = _validate_node(value)
+        self._update_bare_full()
+
     @domain.setter
     def domain(self, value):
         self._domain = _validate_domain(value)
         self._update_bare_full()
 
+    @server.setter
+    def server(self, value):
+        self._domain = _validate_domain(value)
+        self._update_bare_full()
+
+    @host.setter
+    def host(self, value):
+        self._domain = _validate_domain(value)
+        self._update_bare_full()
+
     @bare.setter
     def bare(self, value):
         node, domain, resource = _parse_jid(value)
@@ -390,14 +439,10 @@ class JID:
         self._node, self._domain, self._resource = _parse_jid(value)
         self._update_bare_full()
 
-    user = node
-    local = node
-    username = node
-
-    server = domain
-    host = domain
-
-    jid = full
+    @jid.setter
+    def jid(self, value):
+        self._node, self._domain, self._resource = _parse_jid(value)
+        self._update_bare_full()
 
     def __str__(self):
         """Use the full JID as the string value."""

slixmpp/plugins/google/__init__.py

@@ -1,47 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.base import register_plugin, BasePlugin
-
-from slixmpp.plugins.google.gmail import Gmail
-from slixmpp.plugins.google.auth import GoogleAuth
-from slixmpp.plugins.google.settings import GoogleSettings
-from slixmpp.plugins.google.nosave import GoogleNoSave
-
-
-class Google(BasePlugin):
-
-    """
-    Google: Custom GTalk Features
-
-    Also see: <https://developers.google.com/talk/jep_extensions/extensions>
-    """
-
-    name = 'google'
-    description = 'Google: Custom GTalk Features'
-    dependencies = set([
-        'gmail',
-        'google_settings',
-        'google_nosave',
-        'google_auth'
-    ])
-
-    def __getitem__(self, attr):
-        if attr in ('settings', 'nosave', 'auth'):
-            return self.xmpp['google_%s' % attr]
-        elif attr == 'gmail':
-            return self.xmpp['gmail']
-        else:
-            raise KeyError(attr)
-
-
-register_plugin(Gmail)
-register_plugin(GoogleAuth)
-register_plugin(GoogleSettings)
-register_plugin(GoogleNoSave)
-register_plugin(Google)

slixmpp/plugins/google/auth/__init__.py

@@ -1,10 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.google.auth import stanza
-from slixmpp.plugins.google.auth.auth import GoogleAuth

slixmpp/plugins/google/auth/auth.py

@@ -1,47 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.xmlstream import register_stanza_plugin
-from slixmpp.plugins import BasePlugin
-from slixmpp.plugins.google.auth import stanza
-
-
-class GoogleAuth(BasePlugin):
-
-    """
-    Google: Auth Extensions (JID Domain Discovery, OAuth2)
-
-    Also see:
-        <https://developers.google.com/talk/jep_extensions/jid_domain_change>
-        <https://developers.google.com/talk/jep_extensions/oauth>
-    """
-
-    name = 'google_auth'
-    description = 'Google: Auth Extensions (JID Domain Discovery, OAuth2)'
-    dependencies = set(['feature_mechanisms'])
-    stanza = stanza
-
-    def plugin_init(self):
-        self.xmpp.namespace_map['http://www.google.com/talk/protocol/auth'] = 'ga'
-
-        register_stanza_plugin(self.xmpp['feature_mechanisms'].stanza.Auth,
-                               stanza.GoogleAuth)
-
-        self.xmpp.add_filter('out', self._auth)
-
-    def plugin_end(self):
-        self.xmpp.del_filter('out', self._auth)
-
-    def _auth(self, stanza):
-        if isinstance(stanza, self.xmpp['feature_mechanisms'].stanza.Auth):
-            stanza.stream = self.xmpp
-            stanza['google']['client_uses_full_bind_result'] = True
-            if stanza['mechanism'] == 'X-OAUTH2':
-                stanza['google']['service'] = 'oauth2'
-            print(stanza)
-        return stanza

slixmpp/plugins/google/gmail/__init__.py

@@ -1,10 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.google.gmail import stanza
-from slixmpp.plugins.google.gmail.notifications import Gmail

slixmpp/plugins/google/gmail/stanza.py

@@ -1,101 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.xmlstream import ElementBase, register_stanza_plugin
-
-
-class GmailQuery(ElementBase):
-    namespace = 'google:mail:notify'
-    name = 'query'
-    plugin_attrib = 'gmail'
-    interfaces = set(['newer_than_time', 'newer_than_tid', 'search'])
-
-    def get_search(self):
-        return self._get_attr('q', '')
-
-    def set_search(self, search):
-        self._set_attr('q', search)
-
-    def del_search(self):
-        self._del_attr('q')
-
-    def get_newer_than_time(self):
-        return self._get_attr('newer-than-time', '')
-
-    def set_newer_than_time(self, value):
-        self._set_attr('newer-than-time', value)
-
-    def del_newer_than_time(self):
-        self._del_attr('newer-than-time')
-
-    def get_newer_than_tid(self):
-        return self._get_attr('newer-than-tid', '')
-
-    def set_newer_than_tid(self, value):
-        self._set_attr('newer-than-tid', value)
-
-    def del_newer_than_tid(self):
-        self._del_attr('newer-than-tid')
-
-
-class MailBox(ElementBase):
-    namespace = 'google:mail:notify'
-    name = 'mailbox'
-    plugin_attrib = 'gmail_messages'
-    interfaces = set(['result_time', 'url', 'matched', 'estimate'])
-
-    def get_matched(self):
-        return self._get_attr('total-matched', '')
-
-    def get_estimate(self):
-        return self._get_attr('total-estimate', '') == '1'
-
-    def get_result_time(self):
-        return self._get_attr('result-time', '')
-
-
-class MailThread(ElementBase):
-    namespace = 'google:mail:notify'
-    name = 'mail-thread-info'
-    plugin_attrib = 'thread'
-    plugin_multi_attrib = 'threads'
-    interfaces = set(['tid', 'participation', 'messages', 'date',
-                      'senders', 'url', 'labels', 'subject', 'snippet'])
-    sub_interfaces = set(['labels', 'subject', 'snippet'])
-
-    def get_senders(self):
-        result = []
-        senders = self.xml.findall('{%s}senders/{%s}sender' % (
-            self.namespace, self.namespace))
-
-        for sender in senders:
-            result.append(MailSender(xml=sender))
-
-        return result
-
-
-class MailSender(ElementBase):
-    namespace = 'google:mail:notify'
-    name = 'sender'
-    plugin_attrib = name
-    interfaces = set(['address', 'name', 'originator', 'unread'])
-
-    def get_originator(self):
-        return self.xml.attrib.get('originator', '0') == '1'
-
-    def get_unread(self):
-        return self.xml.attrib.get('unread', '0') == '1'
-
-
-class NewMail(ElementBase):
-    namespace = 'google:mail:notify'
-    name = 'new-mail'
-    plugin_attrib = 'gmail_notification'
-
-
-register_stanza_plugin(MailBox, MailThread, iterable=True)

slixmpp/plugins/google/nosave/__init__.py

@@ -1,10 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.google.nosave import stanza
-from slixmpp.plugins.google.nosave.nosave import GoogleNoSave

slixmpp/plugins/google/nosave/nosave.py

@@ -1,78 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.stanza import Iq, Message
-from slixmpp.xmlstream.handler import Callback
-from slixmpp.xmlstream.matcher import StanzaPath
-from slixmpp.xmlstream import register_stanza_plugin
-from slixmpp.plugins import BasePlugin
-from slixmpp.plugins.google.nosave import stanza
-
-
-class GoogleNoSave(BasePlugin):
-
-    """
-    Google: Off the Record Chats
-
-    NOTE: This is NOT an encryption method.
-
-    Also see <https://developers.google.com/talk/jep_extensions/otr>.
-    """
-
-    name = 'google_nosave'
-    description = 'Google: Off the Record Chats'
-    dependencies = set(['google_settings'])
-    stanza = stanza
-
-    def plugin_init(self):
-        register_stanza_plugin(Message, stanza.NoSave)
-        register_stanza_plugin(Iq, stanza.NoSaveQuery)
-
-        self.xmpp.register_handler(
-                Callback('Google Nosave',
-                    StanzaPath('iq@type=set/google_nosave'),
-                    self._handle_nosave_change))
-
-    def plugin_end(self):
-        self.xmpp.remove_handler('Google Nosave')
-
-    def enable(self, jid=None, timeout=None, callback=None):
-        if jid is None:
-            self.xmpp['google_settings'].update({'archiving_enabled': False},
-                    timeout=timeout, callback=callback)
-        else:
-            iq = self.xmpp.Iq()
-            iq['type'] = 'set'
-            iq['google_nosave']['item']['jid'] = jid
-            iq['google_nosave']['item']['value'] = True
-            return iq.send(timeout=timeout, callback=callback)
-
-    def disable(self, jid=None, timeout=None, callback=None):
-        if jid is None:
-            self.xmpp['google_settings'].update({'archiving_enabled': True},
-                    timeout=timeout, callback=callback)
-        else:
-            iq = self.xmpp.Iq()
-            iq['type'] = 'set'
-            iq['google_nosave']['item']['jid'] = jid
-            iq['google_nosave']['item']['value'] = False
-            return iq.send(timeout=timeout, callback=callback)
-
-    def get(self, timeout=None, callback=None):
-        iq = self.xmpp.Iq()
-        iq['type'] = 'get'
-        iq.enable('google_nosave')
-        return iq.send(timeout=timeout, callback=callback)
-
-    def _handle_nosave_change(self, iq):
-        reply = self.xmpp.Iq()
-        reply['type'] = 'result'
-        reply['id'] = iq['id']
-        reply['to'] = iq['from']
-        reply.send()
-        self.xmpp.event('google_nosave_change', iq)

slixmpp/plugins/google/settings/__init__.py

@@ -1,10 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.google.settings import stanza
-from slixmpp.plugins.google.settings.settings import GoogleSettings

slixmpp/plugins/google/settings/stanza.py

@@ -1,110 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2013 Nathanael C. Fritz, Lance J.T. Stout
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.xmlstream import ET, ElementBase
-
-
-class UserSettings(ElementBase):
-    name = 'usersetting'
-    namespace = 'google:setting'
-    plugin_attrib = 'google_settings'
-    interfaces = set(['auto_accept_suggestions',
-                      'mail_notifications',
-                      'archiving_enabled',
-                      'gmail',
-                      'email_verified',
-                      'domain_privacy_notice',
-                      'display_name'])
-
-    def _get_setting(self, setting):
-        xml = self.xml.find('{%s}%s' % (self.namespace, setting))
-        if xml is not None:
-            return xml.attrib.get('value', '') == 'true'
-        return False
-
-    def _set_setting(self, setting, value):
-        self._del_setting(setting)
-        if value in (True, False):
-            xml = ET.Element('{%s}%s' % (self.namespace, setting))
-            xml.attrib['value'] = 'true' if value else 'false'
-            self.xml.append(xml)
-
-    def _del_setting(self, setting):
-        xml = self.xml.find('{%s}%s' % (self.namespace, setting))
-        if xml is not None:
-            self.xml.remove(xml)
-
-    def get_display_name(self):
-        xml = self.xml.find('{%s}%s' % (self.namespace, 'displayname'))
-        if xml is not None:
-            return xml.attrib.get('value', '')
-        return ''
-
-    def set_display_name(self, value):
-        self._del_setting(setting)
-        if value:
-            xml = ET.Element('{%s}%s' % (self.namespace, 'displayname'))
-            xml.attrib['value'] = value
-            self.xml.append(xml)
-
-    def del_display_name(self):
-        self._del_setting('displayname')
-
-    def get_auto_accept_suggestions(self):
-        return self._get_setting('autoacceptsuggestions')
-
-    def get_mail_notifications(self):
-        return self._get_setting('mailnotifications')
-
-    def get_archiving_enabled(self):
-        return self._get_setting('archivingenabled')
-
-    def get_gmail(self):
-        return self._get_setting('gmail')
-
-    def get_email_verified(self):
-        return self._get_setting('emailverified')
-
-    def get_domain_privacy_notice(self):
-        return self._get_setting('domainprivacynotice')
-
-    def set_auto_accept_suggestions(self, value):
-        self._set_setting('autoacceptsuggestions', value)
-
-    def set_mail_notifications(self, value):
-        self._set_setting('mailnotifications', value)
-
-    def set_archiving_enabled(self, value):
-        self._set_setting('archivingenabled', value)
-
-    def set_gmail(self, value):
-        self._set_setting('gmail', value)
-
-    def set_email_verified(self, value):
-        self._set_setting('emailverified', value)
-
-    def set_domain_privacy_notice(self, value):
-        self._set_setting('domainprivacynotice', value)
-
-    def del_auto_accept_suggestions(self):
-        self._del_setting('autoacceptsuggestions')
-
-    def del_mail_notifications(self):
-        self._del_setting('mailnotifications')
-
-    def del_archiving_enabled(self):
-        self._del_setting('archivingenabled')
-
-    def del_gmail(self):
-        self._del_setting('gmail')
-
-    def del_email_verified(self):
-        self._del_setting('emailverified')
-
-    def del_domain_privacy_notice(self):
-        self._del_setting('domainprivacynotice')

slixmpp/plugins/xep_0004/stanza/form.py

@@ -23,7 +23,7 @@ class Form(ElementBase):
     namespace = 'jabber:x:data'
     name = 'x'
     plugin_attrib = 'form'
-    interfaces = OrderedSet(('instructions', 'reported', 'title', 'type', 'items', 'values'))
+    interfaces = OrderedSet(('instructions', 'reported', 'title', 'type', 'items', ))
     sub_interfaces = {'title'}
     form_types = {'cancel', 'form', 'result', 'submit'}
 

slixmpp/plugins/xep_0009/remote.py

@@ -61,7 +61,7 @@ def _intercept(method, name, public):
         except InvocationException:
             raise
         except Exception as e:
-            raise InvocationException("A problem occurred calling %s.%s!" % (instance.FQN(), method.__name__), e)
+            raise InvocationException("A problem occured calling %s.%s!" % (instance.FQN(), method.__name__), e)
     _resolver._rpc = public
     _resolver._rpc_name = method.__name__ if name is None else name
     return _resolver
@@ -405,10 +405,8 @@ class Proxy(Endpoint):
         self._callback = callback
 
     def __getattribute__(self, name, *args):
-        if name in ('__dict__', '_endpoint', '_callback'):
+        if name in ('__dict__', '_endpoint', 'async', '_callback'):
             return object.__getattribute__(self, name)
-        elif name == 'async':
-            return lambda callback: Proxy(self._endpoint, callback)
         else:
             attribute = self._endpoint.__getattribute__(name)
             if hasattr(attribute, '__call__'):
@@ -422,6 +420,9 @@ class Proxy(Endpoint):
                     pass   # If the attribute doesn't exist, don't care!
             return attribute
 
+    def async(self, callback):
+        return Proxy(self._endpoint, callback)
+
     def get_endpoint(self):
         '''
         Returns the proxified endpoint.
@@ -695,7 +696,7 @@ class RemoteSession(object):
         e = {
             'item-not-found': RemoteException("No remote handler available for %s at %s!" % (pmethod, iq['from'])),
             'forbidden': AuthorizationException("Forbidden to invoke remote handler for %s at %s!" % (pmethod, iq['from'])),
-            'undefined-condition': RemoteException("An unexpected problem occurred trying to invoke %s at %s!" % (pmethod, iq['from'])),
+            'undefined-condition': RemoteException("An unexpected problem occured trying to invoke %s at %s!" % (pmethod, iq['from'])),
         }[condition]
         if e is None:
             RemoteException("An unexpected exception occurred at %s!" % iq['from'])

slixmpp/plugins/xep_0009/rpc.py

@@ -121,7 +121,7 @@ class XEP_0009(BasePlugin):
     def _recipient_unvailable(self, iq):
         payload = iq.get_payload()
         iq = iq.reply()
-        iq.error().set_payload(payload)
+        error().set_payload(payload)
         iq['error']['code'] = '404'
         iq['error']['type'] = 'wait'
         iq['error']['condition'] = 'recipient-unavailable'

slixmpp/plugins/xep_0030/disco.py

@@ -6,7 +6,6 @@
     See the file LICENSE for copying permission.
 """
 
-import asyncio
 import logging
 
 from slixmpp import Iq
@@ -124,8 +123,6 @@ class XEP_0030(BasePlugin):
         for op in self._disco_ops:
             self.api.register(getattr(self.static, op), op, default=True)
 
-        self.domain_infos = {}
-
     def session_bind(self, jid):
         self.add_feature('http://jabber.org/protocol/disco#info')
 
@@ -298,35 +295,6 @@ class XEP_0030(BasePlugin):
                 'cached': cached}
         return self.api['has_identity'](jid, node, ifrom, data)
 
-    async def get_info_from_domain(self, domain=None, timeout=None,
-                                   cached=True, callback=None):
-        if domain is None:
-            domain = self.xmpp.boundjid.domain
-
-        if not cached or domain not in self.domain_infos:
-            infos = [self.get_info(
-                domain, timeout=timeout)]
-            iq_items = await self.get_items(
-                domain, timeout=timeout)
-            items = iq_items['disco_items']['items']
-            infos += [
-                self.get_info(item[0], timeout=timeout)
-                for item in items]
-            info_futures, _ = await asyncio.wait(
-                infos,
-                timeout=timeout,
-                loop=self.xmpp.loop
-            )
-
-            self.domain_infos[domain] = [
-                future.result() for future in info_futures if not future.exception()]
-
-        results = self.domain_infos[domain]
-
-        if callback is not None:
-            callback(results)
-        return results
-
     @future_wrapper
     def get_info(self, jid=None, node=None, local=None,
                        cached=None, **kwargs):
@@ -678,11 +646,9 @@ class XEP_0030(BasePlugin):
                 info['id'] = iq['id']
                 info.send()
             else:
-                node = iq['disco_info']['node']
                 iq = iq.reply()
                 if info:
                     info = self._fix_default_info(info)
-                    info['node'] = node
                     iq.set_payload(info.xml)
                 iq.send()
         elif iq['type'] == 'result':

slixmpp/plugins/xep_0030/static.py

@@ -66,11 +66,10 @@ class StaticDisco(object):
         if isinstance(ifrom, JID):
             ifrom = ifrom.full
         if (jid, node, ifrom) not in self.nodes:
-            new_node = {'info': DiscoInfo(), 'items': DiscoItems()}
-            new_node['info']['node'] = node
-            new_node['items']['node'] = node
-            self.nodes[(jid, node, ifrom)] = new_node
-        return self.nodes[(jid, node, ifrom)]
+            self.nodes[(jid, node, ifrom)] = {'info': DiscoInfo(),
+                                       'items': DiscoItems()}
+            self.nodes[(jid, node, ifrom)]['info']['node'] = node
+            self.nodes[(jid, node, ifrom)]['items']['node'] = node
 
     def get_node(self, jid=None, node=None, ifrom=None):
         if jid is None:
@@ -209,8 +208,8 @@ class StaticDisco(object):
 
         The data parameter is a disco#info substanza.
         """
-        new_node = self.add_node(jid, node)
-        new_node['info'] = data
+        self.add_node(jid, node)
+        self.get_node(jid, node)['info'] = data
 
     def del_info(self, jid, node, ifrom, data):
         """
@@ -243,8 +242,8 @@ class StaticDisco(object):
             items -- A set of items in tuple format.
         """
         items = data.get('items', set())
-        new_node = self.add_node(jid, node)
-        new_node['items']['items'] = items
+        self.add_node(jid, node)
+        self.get_node(jid, node)['items']['items'] = items
 
     def del_items(self, jid, node, ifrom, data):
         """
@@ -257,7 +256,7 @@ class StaticDisco(object):
 
     def add_identity(self, jid, node, ifrom, data):
         """
-        Add a new identity to the JID/node combination.
+        Add a new identity to te JID/node combination.
 
         The data parameter may provide:
             category -- The general category to which the agent belongs.
@@ -265,8 +264,8 @@ class StaticDisco(object):
             name     -- Optional human readable name for this identity.
             lang     -- Optional standard xml:lang value.
         """
-        new_node = self.add_node(jid, node)
-        new_node['info'].add_identity(
+        self.add_node(jid, node)
+        self.get_node(jid, node)['info'].add_identity(
                 data.get('category', ''),
                 data.get('itype', ''),
                 data.get('name', None),
@@ -281,8 +280,8 @@ class StaticDisco(object):
                             (category, type, name, lang)
         """
         identities = data.get('identities', set())
-        new_node = self.add_node(jid, node)
-        new_node['info']['identities'] = identities
+        self.add_node(jid, node)
+        self.get_node(jid, node)['info']['identities'] = identities
 
     def del_identity(self, jid, node, ifrom, data):
         """
@@ -317,8 +316,8 @@ class StaticDisco(object):
         The data parameter should include:
             feature -- The namespace of the supported feature.
         """
-        new_node = self.add_node(jid, node)
-        new_node['info'].add_feature(
+        self.add_node(jid, node)
+        self.get_node(jid, node)['info'].add_feature(
                 data.get('feature', ''))
 
     def set_features(self, jid, node, ifrom, data):
@@ -329,8 +328,8 @@ class StaticDisco(object):
             features -- The new set of supported features.
         """
         features = data.get('features', set())
-        new_node = self.add_node(jid, node)
-        new_node['info']['features'] = features
+        self.add_node(jid, node)
+        self.get_node(jid, node)['info']['features'] = features
 
     def del_feature(self, jid, node, ifrom, data):
         """
@@ -363,8 +362,8 @@ class StaticDisco(object):
                      non-addressable items.
             name  -- Optional human readable name for the item.
         """
-        new_node = self.add_node(jid, node)
-        new_node['items'].add_item(
+        self.add_node(jid, node)
+        self.get_node(jid, node)['items'].add_item(
                 data.get('ijid', ''),
                 node=data.get('inode', ''),
                 name=data.get('name', ''))
@@ -393,8 +392,8 @@ class StaticDisco(object):
         if isinstance(data, Iq):
             data = data['disco_info']
 
-        new_node = self.add_node(jid, node, ifrom)
-        new_node['info'] = data
+        self.add_node(jid, node, ifrom)
+        self.get_node(jid, node, ifrom)['info'] = data
 
     def get_cached_info(self, jid, node, ifrom, data):
         """

slixmpp/plugins/xep_0047/stream.py

@@ -31,7 +31,8 @@ class IBBytestream(object):
 
         self.recv_queue = asyncio.Queue()
 
-    async def send(self, data, timeout=None):
+    @asyncio.coroutine
+    def send(self, data, timeout=None):
         if not self.stream_started or self.stream_out_closed:
             raise socket.error
         if len(data) > self.block_size:
@@ -55,20 +56,22 @@ class IBBytestream(object):
             iq['ibb_data']['sid'] = self.sid
             iq['ibb_data']['seq'] = seq
             iq['ibb_data']['data'] = data
-            await iq.send(timeout=timeout)
+            yield from iq.send(timeout=timeout)
         return len(data)
 
-    async def sendall(self, data, timeout=None):
+    @asyncio.coroutine
+    def sendall(self, data, timeout=None):
         sent_len = 0
         while sent_len < len(data):
-            sent_len += await self.send(data[sent_len:self.block_size], timeout=timeout)
+            sent_len += yield from self.send(data[sent_len:self.block_size], timeout=timeout)
 
-    async def sendfile(self, file, timeout=None):
+    @asyncio.coroutine
+    def sendfile(self, file, timeout=None):
         while True:
             data = file.read(self.block_size)
             if not data:
                 break
-            await self.send(data, timeout=timeout)
+            yield from self.send(data, timeout=timeout)
 
     def _recv_data(self, stanza):
         new_seq = stanza['ibb_data']['seq']

slixmpp/plugins/xep_0050/adhoc.py

@@ -611,7 +611,7 @@ class XEP_0050(BasePlugin):
     def terminate_command(self, session):
         """
         Delete a command's session after a command has completed
-        or an error has occurred.
+        or an error has occured.
 
         Arguments:
             session -- All stored data relevant to the current

slixmpp/plugins/xep_0054/stanza.py

@@ -261,7 +261,7 @@ class BinVal(ElementBase):
 
     def get_binval(self):
         parent = self.parent()
-        xml = parent.xml.find('{%s}BINVAL' % self.namespace)
+        xml = parent.find('{%s}BINVAL' % self.namespace)
         if xml is not None:
             return base64.b64decode(bytes(xml.text))
         return b''

slixmpp/plugins/xep_0054/vcard_temp.py

@@ -123,7 +123,7 @@ class XEP_0054(BasePlugin):
         if iq['type'] == 'result':
             self.api['set_vcard'](jid=iq['from'], args=iq['vcard_temp'])
             return
-        elif iq['type'] == 'get' and self.xmpp.is_component:
+        elif iq['type'] == 'get':
             vcard = self.api['get_vcard'](iq['from'].bare)
             if isinstance(vcard, Iq):
                 vcard.send()

slixmpp/plugins/xep_0059/rsm.py

@@ -19,27 +19,23 @@ from slixmpp.exceptions import XMPPError
 log = logging.getLogger(__name__)
 
 
-class ResultIterator:
+class ResultIterator():
 
     """
-    An iterator for Result Set Management
+    An iterator for Result Set Managment
     """
 
     def __init__(self, query, interface, results='substanzas', amount=10,
-                       start=None, reverse=False, recv_interface=None,
-                       pre_cb=None, post_cb=None):
+                       start=None, reverse=False):
         """
         Arguments:
            query     -- The template query
-           interface -- The substanza of the query to send, for example disco_items
-           recv_interface -- The substanza of the query to receive, for example disco_items
+           interface -- The substanza of the query, for example disco_items
            results   -- The query stanza's interface which provides a
                         countable list of query results.
            amount    -- The max amounts of items to request per iteration
            start     -- From which item id to start
            reverse   -- If True, page backwards through the results
-           pre_cb    -- Callback to run before sending the stanza
-           post_cb   -- Callback to run after receiving the reply
 
         Example:
            q = Iq()
@@ -53,23 +49,17 @@ class ResultIterator:
         self.amount = amount
         self.start = start
         self.interface = interface
-        if recv_interface:
-            self.recv_interface = recv_interface
-        else:
-            self.recv_interface = interface
-        self.pre_cb = pre_cb
-        self.post_cb = post_cb
         self.results = results
         self.reverse = reverse
         self._stop = False
 
-    def __aiter__(self):
+    def __iter__(self):
         return self
 
-    async def __anext__(self):
-        return await self.next()
+    def __next__(self):
+        return self.next()
 
-    async def next(self):
+    def next(self):
         """
         Return the next page of results from a query.
 
@@ -78,7 +68,7 @@ class ResultIterator:
               of items.
         """
         if self._stop:
-            raise StopAsyncIteration
+            raise StopIteration
         self.query[self.interface]['rsm']['before'] = self.reverse
         self.query['id'] = self.query.stream.new_id()
         self.query[self.interface]['rsm']['max'] = str(self.amount)
@@ -89,32 +79,28 @@ class ResultIterator:
             self.query[self.interface]['rsm']['after'] = self.start
 
         try:
-            if self.pre_cb:
-                self.pre_cb(self.query)
-            r = await self.query.send()
+            r = self.query.send(block=True)
 
-            if not r[self.recv_interface]['rsm']['first'] and \
-               not r[self.recv_interface]['rsm']['last']:
-                raise StopAsyncIteration
+            if not r[self.interface]['rsm']['first'] and \
+               not r[self.interface]['rsm']['last']:
+                raise StopIteration
 
-            if r[self.recv_interface]['rsm']['count'] and \
-               r[self.recv_interface]['rsm']['first_index']:
-                count = int(r[self.recv_interface]['rsm']['count'])
-                first = int(r[self.recv_interface]['rsm']['first_index'])
-                num_items = len(r[self.recv_interface][self.results])
+            if r[self.interface]['rsm']['count'] and \
+               r[self.interface]['rsm']['first_index']:
+                count = int(r[self.interface]['rsm']['count'])
+                first = int(r[self.interface]['rsm']['first_index'])
+                num_items = len(r[self.interface][self.results])
                 if first + num_items == count:
                     self._stop = True
 
             if self.reverse:
-                self.start = r[self.recv_interface]['rsm']['first']
+                self.start = r[self.interface]['rsm']['first']
             else:
-                self.start = r[self.recv_interface]['rsm']['last']
+                self.start = r[self.interface]['rsm']['last']
 
-            if self.post_cb:
-                self.post_cb(r)
             return r
         except XMPPError:
-            raise StopAsyncIteration
+            raise StopIteration
 
 
 class XEP_0059(BasePlugin):
@@ -141,8 +127,7 @@ class XEP_0059(BasePlugin):
     def session_bind(self, jid):
         self.xmpp['xep_0030'].add_feature(Set.namespace)
 
-    def iterate(self, stanza, interface, results='substanzas',
-                recv_interface=None, pre_cb=None, post_cb=None):
+    def iterate(self, stanza, interface, results='substanzas'):
         """
         Create a new result set iterator for a given stanza query.
 
@@ -152,23 +137,9 @@ class XEP_0059(BasePlugin):
                          basic disco#items query.
             interface -- The name of the substanza to which the
                          result set management stanza should be
-                         appended in the query stanza. For example,
-                         for disco#items queries the interface
-                         'disco_items' should be used.
-            recv_interface -- The name of the substanza from which the
-                              result set management stanza should be
-                              read in the result stanza. If unspecified,
-                              it will be set to the same value as the
-                              ``interface`` parameter.
-            pre_cb    -- Callback to run before sending each stanza e.g.
-                         setting the MAM queryid and starting a stanza
-                         collector.
-            post_cb   -- Callback to run after receiving each stanza e.g.
-                         stopping a MAM stanza collector in order to
-                         gather results.
+                         appended. For example, for disco#items queries
+                         the interface 'disco_items' should be used.
             results   -- The name of the interface containing the
                          query results (typically just 'substanzas').
         """
-        return ResultIterator(stanza, interface, results,
-                              recv_interface=recv_interface, pre_cb=pre_cb,
-                              post_cb=post_cb)
+        return ResultIterator(stanza, interface, results)

slixmpp/plugins/xep_0059/stanza.py

@@ -13,7 +13,7 @@ from slixmpp.plugins.xep_0030.stanza.items import DiscoItems
 class Set(ElementBase):
 
     """
-    XEP-0059 (Result Set Management) can be used to manage the
+    XEP-0059 (Result Set Managment) can be used to manage the
     results of queries. For example, limiting the number of items
     per response or starting at certain positions.
 

slixmpp/plugins/xep_0060/pubsub.py

@@ -185,14 +185,14 @@ class XEP_0060(BasePlugin):
 
         if config is not None:
             form_type = 'http://jabber.org/protocol/pubsub#node_config'
-            if 'FORM_TYPE' in config.get_fields():
+            if 'FORM_TYPE' in config['fields']:
                 config.field['FORM_TYPE']['value'] = form_type
             else:
                 config.add_field(var='FORM_TYPE',
                                  ftype='hidden',
                                  value=form_type)
             if ntype:
-                if 'pubsub#node_type' in config.get_fields():
+                if 'pubsub#node_type' in config['fields']:
                     config.field['pubsub#node_type']['value'] = ntype
                 else:
                     config.add_field(var='pubsub#node_type', value=ntype)

slixmpp/plugins/xep_0060/stanza/pubsub.py

@@ -82,9 +82,9 @@ class Item(ElementBase):
             self.xml.append(value)
 
     def get_payload(self):
-        children = list(self.xml)
-        if len(children) > 0:
-            return children[0]
+        childs = list(self.xml)
+        if len(childs) > 0:
+            return childs[0]
 
     def del_payload(self):
         for child in self.xml:

slixmpp/plugins/xep_0060/stanza/pubsub_event.py

@@ -31,9 +31,9 @@ class EventItem(ElementBase):
         self.xml.append(value)
 
     def get_payload(self):
-        children = list(self.xml)
-        if len(children) > 0:
-            return children[0]
+        childs = list(self.xml)
+        if len(childs) > 0:
+            return childs[0]
 
     def del_payload(self):
         for child in self.xml:

slixmpp/plugins/xep_0065/proxy.py

@@ -55,17 +55,17 @@ class XEP_0065(BasePlugin):
         """Returns the socket associated to the SID."""
         return self._sessions.get(sid, None)
 
-    async def handshake(self, to, ifrom=None, sid=None, timeout=None):
+    def handshake(self, to, ifrom=None, sid=None, timeout=None):
         """ Starts the handshake to establish the socks5 bytestreams
         connection.
         """
         if not self._proxies:
-            self._proxies = await self.discover_proxies()
+            self._proxies = yield from self.discover_proxies()
 
         if sid is None:
             sid = uuid4().hex
 
-        used = await self.request_stream(to, sid=sid, ifrom=ifrom, timeout=timeout)
+        used = yield from self.request_stream(to, sid=sid, ifrom=ifrom, timeout=timeout)
         proxy = used['socks']['streamhost_used']['jid']
 
         if proxy not in self._proxies:
@@ -73,16 +73,16 @@ class XEP_0065(BasePlugin):
             return
 
         try:
-            self._sessions[sid] = (await self._connect_proxy(
+            self._sessions[sid] = (yield from self._connect_proxy(
                     self._get_dest_sha1(sid, self.xmpp.boundjid, to),
                     self._proxies[proxy][0],
                     self._proxies[proxy][1]))[1]
         except socket.error:
             return None
-        addr, port = await self._sessions[sid].connected
+        addr, port = yield from self._sessions[sid].connected
 
         # Request that the proxy activate the session with the target.
-        await self.activate(proxy, sid, to, timeout=timeout)
+        yield from self.activate(proxy, sid, to, timeout=timeout)
         sock = self.get_socket(sid)
         self.xmpp.event('stream:%s:%s' % (sid, to), sock)
         return sock
@@ -104,7 +104,7 @@ class XEP_0065(BasePlugin):
             iq['socks'].add_streamhost(proxy, host, port)
         return iq.send(timeout=timeout, callback=callback)
 
-    async def discover_proxies(self, jid=None, ifrom=None, timeout=None):
+    def discover_proxies(self, jid=None, ifrom=None, timeout=None):
         """Auto-discover the JIDs of SOCKS5 proxies on an XMPP server."""
         if jid is None:
             if self.xmpp.is_component:
@@ -114,7 +114,7 @@ class XEP_0065(BasePlugin):
 
         discovered = set()
 
-        disco_items = await self.xmpp['xep_0030'].get_items(jid, timeout=timeout)
+        disco_items = yield from self.xmpp['xep_0030'].get_items(jid, timeout=timeout)
         disco_items = {item[0] for item in disco_items['disco_items']['items']}
 
         disco_info_futures = {}
@@ -123,7 +123,7 @@ class XEP_0065(BasePlugin):
 
         for item in disco_items:
             try:
-                disco_info = await disco_info_futures[item]
+                disco_info = yield from disco_info_futures[item]
             except XMPPError:
                 continue
             else:
@@ -135,7 +135,7 @@ class XEP_0065(BasePlugin):
 
         for jid in discovered:
             try:
-                addr = await self.get_network_address(jid, ifrom=ifrom, timeout=timeout)
+                addr = yield from self.get_network_address(jid, ifrom=ifrom, timeout=timeout)
                 self._proxies[jid] = (addr['socks']['streamhost']['host'],
                                       addr['socks']['streamhost']['port'])
             except XMPPError:
@@ -180,8 +180,9 @@ class XEP_0065(BasePlugin):
                     streamhost['host'],
                     streamhost['port']))
 
-        async def gather(futures, iq, streamhosts):
-            proxies = await asyncio.gather(*futures, return_exceptions=True)
+        @asyncio.coroutine
+        def gather(futures, iq, streamhosts):
+            proxies = yield from asyncio.gather(*futures, return_exceptions=True)
             for streamhost, proxy in zip(streamhosts, proxies):
                 if isinstance(proxy, ValueError):
                     continue
@@ -191,7 +192,7 @@ class XEP_0065(BasePlugin):
                 proxy = proxy[1]
                 # TODO: what if the future never happens?
                 try:
-                    addr, port = await proxy.connected
+                    addr, port = yield from proxy.connected
                 except socket.error:
                     log.exception('Socket error while connecting to the proxy.')
                     continue
@@ -212,7 +213,7 @@ class XEP_0065(BasePlugin):
             self.xmpp.event('socks5_stream', conn)
             self.xmpp.event('stream:%s:%s' % (sid, requester), conn)
 
-        asyncio.ensure_future(gather(proxy_futures, iq, streamhosts))
+        asyncio.async(gather(proxy_futures, iq, streamhosts))
 
     def activate(self, proxy, sid, target, ifrom=None, timeout=None, callback=None):
         """Activate the socks5 session that has been negotiated."""
@@ -230,7 +231,7 @@ class XEP_0065(BasePlugin):
                 sock.close()
             except socket.error:
                 pass
-            # Though this should not be necessary remove the closed session anyway
+            # Though this should not be neccessary remove the closed session anyway
             if sid in self._sessions:
                 log.warn(('SOCKS5 session with sid = "%s" was not ' +
                           'removed from _sessions by sock.close()') % sid)

slixmpp/plugins/xep_0065/socks5.py

@@ -137,8 +137,8 @@ class Socks5Protocol(asyncio.Protocol):
     def resume_writing(self):
         self.paused.set_result(None)
 
-    async def write(self, data):
-        await self.paused
+    def write(self, data):
+        yield from self.paused
         self.transport.write(data)
 
     def _send_methods(self):

slixmpp/plugins/xep_0077/register.py

@@ -59,7 +59,7 @@ class XEP_0077(BasePlugin):
 
     def _force_stream_feature(self, stanza):
         if isinstance(stanza, StreamFeatures):
-            if not self.xmpp.disable_starttls:
+            if self.xmpp.use_tls or self.xmpp.use_ssl:
                 if 'starttls' not in self.xmpp.features:
                     return stanza
                 elif not isinstance(self.xmpp.socket, ssl.SSLSocket):

slixmpp/plugins/xep_0079/stanza.py

@@ -8,7 +8,6 @@
 
 from __future__ import unicode_literals
 
-from slixmpp import JID
 from slixmpp.xmlstream import ElementBase, register_stanza_plugin
 
 

slixmpp/plugins/xep_0092/version.py

@@ -65,14 +65,9 @@ class XEP_0092(BasePlugin):
             iq -- The Iq stanza containing the software version query.
         """
         iq = iq.reply()
-        if self.software_name:
-            iq['software_version']['name'] = self.software_name
-            iq['software_version']['version'] = self.version
-            iq['software_version']['os'] = self.os
-        else:
-            iq.error()
-            iq['error']['type'] = 'cancel'
-            iq['error']['condition'] = 'service-unavailable'
+        iq['software_version']['name'] = self.software_name
+        iq['software_version']['version'] = self.version
+        iq['software_version']['os'] = self.os
         iq.send()
 
     def get_version(self, jid, ifrom=None, timeout=None, callback=None,

slixmpp/plugins/xep_0095/stream_initiation.py

@@ -97,7 +97,7 @@ class XEP_0095(BasePlugin):
                 extension='bad-profile',
                 extension_ns=SI.namespace)
 
-        neg = iq['si']['feature_neg']['form'].get_fields()
+        neg = iq['si']['feature_neg']['form']['fields']
         options = neg['stream-method']['options'] or []
         methods = []
         for opt in options:

slixmpp/plugins/xep_0115/caps.py

@@ -15,7 +15,6 @@ from slixmpp.stanza import StreamFeatures, Presence, Iq
 from slixmpp.xmlstream import register_stanza_plugin, JID
 from slixmpp.xmlstream.handler import Callback
 from slixmpp.xmlstream.matcher import StanzaPath
-from slixmpp.util import MemoryCache
 from slixmpp import asyncio
 from slixmpp.exceptions import XMPPError, IqError, IqTimeout
 from slixmpp.plugins import BasePlugin
@@ -28,7 +27,7 @@ log = logging.getLogger(__name__)
 class XEP_0115(BasePlugin):
 
     """
-    XEP-0115: Entity Capabilities
+    XEP-0115: Entity Capabalities
     """
 
     name = 'xep_0115'
@@ -38,8 +37,7 @@ class XEP_0115(BasePlugin):
     default_config = {
         'hash': 'sha-1',
         'caps_node': None,
-        'broadcast': True,
-        'cache': None,
+        'broadcast': True
     }
 
     def plugin_init(self):
@@ -50,9 +48,6 @@ class XEP_0115(BasePlugin):
         if self.caps_node is None:
             self.caps_node = 'http://slixmpp.com/ver/%s' % __version__
 
-        if self.cache is None:
-            self.cache = MemoryCache()
-
         register_stanza_plugin(Presence, stanza.Capabilities)
         register_stanza_plugin(StreamFeatures, stanza.Capabilities)
 
@@ -137,7 +132,8 @@ class XEP_0115(BasePlugin):
 
         self.xmpp.event('entity_caps', p)
 
-    async def _process_caps(self, pres):
+    @asyncio.coroutine
+    def _process_caps(self, pres):
         if not pres['caps']['hash']:
             log.debug("Received unsupported legacy caps: %s, %s, %s",
                     pres['caps']['node'],
@@ -168,7 +164,7 @@ class XEP_0115(BasePlugin):
         log.debug("New caps verification string: %s", ver)
         try:
             node = '%s#%s' % (pres['caps']['node'], ver)
-            caps = await self.xmpp['xep_0030'].get_info(pres['from'], node,
+            caps = yield from self.xmpp['xep_0030'].get_info(pres['from'], node,
                                                              coroutine=True)
 
             if isinstance(caps, Iq):
@@ -203,8 +199,8 @@ class XEP_0115(BasePlugin):
                 log.debug("Non form extension found, ignoring for caps")
                 caps.xml.remove(stanza.xml)
                 continue
-            if 'FORM_TYPE' in stanza.get_fields():
-                f_type = tuple(stanza.get_fields()['FORM_TYPE']['value'])
+            if 'FORM_TYPE' in stanza['fields']:
+                f_type = tuple(stanza['fields']['FORM_TYPE']['value'])
                 form_types.append(f_type)
                 deduped_form_types.add(f_type)
                 if len(form_types) != len(deduped_form_types):
@@ -218,7 +214,7 @@ class XEP_0115(BasePlugin):
                         log.debug("Extra FORM_TYPE data, invalid for caps")
                         return False
 
-                if stanza.get_fields()['FORM_TYPE']['type'] != 'hidden':
+                if stanza['fields']['FORM_TYPE']['type'] != 'hidden':
                     log.debug("Field FORM_TYPE type not 'hidden', " + \
                               "ignoring form for caps")
                     caps.xml.remove(stanza.xml)
@@ -257,7 +253,7 @@ class XEP_0115(BasePlugin):
 
         for stanza in info['substanzas']:
             if isinstance(stanza, self.xmpp['xep_0004'].stanza.Form):
-                if 'FORM_TYPE' in stanza.get_fields():
+                if 'FORM_TYPE' in stanza['fields']:
                     f_type = stanza['values']['FORM_TYPE']
                     if len(f_type):
                         f_type = f_type[0]
@@ -269,11 +265,11 @@ class XEP_0115(BasePlugin):
         for f_type in sorted_forms:
             for form in form_types[f_type]:
                 S += '%s<' % f_type
-                fields = sorted(form.get_fields().keys())
+                fields = sorted(form['fields'].keys())
                 fields.remove('FORM_TYPE')
                 for field in fields:
                     S += '%s<' % field
-                    vals = form.get_fields()[field].get_value(convert=False)
+                    vals = form['fields'][field].get_value(convert=False)
                     if vals is None:
                         S += '<'
                     else:
@@ -284,9 +280,10 @@ class XEP_0115(BasePlugin):
         binary = hash(S.encode('utf8')).digest()
         return base64.b64encode(binary).decode('utf-8')
 
-    async def update_caps(self, jid=None, node=None, preserve=False):
+    @asyncio.coroutine
+    def update_caps(self, jid=None, node=None, preserve=False):
         try:
-            info = await self.xmpp['xep_0030'].get_info(jid, node, local=True)
+            info = yield from self.xmpp['xep_0030'].get_info(jid, node, local=True)
             if isinstance(info, Iq):
                 info = info['disco_info']
             ver = self.generate_verstring(info, self.hash)

slixmpp/plugins/xep_0115/static.py

@@ -33,6 +33,7 @@ class StaticCaps(object):
         self.disco = self.xmpp['xep_0030']
         self.caps = self.xmpp['xep_0115']
         self.static = static
+        self.ver_cache = {}
         self.jid_vers = {}
 
     def supports(self, jid, node, ifrom, data):
@@ -127,7 +128,7 @@ class StaticCaps(object):
         info = data.get('info', None)
         if not verstring or not info:
             return
-        self.caps.cache.store(verstring, info)
+        self.ver_cache[verstring] = info
 
     def assign_verstring(self, jid, node, ifrom, data):
         if isinstance(jid, JID):
@@ -138,7 +139,4 @@ class StaticCaps(object):
         return self.jid_vers.get(jid, None)
 
     def get_caps(self, jid, node, ifrom, data):
-        verstring = data.get('verstring', None)
-        if verstring is None:
-            return None
-        return self.caps.cache.retrieve(verstring)
+        return self.ver_cache.get(data.get('verstring', None), None)

slixmpp/plugins/xep_0153/vcard_avatar.py

@@ -98,9 +98,10 @@ class XEP_0153(BasePlugin):
         first_future.add_done_callback(propagate_timeout_exception)
         return future
 
-    async def _start(self, event):
+    @asyncio.coroutine
+    def _start(self, event):
         try:
-            vcard = await self.xmpp['xep_0054'].get_vcard(self.xmpp.boundjid.bare)
+            vcard = yield from self.xmpp['xep_0054'].get_vcard(self.xmpp.boundjid.bare)
             data = vcard['vcard_temp']['PHOTO']['BINVAL']
             if not data:
                 new_hash = ''
@@ -137,11 +138,7 @@ class XEP_0153(BasePlugin):
             if iq['type'] == 'error':
                 log.debug('Could not retrieve vCard for %s', jid)
                 return
-            try:
-                data = iq['vcard_temp']['PHOTO']['BINVAL']
-            except ValueError:
-                log.debug('Invalid BINVAL in vCard’s PHOTO for %s:', jid, exc_info=True)
-                data = None
+            data = iq['vcard_temp']['PHOTO']['BINVAL']
             if not data:
                 new_hash = ''
             else:

slixmpp/plugins/xep_0163.py

@@ -62,10 +62,7 @@ class XEP_0163(BasePlugin):
         for ns in namespace:
             self.xmpp['xep_0030'].add_feature('%s+notify' % ns,
                                               jid=jid)
-        asyncio.ensure_future(
-            self.xmpp['xep_0115'].update_caps(jid),
-            loop=self.xmpp.loop,
-        )
+        asyncio.async(self.xmpp['xep_0115'].update_caps(jid))
 
     def remove_interest(self, namespace, jid=None):
         """
@@ -84,10 +81,7 @@ class XEP_0163(BasePlugin):
         for ns in namespace:
             self.xmpp['xep_0030'].del_feature(jid=jid,
                                               feature='%s+notify' % namespace)
-        asyncio.ensure_future(
-            self.xmpp['xep_0115'].update_caps(jid),
-            loop=self.xmpp.loop,
-        )
+        asyncio.async(self.xmpp['xep_0115'].update_caps(jid))
 
     def publish(self, stanza, node=None, id=None, options=None, ifrom=None,
                 timeout_callback=None, callback=None, timeout=None):

slixmpp/plugins/xep_0198/stream_management.py

@@ -174,7 +174,8 @@ class XEP_0198(BasePlugin):
         req = stanza.RequestAck(self.xmpp)
         self.xmpp.send_raw(str(req))
 
-    async def _handle_sm_feature(self, features):
+    @asyncio.coroutine
+    def _handle_sm_feature(self, features):
         """
         Enable or resume stream management.
 
@@ -202,7 +203,7 @@ class XEP_0198(BasePlugin):
                             MatchXPath(stanza.Enabled.tag_name()),
                             MatchXPath(stanza.Failed.tag_name())]))
                 self.xmpp.register_handler(waiter)
-                result = await waiter.wait()
+                result = yield from waiter.wait()
         elif self.sm_id and self.allow_resume and 'bind' not in self.xmpp.features:
             self.enabled = True
             resume = stanza.Resume(self.xmpp)
@@ -218,7 +219,7 @@ class XEP_0198(BasePlugin):
                         MatchXPath(stanza.Resumed.tag_name()),
                         MatchXPath(stanza.Failed.tag_name())]))
             self.xmpp.register_handler(waiter)
-            result = await waiter.wait()
+            result = yield from waiter.wait()
             if result is not None and result.name == 'resumed':
                 return True
         return False

slixmpp/plugins/xep_0199/ping.py

@@ -95,10 +95,7 @@ class XEP_0199(BasePlugin):
             self.timeout = timeout
 
         self.keepalive = True
-        handler = lambda event=None: asyncio.ensure_future(
-            self._keepalive(event),
-            loop=self.xmpp.loop,
-        )
+        handler = lambda event=None: asyncio.ensure_future(self._keepalive(event))
         self.xmpp.schedule('Ping keepalive',
                            self.interval,
                            handler,
@@ -107,12 +104,13 @@ class XEP_0199(BasePlugin):
     def disable_keepalive(self, event=None):
         self.xmpp.cancel_schedule('Ping keepalive')
 
-    async def _keepalive(self, event=None):
+    @asyncio.coroutine
+    def _keepalive(self, event=None):
         log.debug("Keepalive ping...")
         try:
-            rtt = await self.ping(self.xmpp.boundjid.host, timeout=self.timeout)
+            rtt = yield from self.ping(self.xmpp.boundjid.host, timeout=self.timeout)
         except IqTimeout:
-            log.debug("Did not receive ping back in time." + \
+            log.debug("Did not recieve ping back in time." + \
                       "Requesting Reconnect.")
             self.xmpp.reconnect()
         else:
@@ -147,7 +145,8 @@ class XEP_0199(BasePlugin):
         return iq.send(timeout=timeout, callback=callback,
                        timeout_callback=timeout_callback)
 
-    async def ping(self, jid=None, ifrom=None, timeout=None):
+    @asyncio.coroutine
+    def ping(self, jid=None, ifrom=None, timeout=None):
         """Send a ping request and calculate RTT.
         This is a coroutine.
 
@@ -175,7 +174,7 @@ class XEP_0199(BasePlugin):
 
         log.debug('Pinging %s' % jid)
         try:
-            await self.send_ping(jid, ifrom=ifrom, timeout=timeout)
+            yield from self.send_ping(jid, ifrom=ifrom, timeout=timeout)
         except IqError as e:
             if own_host:
                 rtt = time.time() - start

slixmpp/plugins/xep_0221/stanza.py

@@ -36,7 +36,7 @@ class URI(ElementBase):
         self.xml.text = value
 
     def del_value(self):
-        self.xml.text = ''
+        sel.xml.text = ''
 
 
 register_stanza_plugin(Media, URI, iterable=True)

slixmpp/plugins/xep_0222.py

@@ -28,7 +28,7 @@ class XEP_0222(BasePlugin):
     profile = {'pubsub#persist_items': True,
                'pubsub#send_last_published_item': 'never'}
 
-    def configure(self, node, ifrom=None, callback=None, timeout=None):
+    def configure(self, node):
         """
         Update a node's configuration to match the public storage profile.
         """
@@ -73,11 +73,11 @@ class XEP_0222(BasePlugin):
                 ftype='hidden',
                 value='http://jabber.org/protocol/pubsub#publish-options')
 
-        fields = options.get_fields()
+        fields = options['fields']
         for field, value in self.profile.items():
             if field not in fields:
                 options.add_field(var=field)
-            options.get_fields()[field]['value'] = value
+            options['fields'][field]['value'] = value
 
         return self.xmpp['xep_0163'].publish(stanza, node,
                 options=options,

slixmpp/plugins/xep_0223.py

@@ -28,7 +28,7 @@ class XEP_0223(BasePlugin):
     profile = {'pubsub#persist_items': True,
                'pubsub#send_last_published_item': 'never'}
 
-    def configure(self, node, ifrom=None, callback=None, timeout=None):
+    def configure(self, node):
         """
         Update a node's configuration to match the public storage profile.
         """
@@ -78,7 +78,7 @@ class XEP_0223(BasePlugin):
         for field, value in self.profile.items():
             if field not in fields:
                 options.add_field(var=field)
-            options.get_fields()[field]['value'] = value
+            options['fields'][field]['value'] = value
 
         return self.xmpp['xep_0163'].publish(stanza, node, options=options,
                                              ifrom=ifrom, callback=callback,

slixmpp/plugins/xep_0258/stanza.py

@@ -8,7 +8,6 @@
 
 from base64 import b64encode, b64decode
 
-from slixmpp import JID
 from slixmpp.util import bytes
 from slixmpp.xmlstream import ElementBase, ET, register_stanza_plugin
 

slixmpp/plugins/xep_0280/carbons.py

@@ -61,12 +61,10 @@ class XEP_0280(BasePlugin):
         self.xmpp.plugin['xep_0030'].add_feature('urn:xmpp:carbons:2')
 
     def _handle_carbon_received(self, msg):
-        if msg['from'].bare == self.xmpp.boundjid.bare:
-            self.xmpp.event('carbon_received', msg)
+        self.xmpp.event('carbon_received', msg)
 
     def _handle_carbon_sent(self, msg):
-        if msg['from'].bare == self.xmpp.boundjid.bare:
-            self.xmpp.event('carbon_sent', msg)
+        self.xmpp.event('carbon_sent', msg)
 
     def enable(self, ifrom=None, timeout=None, callback=None,
                timeout_callback=None):

slixmpp/plugins/xep_0300/__init__.py

@@ -1,16 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2017 Emmanuel Gil Peyrot
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.base import register_plugin
-
-from slixmpp.plugins.xep_0300 import stanza
-from slixmpp.plugins.xep_0300.stanza import Hash
-from slixmpp.plugins.xep_0300.hash import XEP_0300
-
-
-register_plugin(XEP_0300)

slixmpp/plugins/xep_0300/hash.py

@@ -1,87 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2017 Emmanuel Gil Peyrot
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from base64 import b64encode
-import hashlib
-import logging
-
-from slixmpp.plugins import BasePlugin
-from slixmpp.plugins.xep_0300 import stanza, Hash
-
-
-log = logging.getLogger(__name__)
-
-
-class XEP_0300(BasePlugin):
-
-    name = 'xep_0300'
-    description = 'XEP-0300: Use of Cryptographic Hash Functions in XMPP'
-    dependencies = {'xep_0030'}
-    stanza = stanza
-    default_config = {
-        'block_size': 1024 * 1024,  # One MiB
-        'preferded': 'sha-256',
-        'enable_sha-1': False,
-        'enable_sha-256': True,
-        'enable_sha-512': True,
-        'enable_sha3-256': True,
-        'enable_sha3-512': True,
-        'enable_BLAKE2b256': True,
-        'enable_BLAKE2b512': True,
-    }
-
-    _hashlib_function = {
-        'sha-1': hashlib.sha1,
-        'sha-256': hashlib.sha256,
-        'sha-512': hashlib.sha512,
-        'sha3-256': lambda: hashlib.sha3_256(),
-        'sha3-512': lambda: hashlib.sha3_512(),
-        'BLAKE2b256': lambda: hashlib.blake2b(digest_size=32),
-        'BLAKE2b512': lambda: hashlib.blake2b(digest_size=64),
-    }
-
-    def plugin_init(self):
-        namespace = 'urn:xmpp:hash-function-text-names:%s'
-        self.enabled_hashes = []
-        for algo in self._hashlib_function:
-            if getattr(self, 'enable_' + algo, False):
-                # XXX: this is a hack for Python 3.5 or below, which
-                # don’t support sha3 or blake2b…
-                try:
-                    self._hashlib_function[algo]()
-                except AttributeError:
-                    log.warn('Algorithm %s unavailable, disabling.', algo)
-                else:
-                    self.enabled_hashes.append(namespace % algo)
-
-    def session_bind(self, jid):
-        self.xmpp['xep_0030'].add_feature(Hash.namespace)
-
-        for namespace in self.enabled_hashes:
-            self.xmpp['xep_0030'].add_feature(namespace)
-
-    def plugin_end(self):
-        for namespace in self.enabled_hashes:
-            self.xmpp['xep_0030'].del_feature(namespace)
-
-        self.xmpp['xep_0030'].del_feature(feature=Hash.namespace)
-
-    def compute_hash(self, filename, function=None):
-        if function is None:
-            function = self.preferred
-        h = self._hashlib_function[function]()
-        with open(filename, 'rb') as f:
-            while True:
-                block = f.read(self.block_size)
-                if not block:
-                    break
-                h.update(block)
-        hash_elem = Hash()
-        hash_elem['algo'] = function
-        hash_elem['value'] = b64encode(h.digest())
-        return hash_elem

slixmpp/plugins/xep_0300/stanza.py

@@ -1,35 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2017 Emmanuel Gil Peyrot
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.xmlstream import ElementBase
-
-
-class Hash(ElementBase):
-    name = 'hash'
-    namespace = 'urn:xmpp:hashes:2'
-    plugin_attrib = 'hash'
-    interfaces = {'algo', 'value'}
-
-    allowed_algos = ['sha-1', 'sha-256', 'sha-512', 'sha3-256', 'sha3-512', 'BLAKE2b256', 'BLAKE2b512']
-
-    def set_algo(self, value):
-        if value in self.allowed_algos:
-            self._set_attr('algo', value)
-        elif value in [None, '']:
-            self._del_attr('algo')
-        else:
-            raise ValueError('Invalid algo: %s' % value)
-
-    def get_value(self):
-        return self.xml.text
-
-    def set_value(self, value):
-        self.xml.text = value
-
-    def del_value(self):
-        self.xml.text = ''

slixmpp/plugins/xep_0313/mam.py

@@ -36,58 +36,35 @@ class XEP_0313(BasePlugin):
         register_stanza_plugin(Iq, stanza.MAM)
         register_stanza_plugin(Iq, stanza.Preferences)
         register_stanza_plugin(Message, stanza.Result)
-        register_stanza_plugin(Iq, stanza.Fin)
+        register_stanza_plugin(Message, stanza.Archived, iterable=True)
         register_stanza_plugin(stanza.Result, self.xmpp['xep_0297'].stanza.Forwarded)
         register_stanza_plugin(stanza.MAM, self.xmpp['xep_0059'].stanza.Set)
-        register_stanza_plugin(stanza.Fin, self.xmpp['xep_0059'].stanza.Set)
 
     def retrieve(self, jid=None, start=None, end=None, with_jid=None, ifrom=None,
-                 timeout=None, callback=None, iterator=False, rsm=None):
+                 timeout=None, callback=None, iterator=False):
         iq = self.xmpp.Iq()
         query_id = iq['id']
 
         iq['to'] = jid
         iq['from'] = ifrom
-        iq['type'] = 'set'
+        iq['type'] = 'get'
         iq['mam']['queryid'] = query_id
         iq['mam']['start'] = start
         iq['mam']['end'] = end
         iq['mam']['with'] = with_jid
-        if rsm:
-            for key, value in rsm.items():
-                iq['mam']['rsm'][key] = str(value)
-
-        cb_data = {}
-        def pre_cb(query):
-            query['mam']['queryid'] = query['id']
-            collector = Collector(
-                'MAM_Results_%s' % query_id,
-                StanzaPath('message/mam_result@queryid=%s' % query['id']))
-            self.xmpp.register_handler(collector)
-            cb_data['collector'] = collector
-
-        def post_cb(result):
-            results = cb_data['collector'].stop()
-            if result['type'] == 'result':
-                result['mam']['results'] = results
-
-        if iterator:
-            return self.xmpp['xep_0059'].iterate(iq, 'mam', 'results',
-                                                 recv_interface='mam_fin',
-                                                 pre_cb=pre_cb, post_cb=post_cb)
 
         collector = Collector(
             'MAM_Results_%s' % query_id,
             StanzaPath('message/mam_result@queryid=%s' % query_id))
         self.xmpp.register_handler(collector)
 
+        if iterator:
+            return self.xmpp['xep_0059'].iterate(iq, 'mam', 'results')
         def wrapped_cb(iq):
             results = collector.stop()
             if iq['type'] == 'result':
                 iq['mam']['results'] = results
-            if callback:
-                callback(iq)
-
+            callback(iq)
         return iq.send(timeout=timeout, callback=wrapped_cb)
 
     def set_preferences(self, jid=None, default=None, always=None, never=None,

slixmpp/plugins/xep_0313/stanza.py

@@ -10,76 +10,44 @@ import datetime as dt
 
 from slixmpp.jid import JID
 from slixmpp.xmlstream import ElementBase, ET
-from slixmpp.plugins import xep_0082, xep_0004
+from slixmpp.plugins import xep_0082
 
 
 class MAM(ElementBase):
     name = 'query'
-    namespace = 'urn:xmpp:mam:2'
+    namespace = 'urn:xmpp:mam:tmp'
     plugin_attrib = 'mam'
     interfaces = {'queryid', 'start', 'end', 'with', 'results'}
     sub_interfaces = {'start', 'end', 'with'}
 
     def setup(self, xml=None):
         ElementBase.setup(self, xml)
-        self._form = xep_0004.stanza.Form()
-        self._form['type'] = 'submit'
-        field = self._form.add_field(var='FORM_TYPE', ftype='hidden',
-                             value='urn:xmpp:mam:2')
-        self.append(self._form)
         self._results = []
 
-    def __get_fields(self):
-        return self._form.get_fields()
-
     def get_start(self):
-        fields = self.__get_fields()
-        field = fields.get('start')
-        if field:
-            return xep_0082.parse(field['value'])
+        timestamp = self._get_sub_text('start')
+        return xep_0082.parse(timestamp)
 
     def set_start(self, value):
         if isinstance(value, dt.datetime):
             value = xep_0082.format_datetime(value)
-        fields = self.__get_fields()
-        field = fields.get('start')
-        if field:
-            field['value'] = value
-        else:
-            field = self._form.add_field(var='start')
-            field['value'] = value
+        self._set_sub_text('start', value)
 
     def get_end(self):
-        fields = self.__get_fields()
-        field = fields.get('end')
-        if field:
-            return xep_0082.parse(field['value'])
+        timestamp = self._get_sub_text('end')
+        return xep_0082.parse(timestamp)
 
     def set_end(self, value):
         if isinstance(value, dt.datetime):
             value = xep_0082.format_datetime(value)
-        fields = self.__get_fields()
-        field = fields.get('end')
-        if field:
-            field['value'] = value
-        else:
-            field = self._form.add_field(var='end')
-            field['value'] = value
+        self._set_sub_text('end', value)
 
     def get_with(self):
-        fields = self.__get_fields()
-        field = fields.get('with')
-        if field:
-            return JID(field['value'])
+        return JID(self._get_sub_text('with'))
 
     def set_with(self, value):
-        fields = self.__get_fields()
-        field = fields.get('with')
-        if field:
-            field['with'] = str(value)
-        else:
-            field = self._form.add_field(var='with')
-            field['value'] = str(value)
+        self._set_sub_text('with', str(value))
+
     # The results interface is meant only as an easy
     # way to access the set of collected message responses
     # from the query.
@@ -96,7 +64,7 @@ class MAM(ElementBase):
 
 class Preferences(ElementBase):
     name = 'prefs'
-    namespace = 'urn:xmpp:mam:2'
+    namespace = 'urn:xmpp:mam:tmp'
     plugin_attrib = 'mam_prefs'
     interfaces = {'default', 'always', 'never'}
     sub_interfaces = {'always', 'never'}
@@ -150,13 +118,22 @@ class Preferences(ElementBase):
             never.append(jid_xml)
 
 
-class Fin(ElementBase):
-    name = 'fin'
-    namespace = 'urn:xmpp:mam:2'
-    plugin_attrib = 'mam_fin'
-
 class Result(ElementBase):
     name = 'result'
-    namespace = 'urn:xmpp:mam:2'
+    namespace = 'urn:xmpp:mam:tmp'
     plugin_attrib = 'mam_result'
     interfaces = {'queryid', 'id'}
+
+
+class Archived(ElementBase):
+    name = 'archived'
+    namespace = 'urn:xmpp:mam:tmp'
+    plugin_attrib = 'mam_archived'
+    plugin_multi_attrib = 'mam_archives'
+    interfaces = {'by', 'id'}
+
+    def get_by(self):
+        return JID(self._get_attr('by'))
+
+    def set_by(self):
+        return self._set_attr('by', str(value))

slixmpp/plugins/xep_0319/idle.py

@@ -6,7 +6,7 @@
     See the file LICENSE for copying permission.
 """
 
-from datetime import datetime, timedelta, timezone
+from datetime import datetime, timedelta
 
 from slixmpp.stanza import Presence
 from slixmpp.plugins import BasePlugin
@@ -16,10 +16,6 @@ from slixmpp.xmlstream.matcher import StanzaPath
 from slixmpp.plugins.xep_0319 import stanza
 
 
-def get_local_timezone():
-    return datetime.now(timezone.utc).astimezone().tzinfo
-
-
 class XEP_0319(BasePlugin):
     name = 'xep_0319'
     description = 'XEP-0319: Last User Interaction in Presence'
@@ -51,11 +47,10 @@ class XEP_0319(BasePlugin):
 
     def idle(self, jid=None, since=None):
         seconds = None
-        timezone = get_local_timezone()
         if since is None:
-            since = datetime.now(timezone)
+            since = datetime.now()
         else:
-            seconds = datetime.now(timezone) - since
+            seconds = datetime.now() - since
         self.api['set_idle'](jid, None, None, since)
         self.xmpp['xep_0012'].set_last_activity(jid=jid, seconds=seconds)
 

slixmpp/plugins/xep_0323/sensordata.py

@@ -291,7 +291,7 @@ class XEP_0323(BasePlugin):
                 request_delay_sec = dtdiff.seconds + dtdiff.days * 24 * 3600
                 if request_delay_sec <= 0:
                     req_ok = False
-                    error_msg = "Invalid datetime in 'when' flag, cannot set a time in the past (%s). Current time: %s" % (dt.isoformat(), dtnow.isoformat())
+                    error_msg = "Invalid datetime in 'when' flag, cannot set a time in the past. Current time: " + dtnow.isoformat()
 
         if req_ok:
             session = self._new_session()

slixmpp/plugins/xep_0323/stanza/sensordata.py

@@ -10,7 +10,7 @@
 
 from slixmpp import Iq, Message
 from slixmpp.xmlstream import register_stanza_plugin, ElementBase, ET, JID
-import re
+from re import match
 
 class Sensordata(ElementBase):
     """ Placeholder for the namespace, not used as a stanza """

slixmpp/plugins/xep_0325/control.py

@@ -399,7 +399,7 @@ class XEP_0325(BasePlugin):
         """
 
         if not session in self.sessions:
-            # This can happen if a session was deleted, like in a timeout. Just drop the data.
+            # This can happend if a session was deleted, like in a timeout. Just drop the data.
             return
 
         if result == "error":
@@ -457,7 +457,7 @@ class XEP_0325(BasePlugin):
         Arguments:
             from_jid        -- The jid of the requester
             to_jid          -- The jid of the device(s)
-            callback        -- The callback function to call when data is available.
+            callback        -- The callback function to call when data is availble.
 
                             The callback function must support the following arguments:
 

slixmpp/plugins/xep_0333/hints.py

@@ -11,8 +11,6 @@ import logging
 from slixmpp import Message
 from slixmpp.plugins import BasePlugin
 from slixmpp.xmlstream import register_stanza_plugin
-from slixmpp.xmlstream.handler import Callback
-from slixmpp.xmlstream.matcher import StanzaPath
 from slixmpp.plugins.xep_0333 import stanza, Markable, Received, Displayed, Acknowledged
 
 log = logging.getLogger(__name__)

slixmpp/plugins/xep_0363/__init__.py

@@ -1,14 +0,0 @@
-"""
-    slixmpp: The Slick XMPP Library
-    Copyright (C) 2018 Emmanuel Gil Peyrot
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.base import register_plugin
-
-from slixmpp.plugins.xep_0363.stanza import Request, Slot, Put, Get, Header
-from slixmpp.plugins.xep_0363.http_upload import XEP_0363
-
-register_plugin(XEP_0363)

slixmpp/plugins/xep_0363/http_upload.py

@@ -1,153 +0,0 @@
-"""
-    slixmpp: The Slick XMPP Library
-    Copyright (C) 2018 Emmanuel Gil Peyrot
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-import logging
-import os.path
-
-from aiohttp import ClientSession
-from mimetypes import guess_type
-
-from slixmpp import Iq, __version__
-from slixmpp.plugins import BasePlugin
-from slixmpp.xmlstream import register_stanza_plugin
-from slixmpp.xmlstream.handler import Callback
-from slixmpp.xmlstream.matcher import StanzaPath
-from slixmpp.plugins.xep_0363 import stanza, Request, Slot, Put, Get, Header
-
-log = logging.getLogger(__name__)
-
-class FileUploadError(Exception):
-    pass
-
-class UploadServiceNotFound(FileUploadError):
-    pass
-
-class FileTooBig(FileUploadError):
-    pass
-
-class XEP_0363(BasePlugin):
-    ''' This plugin only supports Python 3.5+ '''
-
-    name = 'xep_0363'
-    description = 'XEP-0363: HTTP File Upload'
-    dependencies = {'xep_0030', 'xep_0128'}
-    stanza = stanza
-    default_config = {
-        'upload_service': None,
-        'max_file_size': float('+inf'),
-        'default_content_type': 'application/octet-stream',
-    }
-
-    def plugin_init(self):
-        register_stanza_plugin(Iq, Request)
-        register_stanza_plugin(Iq, Slot)
-        register_stanza_plugin(Slot, Put)
-        register_stanza_plugin(Slot, Get)
-        register_stanza_plugin(Put, Header, iterable=True)
-
-        self.xmpp.register_handler(
-                Callback('HTTP Upload Request',
-                         StanzaPath('iq@type=get/http_upload_request'),
-                         self._handle_request))
-
-    def plugin_end(self):
-        self._http_session.close()
-        self.xmpp.remove_handler('HTTP Upload Request')
-        self.xmpp.remove_handler('HTTP Upload Slot')
-        self.xmpp['xep_0030'].del_feature(feature=Request.namespace)
-
-    def session_bind(self, jid):
-        self.xmpp.plugin['xep_0030'].add_feature(Request.namespace)
-
-    def _handle_request(self, iq):
-        self.xmpp.event('http_upload_request', iq)
-
-    async def find_upload_service(self, domain=None, timeout=None):
-        results = await self.xmpp['xep_0030'].get_info_from_domain(
-            domain=domain, timeout=timeout)
-
-        candidates = []
-        for info in results:
-            for identity in info['disco_info']['identities']:
-                if identity[0] == 'store' and identity[1] == 'file':
-                    candidates.append(info)
-        for info in candidates:
-            for feature in info['disco_info']['features']:
-                if feature == Request.namespace:
-                    return info
-
-    def request_slot(self, jid, filename, size, content_type=None, ifrom=None,
-                     timeout=None, callback=None, timeout_callback=None):
-        iq = self.xmpp.Iq()
-        iq['to'] = jid
-        iq['from'] = ifrom
-        iq['type'] = 'get'
-        request = iq['http_upload_request']
-        request['filename'] = filename
-        request['size'] = str(size)
-        request['content-type'] = content_type or self.default_content_type
-        return iq.send(timeout=timeout, callback=callback,
-                       timeout_callback=timeout_callback)
-
-    async def upload_file(self, filename, size=None, content_type=None, *,
-                          input_file=None, ifrom=None, domain=None, timeout=None,
-                          callback=None, timeout_callback=None):
-        ''' Helper function which does all of the uploading process. '''
-        if self.upload_service is None:
-            info_iq = await self.find_upload_service(
-                domain=domain, timeout=timeout)
-            if info_iq is None:
-                raise UploadServiceNotFound()
-            self.upload_service = info_iq['from']
-            for form in info_iq['disco_info'].iterables:
-                values = form['values']
-                if values['FORM_TYPE'] == ['urn:xmpp:http:upload:0']:
-                    try:
-                        self.max_file_size = int(values['max-file-size'])
-                    except (TypeError, ValueError):
-                        log.error('Invalid max size received from HTTP File Upload service')
-                        self.max_file_size = float('+inf')
-                break
-
-        if input_file is None:
-            input_file = open(filename, 'rb')
-
-        if size is None:
-            size = input_file.seek(0, 2)
-            input_file.seek(0)
-
-        if size > self.max_file_size:
-            raise FileTooBig()
-
-        if content_type is None:
-            content_type = guess_type(filename)[0]
-            if content_type is None:
-                content_type = self.default_content_type
-
-        basename = os.path.basename(filename)
-        slot_iq = await self.request_slot(self.upload_service, basename, size,
-                                          content_type, ifrom, timeout,
-                                          timeout_callback=timeout_callback)
-        slot = slot_iq['http_upload_slot']
-
-        headers = {
-            'Content-Length': str(size),
-            'Content-Type': content_type or self.default_content_type,
-            **{header['name']: header['value'] for header in slot['put']['headers']}
-        }
-
-        # Do the actual upload here.
-        async with ClientSession(headers={'User-Agent': 'slixmpp ' + __version__}) as session:
-            response = await session.put(
-                    slot['put']['url'],
-                    data=input_file,
-                    headers=headers,
-                    timeout=timeout)
-            log.info('Response code: %d (%s)', response.status, await response.text())
-            response.close()
-            return slot['get']['url']

slixmpp/plugins/xep_0363/stanza.py

@@ -1,48 +0,0 @@
-"""
-    slixmpp: The Slick XMPP Library
-    Copyright (C) 2018 Emmanuel Gil Peyrot
-    This file is part of slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.xmlstream import ElementBase
-
-class Request(ElementBase):
-    plugin_attrib = 'http_upload_request'
-    name = 'request'
-    namespace = 'urn:xmpp:http:upload:0'
-    interfaces = {'filename', 'size', 'content-type'}
-
-class Slot(ElementBase):
-    plugin_attrib = 'http_upload_slot'
-    name = 'slot'
-    namespace = 'urn:xmpp:http:upload:0'
-
-class Put(ElementBase):
-    plugin_attrib = 'put'
-    name = 'put'
-    namespace = 'urn:xmpp:http:upload:0'
-    interfaces = {'url'}
-
-class Get(ElementBase):
-    plugin_attrib = 'get'
-    name = 'get'
-    namespace = 'urn:xmpp:http:upload:0'
-    interfaces = {'url'}
-
-class Header(ElementBase):
-    plugin_attrib = 'header'
-    name = 'header'
-    namespace = 'urn:xmpp:http:upload:0'
-    plugin_multi_attrib = 'headers'
-    interfaces = {'name', 'value'}
-
-    def get_value(self):
-        return self.xml.text
-
-    def set_value(self, value):
-        self.xml.text = value
-
-    def del_value(self):
-        self.xml.text = ''

slixmpp/plugins/xep_0380/__init__.py

@@ -1,15 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2016 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.base import register_plugin
-
-from slixmpp.plugins.xep_0380.stanza import Encryption
-from slixmpp.plugins.xep_0380.eme import XEP_0380
-
-
-register_plugin(XEP_0380)

slixmpp/plugins/xep_0380/eme.py

@@ -1,69 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2016 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-import logging
-
-import slixmpp
-from slixmpp.stanza import Message
-from slixmpp.xmlstream.handler import Callback
-from slixmpp.xmlstream.matcher import StanzaPath
-from slixmpp.xmlstream import register_stanza_plugin, ElementBase, ET
-from slixmpp.plugins import BasePlugin
-from slixmpp.plugins.xep_0380 import stanza, Encryption
-
-
-log = logging.getLogger(__name__)
-
-
-class XEP_0380(BasePlugin):
-
-    """
-    XEP-0380: Explicit Message Encryption
-    """
-
-    name = 'xep_0380'
-    description = 'XEP-0380: Explicit Message Encryption'
-    dependencies = {'xep_0030'}
-    default_config = {
-        'template': 'This message is encrypted with {name} ({namespace})',
-    }
-
-    mechanisms = {
-        'jabber:x:encrypted': 'Legacy OpenPGP',
-        'urn:xmpp:ox:0': 'OpenPGP for XMPP',
-        'urn:xmpp:otr:0': 'OTR',
-        'eu.siacs.conversations.axolotl': 'Legacy OMEMO',
-        'urn:xmpp:omemo:0': 'OMEMO',
-    }
-
-    def plugin_init(self):
-        self.xmpp.register_handler(
-            Callback('Explicit Message Encryption',
-                     StanzaPath('message/eme'),
-                     self._handle_eme))
-
-        register_stanza_plugin(Message, Encryption)
-
-    def plugin_end(self):
-        self.xmpp.remove_handler('Chat State')
-
-    def session_bind(self, jid):
-        self.xmpp.plugin['xep_0030'].add_feature(Encryption.namespace)
-
-    def has_eme(self, msg):
-        return msg.xml.find('{%s}encryption' % Encryption.namespace) is not None
-
-    def replace_body_with_eme(self, msg):
-        eme = msg['eme']
-        namespace = eme['namespace']
-        name = self.mechanisms[namespace] if namespace in self.mechanisms else eme['name']
-        body = self.config['template'].format(name=name, namespace=namespace)
-        msg['body'] = body
-
-    def _handle_eme(self, msg):
-        self.xmpp.event('message_encryption', msg)

slixmpp/plugins/xep_0380/stanza.py

@@ -1,16 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2016 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.xmlstream import ElementBase
-
-
-class Encryption(ElementBase):
-    name = 'encryption'
-    namespace = 'urn:xmpp:eme:0'
-    plugin_attrib = 'eme'
-    interfaces = {'namespace', 'name'}

slixmpp/plugins/xep_0394/__init__.py

@@ -1,15 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2017 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.plugins.base import register_plugin
-
-from slixmpp.plugins.xep_0394.stanza import Markup, Span, BlockCode, List, Li, BlockQuote
-from slixmpp.plugins.xep_0394.markup import XEP_0394
-
-
-register_plugin(XEP_0394)

slixmpp/plugins/xep_0394/markup.py

@@ -1,161 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2017 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-
-from slixmpp.stanza import Message
-from slixmpp.plugins import BasePlugin
-from slixmpp.xmlstream import register_stanza_plugin, ET, tostring
-from slixmpp.plugins.xep_0394 import stanza, Markup, Span, BlockCode, List, Li, BlockQuote
-from slixmpp.plugins.xep_0071 import XHTML_IM
-
-
-class Start:
-    def __init__(self, elem):
-        self.elem = elem
-
-    def __repr__(self):
-        return 'Start(%s)' % self.elem
-
-
-class End:
-    def __init__(self, elem):
-        self.elem = elem
-
-    def __repr__(self):
-        return 'End(%s)' % self.elem
-
-
-class XEP_0394(BasePlugin):
-
-    name = 'xep_0394'
-    description = 'XEP-0394: Message Markup'
-    dependencies = {'xep_0030', 'xep_0071'}
-    stanza = stanza
-
-    def plugin_init(self):
-        register_stanza_plugin(Message, Markup)
-
-    def session_bind(self, jid):
-        self.xmpp['xep_0030'].add_feature(feature=Markup.namespace)
-
-    def plugin_end(self):
-        self.xmpp['xep_0030'].del_feature(feature=Markup.namespace)
-
-    @staticmethod
-    def _split_first_level(body, markup_elem):
-        split_points = []
-        elements = {}
-        for markup in markup_elem['substanzas']:
-            start = markup['start']
-            end = markup['end']
-            split_points.append(start)
-            split_points.append(end)
-            elements.setdefault(start, []).append(Start(markup))
-            elements.setdefault(end, []).append(End(markup))
-            if isinstance(markup, List):
-                lis = markup['lis']
-                for i, li in enumerate(lis):
-                    start = li['start']
-                    split_points.append(start)
-                    li_end = lis[i + 1]['start'] if i < len(lis) - 1 else end
-                    elements.setdefault(li_end, []).append(End(li))
-                    elements.setdefault(start, []).append(Start(li))
-        split_points = set(split_points)
-        new_body = [[]]
-        for i, letter in enumerate(body + '\x00'):
-            if i in split_points:
-                body_elements = []
-                for elem in elements[i]:
-                    body_elements.append(elem)
-                new_body.append(body_elements)
-                new_body.append([])
-            new_body[-1].append(letter)
-        new_body[-1] = new_body[-1][:-1]
-        final = []
-        for chunk in new_body:
-            if not chunk:
-                continue
-            final.append(''.join(chunk) if isinstance(chunk[0], str) else chunk)
-        return final
-
-    def to_plain_text(self, body, markup_elem):
-        chunks = self._split_first_level(body, markup_elem)
-        final = []
-        for chunk in chunks:
-            if isinstance(chunk, str):
-                final.append(chunk)
-        return ''.join(final)
-
-    def to_xhtml_im(self, body, markup_elem):
-        chunks = self._split_first_level(body, markup_elem)
-        final = []
-        stack = []
-        for chunk in chunks:
-            if isinstance(chunk, str):
-                chunk = (chunk.replace("&", '&amp;')
-                              .replace('<', '&lt;')
-                              .replace('>', '&gt;')
-                              .replace('"', '&quot;')
-                              .replace("'", '&apos;')
-                              .replace('\n', '<br/>'))
-                final.append(chunk)
-                continue
-            num_end = 0
-            for elem in chunk:
-                if isinstance(elem, End):
-                    num_end += 1
-
-            for i in range(num_end):
-                stack_top = stack.pop()
-                for elem in chunk:
-                    if not isinstance(elem, End):
-                        continue
-                    elem = elem.elem
-                    if elem is stack_top:
-                        if isinstance(elem, Span):
-                            final.append('</span>')
-                        elif isinstance(elem, BlockCode):
-                            final.append('</code></pre>')
-                        elif isinstance(elem, List):
-                            final.append('</ul>')
-                        elif isinstance(elem, Li):
-                            final.append('</li>')
-                        elif isinstance(elem, BlockQuote):
-                            final.append('</blockquote>')
-                        break
-                else:
-                    assert False
-            for elem in chunk:
-                if not isinstance(elem, Start):
-                    continue
-                elem = elem.elem
-                stack.append(elem)
-                if isinstance(elem, Span):
-                    style = []
-                    for type_ in elem['types']:
-                        if type_ == 'emphasis':
-                            style.append('font-style: italic;')
-                        if type_ == 'code':
-                            style.append('font-family: monospace;')
-                        if type_ == 'deleted':
-                            style.append('text-decoration: line-through;')
-                    final.append("<span style='%s'>" % ' '.join(style))
-                elif isinstance(elem, BlockCode):
-                    final.append('<pre><code>')
-                elif isinstance(elem, List):
-                    final.append('<ul>')
-                elif isinstance(elem, Li):
-                    final.append('<li>')
-                elif isinstance(elem, BlockQuote):
-                    final.append('<blockquote>')
-        p = "<p xmlns='http://www.w3.org/1999/xhtml'>%s</p>" % ''.join(final)
-        p2 = ET.fromstring(p)
-        print('coucou', p, tostring(p2))
-        xhtml_im = XHTML_IM()
-        xhtml_im['body'] = p2
-        return xhtml_im

slixmpp/plugins/xep_0394/stanza.py

@@ -1,123 +0,0 @@
-"""
-    Slixmpp: The Slick XMPP Library
-    Copyright (C) 2017 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
-    This file is part of Slixmpp.
-
-    See the file LICENSE for copying permission.
-"""
-
-from slixmpp.xmlstream import ElementBase, register_stanza_plugin, ET
-
-
-class Markup(ElementBase):
-    namespace = 'urn:xmpp:markup:0'
-    name = 'markup'
-    plugin_attrib = 'markup'
-
-
-class _FirstLevel(ElementBase):
-    namespace = 'urn:xmpp:markup:0'
-    interfaces = {'start', 'end'}
-
-    def get_start(self):
-        return int(self._get_attr('start'))
-
-    def set_start(self, value):
-        self._set_attr('start', '%d' % value)
-
-    def get_end(self):
-        return int(self._get_attr('end'))
-
-    def set_end(self, value):
-        self._set_attr('end', '%d' % value)
-
-class Span(_FirstLevel):
-    name = 'span'
-    plugin_attrib = 'span'
-    plugin_multi_attrib = 'spans'
-    interfaces = {'start', 'end', 'types'}
-
-    def get_types(self):
-        types = []
-        if self.xml.find('{urn:xmpp:markup:0}emphasis') is not None:
-            types.append('emphasis')
-        if self.xml.find('{urn:xmpp:markup:0}code') is not None:
-            types.append('code')
-        if self.xml.find('{urn:xmpp:markup:0}deleted') is not None:
-            types.append('deleted')
-        return types
-
-    def set_types(self, value):
-        del self['types']
-        for type_ in value:
-            if type_ == 'emphasis':
-                self.xml.append(ET.Element('{urn:xmpp:markup:0}emphasis'))
-            elif type_ == 'code':
-                self.xml.append(ET.Element('{urn:xmpp:markup:0}code'))
-            elif type_ == 'deleted':
-                self.xml.append(ET.Element('{urn:xmpp:markup:0}deleted'))
-
-    def det_types(self):
-        for child in self.xml:
-            self.xml.remove(child)
-
-
-class _SpanType(ElementBase):
-    namespace = 'urn:xmpp:markup:0'
-
-
-class EmphasisType(_SpanType):
-    name = 'emphasis'
-    plugin_attrib = 'emphasis'
-
-
-class CodeType(_SpanType):
-    name = 'code'
-    plugin_attrib = 'code'
-
-
-class DeletedType(_SpanType):
-    name = 'deleted'
-    plugin_attrib = 'deleted'
-
-
-class BlockCode(_FirstLevel):
-    name = 'bcode'
-    plugin_attrib = 'bcode'
-    plugin_multi_attrib = 'bcodes'
-
-
-class List(_FirstLevel):
-    name = 'list'
-    plugin_attrib = 'list'
-    plugin_multi_attrib = 'lists'
-    interfaces = {'start', 'end', 'li'}
-
-
-class Li(ElementBase):
-    namespace = 'urn:xmpp:markup:0'
-    name = 'li'
-    plugin_attrib = 'li'
-    plugin_multi_attrib = 'lis'
-    interfaces = {'start'}
-
-    def get_start(self):
-        return int(self._get_attr('start'))
-
-    def set_start(self, value):
-        self._set_attr('start', '%d' % value)
-
-
-class BlockQuote(_FirstLevel):
-    name = 'bquote'
-    plugin_attrib = 'bquote'
-    plugin_multi_attrib = 'bquotes'
-
-register_stanza_plugin(Markup, Span, iterable=True)
-register_stanza_plugin(Markup, BlockCode, iterable=True)
-register_stanza_plugin(Markup, List, iterable=True)
-register_stanza_plugin(Markup, BlockQuote, iterable=True)
-register_stanza_plugin(Span, EmphasisType)
-register_stanza_plugin(Span, CodeType)
-register_stanza_plugin(Span, DeletedType)
-register_stanza_plugin(List, Li, iterable=True)

slixmpp/stanza/iq.py

@@ -188,19 +188,10 @@ class Iq(RootStanza):
         future = asyncio.Future()
 
         def callback_success(result):
-            type_ = result['type']
-            if type_ == 'result':
-                future.set_result(result)
-            elif type_ == 'error':
+            if result['type'] == 'error':
                 future.set_exception(IqError(result))
             else:
-                # Most likely an iq addressed to ourself, rearm the callback.
-                handler = constr(handler_name,
-                                 matcher,
-                                 callback_success,
-                                 once=True)
-                self.stream.register_handler(handler)
-                return
+                future.set_result(result)
 
             if timeout is not None:
                 self.stream.cancel_schedule('IqTimeout_%s' % self['id'])

slixmpp/stanza/message.py

@@ -48,7 +48,7 @@ class Message(RootStanza):
     namespace = 'jabber:client'
     plugin_attrib = name
     interfaces = {'type', 'to', 'from', 'id', 'body', 'subject', 'thread',
-                  'parent_thread', 'mucroom', 'mucnick'}
+                  'parent_thread', 'mucroom', 'mucnick'])
     sub_interfaces = {'body', 'subject', 'thread'}
     lang_interfaces = sub_interfaces
     types = {'normal', 'chat', 'headline', 'error', 'groupchat'}

slixmpp/stanza/roster.py

@@ -40,7 +40,7 @@ class Roster(ElementBase):
 
     def get_ver(self):
         """
-        Ensure handling an empty ver attribute property.
+        Ensure handling an empty ver attribute propery.
 
         The ver attribute is special in that the presence of the
         attribute with an empty value is important for boostrapping
@@ -50,7 +50,7 @@ class Roster(ElementBase):
 
     def set_ver(self, ver):
         """
-        Ensure handling an empty ver attribute property.
+        Ensure handling an empty ver attribute propery.
 
         The ver attribute is special in that the presence of the
         attribute with an empty value is important for boostrapping

slixmpp/stringprep.py

@@ -114,7 +114,7 @@ def punycode(domain):
             if char in ILLEGAL_CHARS:
                 raise StringprepError
 
-        domain_parts.append(label.encode('ascii'))
+        domain_parts.append(label)
     return b'.'.join(domain_parts)
 
 logging.getLogger(__name__).warning('Using slower stringprep, consider '

slixmpp/test/slixtest.py

@@ -222,7 +222,7 @@ class SlixTest(unittest.TestCase):
             if Matcher is None:
                 raise ValueError("Unknown matching method.")
             test = Matcher(criteria)
-            self.assertTrue(test.match(stanza),
+            self.failUnless(test.match(stanza),
                     "Stanza did not match using %s method:\n" % method + \
                     "Criteria:\n%s\n" % str(criteria) + \
                     "Stanza:\n%s" % str(stanza))
@@ -280,7 +280,7 @@ class SlixTest(unittest.TestCase):
                 debug += "Generated stanza:\n%s\n" % highlight(tostring(stanza2.xml))
                 result = self.compare(xml, stanza.xml, stanza2.xml)
 
-            self.assertTrue(result, debug)
+            self.failUnless(result, debug)
 
     # ------------------------------------------------------------------
     # Methods for simulating stanza streams.
@@ -487,7 +487,7 @@ class SlixTest(unittest.TestCase):
             recv_xml.clear()
             recv_xml.attrib = attrib
 
-        self.assertTrue(
+        self.failUnless(
             self.compare(xml, recv_xml),
             "Stream headers do not match:\nDesired:\n%s\nReceived:\n%s" % (
                 '%s %s' % (xml.tag, xml.attrib),
@@ -543,7 +543,7 @@ class SlixTest(unittest.TestCase):
         xml = self.parse_xml(header2)
         sent_xml = self.parse_xml(sent_header2)
 
-        self.assertTrue(
+        self.failUnless(
             self.compare(xml, sent_xml),
             "Stream headers do not match:\nDesired:\n%s\nSent:\n%s" % (
                 header, sent_header))
@@ -557,12 +557,12 @@ class SlixTest(unittest.TestCase):
         if sent_data is None:
             self.fail("No stanza was sent.")
         if method == 'exact':
-            self.assertTrue(self.compare(xml, sent_xml),
+            self.failUnless(self.compare(xml, sent_xml),
                 "Features do not match.\nDesired:\n%s\nReceived:\n%s" % (
                     highlight(tostring(xml)), highlight(tostring(sent_xml))))
         elif method == 'mask':
             matcher = MatchXMLMask(xml)
-            self.assertTrue(matcher.match(sent_xml),
+            self.failUnless(matcher.match(sent_xml),
                 "Stanza did not match using %s method:\n" % method + \
                 "Criteria:\n%s\n" % highlight(tostring(xml)) + \
                 "Stanza:\n%s" % highlight(tostring(sent_xml)))