Make version mismatch a critical error

raspberry-dataserver/ArduinoEmulator.py

@@ -9,7 +9,7 @@ import binascii
 from pathlib import Path
 from subprocess import Popen
 from CommsLLI import CommsLLI
-from CommsCommon import PayloadFormat
+from CommsCommon import PayloadFormat, HEVVersionError
 
 # Set up logging
 logging.basicConfig(format='%(asctime)s - %(levelname)s - %(message)s')
@@ -32,7 +32,11 @@ class ArduinoEmulator:
                         await asyncio.sleep(0.02)
         except FileNotFoundError:
             logging.critical("File not found")
-            exit(0)
+            exit(1)
+        except HEVVersionError as e:
+            logging.critical(f"HEVVersionError: {e}")
+            exit(1)
+
 
     async def receiver(self):
         payload = await self._lli._payloadrecv.get()

raspberry-dataserver/CommsCommon.py

@@ -153,6 +153,9 @@ class PAYLOAD_TYPE(IntEnum):
     IVT        = 8
     LOGMSG     = 9
 
+class HEVVersionError(Exception):
+    pass
+
 @dataclass
 class PayloadFormat():
     # class variables excluded from init args and output dict
@@ -203,7 +206,7 @@ class PayloadFormat():
     # check for mismatch between pi and microcontroller version
     def checkVersion(self):
         if self._RPI_VERSION != self.version : 
-            raise Exception('Version Mismatch', "PI:", self._RPI_VERSION, "uC:", self.version)
+            raise HEVVersionError('Version Mismatch', "PI:", self._RPI_VERSION, "uC:", self.version)
 
     def getSize(self) -> int:
         return len(self.byteArray)

raspberry-dataserver/CommsLLI.py

@@ -10,7 +10,7 @@ from collections import deque
 from enum import Enum, IntEnum
 from dataclasses import asdict
 from struct import error as StructError
-from CommsCommon import PayloadFormat, PAYLOAD_TYPE
+from CommsCommon import PayloadFormat, PAYLOAD_TYPE, HEVVersionError
 from CommsFormat import CommsPacket, CommsACK, CommsNACK, CommsChecksumError, generateAlarm, generateCmd, generateData
 
 # Set up logging
@@ -198,6 +198,9 @@ class CommsLLI:
                     logging.error(f"Invalid payload: {payload}")
                     # restart/reflash/swap to redundant microcontroller?
                     comms_response = CommsNACK(packet.address)
+                except HEVVersionError as e:
+                    logging.critical(f"HEVVersionError: {e}")
+                    exit(1)
                 finally:
                     comms_response.setSequenceReceive(packet.sequence_receive)
                     await self.sendPacket(comms_response)