Skip to content
Snippets Groups Projects
Commit 8c07170d authored by Ramin Yaghoubzadeh's avatar Ramin Yaghoubzadeh
Browse files

Added 2 good and 2 broken tests, you are welcome

parent 64d74419
No related branches found
No related tags found
No related merge requests found
...@@ -64,6 +64,21 @@ class IpaacaCommitTestCases(unittest.TestCase): ...@@ -64,6 +64,21 @@ class IpaacaCommitTestCases(unittest.TestCase):
time.sleep(0.1) time.sleep(0.1)
received_iu = self.ib.iu_store[self.iu.uid] received_iu = self.ib.iu_store[self.iu.uid]
self.assertTrue(received_iu.committed) self.assertTrue(received_iu.committed)
def testCommitAndLocalWrite(self):
self.ob.add(self.iu)
time.sleep(0.1)
self.iu.commit()
with self.assertRaises(ipaaca.IUCommittedError):
self.iu.payload['data'] = 'updatedData'
def testCommitAndRemoteWrite(self):
self.ob.add(self.iu)
time.sleep(0.1)
self.iu.commit()
received_iu = self.ib.iu_store[self.iu.uid]
with self.assertRaises(ipaaca.IUCommittedError):
received_iu.payload['data'] = 'updatedData'
class IpaacaLinksTestCase(unittest.TestCase): class IpaacaLinksTestCase(unittest.TestCase):
...@@ -130,27 +145,27 @@ class IpaacaRemoteWriteTestCase(unittest.TestCase): ...@@ -130,27 +145,27 @@ class IpaacaRemoteWriteTestCase(unittest.TestCase):
self.ib = ipaaca.InputBuffer('TestIn', ['sensorcategory']) self.ib = ipaaca.InputBuffer('TestIn', ['sensorcategory'])
self.ib.register_handler(handle_iu_event) self.ib.register_handler(handle_iu_event)
self.ob = ipaaca.OutputBuffer('TestOut') self.ob = ipaaca.OutputBuffer('TestOut')
self.sensor_iu = ipaaca.IU('sensorcategory') self.iu = ipaaca.IU('sensorcategory')
self.sensor_iu.payload = {'data': 'sensordata'} self.iu.payload = {'data': 'sensordata'}
time.sleep(0.1) time.sleep(0.1)
self.ob.add(self.sensor_iu) self.ob.add(self.iu)
time.sleep(0.1) time.sleep(0.1)
def tearDown(self): def tearDown(self):
pass pass
def testRemotePayloadChange(self): def testRemotePayloadChange(self):
self.assertIn(self.sensor_iu.uid, self.ib.iu_store) self.assertIn(self.iu.uid, self.ib.iu_store)
received_iu = self.ib.iu_store[self.sensor_iu.uid] received_iu = self.ib.iu_store[self.iu.uid]
received_iu.payload['data'] = 'updatedData' received_iu.payload['data'] = 'updatedData'
time.sleep(0.1) time.sleep(0.1)
self.assertEqual(self.sensor_iu.payload['data'], 'updatedData') self.assertEqual(self.iu.payload['data'], 'updatedData')
def testRemotePayloadReplace(self): def testRemotePayloadReplace(self):
self.assertIn(self.sensor_iu.uid, self.ib.iu_store) self.assertIn(self.iu.uid, self.ib.iu_store)
received_iu = self.ib.iu_store[self.sensor_iu.uid] received_iu = self.ib.iu_store[self.iu.uid]
received_iu.payload = { 'key1': 'value1', 'key2': 'value2' } received_iu.payload = { 'key1': 'value1', 'key2': 'value2' }
time.sleep(0.1) time.sleep(0.1)
self.assertEqual(len(self.sensor_iu.payload), 2) self.assertEqual(len(self.iu.payload), 2)
self.assertEqual(self.sensor_iu.payload['key1'], 'value1') self.assertEqual(self.iu.payload['key1'], 'value1')
self.assertEqual(self.sensor_iu.payload['key2'], 'value2') self.assertEqual(self.iu.payload['key2'], 'value2')
if __name__ == '__main__': if __name__ == '__main__':
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment