Add integration for APsystems EZ1 microinverter

.coveragerc

@@ -81,6 +81,10 @@ omit =
     homeassistant/components/aprilaire/climate.py
     homeassistant/components/aprilaire/coordinator.py
     homeassistant/components/aprilaire/entity.py
+    homeassistant/components/apsystems/__init__.py
+    homeassistant/components/apsystems/const.py
+    homeassistant/components/apsystems/coordinator.py
+    homeassistant/components/apsystems/sensor.py
     homeassistant/components/aqualogic/*
     homeassistant/components/aquostv/media_player.py
     homeassistant/components/arcam_fmj/__init__.py

.strict-typing

@@ -84,6 +84,7 @@ homeassistant.components.api.*
 homeassistant.components.apple_tv.*
 homeassistant.components.apprise.*
 homeassistant.components.aprs.*
+homeassistant.components.apsystems.*
 homeassistant.components.aqualogic.*
 homeassistant.components.aquostv.*
 homeassistant.components.aranet.*

CODEOWNERS

@@ -127,6 +127,8 @@ build.json @home-assistant/supervisor
 /tests/components/aprilaire/ @chamberlain2007
 /homeassistant/components/aprs/ @PhilRW
 /tests/components/aprs/ @PhilRW
+/homeassistant/components/apsystems/ @mawoka-myblock @SonnenladenGmbH
+/tests/components/apsystems/ @mawoka-myblock @SonnenladenGmbH
 /homeassistant/components/aranet/ @aschmitz @thecode @anrijs
 /tests/components/aranet/ @aschmitz @thecode @anrijs
 /homeassistant/components/arcam_fmj/ @elupus

homeassistant/components/apsystems/__init__.py

@@ -0,0 +1,34 @@
+"""The APsystems local API integration."""
+
+from __future__ import annotations
+
+import logging
+
+from APsystemsEZ1 import APsystemsEZ1M
+
+from homeassistant.config_entries import ConfigEntry
+from homeassistant.const import CONF_IP_ADDRESS, Platform
+from homeassistant.core import HomeAssistant
+
+from .coordinator import ApSystemsDataCoordinator
+
+_LOGGER = logging.getLogger(__name__)
+
+PLATFORMS: list[Platform] = [Platform.SENSOR]
+
+
+async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+    """Set up this integration using UI."""
+    entry.runtime_data = {}
+    api = APsystemsEZ1M(ip_address=entry.data[CONF_IP_ADDRESS], timeout=8)
+    coordinator = ApSystemsDataCoordinator(hass, api)
+    await coordinator.async_config_entry_first_refresh()
+    entry.runtime_data = {"COORDINATOR": coordinator}
+    await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)
+
+    return True
+
+
+async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+    """Unload a config entry."""
+    return await hass.config_entries.async_unload_platforms(entry, PLATFORMS)

homeassistant/components/apsystems/config_flow.py

@@ -0,0 +1,51 @@
+"""The config_flow for APsystems local API integration."""
+
+from aiohttp import client_exceptions
+from APsystemsEZ1 import APsystemsEZ1M
+import voluptuous as vol
+
+from homeassistant import config_entries
+from homeassistant.const import CONF_IP_ADDRESS
+from homeassistant.helpers.aiohttp_client import async_get_clientsession
+
+from .const import DOMAIN, LOGGER
+
+DATA_SCHEMA = vol.Schema(
+    {
+        vol.Required(CONF_IP_ADDRESS): str,
+    }
+)
+
+
+class APsystemsLocalAPIFlow(config_entries.ConfigFlow, domain=DOMAIN):
+    """Config flow for Apsystems local."""
+
+    VERSION = 1
+
+    async def async_step_user(
+        self,
+        user_input: dict | None = None,
+    ) -> config_entries.ConfigFlowResult:
+        """Handle a flow initialized by the user."""
+        _errors = {}
+        session = async_get_clientsession(self.hass, False)
+
+        if user_input is not None:
+            try:
+                session = async_get_clientsession(self.hass, False)
+                api = APsystemsEZ1M(user_input[CONF_IP_ADDRESS], session=session)
+                device_info = await api.get_device_info()
+                await self.async_set_unique_id(device_info.deviceId)
+            except (TimeoutError, client_exceptions.ClientConnectionError) as exception:
+                LOGGER.warning(exception)
+                _errors["base"] = "connection_refused"
+            else:
+                return self.async_create_entry(
+                    title="Solar",
+                    data=user_input,
+                )
+        return self.async_show_form(
+            step_id="user",
+            data_schema=DATA_SCHEMA,
+            errors=_errors,
+        )

homeassistant/components/apsystems/const.py

@@ -0,0 +1,6 @@
+"""Constants for the APsystems Local API integration."""
+
+from logging import Logger, getLogger
+
+LOGGER: Logger = getLogger(__package__)
+DOMAIN = "apsystems"

homeassistant/components/apsystems/coordinator.py

@@ -0,0 +1,37 @@
+"""The coordinator for APsystems local API integration."""
+
+from __future__ import annotations
+
+from datetime import timedelta
+import logging
+
+from APsystemsEZ1 import APsystemsEZ1M, ReturnOutputData
+
+from homeassistant.core import HomeAssistant
+from homeassistant.helpers.update_coordinator import DataUpdateCoordinator
+
+_LOGGER = logging.getLogger(__name__)
+
+
+class InverterNotAvailable(Exception):
+    """Error used when Device is offline."""
+
+
+class ApSystemsDataCoordinator(DataUpdateCoordinator):
+    """Coordinator used for all sensors."""
+
+    def __init__(self, hass: HomeAssistant, api: APsystemsEZ1M) -> None:
+        """Initialize my coordinator."""
+        super().__init__(
+            hass,
+            _LOGGER,
+            # Name of the data. For logging purposes.
+            name="APSystems Data",
+            # Polling interval. Will only be polled if there are subscribers.
+            update_interval=timedelta(seconds=12),
+        )
+        self.api = api
+        self.always_update = True
+
+    async def _async_update_data(self) -> ReturnOutputData:
+        return await self.api.get_output_data()

homeassistant/components/apsystems/manifest.json

@@ -0,0 +1,13 @@
+{
+  "domain": "apsystems",
+  "name": "APsystems",
+  "codeowners": ["@mawoka-myblock", "@SonnenladenGmbH"],
+  "config_flow": true,
+  "dependencies": [],
+  "documentation": "https://www.home-assistant.io/integrations/apsystems",
+  "homekit": {},
+  "iot_class": "local_polling",
+  "requirements": ["apsystems-ez1==1.3.1"],
+  "ssdp": [],
+  "zeroconf": []
+}

homeassistant/components/apsystems/sensor.py

@@ -0,0 +1,165 @@
+"""The read-only sensors for APsystems local API integration."""
+
+from __future__ import annotations
+
+from collections.abc import Callable
+from dataclasses import dataclass
+
+from APsystemsEZ1 import ReturnOutputData
+
+from homeassistant import config_entries
+from homeassistant.components.sensor import (
+    SensorDeviceClass,
+    SensorEntity,
+    SensorEntityDescription,
+    SensorStateClass,
+)
+from homeassistant.const import UnitOfEnergy, UnitOfPower
+from homeassistant.core import HomeAssistant, callback
+from homeassistant.helpers.device_registry import DeviceInfo
+from homeassistant.helpers.entity_platform import AddEntitiesCallback
+from homeassistant.helpers.typing import DiscoveryInfoType
+from homeassistant.helpers.update_coordinator import CoordinatorEntity
+
+from .coordinator import ApSystemsDataCoordinator
+
+
+@dataclass(frozen=True, kw_only=True)
+class ApsystemsLocalApiSensorDescription(SensorEntityDescription):
+    """Describes Apsystens Inverter sensor entity."""
+
+    value_fn: Callable[[ReturnOutputData], float | None]
+
+
+SENSORS: tuple[ApsystemsLocalApiSensorDescription, ...] = (
+    ApsystemsLocalApiSensorDescription(
+        key="total_power",
+        translation_key="total_power",
+        native_unit_of_measurement=UnitOfPower.WATT,
+        device_class=SensorDeviceClass.POWER,
+        state_class=SensorStateClass.MEASUREMENT,
+        value_fn=lambda c: c.p1 + c.p2,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="total_power_p1",
+        translation_key="total_power_p1",
+        native_unit_of_measurement=UnitOfPower.WATT,
+        device_class=SensorDeviceClass.POWER,
+        state_class=SensorStateClass.MEASUREMENT,
+        value_fn=lambda c: c.p1,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="total_power_p2",
+        translation_key="total_power_p2",
+        native_unit_of_measurement=UnitOfPower.WATT,
+        device_class=SensorDeviceClass.POWER,
+        state_class=SensorStateClass.MEASUREMENT,
+        value_fn=lambda c: c.p2,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="lifetime_production",
+        translation_key="lifetime_production",
+        native_unit_of_measurement=UnitOfEnergy.KILO_WATT_HOUR,
+        device_class=SensorDeviceClass.ENERGY,
+        state_class=SensorStateClass.TOTAL_INCREASING,
+        value_fn=lambda c: c.te1 + c.te2,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="lifetime_production_p1",
+        translation_key="lifetime_production_p1",
+        native_unit_of_measurement=UnitOfEnergy.KILO_WATT_HOUR,
+        device_class=SensorDeviceClass.ENERGY,
+        state_class=SensorStateClass.TOTAL_INCREASING,
+        value_fn=lambda c: c.te1,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="lifetime_production_p2",
+        translation_key="lifetime_production_p2",
+        native_unit_of_measurement=UnitOfEnergy.KILO_WATT_HOUR,
+        device_class=SensorDeviceClass.ENERGY,
+        state_class=SensorStateClass.TOTAL_INCREASING,
+        value_fn=lambda c: c.te2,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="today_production",
+        translation_key="today_production",
+        native_unit_of_measurement=UnitOfEnergy.KILO_WATT_HOUR,
+        device_class=SensorDeviceClass.ENERGY,
+        state_class=SensorStateClass.TOTAL_INCREASING,
+        value_fn=lambda c: c.e1 + c.e2,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="today_production_p1",
+        translation_key="today_production_p1",
+        native_unit_of_measurement=UnitOfEnergy.KILO_WATT_HOUR,
+        device_class=SensorDeviceClass.ENERGY,
+        state_class=SensorStateClass.TOTAL_INCREASING,
+        value_fn=lambda c: c.e1,
+    ),
+    ApsystemsLocalApiSensorDescription(
+        key="today_production_p2",
+        translation_key="today_production_p2",
+        native_unit_of_measurement=UnitOfEnergy.KILO_WATT_HOUR,
+        device_class=SensorDeviceClass.ENERGY,
+        state_class=SensorStateClass.TOTAL_INCREASING,
+        value_fn=lambda c: c.e2,
+    ),
+)
+
+
+async def async_setup_entry(
+    hass: HomeAssistant,
+    config_entry: config_entries.ConfigEntry,
+    add_entities: AddEntitiesCallback,
+    discovery_info: DiscoveryInfoType | None = None,
+) -> None:
+    """Set up the sensor platform."""
+    config = config_entry.runtime_data
+    coordinator = config["COORDINATOR"]
+    device_name = config_entry.title
+    device_id: str = config_entry.unique_id  # type: ignore[assignment]
+
+    add_entities(
+        ApSystemsSensorWithDescription(coordinator, desc, device_name, device_id)
+        for desc in SENSORS
+    )
+
+
+class ApSystemsSensorWithDescription(CoordinatorEntity, SensorEntity):
+    """Base sensor to be used with description."""
+
+    entity_description: ApsystemsLocalApiSensorDescription
+
+    def __init__(
+        self,
+        coordinator: ApSystemsDataCoordinator,
+        entity_description: ApsystemsLocalApiSensorDescription,
+        device_name: str,
+        device_id: str,
+    ) -> None:
+        """Initialize the sensor."""
+        super().__init__(coordinator)
+        self.entity_description = entity_description
+        self._device_name = device_name
+        self._device_id = device_id
+        self._attr_unique_id = f"{device_id}_{entity_description.key}"
+
+    @property
+    def device_info(self) -> DeviceInfo:
+        """Get the DeviceInfo."""
+        return DeviceInfo(
+            identifiers={("apsystems", self._device_id)},
+            name=self._device_name,
+            serial_number=self._device_id,
+            manufacturer="APsystems",
+            model="EZ1-M",
+        )
+
+    @callback
+    def _handle_coordinator_update(self) -> None:
+        if self.coordinator.data is None:
+            return  # type: ignore[unreachable]
+        self._attr_native_value = self.entity_description.value_fn(
+            self.coordinator.data
+        )
+        self.async_write_ha_state()

homeassistant/components/apsystems/strings.json

@@ -0,0 +1,21 @@
+{
+  "config": {
+    "step": {
+      "user": {
+        "data": {
+          "host": "[%key:common::config_flow::data::host%]",
+          "username": "[%key:common::config_flow::data::username%]",
+          "password": "[%key:common::config_flow::data::password%]"
+        }
+      }
+    },
+    "error": {
+      "cannot_connect": "[%key:common::config_flow::error::cannot_connect%]",
+      "invalid_auth": "[%key:common::config_flow::error::invalid_auth%]",
+      "unknown": "[%key:common::config_flow::error::unknown%]"
+    },
+    "abort": {
+      "already_configured": "[%key:common::config_flow::abort::already_configured_device%]"
+    }
+  }
+}

homeassistant/generated/config_flows.py

@@ -54,6 +54,7 @@
         "apcupsd",
         "apple_tv",
         "aprilaire",
+        "apsystems",
         "aranet",
         "arcam_fmj",
         "arve",

homeassistant/generated/integrations.json

@@ -408,6 +408,12 @@
       "config_flow": false,
       "iot_class": "cloud_push"
     },
+    "apsystems": {
+      "name": "APsystems",
+      "integration_type": "hub",
+      "config_flow": true,
+      "iot_class": "local_polling"
+    },
     "aqualogic": {
       "name": "AquaLogic",
       "integration_type": "hub",

mypy.ini

@@ -601,6 +601,16 @@ disallow_untyped_defs = true
 warn_return_any = true
 warn_unreachable = true
 
+[mypy-homeassistant.components.apsystems.*]
+check_untyped_defs = true
+disallow_incomplete_defs = true
+disallow_subclassing_any = true
+disallow_untyped_calls = true
+disallow_untyped_decorators = true
+disallow_untyped_defs = true
+warn_return_any = true
+warn_unreachable = true
+
 [mypy-homeassistant.components.aqualogic.*]
 check_untyped_defs = true
 disallow_incomplete_defs = true