Add air_bags plugin

background.py

@@ -0,0 +1,25 @@
+#!/usr/bin/env python
+"Background Daemon"
+import time
+import logging
+
+from mycroft_bus_client import MessageBusClient
+
+import config
+from daemon import Daemon
+from plugins import plugins
+
+def main():
+    "Main function"
+    logging.basicConfig(level=logging.DEBUG)
+    mycroft = MessageBusClient()
+    mycroft.run_in_thread()
+    daemon = Daemon(config.OSD_URL, config.CAR_API_URL, mycroft)
+    for plugin in plugins:
+        daemon.register_plugin(plugin)
+    while True:
+        daemon.check_all()
+        time.sleep(config.DELAY)
+
+if __name__ == "__main__":
+    main()

daemon.py

@@ -1,25 +0,0 @@
-#!/usr/bin/env python
-import time
-
-import requests
-
-import config
-from plugins import plugins
-
-def emit(event, data):
-    json = {
-        "event": event,
-        "data": data
-    }
-    print(json)
-    return requests.post(config.OSD_URL, json=json)
-
-def main():
-    data = requests.get(config.CAR_API_URL)
-    for plugin in plugins:
-        plugin.check(data.json(), emit)
-
-if __name__ == "__main__":
-    while True:
-        main()
-        time.sleep(config.DELAY)

daemon/__init__.py

@@ -0,0 +1,2 @@
+from .daemon import Daemon
+from .daemon_plugin import DaemonPlugin

daemon/daemon.py

@@ -0,0 +1,40 @@
+"Daemon class"
+import logging
+import requests
+
+class Daemon:
+    "Daemon "
+    def __init__(self, osd_backend, car_api, messagebus_client):
+        self.plugins = []
+        self.osd_backend = osd_backend
+        self.car_api = car_api
+        self.messagebus_client = messagebus_client
+
+    def register_plugin(self, plugin_class):
+        "Registers a plugin"
+        plugin = plugin_class(self)
+        self.plugins.append(plugin)
+
+    def get_data(self):
+        "Gets data from car api"
+        return requests.get(self.car_api).json()
+
+    def emit(self, event, data):
+        "Events data to OSD Backend"
+        json = {
+            "event": event,
+            "data": data
+        }
+        logging.info("Emitting to OSD Frontend")
+        logging.debug("%s", json)
+        return requests.post(self.osd_backend, json=json)
+
+    def check_all(self):
+        "Checks all the plugins"
+        data = self.get_data()
+        for plugin in self.plugins:
+            logging.debug("Checking plugin %s", plugin)
+            try:
+                plugin.check(data)
+            except Exception as error:  # pylint: disable=broad-except
+                logging.error("Exception raised by %s: %s", plugin, error)

daemon/daemon_plugin.py

@@ -0,0 +1,30 @@
+"defines DaemonPlugin base class"
+from abc import ABC, abstractmethod
+from mycroft_bus_client import Message
+
+class DaemonPlugin(ABC):
+    "Abstract class for Plugins to inherit from"
+
+    def __init__(self, daemon):
+        self.daemon = daemon
+        self.messagebus_client = daemon.messagebus_client
+        self.initialize()
+
+    def initialize(self):
+        """
+        Initialize is called after the plugin object has been created. Add
+        any handlers for messagebus_client here
+        """
+
+    def emit(self, event, data):
+        "Emits a message for OSD frontend"
+        self.daemon.emit(event, data)
+
+    def speak(self, utterance):
+        "Speaks the given string"
+        message = Message("speak", {"utterance": utterance})
+        self.messagebus_client.emit(message)
+
+    @abstractmethod
+    def check(self, data):
+        "Implement the core checks here"

plugins/__init__.py

@@ -1,2 +1,2 @@
-from . import fuel_check
+from .fuel_check import FuelCheck
-plugins = [fuel_check]
+plugins = [FuelCheck]

plugins/air_bags.py

@@ -0,0 +1,28 @@
+"AirBags"
+import time
+
+from daemon import DaemonPlugin
+
+class AirBags(DaemonPlugin):
+    "Checks AirBags and sends relevant warnings"
+    last_message = None
+    start = None
+
+    def initialize(self):
+        "Initialize plugin"
+        self.start = time.monotonic()
+
+    def check(self, data):
+        "Checks if the air bags are deployed"
+        if "AirBags-Deploy" not in data:
+            return
+
+        if data["AirBags-Deploy"]:
+            if self.last_message is None:
+                self.emit("switchPlugin", { "plugin": "accident" })
+                message = ("Airbags were released. Calling ambulance in 20 "
+                           "seconds. Tap screen to cancel.")
+                self.speak(message)
+                self.last_message = time.monotonic()
+        else:
+            self.last_message = None

plugins/fuel_check.py

@@ -1,26 +1,35 @@
+"Fuel Check"
 import time
 
-start = time.monotonic()
+from daemon import DaemonPlugin
-last_message = None
-threshold = 5
 
-def check(data, emit):
+class FuelCheck(DaemonPlugin):
-    "Checks if the fuel ratio is below a certain threshold"
+    start = None
-    global last_message
+    last_message = None
-    if "FuelRatio" not in data:
+    threshold = 5
-        return
 
-    ratio = data["FuelRatio"]
+    def initialize(self):
-    if ratio <= threshold:
+        "Initialize plugin"
-        if last_message is None:
+        self.start = time.monotonic()
-            emit("switchPlugin", {
+
-                "plugin": "warning",
+    def check(self, data):
-                "data": {
+        "Checks if the fuel ratio is below a certain threshold"
-                    "title": "Low Fuel",
+        if "FuelRatio" not in data:
-                    "description": f"Only {int(ratio)}% fuel left. Please refill the tank."
+            return
-                },
+
-                "time": 5000
+        ratio = data["FuelRatio"]
-            })
+        if ratio <= self.threshold:
-            last_message = time.monotonic()
+            if self.last_message is None:
-    else:
+                desc = f"Only {int(ratio)}% fuel left. Please refill the tank."
-        last_message = None
+                self.speak(desc)
+                self.emit("switchPlugin", {
+                    "plugin": "warning",
+                    "data": {
+                        "title": "Low Fuel",
+                        "description": desc
+                    },
+                    "time": 5000
+                })
+                self.last_message = time.monotonic()
+        else:
+            self.last_message = None