Use dispatcher instead of bus

Author: AfonsoFGarcia

custom_components/bluecon/ConfigEntryNotificationInfoStorage.py

@@ -3,6 +3,7 @@
 from homeassistant.core import HomeAssistant
 from typing import Any
 from .const import SIGNAL_ENTITY_UPDATED
+from homeassistant.helpers.dispatcher import dispatcher_send
 
 class ConfigEntryNotificationInfoStorage(INotificationInfoStorage):
     def __init__(self, hass: HomeAssistant, entry: ConfigEntry):
@@ -15,7 +16,7 @@ def retrieveCredentials(self) -> dict[str, dict[str, Any]] | None:
     def storeCredentials(self, credentials: dict[str, dict[str, Any]]):
         new = {**self.__entry.options,
                       "credentials": credentials}
-        self.__hass.bus.fire(SIGNAL_ENTITY_UPDATED.format(self.__entry.entry_id), new)
+        dispatcher_send(self.__hass, SIGNAL_ENTITY_UPDATED.format(self.__entry.entry_id), new)
 
     def retrievePersistentIds(self) -> list[str] | None:
         return self.__entry.options["persistentIds"]
@@ -29,4 +30,4 @@ def storePersistentId(self, persistentId: str):
 
         new = {**self.__entry.options,
                       "persistentIds": stored_persistent_ids}
-        self.__hass.bus.fire(SIGNAL_ENTITY_UPDATED.format(self.__entry.entry_id), new)
+        dispatcher_send(self.__hass, SIGNAL_ENTITY_UPDATED.format(self.__entry.entry_id), new)

custom_components/bluecon/ConfigEntryOAuthTokenStorage.py

@@ -2,6 +2,7 @@
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import HomeAssistant
 from .const import SIGNAL_ENTITY_UPDATED
+from homeassistant.helpers.dispatcher import dispatcher_send
 
 class ConfigEntryOAuthTokenStorage(IOAuthTokenStorage):
     def __init__(self, hass: HomeAssistant, entry: ConfigEntry):
@@ -14,4 +15,4 @@ def retrieveOAuthToken(self) -> OAuthToken:
     def storeOAuthToken(self, oAuthToken: OAuthToken):
         new = {**self.__entry.options,
                       "token": oAuthToken.toJson()}
-        self.__hass.bus.fire(SIGNAL_ENTITY_UPDATED.format(self.__entry.entry_id), new)
+        dispatcher_send(self.__hass, SIGNAL_ENTITY_UPDATED.format(self.__entry.entry_id), new)

custom_components/bluecon/__init__.py

@@ -2,7 +2,7 @@
 from .ConfigEntryOAuthTokenStorage import ConfigEntryOAuthTokenStorage
 from .ConfigEntryNotificationInfoStorage import ConfigEntryNotificationInfoStorage
 from homeassistant.const import EVENT_HOMEASSISTANT_STOP, Platform
-from homeassistant.helpers.dispatcher import dispatcher_send
+from homeassistant.helpers.dispatcher import dispatcher_send, async_dispatcher_connect
 from bluecon import BlueConAPI, INotification, CallNotification, CallEndNotification
 from homeassistant.core import HomeAssistant, callback
 from homeassistant.config_entries import ConfigEntry
@@ -34,12 +34,12 @@ async def cleanup(event):
         await bluecon.stopNotificationListener()
 
     @callback
-    async def updateConfigEntry(event):
+    async def updateConfigEntry(data):
         _LOGGER.warning(f"Updating config entry {entry.entry_id}")
-        hass.config_entries.async_update_entry(entry, options=event.data)
+        hass.config_entries.async_update_entry(entry, options=data)
 
     hass.bus.async_listen_once(EVENT_HOMEASSISTANT_STOP, cleanup)
-    hass.bus.async_listen(SIGNAL_ENTITY_UPDATED.format(entry.entry_id), updateConfigEntry)
+    async_dispatcher_connect(hass, SIGNAL_ENTITY_UPDATED.format(entry.entry_id), updateConfigEntry)
     hass.data[DOMAIN][entry.entry_id] = bluecon
 
     await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)

custom_components/bluecon/manifest.json

@@ -1,7 +1,7 @@
 {
     "domain": "bluecon",
     "name": "Fermax Blue",
-    "version": "0.1.8",
+    "version": "0.1.9",
     "documentation": "https://hass-bluecon.afonsogarcia.dev/",
     "issue_tracker": "https://github.com/AfonsoFGarcia/hass-bluecon/issues",
     "requirements": ["bluecon==0.1.2", "aiohttp", "oscrypto", "protobuf", "http-ece"],