Add IoTMeter integration

CODEOWNERS

@@ -696,6 +696,7 @@ build.json @home-assistant/supervisor
 /tests/components/ios/ @robbiet480
 /homeassistant/components/iotawatt/ @gtdiehl @jyavenard
 /tests/components/iotawatt/ @gtdiehl @jyavenard
+/homeassistant/components/iotmeter/ @lipic
 /homeassistant/components/iotty/ @pburgio
 /tests/components/iotty/ @pburgio
 /homeassistant/components/iperf3/ @rohankapoorcom

homeassistant/components/iotmeter/__init__.py

@@ -0,0 +1,55 @@
+"""IoTMeter integration for Home Assistant."""
+
+import logging
+
+from homeassistant.config_entries import ConfigEntry
+from homeassistant.const import Platform
+from homeassistant.core import HomeAssistant
+
+from .const import DOMAIN
+from .coordinator import IotMeterDataUpdateCoordinator
+
+_LOGGER = logging.getLogger(__name__)
+_LOGGER.setLevel(logging.DEBUG)
+
+PLATFORMS = [Platform.SENSOR] # Platform.NUMBER
+
+
+async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+ """Set up IoTMeter from a config entry."""
+ _LOGGER.debug("Setting up IoTMeter integration")
+ if DOMAIN not in hass.data:
+ hass.data[DOMAIN] = {} # Ensure that the domain is a dictionary
+
+ ip_address = entry.data.get("ip_address")
+ port = entry.data.get("port", 8000) # Default to port 8000 if not set
+
+ _coordinator = IotMeterDataUpdateCoordinator(hass, ip_address, port)
+ await _coordinator.async_config_entry_first_refresh()
+
+ hass.data[DOMAIN] = {
+ "coordinator": _coordinator,
+ "ip_address": ip_address,
+ "port": port,
+ }
+
+ await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)
+ entry.async_on_unload(entry.add_update_listener(update_listener))
+ return True
+
+
+async def update_listener(hass: HomeAssistant, entry: ConfigEntry):
+ """Handle options update."""
+ ip_address = entry.data.get("ip_address", entry.data.get("ip_address"))
+ port = entry.data.get("port", entry.data.get("port", 8000))
+ _coordinator = hass.data[DOMAIN]["coordinator"]
+ _coordinator.update_ip_port(ip_address, port)
+ await _coordinator.async_request_refresh()
+
+
+async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+ """Handle unloading of an entry."""
+ unload_ok = await hass.config_entries.async_unload_platforms(entry, PLATFORMS)
+ if unload_ok:
+ hass.data.pop(DOMAIN)
+ return unload_ok

homeassistant/components/iotmeter/config_flow.py

@@ -0,0 +1,63 @@
+"""Config flow for IoTMeter integration."""
+
+import voluptuous as vol
+
+from homeassistant import config_entries
+
+from .const import DOMAIN
+
+
+class EVConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
+ """Handle a config flow for IoTMeter."""
+
+ async def async_step_user(self, user_input=None):
+ """Handle the initial step."""
+ errors = {}
+ if user_input is not None:
+ ip_address = user_input.get("ip_address")
+ port = user_input.get("port")
+
+ if ip_address and port:
+ return self.async_create_entry(title="IoTMeter", data=user_input)
+ errors["base"] = "invalid_input"
+
+ data_schema = vol.Schema(
+ {vol.Required("ip_address"): str, vol.Optional("port", default=8000): int}
+ )
+
+ return self.async_show_form(
+ step_id="user", data_schema=data_schema, errors=errors
+ )
+
+ async def async_step_reconfigure(self, user_input=None):
+ """Handle the reconfiguration step."""
+ errors = {}
+ # Get the current configuration from config_entry
+ config_entry = self.hass.config_entries.async_get_entry(
+ self.context["entry_id"]
+ )
+ current_ip = config_entry.data.get("ip_address", "")
+ current_port = config_entry.data.get("port", 8000)
+
+ if user_input is not None:
+ ip_address = user_input.get("ip_address")
+ port = user_input.get("port")
+
+ if ip_address and port:
+ # Update the config_entry with new data
+ self.hass.config_entries.async_update_entry(
+ config_entry, data=user_input
+ )
+ return self.async_abort(reason="reconfigured")
+ errors["base"] = "invalid_input"
+
+ data_schema = vol.Schema(
+ {
+ vol.Required("ip_address", default=current_ip): str,
+ vol.Optional("port", default=current_port): int,
+ }
+ )
+
+ return self.async_show_form(
+ step_id="reconfigure", data_schema=data_schema, errors=errors
+ )

homeassistant/components/iotmeter/const.py

@@ -0,0 +1,3 @@
+"""Constants for the wallbox integration."""
+
+DOMAIN = "iotmeter"

homeassistant/components/iotmeter/coordinator.py

