From cd2d25cf874c5931b5c5a843c09875625bb9a84c Mon Sep 17 00:00:00 2001 From: Lance Stout Date: Fri, 20 Sep 2013 11:50:51 -0700 Subject: Chmod +x examples, and add shebang lines --- examples/IoT_TestDevice.py | 29 +++++++++++++++-------------- examples/download_avatars.py | 0 examples/echo_client.py | 2 +- examples/migrate_roster.py | 3 +++ examples/pubsub_client.py | 7 +++++-- examples/pubsub_events.py | 5 ++++- examples/register_account.py | 0 examples/roster_browser.py | 0 examples/rpc_async.py | 29 ++++++++++++++++------------- examples/rpc_client_side.py | 29 ++++++++++++++++------------- examples/rpc_server_side.py | 31 +++++++++++++++++-------------- examples/set_avatar.py | 0 examples/thirdparty_auth.py | 0 examples/user_location.py | 0 examples/user_tune.py | 0 15 files changed, 77 insertions(+), 58 deletions(-) mode change 100644 => 100755 examples/IoT_TestDevice.py mode change 100644 => 100755 examples/download_avatars.py mode change 100644 => 100755 examples/migrate_roster.py mode change 100644 => 100755 examples/pubsub_client.py mode change 100644 => 100755 examples/pubsub_events.py mode change 100644 => 100755 examples/register_account.py mode change 100644 => 100755 examples/roster_browser.py mode change 100644 => 100755 examples/rpc_async.py mode change 100644 => 100755 examples/rpc_client_side.py mode change 100644 => 100755 examples/rpc_server_side.py mode change 100644 => 100755 examples/set_avatar.py mode change 100644 => 100755 examples/thirdparty_auth.py mode change 100644 => 100755 examples/user_location.py mode change 100644 => 100755 examples/user_tune.py diff --git a/examples/IoT_TestDevice.py b/examples/IoT_TestDevice.py old mode 100644 new mode 100755 index c754cfb4..8105aaff --- a/examples/IoT_TestDevice.py +++ b/examples/IoT_TestDevice.py @@ -1,4 +1,5 @@ #!/usr/bin/env python +# -*- coding: utf-8 -*- """ SleekXMPP: The Sleek XMPP Library @@ -35,7 +36,7 @@ if sys.version_info < (3, 0): setdefaultencoding('utf8') else: raw_input = input - + from sleekxmpp.plugins.xep_0323.device import Device #from sleekxmpp.exceptions import IqError, IqTimeout @@ -68,7 +69,7 @@ class IoT_TestDevice(sleekxmpp.ClientXMPP): else: self.beServer=False self.clientJID=clientJID - + def testForRelease(self): # todo thread safe return self.releaseMe @@ -76,14 +77,14 @@ class IoT_TestDevice(sleekxmpp.ClientXMPP): def doReleaseMe(self): # todo thread safe self.releaseMe=True - + def addDevice(self, device): self.device=device - + def session_start(self, event): self.send_presence() self.get_roster() - # tell your preffered friend that you are alive + # tell your preffered friend that you are alive self.send_message(mto='jocke@jabber.sust.se', mbody=self.boundjid.bare +' is now online use xep_323 stanza to talk to me') if not(self.beServer): @@ -96,7 +97,7 @@ class IoT_TestDevice(sleekxmpp.ClientXMPP): msg.reply("Hi I am " + self.boundjid.full + " and I am on IP " + ip).send() else: logging.debug("got unknown message type %s", str(msg['type'])) - + class TheDevice(Device): """ This is the actual device object that you will use to get information from your real hardware @@ -112,8 +113,8 @@ class TheDevice(Device): """ self._set_momentary_timestamp(self._get_timestamp()) self.counter+=self.counter - self._add_field_momentary_data(self, "Temperature", self.counter) - + self._add_field_momentary_data(self, "Temperature", self.counter) + if __name__ == '__main__': # Setup the command line arguments. @@ -123,7 +124,7 @@ if __name__ == '__main__': # python IoT_TestDevice.py -j "serverjid@yourdomain.com" -p "password" -n "TestIoT" --debug # # "client" an IoT device or other party that would like to get data from another device - + optp = OptionParser() # Output verbosity options. @@ -151,7 +152,7 @@ if __name__ == '__main__': help="Another device to call for data on", default=None) optp.add_option("-n", "--nodeid", dest="nodeid", help="I am a device get ready to be called", default=None) - + opts, args = optp.parse_args() # Setup logging. @@ -162,7 +163,7 @@ if __name__ == '__main__': opts.jid = raw_input("Username: ") if opts.password is None: opts.password = getpass.getpass("Password: ") - + xmpp = IoT_TestDevice(opts.jid,opts.password) xmpp.register_plugin('xep_0030') @@ -183,12 +184,12 @@ if __name__ == '__main__': myDevice._add_field(name="Temperature", typename="numeric", unit="C"); myDevice._set_momentary_timestamp("2013-03-07T16:24:30") myDevice._add_field_momentary_data("Temperature", "23.4", flags={"automaticReadout": "true"}); - + xmpp['xep_0323'].register_node(nodeId=opts.nodeid, device=myDevice, commTimeout=10); xmpp.beClientOrServer(server=True) while not(xmpp.testForRelease()): xmpp.connect() - xmpp.process(block=True) + xmpp.process(block=True) logging.debug("lost connection") if opts.sensorjid: logging.debug("will try to call another device for data") @@ -196,7 +197,7 @@ if __name__ == '__main__': xmpp.connect() xmpp.process(block=True) logging.debug("ready ending") - + else: print "noopp didn't happen" diff --git a/examples/download_avatars.py b/examples/download_avatars.py old mode 100644 new mode 100755 diff --git a/examples/echo_client.py b/examples/echo_client.py index f2d38847..18125a0d 100755 --- a/examples/echo_client.py +++ b/examples/echo_client.py @@ -151,7 +151,7 @@ if __name__ == '__main__': # # if xmpp.connect(('talk.google.com', 5222)): # ... - xmpp.process(block=True) + xmpp.process(block=False) print("Done") else: print("Unable to connect.") diff --git a/examples/migrate_roster.py b/examples/migrate_roster.py old mode 100644 new mode 100755 index a93bdecd..797e4f44 --- a/examples/migrate_roster.py +++ b/examples/migrate_roster.py @@ -1,3 +1,6 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + import sys import logging import getpass diff --git a/examples/pubsub_client.py b/examples/pubsub_client.py old mode 100644 new mode 100755 index 2fa419fb..9a65553b --- a/examples/pubsub_client.py +++ b/examples/pubsub_client.py @@ -1,3 +1,6 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + import sys import logging import getpass @@ -20,7 +23,7 @@ else: class PubsubClient(sleekxmpp.ClientXMPP): - def __init__(self, jid, password, server, + def __init__(self, jid, password, server, node=None, action='list', data=''): super(PubsubClient, self).__init__(jid, password) @@ -28,7 +31,7 @@ class PubsubClient(sleekxmpp.ClientXMPP): self.register_plugin('xep_0059') self.register_plugin('xep_0060') - self.actions = ['nodes', 'create', 'delete', + self.actions = ['nodes', 'create', 'delete', 'publish', 'get', 'retract', 'purge', 'subscribe', 'unsubscribe'] diff --git a/examples/pubsub_events.py b/examples/pubsub_events.py old mode 100644 new mode 100755 index 0dfb6c65..12c33a76 --- a/examples/pubsub_events.py +++ b/examples/pubsub_events.py @@ -1,3 +1,6 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + import sys import logging import getpass @@ -77,7 +80,7 @@ class PubsubEvents(sleekxmpp.ClientXMPP): """Handle receiving a node deletion event.""" print('Deleted node %s' % ( msg['pubsub_event']['delete']['node'])) - + def _config(self, msg): """Handle receiving a node configuration event.""" print('Configured node %s:' % ( diff --git a/examples/register_account.py b/examples/register_account.py old mode 100644 new mode 100755 diff --git a/examples/roster_browser.py b/examples/roster_browser.py old mode 100644 new mode 100755 diff --git a/examples/rpc_async.py b/examples/rpc_async.py old mode 100644 new mode 100755 index 0b6d1936..e3e23b69 --- a/examples/rpc_async.py +++ b/examples/rpc_async.py @@ -1,3 +1,6 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + """ SleekXMPP: The Sleek XMPP Library Copyright (C) 2011 Dann Martens @@ -11,34 +14,34 @@ from sleekxmpp.plugins.xep_0009.remote import Endpoint, remote, Remote, \ import time class Boomerang(Endpoint): - + def FQN(self): return 'boomerang' - + @remote def throw(self): print "Duck!" - + def main(): session = Remote.new_session('kangaroo@xmpp.org/rpc', '*****') - session.new_handler(ANY_ALL, Boomerang) - + session.new_handler(ANY_ALL, Boomerang) + boomerang = session.new_proxy('kangaroo@xmpp.org/rpc', Boomerang) - + callback = Future() - + boomerang.async(callback).throw() - + time.sleep(10) - + session.close() - - - + + + if __name__ == '__main__': main() - \ No newline at end of file + diff --git a/examples/rpc_client_side.py b/examples/rpc_client_side.py old mode 100644 new mode 100755 index 135d6237..e792fc94 --- a/examples/rpc_client_side.py +++ b/examples/rpc_client_side.py @@ -1,3 +1,6 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + """ SleekXMPP: The Sleek XMPP Library Copyright (C) 2011 Dann Martens @@ -12,18 +15,18 @@ import threading import time class Thermostat(Endpoint): - + def FQN(self): return 'thermostat' - + def __init__(self, initial_temperature): self._temperature = initial_temperature - self._event = threading.Event() - + self._event = threading.Event() + @remote def set_temperature(self, temperature): return NotImplemented - + @remote def get_temperature(self): return NotImplemented @@ -31,23 +34,23 @@ class Thermostat(Endpoint): @remote(False) def release(self): return NotImplemented - + def main(): session = Remote.new_session('operator@xmpp.org/rpc', '*****') - + thermostat = session.new_proxy('thermostat@xmpp.org/rpc', Thermostat) - + print("Current temperature is %s" % thermostat.get_temperature()) - + thermostat.set_temperature(20) - + time.sleep(10) - + session.close() - + if __name__ == '__main__': main() - + diff --git a/examples/rpc_server_side.py b/examples/rpc_server_side.py old mode 100644 new mode 100755 index d1a11c17..9e8b48d6 --- a/examples/rpc_server_side.py +++ b/examples/rpc_server_side.py @@ -1,3 +1,6 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + """ SleekXMPP: The Sleek XMPP Library Copyright (C) 2011 Dann Martens @@ -11,42 +14,42 @@ from sleekxmpp.plugins.xep_0009.remote import Endpoint, remote, Remote, \ import threading class Thermostat(Endpoint): - + def FQN(self): return 'thermostat' - + def __init__(self, initial_temperature): self._temperature = initial_temperature - self._event = threading.Event() - + self._event = threading.Event() + @remote def set_temperature(self, temperature): print("Setting temperature to %s" % temperature) self._temperature = temperature - + @remote def get_temperature(self): return self._temperature @remote(False) def release(self): - self._event.set() - + self._event.set() + def wait_for_release(self): - self._event.wait() - + self._event.wait() + def main(): session = Remote.new_session('sleek@xmpp.org/rpc', '*****') - + thermostat = session.new_handler(ANY_ALL, Thermostat, 18) - + thermostat.wait_for_release() - + session.close() - + if __name__ == '__main__': main() - + diff --git a/examples/set_avatar.py b/examples/set_avatar.py old mode 100644 new mode 100755 diff --git a/examples/thirdparty_auth.py b/examples/thirdparty_auth.py old mode 100644 new mode 100755 diff --git a/examples/user_location.py b/examples/user_location.py old mode 100644 new mode 100755 diff --git a/examples/user_tune.py b/examples/user_tune.py old mode 100644 new mode 100755 -- cgit v1.2.3