2.2b3

* raise scene notifications from controller as HA events

extalife/helpers/const.py

@@ -63,6 +63,7 @@
 
 CONF_EXTALIFE_EVENT_BASE = f"{DOMAIN}"
 CONF_EXTALIFE_EVENT_TRANSMITTER = f"{CONF_EXTALIFE_EVENT_BASE}_transmitter"
+CONF_EXTALIFE_EVENT_SCENE = f"{CONF_EXTALIFE_EVENT_BASE}_scene"
 
 CONF_PROCESSOR_EVENT_STAT_NOTIFICATION = "notification"
 CONF_PROCESSOR_EVENT_UNKNOWN = "unknown"

extalife/helpers/core.py

@@ -10,7 +10,7 @@
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.const import EVENT_HOMEASSISTANT_STOP
 
-from .const import DATA_CORE, DOMAIN
+from .const import DATA_CORE, DOMAIN, CONF_EXTALIFE_EVENT_SCENE
 from ..pyextalife import ExtaLifeAPI
 from .typing import (
     TransmitterManagerType,
@@ -22,6 +22,11 @@
 from .services import ExtaLifeServices
 
 
+MAP_NOTIF_CMD_TO_EVENT = {
+    ExtaLifeAPI.CMD_ACTIVATE_SCENE: CONF_EXTALIFE_EVENT_SCENE
+}
+
+
 _LOGGER = logging.getLogger(__name__)
 
 
@@ -198,7 +203,13 @@ def _on_disconnect_callback(self):
     def _on_status_notification_callback(self, msg):
         if self._is_unloading or self._is_stopping:
             return
-        self._data_manager.on_notify(msg)
+
+        # forward only state notifications to data manager to update channels
+        if msg.get("command") == self.api.CMD_CONTROL_DEVICE:
+            self._data_manager.on_notify(msg)
+
+        self._put_notification_on_event_bus(msg)
+
 
     async def _periodic_reconnect_callback(self, now):
         """Reconnect with the controller after connection is lost
@@ -217,6 +228,13 @@ def controller_entity_added_to_hass(self, entity):
         entity - Entity object"""
         self._controller_entity = entity
 
+    def _put_notification_on_event_bus(self, msg):
+        """ This method raises a notification on HA Event Bus """
+        data = msg.get("data")
+        event = MAP_NOTIF_CMD_TO_EVENT.get(msg.get("command"))
+        if event:
+            self._hass.bus.async_fire(event, event_data=data)
+
     @property
     def api(self) -> ExtaLifeAPI:
         return self._api

extalife/manifest.json

@@ -1,7 +1,7 @@
 {
   "domain": "extalife",
   "name": "Exta Life",
-  "version": "2.2b2",
+  "version": "2.2b3",
   "config_flow": true,
   "documentation": "https://www.forumextalife.pl/index.php/board,56.0.html",
   "requirements": [

extalife/pyextalife.py

@@ -259,6 +259,7 @@ class ExtaLifeAPI:
     CMD_FETCH_RECEIVERS = 37
     CMD_FETCH_SENSORS = 38
     CMD_FETCH_TRANSMITTERS = 39
+    CMD_ACTIVATE_SCENE = 44
     CMD_FETCH_NETW_SETTINGS = 102
     CMD_FETCH_EXTAFREE = 203
     CMD_VERSION = 151
@@ -388,7 +389,7 @@ async def _async_on_tcp_disconnect_callback(self):
 
     async def _async_on_notification_callback(self, data):
         """ Called when notification from the controller is received """
-        if self._on_notification_callback(data) is not None and data.get("command") == self.CMD_CONTROL_DEVICE:
+        if self._on_notification_callback(data) is not None:
             # forward only device status changes to the listener
             self._on_notification_callback(data)