OV-7. Add a script to test sendPacket command handling.

Author: malishav

openvisualizer/openBenchmarkAgent/generateSendPacket.py

@@ -0,0 +1,77 @@
+import paho.mqtt.client as mqtt
+from argparse       import ArgumentParser
+
+class PacketGenerator():
+    OPENBENCHMARK_SENDPACKET_TOPIC = 'openbenchmark/experimentId/000/command/sendPacket'
+
+    def __init__(self):
+        self.parser = ArgumentParser()
+        self._addParserArgs()
+
+        self.argspace = self.parser.parse_args()
+
+        self.confirmable = self.argspace.confirmable
+        self.mqttBroker = self.argspace.mqttBroker
+        self.payloadLen = self.argspace.mqttBroker
+        self.destEui64 = self.argspace.destEui64
+        self.srcEui64 = self.argspace.srcEui64
+
+        # mqtt client
+        self.mqttClient = mqtt.Client('generateSendPacket')
+        self.mqttClient.connect(self.mqttBroker)
+
+        command = {
+            'token' : '123',
+            'source' : self.srcEui64,
+            'destination' : self.destEui64,
+            'packetsInBurst' : 1,
+            'packetToken' : [0, 1, 2, 3, 4],
+            'packetPayloadLen' : 10,
+            'confirmable' : self.confirmable
+        }
+
+        self.mqttClient.publish(
+            topic=self.OPENBENCHMARK_SENDPACKET_TOPIC,
+            payload=json.dumps(command),
+        )
+
+    def _addParserArgs(self):
+        self.parser.add_argument('-c', '--confirmable',
+                            dest='confirmable',
+                            default=False,
+                            action='store',
+                            help='Whether a packet should be ack-ed at the app layer'
+                            )
+        self.parser.add_argument('-p', '--payloadLen',
+                            dest='payloadLen',
+                            default=10,
+                            action='store',
+                            help='Length of the payload in the packet to be sent.'
+                            )
+        self.parser.add_argument('-d', '--destEui64',
+                            dest='destEui64',
+                            default='',
+                            action='store',
+                            help='Destination EUI-64.'
+                            )
+        self.parser.add_argument('-s', '--srcEui64',
+                            dest='srcEui64',
+                            default='',
+                            action='store',
+                            help='Source EUI-64.'
+                            )
+        self.parser.add_argument('-b', '--mqttBroker',
+                            dest='mqttBroker',
+                            default='argus.paris.inria.fr',
+                            action='store_true',
+                            help='MQTT broker to use'
+                            )
+
+    def _on_mqtt_connect(self):
+        pass
+
+    def _on_mqtt_message(self):
+        pass
+
+if __name__ == '__main__':
+    PacketGenerator()