From 6233e9fbd486312856b368160bbf03ce7b44d80d Mon Sep 17 00:00:00 2001
From: Bastian Schroll <bastian@schroll-software.de>
Date: Thu, 24 Oct 2019 08:45:18 +0200
Subject: [PATCH] added testmode to bw_client

---
 bw_client.py | 27 ++++++++++++++++++---------
 1 file changed, 18 insertions(+), 9 deletions(-)

diff --git a/bw_client.py b/bw_client.py
index 6324691..4acf92b 100644
--- a/bw_client.py
+++ b/bw_client.py
@@ -60,7 +60,7 @@ parser = argparse.ArgumentParser(prog="bw_client.py",
                                  epilog="""More options you can find in the extern client.ini
                                  file in the folder /config""")
 parser.add_argument("-c", "--config", help="Name to configuration File", required=True)
-parser.add_argument("-t", "--test", help="Start Client with testdata-set")
+parser.add_argument("-t", "--test", help="Start Client with testdata-set", action="store_true")
 args = parser.parse_args()
 
 bwConfig = ConfigYAML()
@@ -79,9 +79,6 @@ try:
             ip = broadcastClient.serverIP
             port = broadcastClient.serverPort
 
-    inputQueue = queue.Queue()
-    inputThreadRunning = True
-
     # ========== INPUT CODE ==========
     def handleSDRInput(dataQueue, sdrConfig, decoderConfig):  # todo exception handling inside
         sdrProc = ProcessManager(str(sdrConfig.get("rtlPath", default="rtl_fm")))
@@ -134,13 +131,25 @@ try:
         logging.debug("stopping thread")
         mmProc.stop()
         sdrProc.stop()
-
     # ========== INPUT CODE ==========
 
-    mmThread = threading.Thread(target=handleSDRInput, name="mmReader",
-                                args=(inputQueue, bwConfig.get("inputSource", "sdr"), bwConfig.get("decoder")))
-    mmThread.daemon = True
-    mmThread.start()
+    inputQueue = queue.Queue()
+
+    if not args.test:
+        inputThreadRunning = True
+        mmThread = threading.Thread(target=handleSDRInput, name="mmReader",
+                                    args=(inputQueue, bwConfig.get("inputSource", "sdr"), bwConfig.get("decoder")))
+        mmThread.daemon = True
+        mmThread.start()
+    else:
+        logging.warning("STARTING TESTMODE!")
+        logging.debug("reading testdata from file")
+        testFile = open("test/testdata.list", "r")
+        for testData in testFile:
+            if (len(testData.rstrip(' \t\n\r')) > 1) and ("#" not in testData[0]):
+                logging.info("Testdata: %s", testData.rstrip(' \t\n\r'))
+                inputQueue.put_nowait((testData.rstrip(' \t\n\r'), time.time()))
+        logging.debug("finished reading testdata")
 
     bwClient = TCPClient()
     bwClient.connect(ip, port)