kai/aurora_pv_tcp_integration
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update custom_components/aurora_solar/config_flow.py

Browse Source
This commit is contained in:
Kai Osterbrink
2026-03-05 21:30:56 +01:00
parent 16ae7b0bde
commit b7447756ca
1 changed files with 3 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
custom_components/aurora_solar/config_flow.py
View File

@@ -1,27 +1,3 @@
# ALT:
"""class AuroraSolarConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
async def async_step_user(self, user_input=None):
errors = {}
if user_input is not None:
return self.async_create_entry(
title=f"Aurora Wechselrichter {user_input[CONF_SLAVE_ID]}",
data=user_input
)
return self.async_show_form(
step_id="user",
data_schema=vol.Schema({
vol.Required(CONF_HOST): str,
vol.Required(CONF_PORT, default=DEFAULT_PORT): int,
vol.Required(CONF_SLAVE_ID, default=DEFAULT_SLAVE_ID): int,
vol.Required("name"): str,
}),
errors=errors
)
"""
"""Config flow for ABB Aurora Solar Inverter integration.""" """Config flow for ABB Aurora Solar Inverter integration."""
from __future__ import annotations from __future__ import annotations
import logging import logging
@@ -50,12 +26,14 @@ DATA_SCHEMA = vol.Schema(
async def validate_input(hass: HomeAssistant, data: dict[str, Any]) -> dict[str, Any]: async def validate_input(hass: HomeAssistant, data: dict[str, Any]) -> dict[str, Any]:
"""Prüfe, ob die Verbindung zum Wechselrichter möglich ist.""" """Prüfe, ob die Verbindung zum Wechselrichter möglich ist."""
# Hier könntest du eine Verbindungstest-Logik einbauen (z. B. mit `AuroraTCPClient`). # Hier könntest du eine Verbindungstest-Logik einbauen (z. B. mit `AuroraTCPClient`).
# Beispiel: Test, ob der Host erreichbar ist.
# Falls der Test fehlschlägt, wirf eine Exception: # Falls der Test fehlschlägt, wirf eine Exception:
# if not await test_connection(data[CONF_HOST], data[CONF_PORT], data[CONF_SLAVE_ID]): # if not await test_connection(data[CONF_HOST], data[CONF_PORT], data[CONF_SLAVE_ID]):
# raise CannotConnect # raise CannotConnect
return {"title": f"Wechselrichter {data[CONF_SLAVE_ID]}"} return {"title": f"Wechselrichter {data[CONF_SLAVE_ID]}"}
class CannotConnect(HomeAssistantError):
"""Error to indicate we cannot connect to the inverter."""
class AuroraSolarConfigFlow(config_entries.ConfigFlow, domain=DOMAIN): class AuroraSolarConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
"""Handle a config flow for ABB Aurora Solar Inverter.""" """Handle a config flow for ABB Aurora Solar Inverter."""
@@ -71,10 +49,8 @@ class AuroraSolarConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
if user_input is not None: if user_input is not None:
try: try:
info = await validate_input(self.hass, user_input) info = await validate_input(self.hass, user_input)
# Prüfe, ob dieser Wechselrichter bereits konfiguriert ist
await self.async_set_unique_id(f"{user_input[CONF_HOST]}_{user_input[CONF_SLAVE_ID]}") await self.async_set_unique_id(f"{user_input[CONF_HOST]}_{user_input[CONF_SLAVE_ID]}")
self._abort_if_unique_id_configured() self._abort_if_unique_id_configured()
# Erstelle den Config-Entry
return self.async_create_entry(title=info["title"], data=user_input) return self.async_create_entry(title=info["title"], data=user_input)
except CannotConnect: except CannotConnect:
errors["base"] = "cannot_connect" errors["base"] = "cannot_connect"
@@ -121,6 +97,3 @@ class AuroraSolarOptionsFlow(config_entries.OptionsFlow):
} }
), ),
) )
class CannotConnect(HomeAssistantError):
"""Error to indicate we cannot connect to the inverter."""