Added radio_transeiver class

hardware/CommunicationsPi/lan_server.py

@@ -42,7 +42,7 @@ def run(server_class=HTTPServer, handler_class=S, port=8080):
     logging.basicConfig(level=logging.INFO)
     server_address = ("", port)
     httpd = server_class(server_address, handler_class)
-    logging.info("Starting httpd...\n")
+    log.info("Starting httpd...\n")
     try:
         httpd.serve_forever()
     except KeyboardInterrupt:

hardware/CommunicationsPi/radio_transceiver.py

@@ -0,0 +1,46 @@
+import os
+import serial
+import json
+
+from .utils import get_logger, get_serial_stream
+
+
+class Transceiver:
+    def __init__(self, log_file_name=None, port=None):
+        if log_file_name is None:
+            self.logging = get_logger("TRANSMITTER_LOG_FILE")
+        else:
+            self.logging = get_logger(log_file_name)
+
+        port = os.environ["RADIO_TRANSMITTER_PORT"] if port is None else port
+        baudrate = 9600
+        parity = serial.PARITY_NONE
+        stopbits = serial.STOPBITS_ONE
+        bytesize = serial.EIGHTBITS
+        timeout = 1
+
+        self.logging.info("Opening serial")
+        self.serial = serial.Serial(
+            port=port,
+            baudrate=baudrate,
+            parity=parity,
+            stopbits=stopbits,
+            bytesize=bytesize,
+            timeout=timeout,
+        )
+
+    def send(self, payload):
+        self.logging.info("sending")
+        self.serial.write(get_serial_stream(payload))
+        self.logging.info(payload)
+
+    def listen(self):
+        payload = self.serial.readline().decode("utf-8")
+        message = "Error: Check logs"
+        if payload != "":
+            try:
+                message = json.loads(payload)
+                self.logging.info(message)
+            except json.JSONDecodeError:
+                self.logging.error(json.JSONDecodeError)
+        return message