Mercurial > libervia-backend
diff src/plugins/plugin_xep_0060.py @ 891:a7b2aacf22ac
plugin XEP-0060, groupblog: added nodeIdentifiers attribute to getItems in order to retrieve items by ids
author | souliane <souliane@mailoo.org> |
---|---|
date | Tue, 25 Feb 2014 17:49:15 +0100 |
parents | 1fe00f0c9a91 |
children | 1a759096ccbd |
line wrap: on
line diff
--- a/src/plugins/plugin_xep_0060.py Tue Feb 25 11:32:21 2014 +0100 +++ b/src/plugins/plugin_xep_0060.py Tue Feb 25 17:49:15 2014 +0100 @@ -99,9 +99,9 @@ profile, client = self.__getClientNProfile(profile_key, 'publish item') return client.publish(service, nodeIdentifier, items, client.parent.jid) - def getItems(self, service, node, max_items=None, sub_id=None, profile_key='@DEFAULT@'): + def getItems(self, service, node, max_items=None, item_ids=None, sub_id=None, profile_key='@DEFAULT@'): profile, client = self.__getClientNProfile(profile_key, 'get items') - return client.items(service, node, max_items, sub_id, client.parent.jid) + return client.items(service, node, max_items, item_ids, sub_id, client.parent.jid) def getOptions(self, service, nodeIdentifier, subscriber, subscriptionIdentifier=None, profile_key='@DEFAULT@'): profile, client = self.__getClientNProfile(profile_key, 'get options') @@ -139,7 +139,54 @@ def connectionInitialized(self): pubsub.PubSubClient.connectionInitialized(self) - # XXX: this should be done in wokkel + # FIXME: we have to temporary override this method here just + # to set the attributes itemIdentifiers which is not used + # in pubsub.PubSubClient.items + def items(self, service, nodeIdentifier, maxItems=None, itemIdentifiers=None, + subscriptionIdentifier=None, sender=None): + """ + Retrieve previously published items from a publish subscribe node. + + @param service: The publish subscribe service that keeps the node. + @type service: L{JID<twisted.words.protocols.jabber.jid.JID>} + + @param nodeIdentifier: The identifier of the node. + @type nodeIdentifier: C{unicode} + + @param maxItems: Optional limit on the number of retrieved items. + @type maxItems: C{int} + + @param itemIdentifiers: Identifiers of the items to be retracted. + @type itemIdentifiers: C{set} + + @param subscriptionIdentifier: Optional subscription identifier. In + case the node has been subscribed to multiple times, this narrows + the results to the specific subscription. + @type subscriptionIdentifier: C{unicode} + """ + NS_PUBSUB = 'http://jabber.org/protocol/pubsub' + + request = PubSubRequest('items') + request.recipient = service + request.nodeIdentifier = nodeIdentifier + if maxItems: + request.maxItems = str(int(maxItems)) + request.subscriptionIdentifier = subscriptionIdentifier + request.sender = sender + request.itemIdentifiers = itemIdentifiers # XXX: this line has been added + + def cb(iq): + items = [] + for element in iq.pubsub.items.elements(): + if element.uri == NS_PUBSUB and element.name == 'item': + items.append(element) + return items + + d = request.send(self.xmlstream) + d.addCallback(cb) + return d + + # FIXME: this should be done in wokkel def retractItems(self, service, nodeIdentifier, itemIdentifiers, sender=None): """ Retract items from a publish subscribe node.