diff options
Diffstat (limited to 'examples/IoT_TestDevice.py')
| -rwxr-xr-x[-rw-r--r--] | examples/IoT_TestDevice.py | 29 |
1 files changed, 15 insertions, 14 deletions
diff --git a/examples/IoT_TestDevice.py b/examples/IoT_TestDevice.py index c754cfb4..8105aaff 100644..100755 --- 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" |