Merge pull request #6 from bbbenji/patch-8

Add initial MiFlora worker

workers/miflora.py

@@ -0,0 +1,38 @@
+from interruptingcow import timeout
+from mqtt import MqttMessage
+from workers.base import BaseWorker
+
+from miflora.miflora_poller import MiFloraPoller, \
+  MI_CONDUCTIVITY, MI_MOISTURE, MI_LIGHT, MI_TEMPERATURE, MI_BATTERY
+from btlewrap.bluepy import BluepyBackend
+
+REQUIREMENTS = ['miflora']
+
+monitoredAttrs = ["temperature", "moisture", "light", "conductivity", "battery"]
+
+class MifloraWorker(BaseWorker):
+  def _setup(self):
+
+    for name, mac in self.devices.items():
+      self.devices[name] = MiFloraPoller(mac, BluepyBackend)
+
+  def status_update(self):
+    ret = []
+    for name, poller in self.devices.items():
+      try:
+        ret += self.update_device_state(name, poller)
+      except RuntimeError:
+        pass
+
+    return ret
+
+  @timeout(8.0)
+
+  def update_device_state(self, name, poller):
+
+    ret = []
+    for attr in monitoredAttrs:
+
+      ret.append(MqttMessage(topic=self.format_topic(name, attr), payload=poller.parameter_value(attr)))
+
+    return ret