ha(H4): сквозной тест repair-пути key_error -> reconfigure -> online

Ручная форма с исправленным lanip_key_id: реальная пробная сессия, reload
записи, исчезновение issue key_mismatch после выхода на связь.
This commit is contained in:
2026-09-29 14:14:19 +03:00
parent 57ee555704
commit dcbf9a6c7e
+53
View File
@@ -49,3 +49,56 @@ async def test_key_error_creates_and_fixes_issue(
assert registry.async_get_issue(DOMAIN, issue_id) is None
await hass.config_entries.async_unload(entry.entry_id)
async def test_reconfigure_fixes_key_error(
hass: HomeAssistant, mock_ac, socket_enabled
):
"""Repair-путь целиком: bad key_id → issue → reconfigure → online → issue снят."""
from homeassistant.config_entries import SOURCE_RECONFIGURE
from test_config_flow import MANUAL_INPUT, PREVIEW_INPUT
proc = mock_ac(
["--set", "operation_mode=6"], key_id=KEY_ID + 1
)
entry = await _setup_entry(hass, proc.port)
runtime = entry.runtime_data
await _wait_for(lambda: runtime.client.state == State.KEY_ERROR)
registry = ir.async_get(hass)
issue_id = f"key_mismatch_{DSN}"
assert registry.async_get_issue(DOMAIN, issue_id) is not None
# Mock помнит только один app_addr; останавливаем «залипшую» сессию,
# чтобы пробная сессия config flow получила KE (штатно это делает reload).
await runtime.client.async_stop()
result = await hass.config_entries.flow.async_init(
DOMAIN,
context={"source": SOURCE_RECONFIGURE, "entry_id": entry.entry_id},
)
result = await hass.config_entries.flow.async_configure(
result["flow_id"], {"next_step_id": "manual"}
)
result = await hass.config_entries.flow.async_configure(
result["flow_id"],
{
**MANUAL_INPUT,
"host": "127.0.0.1",
"device_port": proc.port,
"lanip_key_id": KEY_ID + 1,
},
)
assert result["step_id"] == "preview", result.get("errors")
result = await hass.config_entries.flow.async_configure(
result["flow_id"], PREVIEW_INPUT
)
assert result["type"] == "abort"
assert result["reason"] == "reconfigure_successful"
await hass.async_block_till_done()
runtime = entry.runtime_data
await _wait_for(lambda: runtime.client.state == State.ONLINE)
assert registry.async_get_issue(DOMAIN, issue_id) is None
assert entry.data["lanip_key_id"] == KEY_ID + 1
assert await hass.config_entries.async_unload(entry.entry_id)