568 lines
24 KiB
Python
568 lines
24 KiB
Python
"""
|
|
SleekXMPP: The Sleek XMPP Library
|
|
Copyright (C) 2011 Nathanael C. Fritz
|
|
This file is part of SleekXMPP.
|
|
|
|
See the file LICENSE for copying permission.
|
|
"""
|
|
|
|
import logging
|
|
|
|
from sleekxmpp.xmlstream import JID
|
|
from sleekxmpp.xmlstream.handler import Callback
|
|
from sleekxmpp.xmlstream.matcher import StanzaPath
|
|
from sleekxmpp.plugins.base import BasePlugin
|
|
from sleekxmpp.plugins.xep_0060 import stanza
|
|
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
|
|
class XEP_0060(BasePlugin):
|
|
|
|
"""
|
|
XEP-0060 Publish Subscribe
|
|
"""
|
|
|
|
name = 'xep_0060'
|
|
description = 'XEP-0060: Publish-Subscribe'
|
|
dependencies = set(['xep_0030', 'xep_0004'])
|
|
stanza = stanza
|
|
|
|
def plugin_init(self):
|
|
self.node_event_map = {}
|
|
|
|
self.xmpp.register_handler(
|
|
Callback('Pubsub Event: Items',
|
|
StanzaPath('message/pubsub_event/items'),
|
|
self._handle_event_items))
|
|
self.xmpp.register_handler(
|
|
Callback('Pubsub Event: Purge',
|
|
StanzaPath('message/pubsub_event/purge'),
|
|
self._handle_event_purge))
|
|
self.xmpp.register_handler(
|
|
Callback('Pubsub Event: Delete',
|
|
StanzaPath('message/pubsub_event/delete'),
|
|
self._handle_event_delete))
|
|
self.xmpp.register_handler(
|
|
Callback('Pubsub Event: Configuration',
|
|
StanzaPath('message/pubsub_event/configuration'),
|
|
self._handle_event_configuration))
|
|
self.xmpp.register_handler(
|
|
Callback('Pubsub Event: Subscription',
|
|
StanzaPath('message/pubsub_event/subscription'),
|
|
self._handle_event_subscription))
|
|
|
|
def _handle_event_items(self, msg):
|
|
"""Raise events for publish and retraction notifications."""
|
|
node = msg['pubsub_event']['items']['node']
|
|
|
|
multi = len(msg['pubsub_event']['items']) > 1
|
|
values = {}
|
|
if multi:
|
|
values = msg.values
|
|
del values['pubsub_event']
|
|
|
|
for item in msg['pubsub_event']['items']:
|
|
event_name = self.node_event_map.get(node, None)
|
|
event_type = 'publish'
|
|
if item.name == 'retract':
|
|
event_type = 'retract'
|
|
|
|
if multi:
|
|
condensed = self.xmpp.Message()
|
|
condensed.values = values
|
|
condensed['pubsub_event']['items']['node'] = node
|
|
condensed['pubsub_event']['items'].append(item)
|
|
self.xmpp.event('pubsub_%s' % event_type, msg)
|
|
if event_name:
|
|
self.xmpp.event('%s_%s' % (event_name, event_type),
|
|
condensed)
|
|
else:
|
|
self.xmpp.event('pubsub_%s' % event_type, msg)
|
|
if event_name:
|
|
self.xmpp.event('%s_%s' % (event_name, event_type), msg)
|
|
|
|
def _handle_event_purge(self, msg):
|
|
"""Raise events for node purge notifications."""
|
|
node = msg['pubsub_event']['purge']['node']
|
|
event_name = self.node_event_map.get(node, None)
|
|
|
|
self.xmpp.event('pubsub_purge', msg)
|
|
if event_name:
|
|
self.xmpp.event('%s_purge' % event_name, msg)
|
|
|
|
def _handle_event_delete(self, msg):
|
|
"""Raise events for node deletion notifications."""
|
|
node = msg['pubsub_event']['delete']['node']
|
|
event_name = self.node_event_map.get(node, None)
|
|
|
|
self.xmpp.event('pubsub_delete', msg)
|
|
if event_name:
|
|
self.xmpp.event('%s_delete' % event_name, msg)
|
|
|
|
def _handle_event_configuration(self, msg):
|
|
"""Raise events for node configuration notifications."""
|
|
node = msg['pubsub_event']['configuration']['node']
|
|
event_name = self.node_event_map.get(node, None)
|
|
|
|
self.xmpp.event('pubsub_config', msg)
|
|
if event_name:
|
|
self.xmpp.event('%s_config' % event_name, msg)
|
|
|
|
def _handle_event_subscription(self, msg):
|
|
"""Raise events for node subscription notifications."""
|
|
node = msg['pubsub_event']['subscription']['node']
|
|
event_name = self.node_event_map.get(node, None)
|
|
|
|
self.xmpp.event('pubsub_subscription', msg)
|
|
if event_name:
|
|
self.xmpp.event('%s_subscription' % event_name, msg)
|
|
|
|
def map_node_event(self, node, event_name):
|
|
"""
|
|
Map node names to events.
|
|
|
|
When a pubsub event is received for the given node,
|
|
raise the provided event.
|
|
|
|
For example::
|
|
|
|
map_node_event('http://jabber.org/protocol/tune',
|
|
'user_tune')
|
|
|
|
will produce the events 'user_tune_publish' and 'user_tune_retract'
|
|
when the respective notifications are received from the node
|
|
'http://jabber.org/protocol/tune', among other events.
|
|
|
|
Arguments:
|
|
node -- The node name to map to an event.
|
|
event_name -- The name of the event to raise when a
|
|
notification from the given node is received.
|
|
"""
|
|
self.node_event_map[node] = event_name
|
|
|
|
def create_node(self, jid, node, config=None, ntype=None, ifrom=None,
|
|
block=True, callback=None, timeout=None):
|
|
"""
|
|
Create and configure a new pubsub node.
|
|
|
|
A server MAY use a different name for the node than the one provided,
|
|
so be sure to check the result stanza for a server assigned name.
|
|
|
|
If no configuration form is provided, the node will be created using
|
|
the server's default configuration. To get the default configuration
|
|
use get_node_config().
|
|
|
|
Arguments:
|
|
jid -- The JID of the pubsub service.
|
|
node -- Optional name of the node to create. If no name is
|
|
provided, the server MAY generate a node ID for you.
|
|
The server can also assign a different name than the
|
|
one you provide; check the result stanza to see if
|
|
the server assigned a name.
|
|
config -- Optional XEP-0004 data form of configuration settings.
|
|
ntype -- The type of node to create. Servers typically default
|
|
to using 'leaf' if no type is provided.
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a response
|
|
before exiting the send call if blocking is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub']['create']['node'] = node
|
|
|
|
if config is not None:
|
|
form_type = 'http://jabber.org/protocol/pubsub#node_config'
|
|
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['fields']:
|
|
config.field['pubsub#node_type']['value'] = ntype
|
|
else:
|
|
config.add_field(var='pubsub#node_type', value=ntype)
|
|
iq['pubsub']['configure'].append(config)
|
|
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def subscribe(self, jid, node, bare=True, subscribee=None, options=None,
|
|
ifrom=None, block=True, callback=None, timeout=None):
|
|
"""
|
|
Subscribe to updates from a pubsub node.
|
|
|
|
The rules for determining the JID that is subscribing to the node are:
|
|
1. If subscribee is given, use that as provided.
|
|
2. If ifrom was given, use the bare or full version based on bare.
|
|
3. Otherwise, use self.xmpp.boundjid based on bare.
|
|
|
|
Arguments:
|
|
jid -- The pubsub service JID.
|
|
node -- The node to subscribe to.
|
|
bare -- Indicates if the subscribee is a bare or full JID.
|
|
Defaults to True for a bare JID.
|
|
subscribee -- The JID that is subscribing to the node.
|
|
options --
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a
|
|
response before exiting the send call if blocking
|
|
is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub']['subscribe']['node'] = node
|
|
|
|
if subscribee is None:
|
|
if ifrom:
|
|
if bare:
|
|
subscribee = JID(ifrom).bare
|
|
else:
|
|
subscribee = ifrom
|
|
else:
|
|
if bare:
|
|
subscribee = self.xmpp.boundjid.bare
|
|
else:
|
|
subscribee = self.xmpp.boundjid
|
|
|
|
iq['pubsub']['subscribe']['jid'] = subscribee
|
|
if options is not None:
|
|
iq['pubsub']['options'].append(options)
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def unsubscribe(self, jid, node, subid=None, bare=True, subscribee=None,
|
|
ifrom=None, block=True, callback=None, timeout=None):
|
|
"""
|
|
Unubscribe from updates from a pubsub node.
|
|
|
|
The rules for determining the JID that is unsubscribing
|
|
from the node are:
|
|
1. If subscribee is given, use that as provided.
|
|
2. If ifrom was given, use the bare or full version based on bare.
|
|
3. Otherwise, use self.xmpp.boundjid based on bare.
|
|
|
|
Arguments:
|
|
jid -- The pubsub service JID.
|
|
node -- The node to subscribe to.
|
|
subid -- The specific subscription, if multiple subscriptions
|
|
exist for this JID/node combination.
|
|
bare -- Indicates if the subscribee is a bare or full JID.
|
|
Defaults to True for a bare JID.
|
|
subscribee -- The JID that is subscribing to the node.
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a
|
|
response before exiting the send call if blocking
|
|
is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub']['unsubscribe']['node'] = node
|
|
|
|
if subscribee is None:
|
|
if ifrom:
|
|
if bare:
|
|
subscribee = JID(ifrom).bare
|
|
else:
|
|
subscribee = ifrom
|
|
else:
|
|
if bare:
|
|
subscribee = self.xmpp.boundjid.bare
|
|
else:
|
|
subscribee = self.xmpp.boundjid
|
|
|
|
iq['pubsub']['unsubscribe']['jid'] = subscribee
|
|
iq['pubsub']['unsubscribe']['subid'] = subid
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_subscriptions(self, jid, node=None, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
iq['pubsub']['subscriptions']['node'] = node
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_affiliations(self, jid, node=None, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
iq['pubsub']['affiliations']['node'] = node
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_subscription_options(self, jid, node=None, user_jid=None,
|
|
ifrom=None, block=True, callback=None,
|
|
timeout=None):
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
if user_jid is None:
|
|
iq['pubsub']['default']['node'] = node
|
|
else:
|
|
iq['pubsub']['options']['node'] = node
|
|
iq['pubsub']['options']['jid'] = user_jid
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def set_subscription_options(self, jid, node, user_jid, options,
|
|
ifrom=None, block=True, callback=None,
|
|
timeout=None):
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
iq['pubsub']['options']['node'] = node
|
|
iq['pubsub']['options']['jid'] = user_jid
|
|
iq['pubsub']['options'].append(options)
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_node_config(self, jid, node=None, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
"""
|
|
Retrieve the configuration for a node, or the pubsub service's
|
|
default configuration for new nodes.
|
|
|
|
Arguments:
|
|
jid -- The JID of the pubsub service.
|
|
node -- The node to retrieve the configuration for. If None,
|
|
the default configuration for new nodes will be
|
|
requested. Defaults to None.
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a response
|
|
before exiting the send call if blocking is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
if node is None:
|
|
iq['pubsub_owner']['default']
|
|
else:
|
|
iq['pubsub_owner']['configure']['node'] = node
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_node_subscriptions(self, jid, node, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
"""
|
|
Retrieve the subscriptions associated with a given node.
|
|
|
|
Arguments:
|
|
jid -- The JID of the pubsub service.
|
|
node -- The node to retrieve subscriptions from.
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a response
|
|
before exiting the send call if blocking is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
iq['pubsub_owner']['subscriptions']['node'] = node
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_node_affiliations(self, jid, node, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
"""
|
|
Retrieve the affiliations associated with a given node.
|
|
|
|
Arguments:
|
|
jid -- The JID of the pubsub service.
|
|
node -- The node to retrieve affiliations from.
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a response
|
|
before exiting the send call if blocking is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
iq['pubsub_owner']['affiliations']['node'] = node
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def delete_node(self, jid, node, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
"""
|
|
Delete a a pubsub node.
|
|
|
|
Arguments:
|
|
jid -- The JID of the pubsub service.
|
|
node -- The node to delete.
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a response
|
|
before exiting the send call if blocking is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub_owner']['delete']['node'] = node
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def set_node_config(self, jid, node, config, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub_owner']['configure']['node'] = node
|
|
iq['pubsub_owner']['configure']['form'].values = config.values
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def publish(self, jid, node, id=None, payload=None, options=None,
|
|
ifrom=None, block=True, callback=None, timeout=None):
|
|
"""
|
|
Add a new item to a node, or edit an existing item.
|
|
|
|
For services that support it, you can use the publish command
|
|
as an event signal by not including an ID or payload.
|
|
|
|
When including a payload and you do not provide an ID then
|
|
the service will generally create an ID for you.
|
|
|
|
Publish options may be specified, and how those options
|
|
are processed is left to the service, such as treating
|
|
the options as preconditions that the node's settings
|
|
must match.
|
|
|
|
Arguments:
|
|
jid -- The JID of the pubsub service.
|
|
node -- The node to publish the item to.
|
|
id -- Optionally specify the ID of the item.
|
|
payload -- The item content to publish.
|
|
options -- A form of publish options.
|
|
ifrom -- Specify the sender's JID.
|
|
block -- Specify if the send call will block until a response
|
|
is received, or a timeout occurs. Defaults to True.
|
|
timeout -- The length of time (in seconds) to wait for a response
|
|
before exiting the send call if blocking is used.
|
|
Defaults to sleekxmpp.xmlstream.RESPONSE_TIMEOUT
|
|
callback -- Optional reference to a stream handler function. Will
|
|
be executed when a reply stanza is received.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub']['publish']['node'] = node
|
|
if id is not None:
|
|
iq['pubsub']['publish']['item']['id'] = id
|
|
if payload is not None:
|
|
iq['pubsub']['publish']['item']['payload'] = payload
|
|
iq['pubsub']['publish_options'] = options
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def retract(self, jid, node, id, notify=None, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
"""
|
|
Delete a single item from a node.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
|
|
iq['pubsub']['retract']['node'] = node
|
|
iq['pubsub']['retract']['notify'] = notify
|
|
iq['pubsub']['retract']['item']['id'] = id
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def purge(self, jid, node, ifrom=None, block=True, callback=None,
|
|
timeout=None):
|
|
"""
|
|
Remove all items from a node.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub_owner']['purge']['node'] = node
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_nodes(self, *args, **kwargs):
|
|
"""
|
|
Discover the nodes provided by a Pubsub service, using disco.
|
|
"""
|
|
return self.xmpp['xep_0030'].get_items(*args, **kwargs)
|
|
|
|
def get_item(self, jid, node, item_id, ifrom=None, block=True,
|
|
callback=None, timeout=None):
|
|
"""
|
|
Retrieve the content of an individual item.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
item = stanza.Item()
|
|
item['id'] = item_id
|
|
iq['pubsub']['items']['node'] = node
|
|
iq['pubsub']['items'].append(item)
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_items(self, jid, node, item_ids=None, max_items=None,
|
|
iterator=False, ifrom=None, block=False,
|
|
callback=None, timeout=None):
|
|
"""
|
|
Request the contents of a node's items.
|
|
|
|
The desired items can be specified, or a query for the last
|
|
few published items can be used.
|
|
|
|
Pubsub services may use result set management for nodes with
|
|
many items, so an iterator can be returned if needed.
|
|
"""
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='get')
|
|
iq['pubsub']['items']['node'] = node
|
|
iq['pubsub']['items']['max_items'] = max_items
|
|
|
|
if item_ids is not None:
|
|
for item_id in item_ids:
|
|
item = stanza.Item()
|
|
item['id'] = item_id
|
|
iq['pubsub']['items'].append(item)
|
|
|
|
if iterator:
|
|
return self.xmpp['xep_0059'].iterate(iq, 'pubsub')
|
|
else:
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def get_item_ids(self, jid, node, ifrom=None, block=True,
|
|
callback=None, timeout=None, iterator=False):
|
|
"""
|
|
Retrieve the ItemIDs hosted by a given node, using disco.
|
|
"""
|
|
return self.xmpp['xep_0030'].get_items(jid, node,
|
|
ifrom=ifrom,
|
|
block=block,
|
|
callback=callback,
|
|
timeout=timeout,
|
|
iterator=iterator)
|
|
|
|
def modify_affiliations(self, jid, node, affiliations=None, ifrom=None,
|
|
block=True, callback=None, timeout=None):
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub_owner']['affiliations']['node'] = node
|
|
|
|
if affiliations is None:
|
|
affiliations = []
|
|
|
|
for jid, affiliation in affiliations:
|
|
aff = stanza.OwnerAffiliation()
|
|
aff['jid'] = jid
|
|
aff['affiliation'] = affiliation
|
|
iq['pubsub_owner']['affiliations'].append(aff)
|
|
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|
|
|
|
def modify_subscriptions(self, jid, node, subscriptions=None, ifrom=None,
|
|
block=True, callback=None, timeout=None):
|
|
iq = self.xmpp.Iq(sto=jid, sfrom=ifrom, stype='set')
|
|
iq['pubsub_owner']['subscriptions']['node'] = node
|
|
|
|
if subscriptions is None:
|
|
subscriptions = []
|
|
|
|
for jid, subscription in subscriptions:
|
|
sub = stanza.OwnerSubscription()
|
|
sub['jid'] = jid
|
|
sub['subscription'] = subscription
|
|
iq['pubsub_owner']['subscriptions'].append(sub)
|
|
|
|
return iq.send(block=block, callback=callback, timeout=timeout)
|