@@ -0,0 +1,152 @@
+"""Module for IoTMeter integration in Home Assistant."""
+
+import asyncio
+from datetime import timedelta
+import logging
+
+import aiohttp
+
+from homeassistant.helpers.translation import async_get_translations
+from homeassistant.helpers.update_coordinator import DataUpdateCoordinator, UpdateFailed
+
+from .const import DOMAIN
+from .number import ChargingCurrentNumber
+from .sensor import (
+ ConsumptionEnergySensor,
+ EvseSensor,
+ GenerationEnergySensor,
+ TotalPowerSensor,
+)
+
+SCAN_INTERVAL = 5
+_LOGGER = logging.getLogger(__name__)
+
+
+async def fetch_data(session, url):
+ """Fetch data from a URL."""
+ async with session.get(url) as response:
+ return await response.json()
+
+
+class IotMeterDataUpdateCoordinator(DataUpdateCoordinator):
+ """Class to manage fetching data from the IotMeter API."""
+
+ def __init__(self, hass, ip_address, port):
+ """Initialize the data update coordinator."""
+ self.ip_address = ip_address
+ self.port = port
+ self.setting_read: bool = False
+ self.async_add_sensor_entities = None
+ self.async_add_number_entities = None
+ self.entities = []
+ self.number_of_evse: int = 0
+ self.is_smartmodul = None
+ super().__init__(
+ hass, _LOGGER, name=DOMAIN, update_interval=timedelta(seconds=SCAN_INTERVAL)
+ )
+
+ def update_ip_port(self, ip_address, port):
+ """Update IP address and port."""
+ self.ip_address = ip_address
+ self.port = port
+
+ async def _async_update_data(self):
+ """Fetch data from API."""
+ try:
+ urls = [
+ f"http://{self.ip_address}:{self.port}/updateSetting",
+ f"http://{self.ip_address}:{self.port}/updateData",
+ ]
+
+ if self.is_smartmodul is not None:
+ if self.is_smartmodul:
+ urls.append(
+ f"http://{self.ip_address}:{self.port}/updateRamSetting"
+ )
+ else:
+ urls.append(f"http://{self.ip_address}:{self.port}/updateEvse")
+
+ async with aiohttp.ClientSession() as session:
+ tasks = [fetch_data(session, url) for url in urls]
+ results = await asyncio.gather(*tasks)
+ data = results[0]
+ data.update(results[1])
+ if self.is_smartmodul is not None:
+ data.update(results[2])
+
+ number_of_evse = data.get("NUMBER_OF_EVSE", 0)
+
+ if "TYPE" in data:
+ if data["TYPE"] == "2":
+ self.is_smartmodul = True
+ elif "inp,EVSE1" in data:
+ self.is_smartmodul = False
+
+ if not self.setting_read or (
+ self.number_of_evse != number_of_evse and self.setting_read
+ ):
+ self.number_of_evse = number_of_evse
+ await self.remove_entities()
+ if self.async_add_sensor_entities:
+ self.setting_read = True
+ await self.add_sensor_entities()
+ if self.async_add_number_entities and self.is_smartmodul:
+ await self.add_number_entities(data["txt,ACTUAL SW VERSION"])
+
+ return data
+
+ except aiohttp.ClientError as err:
+ raise UpdateFailed(f"Error fetching data: {err}") from err
+
+ async def add_sensor_entities(self):
+ """Add sensor entities to Home Assistant."""
+ translations = await async_get_translations(
+ self.hass, self.hass.config.language, "entity"
+ )
+ self.entities = [
+ ConsumptionEnergySensor(
+ self, "Total Consumption Energy", translations, "kWh"
+ ),
+ TotalPowerSensor(self, "Total Power", translations, "kW"),
+ ]
+ if not self.is_smartmodul:
+ self.entities.append(
+ GenerationEnergySensor(
+ self, "Total Generation Energy", translations, "kWh"
+ )
+ )
+ if self.number_of_evse > 0 or self.is_smartmodul:
+ self.entities.append(
+ EvseSensor(
+ self, "Evse", translations, "", smartmodule=self.is_smartmodul
+ )
+ )
+ self.async_add_sensor_entities(self.entities)
+
+ async def add_number_entities(self, fw_version):
+ """Add number entities to Home Assistant."""
+ translations = await async_get_translations(
+ self.hass, self.hass.config.language, "entity"
+ )
+ self.entities = [
+ ChargingCurrentNumber(
+ self,
+ "Charging current",
+ translations,
+ "A",
+ 0,
+ 32,
+ 1,
+ fw_version=fw_version,
+ smartmodule=self.is_smartmodul,
+ )
+ ]
+ self.async_add_number_entities(self.entities)
+
+ async def remove_entities(self):
+ """Remove entities."""
+ if self.entities:
+ _LOGGER.debug("Removing entities: %s", self.entities)
+ for entity in self.entities:
+ await entity.async_remove()
+ self.entities = []

homeassistant/components/iotmeter/manifest.json

@@ -0,0 +1,10 @@
+{
+ "domain": "iotmeter",
+ "name": "IoTMeter",
+ "codeowners": ["@lipic"],
+ "config_flow": true,
+ "dependencies": [],
+ "documentation": "https://www.home-assistant.io/integrations/iotmeter",
+ "iot_class": "local_polling",
+ "requirements": ["aiohttp==3.9.5"]
+}