Added dynamic platform loader

src/actuator/loudspeaker.py

@@ -1,9 +1,6 @@
 #!/usr/bin/env python3
-import random
-import os
-import os.path
 from .abcactuator import AbcActuator
-from birbnetes_iot_platform_raspberry import BirbnetesIoTPlatformPlaybackDriver, BirbnetesIoTPlatformStatusDriver
+from utils import BirbnetesIoTPlatformPlaybackDriver, BirbnetesIoTPlatformStatusDriver
 
 """
 Abstract base class for Sender

src/app.py

@@ -6,7 +6,7 @@ import sentry_sdk
 from sentry_sdk.integrations.logging import LoggingIntegration
 from utils import LoopingTimer
 from signal_processor import SoundSignalProcessor
-from birbnetes_iot_platform_raspberry import BirbnetesIoTPlatformStatusDriver, BirbnetesIoTPlatformRecordDriver
+from utils import BirbnetesIoTPlatformStatusDriver, BirbnetesIoTPlatformRecordDriver
 from actuator import Loudspeaker
 import paho.mqtt.client
 import json

src/preprocessor/soundpreprocessor.py

@@ -15,7 +15,7 @@ if not config.DISABLE_AI:
     from pyAudioAnalysis import MidTermFeatures
     import numpy
 
-from birbnetes_iot_platform_raspberry import BirbnetesIoTPlatformStatusDriver
+from utils import BirbnetesIoTPlatformStatusDriver
 
 """
 Abstract base class for Sender
@@ -150,7 +150,7 @@ class SoundPreProcessorLegit(AbcPreProcessor):
 class SoundPreProcessorDummy(AbcPreProcessor):
 
     def __init__(self):
-        print("AI is disabled! Initializing dummy sound pre-processor...")
+        logging.info("AI is disabled! Initializing dummy sound pre-processor...")
 
     def preprocesssignal(self, file_path) -> bool:
         return True

src/sensor/soundsensor.py

@@ -1,8 +1,7 @@
 #!/usr/bin/env python3
 from typing import Optional
 from .abcsensor import AbcSensor
-from utils import config
+from utils import config, BirbnetesIoTPlatformRecordDriver
-from birbnetes_iot_platform_raspberry import BirbnetesIoTPlatformRecordDriver
 
 """
 Sound sensor high level API

src/signal_processor/soundsignalprocessor.py

@@ -7,7 +7,7 @@ from preprocessor import SoundPreProcessor
 from .abcsignalprocessor import AbcSignalProcessor
 import os
 
-from birbnetes_iot_platform_raspberry import BirbnetesIoTPlatformStatusDriver
+from utils import BirbnetesIoTPlatformStatusDriver
 
 """
 Abstract base class for signalprocessor

src/utils/__init__.py

@@ -1,2 +1,4 @@
 #!/usr/bin/env python3
 from .loopingtimer import LoopingTimer
+from .platform import BirbnetesIoTPlatformStatusDriver, BirbnetesIoTPlatformRecordDriver, \
+        BirbnetesIoTPlatformPlaybackDriver

src/utils/config.py

@@ -34,3 +34,5 @@ REPORT_URL = os.environ.get("REPORT_URL", None)
 REPORT_INTERVAL = float(os.environ.get("REPORT_INTERVAL", 15))
 
 DISABLE_AI = os.environ.get("DISABLE_AI").lower() in ['yes', '1', 'true']
+
+PLATFORM = os.environ.get("PLATFORM", "raspberry")

src/utils/platform.py

@@ -0,0 +1,18 @@
+import config
+
+if config.PLATFORM == 'raspberry':
+    from birbnetes_iot_platform_raspberry import BirbnetesIoTPlatformStatusDriver, BirbnetesIoTPlatformRecordDriver, \
+        BirbnetesIoTPlatformPlaybackDriver
+
+elif config.PLATFORM == 'emulator':
+    from birbnetes_iot_platform_emulator import BirbnetesIoTPlatformStatusDriver, BirbnetesIoTPlatformRecordDriver, \
+        BirbnetesIoTPlatformPlaybackDriver
+
+else:
+    raise ModuleNotFoundError(f"Could not load platform driver for {config.PLATFORM}")
+
+__all__ = [
+    'BirbnetesIoTPlatformStatusDriver',
+    'BirbnetesIoTPlatformRecordDriver',
+    'BirbnetesIoTPlatformPlaybackDriver'
+]