diff options
author | Lance Stout <lancestout@gmail.com> | 2013-01-20 21:35:06 -0800 |
---|---|---|
committer | Lance Stout <lancestout@gmail.com> | 2013-01-20 21:35:06 -0800 |
commit | ea0381fa0999853355321b66aaa58550a33bcfd9 (patch) | |
tree | d0e01993936ff416d1385dee00926a65afd5289d /sleekxmpp/plugins/jobs.py | |
parent | 3423589ba1fc2a6284bf3e4bd7402f1e80fff275 (diff) | |
download | slixmpp-ea0381fa0999853355321b66aaa58550a33bcfd9.tar.gz slixmpp-ea0381fa0999853355321b66aaa58550a33bcfd9.tar.bz2 slixmpp-ea0381fa0999853355321b66aaa58550a33bcfd9.tar.xz slixmpp-ea0381fa0999853355321b66aaa58550a33bcfd9.zip |
Remove old versions of some plugins.
Diffstat (limited to 'sleekxmpp/plugins/jobs.py')
-rw-r--r-- | sleekxmpp/plugins/jobs.py | 49 |
1 files changed, 0 insertions, 49 deletions
diff --git a/sleekxmpp/plugins/jobs.py b/sleekxmpp/plugins/jobs.py deleted file mode 100644 index cb9deba8..00000000 --- a/sleekxmpp/plugins/jobs.py +++ /dev/null @@ -1,49 +0,0 @@ -from . import base -import logging -from xml.etree import cElementTree as ET - - -log = logging.getLogger(__name__) - - -class jobs(base.base_plugin): - def plugin_init(self): - self.xep = 'pubsubjob' - self.description = "Job distribution over Pubsub" - - def post_init(self): - pass - #TODO add event - - def createJobNode(self, host, jid, node, config=None): - pass - - def createJob(self, host, node, jobid=None, payload=None): - return self.xmpp.plugin['xep_0060'].setItem(host, node, ((jobid, payload),)) - - def claimJob(self, host, node, jobid, ifrom=None): - return self._setState(host, node, jobid, ET.Element('{http://andyet.net/protocol/pubsubjob}claimed')) - - def unclaimJob(self, host, node, jobid): - return self._setState(host, node, jobid, ET.Element('{http://andyet.net/protocol/pubsubjob}unclaimed')) - - def finishJob(self, host, node, jobid, payload=None): - finished = ET.Element('{http://andyet.net/protocol/pubsubjob}finished') - if payload is not None: - finished.append(payload) - return self._setState(host, node, jobid, finished) - - def _setState(self, host, node, jobid, state, ifrom=None): - iq = self.xmpp.Iq() - iq['to'] = host - if ifrom: iq['from'] = ifrom - iq['type'] = 'set' - iq['psstate']['node'] = node - iq['psstate']['item'] = jobid - iq['psstate']['payload'] = state - result = iq.send() - if result is None or type(result) == bool or result['type'] != 'result': - log.error("Unable to change %s:%s to %s", node, jobid, state) - return False - return True - |