From 7ed3a20892438f7e5737b13365b418853008c696 Mon Sep 17 00:00:00 2001 From: michaelpivato Date: Mon, 16 Mar 2020 12:33:12 +1030 Subject: [PATCH] Start adding files for testing the algorithms. --- Messaging/message_factory.py | 20 ++++++++++++++++++++ tracking/lidar_tester.py | 5 +++++ 2 files changed, 25 insertions(+) create mode 100644 tracking/lidar_tester.py diff --git a/Messaging/message_factory.py b/Messaging/message_factory.py index fa24312..814e26a 100644 --- a/Messaging/message_factory.py +++ b/Messaging/message_factory.py @@ -32,6 +32,23 @@ class BluetoothStreamer: def send_message(self, message_bytes): pass +class TestStreamer: + def __init__(self): + self._listeners = [] + + def send_message(self, message_bytes): + print('Got a message') + + def send_message_topic(self, topic, message): + print('Got a message with topic: ' + str(topic)) + self._fire_message_received(message) + + def add_message_listener(self, listener): + self._listeners.append(listener) + + def _fire_message_received(self, message): + for listener in self._listeners: + listener(message) def getZmqPubSubStreamer(port): ''' @@ -39,3 +56,6 @@ def getZmqPubSubStreamer(port): to use it. ''' return ZmqPubSubStreamer(port) + +def getTestingStreamer(): + return TestStreamer() \ No newline at end of file diff --git a/tracking/lidar_tester.py b/tracking/lidar_tester.py new file mode 100644 index 0000000..d41215d --- /dev/null +++ b/tracking/lidar_tester.py @@ -0,0 +1,5 @@ +from tracking.lidar_cache import LidarCache +import Messaging.message_factory as mf + + +