mirror of
https://github.com/correl/SleekXMPP.git
synced 2024-12-18 11:06:20 +00:00
265 lines
8.8 KiB
Python
265 lines
8.8 KiB
Python
"""
|
|
SleekXMPP: The Sleek XMPP Library
|
|
Copyright (C) 2010 Nathanael C. Fritz, Lance J.T. Stout
|
|
This file is part of SleekXMPP.
|
|
|
|
See the file LICENSE for copying permission.
|
|
"""
|
|
|
|
import logging
|
|
|
|
import sleekxmpp
|
|
from sleekxmpp import Iq
|
|
from sleekxmpp.exceptions import XMPPError
|
|
from sleekxmpp.plugins.base import base_plugin
|
|
from sleekxmpp.xmlstream.handler import Callback
|
|
from sleekxmpp.xmlstream.matcher import StanzaPath
|
|
from sleekxmpp.xmlstream import register_stanza_plugin, ElementBase, ET, JID
|
|
from sleekxmpp.plugins.xep_0030 import DiscoInfo, DiscoItems
|
|
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
|
|
class StaticDisco(object):
|
|
|
|
"""
|
|
While components will likely require fully dynamic handling
|
|
of service discovery information, most clients and simple bots
|
|
only need to manage a few disco nodes that will remain mostly
|
|
static.
|
|
|
|
StaticDisco provides a set of node handlers that will store
|
|
static sets of disco info and items in memory.
|
|
|
|
Attributes:
|
|
nodes -- A dictionary mapping (JID, node) tuples to a dict
|
|
containing a disco#info and a disco#items stanza.
|
|
xmpp -- The main SleekXMPP object.
|
|
"""
|
|
|
|
def __init__(self, xmpp):
|
|
"""
|
|
Create a static disco interface. Sets of disco#info and
|
|
disco#items are maintained for every given JID and node
|
|
combination. These stanzas are used to store disco
|
|
information in memory without any additional processing.
|
|
|
|
Arguments:
|
|
xmpp -- The main SleekXMPP object.
|
|
"""
|
|
self.nodes = {}
|
|
self.xmpp = xmpp
|
|
|
|
def add_node(self, jid=None, node=None):
|
|
"""
|
|
Create a new set of stanzas for the provided
|
|
JID and node combination.
|
|
|
|
Arguments:
|
|
jid -- The JID that will own the new stanzas.
|
|
node -- The node that will own the new stanzas.
|
|
"""
|
|
if jid is None:
|
|
jid = self.xmpp.boundjid.full
|
|
if node is None:
|
|
node = ''
|
|
if (jid, node) not in self.nodes:
|
|
self.nodes[(jid, node)] = {'info': DiscoInfo(),
|
|
'items': DiscoItems()}
|
|
self.nodes[(jid, node)]['info']['node'] = node
|
|
self.nodes[(jid, node)]['items']['node'] = node
|
|
|
|
# =================================================================
|
|
# Node Handlers
|
|
#
|
|
# Each handler accepts three arguments: jid, node, and data.
|
|
# The jid and node parameters together determine the set of
|
|
# info and items stanzas that will be retrieved or added.
|
|
# The data parameter is a dictionary with additional paramters
|
|
# that will be passed to other calls.
|
|
|
|
def get_info(self, jid, node, data):
|
|
"""
|
|
Return the stored info data for the requested JID/node combination.
|
|
|
|
The data parameter is not used.
|
|
"""
|
|
if (jid, node) not in self.nodes:
|
|
if not node:
|
|
return DiscoInfo()
|
|
else:
|
|
raise XMPPError(condition='item-not-found')
|
|
else:
|
|
return self.nodes[(jid, node)]['info']
|
|
|
|
def del_info(self, jid, node, data):
|
|
"""
|
|
Reset the info stanza for a given JID/node combination.
|
|
|
|
The data parameter is not used.
|
|
"""
|
|
if (jid, node) in self.nodes:
|
|
self.nodes[(jid, node)]['info'] = DiscoInfo()
|
|
|
|
def get_items(self, jid, node, data):
|
|
"""
|
|
Return the stored items data for the requested JID/node combination.
|
|
|
|
The data parameter is not used.
|
|
"""
|
|
if (jid, node) not in self.nodes:
|
|
if not node:
|
|
return DiscoInfo()
|
|
else:
|
|
raise XMPPError(condition='item-not-found')
|
|
else:
|
|
return self.nodes[(jid, node)]['items']
|
|
|
|
def set_items(self, jid, node, data):
|
|
"""
|
|
Replace the stored items data for a JID/node combination.
|
|
|
|
The data parameter may provided:
|
|
items -- A set of items in tuple format.
|
|
"""
|
|
items = data.get('items', set())
|
|
self.add_node(jid, node)
|
|
self.nodes[(jid, node)]['items']['items'] = items
|
|
|
|
def del_items(self, jid, node, data):
|
|
"""
|
|
Reset the items stanza for a given JID/node combination.
|
|
|
|
The data parameter is not used.
|
|
"""
|
|
if (jid, node) in self.nodes:
|
|
self.nodes[(jid, node)]['items'] = DiscoItems()
|
|
|
|
def add_identity(self, jid, node, data):
|
|
"""
|
|
Add a new identity to te JID/node combination.
|
|
|
|
The data parameter may provide:
|
|
category -- The general category to which the agent belongs.
|
|
itype -- A more specific designation with the category.
|
|
name -- Optional human readable name for this identity.
|
|
lang -- Optional standard xml:lang value.
|
|
"""
|
|
self.add_node(jid, node)
|
|
self.nodes[(jid, node)]['info'].add_identity(
|
|
data.get('category', ''),
|
|
data.get('itype', ''),
|
|
data.get('name', None),
|
|
data.get('lang', None))
|
|
|
|
def set_identities(self, jid, node, data):
|
|
"""
|
|
Add or replace all identities for a JID/node combination.
|
|
|
|
The data parameter should include:
|
|
identities -- A list of identities in tuple form:
|
|
(category, type, name, lang)
|
|
"""
|
|
identities = data.get('identities', set())
|
|
self.add_node(jid, node)
|
|
self.nodes[(jid, node)]['info']['identities'] = identities
|
|
|
|
def del_identity(self, jid, node, data):
|
|
"""
|
|
Remove an identity from a JID/node combination.
|
|
|
|
The data parameter may provide:
|
|
category -- The general category to which the agent belonged.
|
|
itype -- A more specific designation with the category.
|
|
name -- Optional human readable name for this identity.
|
|
lang -- Optional, standard xml:lang value.
|
|
"""
|
|
if (jid, node) not in self.nodes:
|
|
return
|
|
self.nodes[(jid, node)]['info'].del_identity(
|
|
data.get('category', ''),
|
|
data.get('itype', ''),
|
|
data.get('name', None),
|
|
data.get('lang', None))
|
|
|
|
def del_identities(self, jid, node, data):
|
|
"""
|
|
Remove all identities from a JID/node combination.
|
|
|
|
The data parameter is not used.
|
|
"""
|
|
if (jid, node) not in self.nodes:
|
|
return
|
|
del self.nodes[(jid, node)]['info']['identities']
|
|
|
|
def add_feature(self, jid, node, data):
|
|
"""
|
|
Add a feature to a JID/node combination.
|
|
|
|
The data parameter should include:
|
|
feature -- The namespace of the supported feature.
|
|
"""
|
|
self.add_node(jid, node)
|
|
self.nodes[(jid, node)]['info'].add_feature(data.get('feature', ''))
|
|
|
|
def set_features(self, jid, node, data):
|
|
"""
|
|
Add or replace all features for a JID/node combination.
|
|
|
|
The data parameter should include:
|
|
features -- The new set of supported features.
|
|
"""
|
|
features = data.get('features', set())
|
|
self.add_node(jid, node)
|
|
self.nodes[(jid, node)]['info']['features'] = features
|
|
|
|
def del_feature(self, jid, node, data):
|
|
"""
|
|
Remove a feature from a JID/node combination.
|
|
|
|
The data parameter should include:
|
|
feature -- The namespace of the removed feature.
|
|
"""
|
|
if (jid, node) not in self.nodes:
|
|
return
|
|
self.nodes[(jid, node)]['info'].del_feature(data.get('feature', ''))
|
|
|
|
def del_features(self, jid, node, data):
|
|
"""
|
|
Remove all features from a JID/node combination.
|
|
|
|
The data parameter is not used.
|
|
"""
|
|
if (jid, node) not in self.nodes:
|
|
return
|
|
del self.nodes[(jid, node)]['info']['features']
|
|
|
|
def add_item(self, jid, node, data):
|
|
"""
|
|
Add an item to a JID/node combination.
|
|
|
|
The data parameter may include:
|
|
ijid -- The JID for the item.
|
|
inode -- Optional additional information to reference
|
|
non-addressable items.
|
|
name -- Optional human readable name for the item.
|
|
"""
|
|
self.add_node(jid, node)
|
|
self.nodes[(jid, node)]['items'].add_item(
|
|
data.get('ijid', ''),
|
|
node=data.get('inode', ''),
|
|
name=data.get('name', ''))
|
|
|
|
def del_item(self, jid, node, data):
|
|
"""
|
|
Remove an item from a JID/node combination.
|
|
|
|
The data parameter may include:
|
|
ijid -- JID of the item to remove.
|
|
inode -- Optional extra identifying information.
|
|
"""
|
|
if (jid, node) in self.nodes:
|
|
self.nodes[(jid, node)]['items'].del_item(
|
|
data.get('ijid', ''),
|
|
node=data.get('inode', None))
|