Merge pull request #78 from twrecked/mqtt-backend

Mqtt backend

changelog

@@ -1,3 +1,4 @@
+0.8.0a12: Use new MQTT backend
 0.8.0a11: Add random user agent support.
 0.8.0a10: Don't request resources for Wirefree doorbells.
 0.8.0a9: Support IMAP port.

pyaarlo/__init__.py

@@ -40,7 +40,7 @@
 
 _LOGGER = logging.getLogger("pyaarlo")
 
-__version__ = "0.8.0a11"
+__version__ = "0.8.0a12"
 
 
 class PyArlo(object):
@@ -238,7 +238,10 @@ def __init__(self, **kwargs):
  self._st.set(["ARLO", TOTAL_BELLS_KEY], len(self._doorbells))
  self._st.set(["ARLO", TOTAL_LIGHTS_KEY], len(self._lights))
 
- # Always ping bases first!
+ # Subscribe to events.
+ self._be.start_monitoring()
+
+ # Now ping the bases.
  self._ping_bases()
 
  # Initial config and state retrieval.
@@ -321,7 +324,11 @@ def _refresh_bases(self, initial):
  if base.has_capability(RESOURCE_CAPABILITY):
  self._be.notify(
  base=base,
- body={"action": "get", "resource": "cameras", "publishResponse": False},
+ body={
+ "action": "get",
+ "resource": "cameras",
+ "publishResponse": False,
+ },
  wait_for="response",
  )
  self._be.notify(
@@ -335,7 +342,11 @@ def _refresh_bases(self, initial):
  )
  self._be.notify(
  base=base,
- body={"action": "get", "resource": "lights", "publishResponse": False},
+ body={
+ "action": "get",
+ "resource": "lights",
+ "publishResponse": False,
+ },
  wait_for="response",
  )
  else:
@@ -423,6 +434,10 @@ def entity_id(self):
  def name(self):
  return "ARLO CONTROLLER"
 
+ @property
+ def devices(self):
+ return self._devices
+
  @property
  def device_id(self):
  return "ARLO"