diff options
Diffstat (limited to 'sleekxmpp/clientxmpp.py')
| -rw-r--r-- | sleekxmpp/clientxmpp.py | 49 |
1 files changed, 22 insertions, 27 deletions
diff --git a/sleekxmpp/clientxmpp.py b/sleekxmpp/clientxmpp.py index d2f24d16..02f7776a 100644 --- a/sleekxmpp/clientxmpp.py +++ b/sleekxmpp/clientxmpp.py @@ -20,7 +20,7 @@ from sleekxmpp.stanza import StreamFeatures from sleekxmpp.basexmpp import BaseXMPP from sleekxmpp.exceptions import XMPPError from sleekxmpp.xmlstream import XMLStream -from sleekxmpp.xmlstream.matcher import MatchXPath +from sleekxmpp.xmlstream.matcher import StanzaPath, MatchXPath from sleekxmpp.xmlstream.handler import Callback # Flag indicating if DNS SRV records are available for use. @@ -103,9 +103,7 @@ class ClientXMPP(BaseXMPP): self._handle_stream_features)) self.register_handler( Callback('Roster Update', - MatchXPath('{%s}iq/{%s}query' % ( - self.default_ns, - 'jabber:iq:roster')), + StanzaPath('iq@type=set/roster'), self._handle_roster)) # Setup default stream features @@ -230,7 +228,8 @@ class ClientXMPP(BaseXMPP): response = iq.send(block, timeout, callback) if block: - self._handle_roster(response, request=True) + self.event('roster_received', response) + self._handle_roster(response) return response def _handle_connected(self, event=None): @@ -254,32 +253,28 @@ class ClientXMPP(BaseXMPP): # restarting the XML stream. return True - def _handle_roster(self, iq, request=False): + def _handle_roster(self, iq): """Update the roster after receiving a roster stanza. :param iq: The roster stanza. - :param request: Indicates if this stanza is a response - to a request for the roster, and not an - empty acknowledgement from the server. """ - if iq['from'].bare and iq['from'].bare != self.boundjid.bare: - raise XMPPError(condition='service-unavailable') - if iq['type'] == 'set' or (iq['type'] == 'result' and request): - roster = self.client_roster - if iq['roster']['ver']: - roster.version = iq['roster']['ver'] - for jid in iq['roster']['items']: - item = iq['roster']['items'][jid] - roster[jid]['name'] = item['name'] - roster[jid]['groups'] = item['groups'] - roster[jid]['from'] = item['subscription'] in ['from', 'both'] - roster[jid]['to'] = item['subscription'] in ['to', 'both'] - roster[jid]['pending_out'] = (item['ask'] == 'subscribe') - - roster[jid].save(remove=(item['subscription'] == 'remove')) - - self.event('roster_received', iq) - + if iq['type'] == 'set': + if iq['from'].bare and iq['from'].bare != self.boundjid.bare: + raise XMPPError(condition='service-unavailable') + + roster = self.client_roster + if iq['roster']['ver']: + roster.version = iq['roster']['ver'] + for jid in iq['roster']['items']: + item = iq['roster']['items'][jid] + roster[jid]['name'] = item['name'] + roster[jid]['groups'] = item['groups'] + roster[jid]['from'] = item['subscription'] in ['from', 'both'] + roster[jid]['to'] = item['subscription'] in ['to', 'both'] + roster[jid]['pending_out'] = (item['ask'] == 'subscribe') + + roster[jid].save(remove=(item['subscription'] == 'remove')) + self.event("roster_update", iq) if iq['type'] == 'set': iq.reply() |