pep/slixmpp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity
slixmpp/tests/test_stream_xep_0323.py

1225 lines
44 KiB
Python
Raw Normal View History

First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
# -*- coding: utf-8 -*-
import sys
import datetime
import time
import threading
Rename to slixmpp
2014-07-17 12:19:04 +00:00
from slixmpp.test import *
from slixmpp.xmlstream import ElementBase
from slixmpp.plugins.xep_0323.device import Device
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
Rename to slixmpp
2014-07-17 12:19:04 +00:00
class TestStreamSensorData(SlixTest):
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
"""
Test using the XEP-0323 plugin.
"""
def setUp(self):
pass
def _time_now(self):
return datetime.datetime.now().replace(microsecond=0).isoformat();
def tearDown(self):
self.stream_close()
def testRequestAccept(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device22");
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"});
self.xmpp['xep_0323'].register_node(nodeId="Device22", device=myDevice, commTimeout=0.5);
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1' momentary='true'/>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1'/>
</iq>
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='1' done='true'>
<node nodeId='Device22'>
<timestamp value='2013-03-07T16:24:30'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Temperature' momentary='true' automaticReadout='true' value='23.4' unit='°C'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testRequestRejectAuth(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
self.xmpp['xep_0323']._set_authenticated("darth@deathstar.com");
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='4'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='5' momentary='true'/>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='error'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='4'>
<rejected xmlns='urn:xmpp:iot:sensordata' seqnr='5'>
<error>Access denied</error>
</rejected>
</iq>
""")
def testRequestNode(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device44");
self.xmpp['xep_0323'].register_node('Device44', myDevice, commTimeout=0.5);
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='77'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='66' momentary='true'>
<node nodeId='Device33'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='error'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='77'>
<rejected xmlns='urn:xmpp:iot:sensordata' seqnr='66'>
<error>Invalid nodeId Device33</error>
</rejected>
</iq>
""")
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='8'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='7' momentary='true'>
<node nodeId='Device44'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='8'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='7'/>
</iq>
""")
def testRequestField(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device44");
myDevice._add_field(name='Voltage', typename="numeric", unit="V");
myDevice._add_field_timestamp_data(name="Voltage", value="230.4", timestamp="2000-01-01T00:01:02", flags={"invoiced": "true"});
self.xmpp['xep_0323'].register_node('Device44', myDevice, commTimeout=0.5);
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='7'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='6'>
<field name='Current'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='error'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='7'>
<rejected xmlns='urn:xmpp:iot:sensordata' seqnr='6'>
<error>Invalid field Current</error>
</rejected>
</iq>
""")
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='8'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='7'>
<field name='Voltage'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='8'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='7'/>
</iq>
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7'>
<node nodeId='Device44'>
<timestamp value='2000-01-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.4' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7' done='true'>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testRequestMultiTimestampSingleField(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device44");
myDevice._add_field(name='Voltage', typename="numeric", unit="V");
myDevice._add_field_timestamp_data(name="Voltage", value="230.4", timestamp="2000-01-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field(name='Current', typename="numeric", unit="A");
myDevice._add_field(name='Height', typename="string");
myDevice._add_field_timestamp_data(name="Voltage", value="230.6", timestamp="2000-01-01T01:01:02");
myDevice._add_field_timestamp_data(name="Height", value="115 m", timestamp="2000-01-01T01:01:02", flags={"invoiced": "true"});
self.xmpp['xep_0323'].register_node('Device44', myDevice, commTimeout=0.5);
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='8'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='7'>
<field name='Voltage'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='8'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='7'/>
</iq>
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7'>
<node nodeId='Device44'>
<timestamp value='2000-01-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.4' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7'>
<node nodeId='Device44'>
<timestamp value='2000-01-01T01:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' value='230.6' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7' done='true'>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testRequestMultiTimestampAllFields(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device44");
myDevice._add_field(name='Voltage', typename="numeric", unit="V");
myDevice._add_field_timestamp_data(name="Voltage", value="230.4", timestamp="2000-01-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field(name='Current', typename="numeric", unit="A");
myDevice._add_field(name='Height', typename="string");
myDevice._add_field_timestamp_data(name="Voltage", value="230.6", timestamp="2000-01-01T01:01:02");
myDevice._add_field_timestamp_data(name="Height", value="115 m", timestamp="2000-01-01T01:01:02", flags={"invoiced": "true"});
self.xmpp['xep_0323'].register_node('Device44', myDevice, commTimeout=0.5);
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='8'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='7'/>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='8'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='7'/>
</iq>
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7'>
<node nodeId='Device44'>
<timestamp value='2000-01-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.4' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7'>
<node nodeId='Device44'>
<timestamp value='2000-01-01T01:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' value='230.6' unit='V'/>
<string name='Height' invoiced='true' value='115 m'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='7' done='true'>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testRequestAPI(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323'])
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", callback=None);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1'/>
</iq>
""")
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", nodeIds=['Device33', 'Device22'], callback=None);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='2'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='2'>
<node nodeId="Device33"/>
<node nodeId="Device22"/>
</req>
</iq>
""")
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", fields=['Temperature', 'Voltage'], callback=None);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='3'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='3'>
<field name="Temperature"/>
<field name="Voltage"/>
</req>
</iq>
""")
def testRequestRejectAPI(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323'])
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
results = [];
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
def my_callback(from_jid, result, nodeId=None, timestamp=None, fields=None, error_msg=None):
if (result == "rejected") and (error_msg == "Invalid device Device22"):
results.append("rejected");
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", nodeIds=['Device33', 'Device22'], callback=my_callback);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId="Device33"/>
<node nodeId="Device22"/>
</req>
</iq>
""")
self.recv("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='error'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='you@google.com'
to='tester@localhost'
id='1'>
<rejected xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<error>Invalid device Device22</error>
</rejected>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
self.failUnless(results == ["rejected"],
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
"Rejected callback was not properly executed");
def testRequestAcceptedAPI(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323'])
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
results = [];
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
def my_callback(from_jid, result, nodeId=None, timestamp=None, fields=None, error_msg=None):
results.append(result);
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", nodeIds=['Device33', 'Device22'], callback=my_callback);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId="Device33"/>
<node nodeId="Device22"/>
</req>
</iq>
""")
self.recv("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='you@google.com'
to='tester@localhost'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
self.failUnless(results == ["accepted"],
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
"Accepted callback was not properly executed");
def testRequestFieldsAPI(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323'])
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
results = [];
callback_data = {};
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
def my_callback(from_jid, result, nodeId=None, timestamp=None, fields=None, error_msg=None):
results.append(result);
if result == "fields":
callback_data["nodeId"] = nodeId;
callback_data["timestamp"] = timestamp;
callback_data["error_msg"] = error_msg;
for f in fields:
callback_data["field_" + f['name']] = f;
Update the test suite. - monkey-patch our own monkey-patched idle_call to run events immediatly rather than adding them to the event queue, and add a fake transport with a fake socket. - remove the test file related to xep_0059 as it relies on blocking behavior, and comment out one xep_0030 test uses xep_0059 - remove many instances of threading and sleep()s because they do nothing except waste time and introduce race conditions. - keep exactly two sleep() in IoT xeps because they rely on timeouts
2015-02-12 11:23:47 +00:00
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost",
to_jid="you@google.com",
nodeIds=['Device33'],
callback=my_callback)
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
#self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", nodeIds=['Device33'], callback=my_callback);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId="Device33"/>
</req>
</iq>
""")
self.recv("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='you@google.com'
to='tester@localhost'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.recv("""
<message from='you@google.com'
to='tester@localhost'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId='Device33'>
<timestamp value='2000-01-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.4' unit='V'/>
<boolean name='TestBool' value='true'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.recv("""
<message from='you@google.com'
to='tester@localhost'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='1' done='true'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.failUnlessEqual(results, ["accepted","fields","done"]);
# self.assertIn("nodeId", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("nodeId" in callback_data)
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["nodeId"], "Device33");
# self.assertIn("timestamp", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("timestamp" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["timestamp"], "2000-01-01T00:01:02");
#self.assertIn("field_Voltage", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("field_Voltage" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["field_Voltage"], {"name": "Voltage", "value": "230.4", "typename": "numeric", "unit": "V", "flags": {"invoiced": "true"}});
#self.assertIn("field_TestBool", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("field_TestBool" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["field_TestBool"], {"name": "TestBool", "value": "true", "typename": "boolean" });
def testServiceDiscoveryClient(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323']);
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='tester@localhost'
id='disco1'>
<query xmlns='http://jabber.org/protocol/disco#info'/>
</iq>
""")
self.send("""
<iq type='result'
to='master@clayster.com/amr'
id='disco1'>
<query xmlns='http://jabber.org/protocol/disco#info'>
<identity category='client' type='bot'/>
<feature var='urn:xmpp:iot:sensordata'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</query>
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testServiceDiscoveryComponent(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323']);
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='tester@localhost'
id='disco1'>
<query xmlns='http://jabber.org/protocol/disco#info'/>
</iq>
""")
self.send("""
<iq type='result'
from='tester@localhost'
to='master@clayster.com/amr'
id='disco1'>
<query xmlns='http://jabber.org/protocol/disco#info'>
<identity category='component' type='generic'/>
<feature var='urn:xmpp:iot:sensordata'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</query>
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testRequestTimeout(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323'])
results = [];
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
callback_data = {};
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
def my_callback(from_jid, result, nodeId=None, timestamp=None, error_msg=None):
results.append(result);
if result == "failure":
callback_data["nodeId"] = nodeId;
callback_data["timestamp"] = timestamp;
callback_data["error_msg"] = error_msg;
Update the test suite. - monkey-patch our own monkey-patched idle_call to run events immediatly rather than adding them to the event queue, and add a fake transport with a fake socket. - remove the test file related to xep_0059 as it relies on blocking behavior, and comment out one xep_0030 test uses xep_0059 - remove many instances of threading and sleep()s because they do nothing except waste time and introduce race conditions. - keep exactly two sleep() in IoT xeps because they rely on timeouts
2015-02-12 11:23:47 +00:00
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost",
to_jid="you@google.com",
nodeIds=['Device33'],
callback=my_callback)
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId="Device33"/>
</req>
</iq>
""")
self.recv("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='you@google.com'
to='tester@localhost'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.recv("""
<message from='you@google.com'
to='tester@localhost'>
<failure xmlns='urn:xmpp:iot:sensordata' seqnr='1' done='true'>
<error nodeId='Device33' timestamp='2013-03-07T17:13:30'>Timeout.</error>
</failure>
</message>
""")
self.failUnlessEqual(results, ["accepted","failure"]);
# self.assertIn("nodeId", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("nodeId" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["nodeId"], "Device33");
# self.assertIn("timestamp", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("timestamp" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["timestamp"], "2013-03-07T17:13:30");
# self.assertIn("error_msg", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("error_msg" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["error_msg"], "Timeout.");
def testDelayedRequest(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device22");
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"});
self.xmpp['xep_0323'].register_node(nodeId="Device22", device=myDevice, commTimeout=0.5);
dtnow = datetime.datetime.now()
ts_2sec = datetime.timedelta(0,2)
dtnow_plus_2sec = dtnow + ts_2sec
when_flag = dtnow_plus_2sec.replace(microsecond=0).isoformat()
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1' momentary='true' when='""" + when_flag + """'/>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1' queued='true' />
</iq>
""")
Update the test suite. - monkey-patch our own monkey-patched idle_call to run events immediatly rather than adding them to the event queue, and add a fake transport with a fake socket. - remove the test file related to xep_0059 as it relies on blocking behavior, and comment out one xep_0030 test uses xep_0059 - remove many instances of threading and sleep()s because they do nothing except waste time and introduce race conditions. - keep exactly two sleep() in IoT xeps because they rely on timeouts
2015-02-12 11:23:47 +00:00
time.sleep(1)
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<started xmlns='urn:xmpp:iot:sensordata' seqnr='1' />
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='1' done='true'>
<node nodeId='Device22'>
<timestamp value='2013-03-07T16:24:30'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Temperature' momentary='true' automaticReadout='true' value='23.4' unit='°C'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testDelayedRequestFail(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device22");
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"});
self.xmpp['xep_0323'].register_node(nodeId="Device22", device=myDevice, commTimeout=0.5);
dtnow = datetime.datetime.now()
ts_2sec = datetime.timedelta(0,2)
dtnow_minus_2sec = dtnow - ts_2sec
when_flag = dtnow_minus_2sec.replace(microsecond=0).isoformat()
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1' momentary='true' when='""" + when_flag + """'/>
</iq>
""")
# Remove the returned datetime to allow predictable test
xml_stanza = self._filtered_stanza_prepare()
error_text = xml_stanza['rejected']['error'] #['text']
error_text = error_text[:error_text.find(':')]
xml_stanza['rejected']['error'] = error_text
self._filtered_stanza_check("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='error'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='1'>
<rejected xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<error>Invalid datetime in 'when' flag, cannot set a time in the past. Current time</error>
</rejected>
</iq>
""", xml_stanza)
def _filtered_stanza_prepare(self, timeout=.5):
sent = self.xmpp.socket.next_sent(timeout)
if sent is None:
self.fail("No stanza was sent.")
xml = self.parse_xml(sent)
self.fix_namespaces(xml, 'jabber:client')
sent = self.xmpp._build_stanza(xml, 'jabber:client')
return sent
def _filtered_stanza_check(self, data, filtered, defaults=None, use_values=True, method='exact'):
self.check(filtered, data,
method=method,
defaults=defaults,
use_values=use_values)
def testRequestFieldFrom(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device44");
myDevice._add_field(name='Voltage', typename="numeric", unit="V");
myDevice._add_field_timestamp_data(name="Voltage", value="230.1", timestamp="2000-01-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field_timestamp_data(name="Voltage", value="230.2", timestamp="2000-02-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field_timestamp_data(name="Voltage", value="230.3", timestamp="2000-03-01T00:01:02", flags={"invoiced": "true"});
self.xmpp['xep_0323'].register_node('Device44', myDevice, commTimeout=0.5);
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='6'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='6' from='2000-01-02T00:00:01'>
<field name='Voltage'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='6'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='6'/>
</iq>
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6'>
<node nodeId='Device44'>
<timestamp value='2000-02-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.2' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6'>
<node nodeId='Device44'>
<timestamp value='2000-03-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.3' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6' done='true'>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testRequestFieldTo(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device44");
myDevice._add_field(name='Voltage', typename="numeric", unit="V");
myDevice._add_field_timestamp_data(name="Voltage", value="230.1", timestamp="2000-01-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field_timestamp_data(name="Voltage", value="230.2", timestamp="2000-02-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field_timestamp_data(name="Voltage", value="230.3", timestamp="2000-03-01T00:01:02", flags={"invoiced": "true"});
self.xmpp['xep_0323'].register_node('Device44', myDevice, commTimeout=0.5);
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='6'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='6' to='2000-02-02T00:00:01'>
<field name='Voltage'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='6'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='6'/>
</iq>
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6'>
<node nodeId='Device44'>
<timestamp value='2000-01-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.1' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6'>
<node nodeId='Device44'>
<timestamp value='2000-02-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.2' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6' done='true'>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testRequestFieldFromTo(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device44");
myDevice._add_field(name='Voltage', typename="numeric", unit="V");
myDevice._add_field_timestamp_data(name="Voltage", value="230.1", timestamp="2000-01-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field_timestamp_data(name="Voltage", value="230.2", timestamp="2000-02-01T00:01:02", flags={"invoiced": "true"});
myDevice._add_field_timestamp_data(name="Voltage", value="230.3", timestamp="2000-03-01T00:01:02", flags={"invoiced": "true"});
self.xmpp['xep_0323'].register_node('Device44', myDevice, commTimeout=0.5);
print("."),
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='6'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='6' from='2000-01-01T00:01:03' to='2000-02-02T00:00:01'>
<field name='Voltage'/>
</req>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='6'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='6'/>
</iq>
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6'>
<node nodeId='Device44'>
<timestamp value='2000-02-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.2' unit='V'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.send("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='6' done='true'>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
def testDelayedRequestClient(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323'])
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
results = [];
callback_data = {};
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
def my_callback(from_jid, result, nodeId=None, timestamp=None, fields=None, error_msg=None):
results.append(result);
if result == "fields":
callback_data["nodeId"] = nodeId;
callback_data["timestamp"] = timestamp;
callback_data["error_msg"] = error_msg;
for f in fields:
callback_data["field_" + f['name']] = f;
Update the test suite. - monkey-patch our own monkey-patched idle_call to run events immediatly rather than adding them to the event queue, and add a fake transport with a fake socket. - remove the test file related to xep_0059 as it relies on blocking behavior, and comment out one xep_0030 test uses xep_0059 - remove many instances of threading and sleep()s because they do nothing except waste time and introduce race conditions. - keep exactly two sleep() in IoT xeps because they rely on timeouts
2015-02-12 11:23:47 +00:00
self.xmpp['xep_0323'].request_data(from_jid="tester@localhost",
to_jid="you@google.com",
nodeIds=['Device33'],
callback=my_callback)
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
#self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", nodeIds=['Device33'], callback=my_callback);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId="Device33"/>
</req>
</iq>
""")
self.recv("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='you@google.com'
to='tester@localhost'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1' queued='true'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.recv("""
<message from='device@clayster.com'
to='master@clayster.com/amr'>
<started xmlns='urn:xmpp:iot:sensordata' seqnr='1' />
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
""")
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.recv("""
<message from='you@google.com'
to='tester@localhost'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId='Device33'>
<timestamp value='2000-01-01T00:01:02'>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<numeric name='Voltage' invoiced='true' value='230.4' unit='V'/>
<boolean name='TestBool' value='true'/>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
</timestamp>
</node>
</fields>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.recv("""
<message from='you@google.com'
to='tester@localhost'>
<fields xmlns='urn:xmpp:iot:sensordata' seqnr='1' done='true'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</message>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.failUnlessEqual(results, ["queued","started","fields","done"]);
# self.assertIn("nodeId", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("nodeId" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["nodeId"], "Device33");
# self.assertIn("timestamp", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("timestamp" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["timestamp"], "2000-01-01T00:01:02");
# self.assertIn("field_Voltage", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("field_Voltage" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["field_Voltage"], {"name": "Voltage", "value": "230.4", "typename": "numeric", "unit": "V", "flags": {"invoiced": "true"}});
# self.assertIn("field_TestBool", callback_data);
Get the IoT plugins to pass tests on Py3
2014-02-06 17:54:45 +00:00
self.assertTrue("field_TestBool" in callback_data);
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
self.failUnlessEqual(callback_data["field_TestBool"], {"name": "TestBool", "value": "true", "typename": "boolean" });
def testRequestFieldsCancelAPI(self):
self.stream_start(mode='client',
plugins=['xep_0030',
'xep_0323'])
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
results = [];
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
def my_callback(from_jid, result, nodeId=None, timestamp=None, fields=None, error_msg=None):
results.append(result);
session = self.xmpp['xep_0323'].request_data(from_jid="tester@localhost", to_jid="you@google.com", nodeIds=['Device33'], callback=my_callback);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<node nodeId="Device33"/>
</req>
</iq>
""")
self.recv("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='you@google.com'
to='tester@localhost'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1'/>
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
</iq>
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
""")
self.xmpp['xep_0323'].cancel_request(session=session);
self.send("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<cancel xmlns='urn:xmpp:iot:sensordata' seqnr='1' />
</iq>
""")
self.recv("""
<iq type='result'
from='tester@localhost'
to='you@google.com'
id='1'>
<cancelled xmlns='urn:xmpp:iot:sensordata' seqnr='1' />
</iq>
""")
self.failUnlessEqual(results, ["accepted","cancelled"]);
def testDelayedRequestCancel(self):
self.stream_start(mode='component',
plugins=['xep_0030',
'xep_0323'])
myDevice = Device("Device22");
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"});
self.xmpp['xep_0323'].register_node(nodeId="Device22", device=myDevice, commTimeout=0.5);
dtnow = datetime.datetime.now()
ts_2sec = datetime.timedelta(0,2)
dtnow_plus_2sec = dtnow + ts_2sec
when_flag = dtnow_plus_2sec.replace(microsecond=0).isoformat()
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='1'>
<req xmlns='urn:xmpp:iot:sensordata' seqnr='1' momentary='true' when='""" + when_flag + """'/>
</iq>
""")
self.send("""
Remove all trailing whitespaces.
2014-08-17 19:53:34 +00:00
<iq type='result'
First implementation of the xep_0323 and xep_325 used in IoT systems. Tests are added for stanza and streams
2013-08-30 00:29:52 +00:00
from='device@clayster.com'
to='master@clayster.com/amr'
id='1'>
<accepted xmlns='urn:xmpp:iot:sensordata' seqnr='1' queued='true' />
</iq>
""")
self.recv("""
<iq type='get'
from='master@clayster.com/amr'
to='device@clayster.com'
id='1'>
<cancel xmlns='urn:xmpp:iot:sensordata' seqnr='1' />
</iq>
""")
self.send("""
<iq type='result'
from='device@clayster.com'
to='master@clayster.com/amr'
id='1'>
<cancelled xmlns='urn:xmpp:iot:sensordata' seqnr='1' />
</iq>
""")
# Test cancel of non-existing request
self.recv("""
<iq type='get'
from='tester@localhost'
to='you@google.com'
id='1'>
<cancel xmlns='urn:xmpp:iot:sensordata' seqnr='1' />
</iq>
""")
self.send("""
<iq type='error'
from='you@google.com'
to='tester@localhost'
id='1'>
<rejected xmlns='urn:xmpp:iot:sensordata' seqnr='1'>
<error>Cancel request received, no matching request is active.</error>
</rejected>
</iq>
""")
# Ensure we don't get anything after cancellation
self.send(None)
suite = unittest.TestLoader().loadTestsFromTestCase(TestStreamSensorData)
Reference in a new issue Copy permalink