Feature: store data in backend

.gitignore

@@ -18,3 +18,7 @@ config/*
 
 homeassistant
 Session.vim
+
+# IntelliJ
+
+.idea

custom_components/optispark/__init__.py

@@ -3,6 +3,7 @@
 For more details about this integration, please refer to
 https://github.com/Big-Tree/HomeAssistant-OptiSpark
 """
+
 from __future__ import annotations
 
 from homeassistant.config_entries import ConfigEntry
@@ -11,30 +12,47 @@
 from homeassistant.helpers.aiohttp_client import async_get_clientsession
 from .api import OptisparkApiClient
 from .const import DOMAIN, LOGGER
+from custom_components.optispark.domain.address.address import Address
 
 PLATFORMS: list[Platform] = [
     Platform.SENSOR,
     Platform.SWITCH,
     Platform.NUMBER,
-    Platform.CLIMATE
+    Platform.CLIMATE,
 ]
 
 
 # https://developers.home-assistant.io/docs/config_entries_index/#setting-up-an-entry
 async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
     """Set up this integration using UI."""
-    from .coordinator import OptisparkDataUpdateCoordinator  # Prevent circular import
+    from .backend_update_handler import BackendUpdateHandler  # Prevent circular import
+    from .coordinator import OptisparkDataUpdateCoordinator
+    from .climate import OptisparkClimate
+
+    address = Address(
+        address=entry.data["address"],
+        postcode=entry.data["postcode"],
+        city=entry.data["city"],
+        country=entry.data["country"]
+    )
+
     hass.data.setdefault(DOMAIN, {})
     hass.data[DOMAIN][entry.entry_id] = coordinator = OptisparkDataUpdateCoordinator(
         hass=hass,
         client=OptisparkApiClient(
-            session=async_get_clientsession(hass)),
-        climate_entity_id=entry.data['climate_entity_id'],
-        heat_pump_power_entity_id=entry.data['heat_pump_power_entity_id'],
-        external_temp_entity_id=entry.data['external_temp_entity_id'],
-        user_hash=entry.data['user_hash'],
-        postcode=entry.data['postcode'],
-        tariff=entry.data['tariff']
+            session=async_get_clientsession(hass),
+            user_hash=entry.data["user_hash"],
+            address=address
+        ),
+        climate_entity_id=entry.data["climate_entity_id"],
+        heat_pump_power_entity_id=entry.data["heat_pump_power_entity_id"],
+        external_temp_entity_id=entry.data["external_temp_entity_id"],
+        user_hash=entry.data["user_hash"],
+        postcode=entry.data["postcode"],
+        tariff=entry.data["tariff"],
+        address=entry.data["address"],
+        city=entry.data["city"],
+        country=entry.data["country"],
     )
     # https://developers.home-assistant.io/docs/integration_fetching_data#coordinated-single-api-poll-for-data-for-all-entities
     await coordinator.async_config_entry_first_refresh()
@@ -77,17 +95,19 @@ def get_entity(hass, entity_id):
     entities_found = []
     successful_domains = []
     for domain in hass.data:
-        if hasattr(hass.data[domain], 'get_entity'):
+        if hasattr(hass.data[domain], "get_entity"):
             entity = hass.data[domain].get_entity(entity_id)
             if entity is not None:
                 entities_found.append(entity)
                 successful_domains.append(domain)
     if len(entities_found) != 1:
-        LOGGER.error(f'({len(entities_found)}) entities found instead of 1')
-        LOGGER.error(f'successful_domains:\n  {successful_domains}')
-        LOGGER.error(f'entities_found:\n  {entities_found}')
-        LOGGER.error(f'hass.data.keys():\n  {hass.data.keys()}')
-        raise OptisparkGetEntityError(f'({len(entities_found)}) entities found instead of 1')
+        LOGGER.error(f"({len(entities_found)}) entities found instead of 1")
+        LOGGER.error(f"successful_domains:\n  {successful_domains}")
+        LOGGER.error(f"entities_found:\n  {entities_found}")
+        LOGGER.error(f"hass.data.keys():\n  {hass.data.keys()}")
+        raise OptisparkGetEntityError(
+            f"({len(entities_found)}) entities found instead of 1"
+        )
     return entities_found[0]
 
 
@@ -97,6 +117,6 @@ def get_username(hass):
     Surely there is a better way than this.
     """
     try:
-        return list(hass.data['person'][1].data.keys())[0]
+        return list(hass.data["person"][1].data.keys())[0]
     except Exception:
         return None