diff options
author | Brian Beggs <macdiesel@gmail.com> | 2010-06-02 07:32:33 -0400 |
---|---|---|
committer | Brian Beggs <macdiesel@gmail.com> | 2010-06-02 07:32:33 -0400 |
commit | 686943a2ec3c97e4e39ee2e38d9fd571ed98dd35 (patch) | |
tree | f8a9b69630792567ddae16ce0627ee2c2b1c6caa /sleekxmpp/plugins/jobs.py | |
parent | dda3e733b59a9e71482538898a807623a79f0dbf (diff) | |
parent | 4eb210bff5753143300e5bf6ae09617901e9a28e (diff) | |
download | slixmpp-686943a2ec3c97e4e39ee2e38d9fd571ed98dd35.tar.gz slixmpp-686943a2ec3c97e4e39ee2e38d9fd571ed98dd35.tar.bz2 slixmpp-686943a2ec3c97e4e39ee2e38d9fd571ed98dd35.tar.xz slixmpp-686943a2ec3c97e4e39ee2e38d9fd571ed98dd35.zip |
Merge remote branch 'tom/hacks'
Diffstat (limited to 'sleekxmpp/plugins/jobs.py')
-rw-r--r-- | sleekxmpp/plugins/jobs.py | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/sleekxmpp/plugins/jobs.py b/sleekxmpp/plugins/jobs.py new file mode 100644 index 00000000..bb2e2554 --- /dev/null +++ b/sleekxmpp/plugins/jobs.py @@ -0,0 +1,44 @@ +from . import base +import logging +from xml.etree import cElementTree as ET + +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, 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 result['type'] != 'result': + return False + return True + |