"""Test for Roborock init."""

import asyncio
import datetime
import pathlib
from typing import Any
from unittest.mock import AsyncMock, patch

from freezegun.api import FrozenDateTimeFactory
import pytest
from roborock import (
    RoborockInvalidCredentials,
    RoborockInvalidUserAgreement,
    RoborockNoUserAgreement,
)
from roborock.exceptions import RoborockException
from roborock.mqtt.session import MqttSessionUnauthorized

from homeassistant.components.homeassistant import (
    DOMAIN as HA_DOMAIN,
    SERVICE_UPDATE_ENTITY,
)
from homeassistant.components.roborock.const import DOMAIN
from homeassistant.config_entries import ConfigEntryState
from homeassistant.const import ATTR_ENTITY_ID, Platform
from homeassistant.core import HomeAssistant
from homeassistant.helpers import (
    device_registry as dr,
    entity_registry as er,
    issue_registry as ir,
)
from homeassistant.helpers.device_registry import DeviceRegistry
from homeassistant.helpers.entity_registry import EntityRegistry
from homeassistant.setup import async_setup_component

from .conftest import FakeDevice, MockDeviceManagerContext
from .mock_data import ROBOROCK_RRUID, USER_EMAIL

from tests.common import MockConfigEntry, async_fire_time_changed
from tests.typing import ClientSessionGenerator


async def test_unload_entry(
    hass: HomeAssistant,
    setup_entry: MockConfigEntry,
    device_manager: AsyncMock,
) -> None:
    """Test unloading roborock integration."""
    assert len(hass.config_entries.async_entries(DOMAIN)) == 1
    assert setup_entry.state is ConfigEntryState.LOADED

    assert not device_manager.close.called

    # Unload the config entry and verify that the device manager is closed
    assert await hass.config_entries.async_unload(setup_entry.entry_id)
    await hass.async_block_till_done()
    assert setup_entry.state is ConfigEntryState.NOT_LOADED

    assert device_manager.close.called


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_stale_device(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_registry: DeviceRegistry,
    device_manager: AsyncMock,
    device_manager_context: MockDeviceManagerContext,
    fake_devices: list[FakeDevice],
) -> None:
    """Test that we remove a device if it no longer is given by home_data."""
    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    if mock_roborock_entry._background_tasks:
        await asyncio.gather(*mock_roborock_entry._background_tasks)
    existing_devices = device_registry.devices.get_devices_for_config_entry_id(
        mock_roborock_entry.entry_id
    )
    assert {device.name for device in existing_devices} == {
        "Roborock S7 MaxV",
        "Roborock S7 MaxV Dock",
        "Roborock S7 2",
        "Roborock S7 2 Dock",
        "Dyad Pro",
        "Zeo One",
        "Roborock Q7",
        "Roborock Q10 S5+",
    }
    fake_devices_copy = fake_devices.copy()
    fake_devices_copy.pop(0)  # Remove one robot
    device_manager.get_devices = AsyncMock(return_value=fake_devices_copy)
    device_manager_context.initial_devices = fake_devices_copy

    await hass.config_entries.async_reload(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    if mock_roborock_entry._background_tasks:
        await asyncio.gather(*mock_roborock_entry._background_tasks)
    new_devices = device_registry.devices.get_devices_for_config_entry_id(
        mock_roborock_entry.entry_id
    )
    assert {device.name for device in new_devices} == {
        "Roborock S7 2",
        "Roborock S7 2 Dock",
        "Dyad Pro",
        "Zeo One",
        "Roborock Q7",
        "Roborock Q10 S5+",
    }


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_no_stale_device(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_registry: DeviceRegistry,
    fake_devices: list[FakeDevice],
) -> None:
    """Test that we don't remove a device if fails to setup."""
    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    if mock_roborock_entry._background_tasks:
        await asyncio.gather(*mock_roborock_entry._background_tasks)
    existing_devices = device_registry.devices.get_devices_for_config_entry_id(
        mock_roborock_entry.entry_id
    )
    assert {device.name for device in existing_devices} == {
        "Roborock S7 MaxV",
        "Roborock S7 MaxV Dock",
        "Roborock S7 2",
        "Roborock S7 2 Dock",
        "Dyad Pro",
        "Zeo One",
        "Roborock Q7",
        "Roborock Q10 S5+",
    }

    await hass.config_entries.async_reload(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    if mock_roborock_entry._background_tasks:
        await asyncio.gather(*mock_roborock_entry._background_tasks)
    new_devices = device_registry.devices.get_devices_for_config_entry_id(
        mock_roborock_entry.entry_id
    )
    assert {device.name for device in new_devices} == {
        "Roborock S7 MaxV",
        "Roborock S7 MaxV Dock",
        "Roborock S7 2",
        "Roborock S7 2 Dock",
        "Dyad Pro",
        "Zeo One",
        "Roborock Q7",
        "Roborock Q10 S5+",
    }


async def test_home_assistant_stop(
    hass: HomeAssistant,
    setup_entry: MockConfigEntry,
    device_manager: AsyncMock,
) -> None:
    """Test shutting down Home Assistant."""
    assert len(hass.config_entries.async_entries(DOMAIN)) == 1
    assert setup_entry.state is ConfigEntryState.LOADED

    assert not device_manager.close.called

    # Perform Home Assistant stop and verify that device manager is closed
    await hass.async_stop()

    assert device_manager.close.called


@pytest.mark.parametrize(
    "side_effect", [RoborockInvalidCredentials(), MqttSessionUnauthorized()]
)
async def test_reauth_started(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    side_effect: Exception,
) -> None:
    """Test reauth flow started."""
    with patch(
        "homeassistant.components.roborock.create_device_manager",
        side_effect=side_effect,
    ):
        await async_setup_component(hass, DOMAIN, {})
        await hass.async_block_till_done()
        assert mock_roborock_entry.state is ConfigEntryState.SETUP_ERROR
    flows = hass.config_entries.flow.async_progress()
    assert len(flows) == 1
    assert flows[0]["step_id"] == "reauth_confirm"


async def test_mqtt_session_unauthorized_hook_called(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_manager: AsyncMock,
) -> None:
    """Test that the mqtt session unauthorized hook is called on unauthorized event."""
    device_manager_kwargs = {}

    def create_device_manager(*args: Any, **kwargs: Any) -> AsyncMock:
        nonlocal device_manager_kwargs
        device_manager_kwargs = kwargs
        return device_manager

    with patch(
        "homeassistant.components.roborock.create_device_manager",
        side_effect=create_device_manager,
    ):
        await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
        await hass.async_block_till_done()
        assert mock_roborock_entry.state is ConfigEntryState.LOADED

    flows = hass.config_entries.flow.async_progress()
    assert not flows

    # Simulate an unauthorized event by calling the captured hook
    assert device_manager_kwargs
    mqtt_session_unauthorized_hook = device_manager_kwargs.get(
        "mqtt_session_unauthorized_hook"
    )
    assert mqtt_session_unauthorized_hook
    mqtt_session_unauthorized_hook()

    # Verify that reauth flow is started
    flows = hass.config_entries.flow.async_progress()
    assert len(flows) == 1
    assert flows[0]["step_id"] == "reauth_confirm"


@pytest.mark.parametrize("platforms", [[Platform.IMAGE]])
@pytest.mark.parametrize(
    ("exists", "is_dir", "rmtree_called"),
    [
        (True, True, True),
        (False, False, False),
        (True, False, False),
    ],
    ids=[
        "old_storage_removed",
        "new_storage_ignored",
        "no_existing_storage",
    ],
)
async def test_remove_old_storage_directory(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    storage_path: pathlib.Path,
    hass_client: ClientSessionGenerator,
    caplog: pytest.LogCaptureFixture,
    exists: bool,
    is_dir: bool,
    rmtree_called: bool,
) -> None:
    """Test cleanup of old old map storage."""
    with (
        patch(
            "homeassistant.components.roborock.roborock_storage.Path.exists",
            return_value=exists,
        ),
        patch(
            "homeassistant.components.roborock.roborock_storage.Path.is_dir",
            return_value=is_dir,
        ),
        patch(
            "homeassistant.components.roborock.roborock_storage.shutil.rmtree",
        ) as mock_rmtree,
    ):
        await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
        await hass.async_block_till_done()
        assert mock_roborock_entry.state is ConfigEntryState.LOADED

    assert mock_rmtree.called == rmtree_called


@pytest.mark.parametrize("platforms", [[Platform.IMAGE]])
async def test_oserror_remove_storage_directory(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    storage_path: pathlib.Path,
    hass_client: ClientSessionGenerator,
    caplog: pytest.LogCaptureFixture,
) -> None:
    """Test that we gracefully handle failing to remove old map storage."""
    with (
        patch(
            "homeassistant.components.roborock.roborock_storage.Path.exists",
            return_value=True,
        ),
        patch(
            "homeassistant.components.roborock.roborock_storage.Path.is_dir",
            return_value=True,
        ),
        patch(
            "homeassistant.components.roborock.roborock_storage.shutil.rmtree",
            side_effect=OSError,
        ) as mock_rmtree,
    ):
        await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
        await hass.async_block_till_done()
        assert mock_roborock_entry.state is ConfigEntryState.LOADED

    assert mock_rmtree.called
    assert "Unable to remove map files" in caplog.text


async def test_not_supported_protocol(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    caplog: pytest.LogCaptureFixture,
    fake_devices: list[FakeDevice],
) -> None:
    """Test that we output a message on incorrect protocol."""
    fake_devices[0].v1_properties = None
    fake_devices[0].zeo = None
    fake_devices[0].dyad = None
    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    assert "because its protocol version " in caplog.text


async def test_invalid_user_agreement(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
) -> None:
    """Test that we fail setting up if the user agreement is out of date."""
    with patch(
        "homeassistant.components.roborock.create_device_manager",
        side_effect=RoborockInvalidUserAgreement(),
    ):
        await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
        assert mock_roborock_entry.state is ConfigEntryState.SETUP_RETRY
        assert (
            mock_roborock_entry.error_reason_translation_key == "invalid_user_agreement"
        )


async def test_no_user_agreement(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
) -> None:
    """Test that we fail setting up if the user has no agreement."""
    with patch(
        "homeassistant.components.roborock.create_device_manager",
        side_effect=RoborockNoUserAgreement(),
    ):
        await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
        assert mock_roborock_entry.state is ConfigEntryState.SETUP_RETRY
        assert mock_roborock_entry.error_reason_translation_key == "no_user_agreement"


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_migrate_config_entry_unique_id(
    hass: HomeAssistant,
    config_entry_data: dict[str, Any],
) -> None:
    """Test migrating the config entry unique id."""
    config_entry = MockConfigEntry(
        domain=DOMAIN,
        unique_id=USER_EMAIL,
        data=config_entry_data,
        version=1,
        minor_version=1,
    )
    config_entry.add_to_hass(hass)
    await hass.config_entries.async_setup(config_entry.entry_id)
    await hass.async_block_till_done()

    assert len(hass.config_entries.async_entries(DOMAIN)) == 1
    assert config_entry.state is ConfigEntryState.LOADED
    assert config_entry.unique_id == ROBOROCK_RRUID


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_update_unavailability_threshold(
    hass: HomeAssistant,
    freezer: FrozenDateTimeFactory,
    setup_entry: MockConfigEntry,
    fake_vacuum: FakeDevice,
) -> None:
    """Test update failures are suppressed before marking unavailable."""
    await async_setup_component(hass, HA_DOMAIN, {})
    assert setup_entry.state is ConfigEntryState.LOADED

    # We pick an arbitrary sensor to test for availability
    sensor_entity_id = "sensor.roborock_s7_maxv_battery"
    expected_state = "100"
    state = hass.states.get(sensor_entity_id)
    assert state is not None
    assert state.state == expected_state

    # Simulate a few update failures below the threshold
    assert fake_vacuum.v1_properties is not None
    fake_vacuum.v1_properties.status.refresh.side_effect = RoborockException(
        "Simulated update failure"
    )

    # Move forward in time less than the threshold
    freezer.tick(datetime.timedelta(seconds=90))
    async_fire_time_changed(hass)
    await hass.async_block_till_done()

    # Force a coordinator refresh.
    await hass.services.async_call(
        HA_DOMAIN,
        SERVICE_UPDATE_ENTITY,
        {ATTR_ENTITY_ID: sensor_entity_id},
        blocking=True,
    )
    await hass.async_block_till_done()

    # Verify that the entity is still available
    state = hass.states.get(sensor_entity_id)
    assert state is not None
    assert state.state == expected_state

    # Move forward in time to exceed the threshold
    freezer.tick(datetime.timedelta(minutes=3))
    async_fire_time_changed(hass)
    await hass.async_block_till_done()

    # Verify that the entity is now unavailable
    state = hass.states.get(sensor_entity_id)
    assert state is not None
    assert state.state == "unavailable"

    # Now restore normal update behavior and refresh.
    fake_vacuum.v1_properties.status.refresh.side_effect = None

    freezer.tick(datetime.timedelta(seconds=45))
    async_fire_time_changed(hass)
    await hass.async_block_till_done()

    # Verify that the entity recovers and is available again
    state = hass.states.get(sensor_entity_id)
    assert state is not None
    assert state.state == expected_state


async def test_cloud_api_repair(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    fake_vacuum: FakeDevice,
) -> None:
    """Test that a repair is created when we use the cloud api."""

    # Fake that the device is only reachable via cloud
    fake_vacuum.is_connected = True
    fake_vacuum.is_local_connected = False

    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()

    issue_registry = ir.async_get(hass)
    assert len(issue_registry.issues) == 1
    # Check that both expected device names are present, regardless of order
    assert all(
        issue.translation_key == "cloud_api_used"
        for issue in issue_registry.issues.values()
    )
    names = {
        issue.translation_placeholders["device_name"]
        for issue in issue_registry.issues.values()
    }
    assert names == {"Roborock S7 MaxV"}
    await hass.config_entries.async_unload(mock_roborock_entry.entry_id)

    # Now fake that the device is reachable locally again
    fake_vacuum.is_local_connected = True

    # Set it back up
    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()

    assert len(issue_registry.issues) == 0


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_cloud_api_repair_cleared_on_update(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    fake_vacuum: FakeDevice,
    freezer: FrozenDateTimeFactory,
) -> None:
    """Test repair is created then cleared when device is local again."""

    # Fake that the device is only reachable via cloud
    fake_vacuum.is_connected = True
    fake_vacuum.is_local_connected = False

    # Load the integration and verify that a repair issue is created
    await async_setup_component(hass, HA_DOMAIN, {})
    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    assert mock_roborock_entry.state is ConfigEntryState.LOADED

    issue_registry = ir.async_get(hass)
    assert len(issue_registry.issues) == 1

    # Fake that the device is reachable locally again.
    fake_vacuum.is_local_connected = True

    # Refresh the coordinator using an arbitrary sensor, which should
    # clear the repair issue.
    sensor_entity_id = "sensor.roborock_s7_maxv_battery"
    await hass.services.async_call(
        HA_DOMAIN,
        SERVICE_UPDATE_ENTITY,
        {ATTR_ENTITY_ID: sensor_entity_id},
        blocking=True,
    )
    await hass.async_block_till_done()

    # Verify that the repair issue is cleared
    issue_registry = ir.async_get(hass)
    assert len(issue_registry.issues) == 0

    # Fake the device is cloud only again. Refreshing the coordinator
    # should not recreate the repair issue.
    fake_vacuum.is_local_connected = False

    await hass.services.async_call(
        HA_DOMAIN,
        SERVICE_UPDATE_ENTITY,
        {ATTR_ENTITY_ID: sensor_entity_id},
        blocking=True,
    )
    await hass.async_block_till_done()

    # Verify that the repair issue still does not exist
    issue_registry = ir.async_get(hass)
    assert len(issue_registry.issues) == 0


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_zeo_device_fails_setup(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_registry: DeviceRegistry,
    entity_registry: EntityRegistry,
    fake_devices: list[FakeDevice],
) -> None:
    """Simulate an error while setting up a zeo device."""
    # We have a single zeo device in the test setup. Find it then set it to fail.
    zeo_device = next(
        (device for device in fake_devices if device.zeo is not None),
        None,
    )
    assert zeo_device is not None
    zeo_device.zeo.query_values.side_effect = RoborockException("Simulated Zeo failure")

    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    if mock_roborock_entry._background_tasks:
        await asyncio.gather(*mock_roborock_entry._background_tasks)
    assert mock_roborock_entry.state is ConfigEntryState.LOADED

    # The Zeo device should be in the registry and have entities
    # because entities are registered immediately without blocking on coordinator refresh.
    zeo_device_entry = device_registry.async_get_device(
        identifiers={(DOMAIN, zeo_device.duid)}
    )
    assert zeo_device_entry is not None
    zeo_entities = er.async_entries_for_device(
        entity_registry, zeo_device_entry.id, include_disabled_entities=True
    )
    assert len(zeo_entities) > 0
    state = hass.states.get(zeo_entities[0].entity_id)
    assert state is not None
    assert state.state == "unavailable"

    # Other devices should have entities.
    all_entities = er.async_entries_for_config_entry(
        entity_registry, mock_roborock_entry.entry_id
    )
    devices_with_entities = {
        device_registry.async_get(entity.device_id).name
        for entity in all_entities
        if entity.device_id is not None
    }
    assert devices_with_entities == {
        "Roborock S7 MaxV",
        "Roborock S7 MaxV Dock",
        "Roborock S7 2",
        "Roborock S7 2 Dock",
        "Dyad Pro",
        "Roborock Q7",
        "Roborock Q10 S5+",
        "Zeo One",
    }


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_dyad_device_fails_setup(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_registry: DeviceRegistry,
    entity_registry: EntityRegistry,
    fake_devices: list[FakeDevice],
) -> None:
    """Simulate an error while setting up a dyad device."""
    # We have a single dyad device in the test setup. Find it then set it to fail.
    dyad_device = next(
        (device for device in fake_devices if device.dyad is not None),
        None,
    )
    assert dyad_device is not None
    dyad_device.dyad.query_values.side_effect = RoborockException(
        "Simulated Dyad failure"
    )

    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    if mock_roborock_entry._background_tasks:
        await asyncio.gather(*mock_roborock_entry._background_tasks)
    assert mock_roborock_entry.state is ConfigEntryState.LOADED

    # The Dyad device should be in the registry and have entities
    # because entities are registered immediately without blocking on coordinator refresh.
    dyad_device_entry = device_registry.async_get_device(
        identifiers={(DOMAIN, dyad_device.duid)}
    )
    assert dyad_device_entry is not None
    dyad_entities = er.async_entries_for_device(
        entity_registry, dyad_device_entry.id, include_disabled_entities=True
    )
    assert len(dyad_entities) > 0
    state = hass.states.get(dyad_entities[0].entity_id)
    assert state is not None
    assert state.state == "unavailable"

    # Other devices should have entities.
    all_entities = er.async_entries_for_config_entry(
        entity_registry, mock_roborock_entry.entry_id
    )
    devices_with_entities = {
        device_registry.async_get(entity.device_id).name
        for entity in all_entities
        if entity.device_id is not None
    }
    assert devices_with_entities == {
        "Roborock S7 MaxV",
        "Roborock S7 MaxV Dock",
        "Roborock S7 2",
        "Roborock S7 2 Dock",
        "Dyad Pro",
        "Zeo One",
        "Roborock Q7",
        "Roborock Q10 S5+",
    }


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_disabled_device_no_coordinator(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_registry: DeviceRegistry,
    fake_devices: list[FakeDevice],
) -> None:
    """Test that a disabled device has close() called and no coordinator is created."""
    # Pre-create the first device as disabled so that async_get_or_create
    # finds it already disabled when async_setup_entry runs.
    first_device = fake_devices[0]
    device_registry.async_get_or_create(
        config_entry_id=mock_roborock_entry.entry_id,
        identifiers={(DOMAIN, first_device.duid)},
        name=first_device.device_info.name,
        manufacturer="Roborock",
        disabled_by=dr.DeviceEntryDisabler.USER,
    )

    first_device.close = AsyncMock()
    # Track close() calls on enabled devices to verify they are NOT closed.
    for device in fake_devices[1:]:
        device.close = AsyncMock()

    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()
    assert mock_roborock_entry.state is ConfigEntryState.LOADED

    # The disabled device should still be registered in the device registry
    disabled_device_entry = device_registry.async_get_device(
        identifiers={(DOMAIN, first_device.duid)}
    )
    assert disabled_device_entry is not None
    assert disabled_device_entry.disabled

    # close() should have been called on the disabled device to stop its
    # background reconnect loop from disrupting the MQTT session.
    first_device.close.assert_awaited_once()

    # close() should NOT have been called on enabled devices.
    for device in fake_devices[1:]:
        device.close.assert_not_called()

    # No coordinator should have been created for the disabled device,
    # so no entities should exist for it.
    coordinators = mock_roborock_entry.runtime_data
    assert all(coord.duid != first_device.duid for coord in coordinators.v1)

    # Other devices should still be set up
    found_devices = device_registry.devices.get_devices_for_config_entry_id(
        mock_roborock_entry.entry_id
    )
    enabled_device_names = {
        device.name for device in found_devices if not device.disabled
    }
    assert "Roborock S7 MaxV" not in enabled_device_names
    assert "Roborock S7 2" in enabled_device_names


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_disabled_device_close_raises(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_registry: DeviceRegistry,
    fake_devices: list[FakeDevice],
) -> None:
    """Test that the integration loads even if close() raises on a disabled device."""
    first_device = fake_devices[0]
    device_registry.async_get_or_create(
        config_entry_id=mock_roborock_entry.entry_id,
        identifiers={(DOMAIN, first_device.duid)},
        name=first_device.device_info.name,
        manufacturer="Roborock",
        disabled_by=dr.DeviceEntryDisabler.USER,
    )

    first_device.close = AsyncMock(side_effect=RoborockException("connection error"))

    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()

    assert mock_roborock_entry.state is ConfigEntryState.LOADED
    first_device.close.assert_awaited_once()


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_all_devices_disabled(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_registry: DeviceRegistry,
    entity_registry: EntityRegistry,
    fake_devices: list[FakeDevice],
) -> None:
    """Test that the integration loads successfully when all devices are disabled."""
    # Pre-create all devices as disabled
    for fake_device in fake_devices:
        device_registry.async_get_or_create(
            config_entry_id=mock_roborock_entry.entry_id,
            identifiers={(DOMAIN, fake_device.duid)},
            name=fake_device.device_info.name,
            manufacturer="Roborock",
            disabled_by=dr.DeviceEntryDisabler.USER,
        )

    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()

    # The integration should still load successfully
    assert mock_roborock_entry.state is ConfigEntryState.LOADED

    # No entities should exist since all devices are disabled
    all_entities = er.async_entries_for_config_entry(
        entity_registry, mock_roborock_entry.entry_id
    )
    assert len(all_entities) == 0

    # All devices should still exist in the registry but be disabled
    for fake_device in fake_devices:
        device_entry = device_registry.async_get_device(
            identifiers={(DOMAIN, fake_device.duid)}
        )
        assert device_entry is not None
        assert device_entry.disabled


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_v1_streaming_updates(
    hass: HomeAssistant,
    setup_entry: MockConfigEntry,
    fake_vacuum: FakeDevice,
) -> None:
    """Test that V1 push updates update entity states immediately."""
    assert setup_entry.state is ConfigEntryState.LOADED
    if setup_entry._background_tasks:
        await asyncio.gather(*setup_entry._background_tasks)
    sensor_entity_id = "sensor.roborock_s7_maxv_battery"
    state = hass.states.get(sensor_entity_id)
    assert state is not None
    assert state.state == "100"

    # Verify that add_update_listener was called on the mock status trait
    status_trait = fake_vacuum.v1_properties.status
    assert status_trait.add_update_listener.called

    # Get the registered callback
    callback_func = status_trait.add_update_listener.call_args[0][0]  # type: ignore[union-attr]

    # Update a status attribute and trigger the callback
    status_trait.battery = 85
    callback_func()
    await hass.async_block_till_done()

    # Check if the state was updated in Home Assistant immediately
    state = hass.states.get(sensor_entity_id)
    assert state is not None
    assert state.state == "85"


@pytest.mark.parametrize("platforms", [[Platform.SENSOR]])
async def test_dynamic_device_discovery(
    hass: HomeAssistant,
    mock_roborock_entry: MockConfigEntry,
    device_manager: AsyncMock,
    device_manager_context: MockDeviceManagerContext,
    fake_devices: list[FakeDevice],
) -> None:
    """Test dynamic device discovery and coordinator/entity setup."""
    # Start with only the first device in the list
    initial_device = fake_devices[0]
    device_manager_context.initial_devices = [initial_device]

    # Set up the integration with the initial device
    await hass.config_entries.async_setup(mock_roborock_entry.entry_id)
    await hass.async_block_till_done()

    assert mock_roborock_entry.state is ConfigEntryState.LOADED

    # Verify that the sensor for the first device is created
    sensor_entity_id_1 = "sensor.roborock_s7_maxv_battery"
    state_1 = hass.states.get(sensor_entity_id_1)
    assert state_1 is not None
    assert state_1.state == "100"

    # Verify that the sensor for the second device is NOT created
    sensor_entity_id_2 = "sensor.roborock_s7_2_battery"
    state_2 = hass.states.get(sensor_entity_id_2)
    assert state_2 is None

    # Now simulate the second device becoming ready via ready_callback
    second_device = fake_devices[1]
    assert device_manager_context.ready_callback is not None
    device_manager_context.ready_callback(second_device)
    await hass.async_block_till_done()

    # Verify that the sensor for the second device has now been dynamically registered and created
    state_2 = hass.states.get(sensor_entity_id_2)
    assert state_2 is not None
    assert state_2.state == "100"