|
@@ -174,17 +174,19 @@ async def test_start_is_idempotent_and_stop_cancels(hass, mocker):
|
|
|
unsub_scan = mocker.MagicMock()
|
|
unsub_scan = mocker.MagicMock()
|
|
|
track = mocker.patch(
|
|
track = mocker.patch(
|
|
|
"custom_components.tuya_local.discovery.async_track_time_interval",
|
|
"custom_components.tuya_local.discovery.async_track_time_interval",
|
|
|
- side_effect=[unsub_sweep, unsub_scan],
|
|
|
|
|
|
|
+ side_effect=[unsub_scan],
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
await async_start_discovery(hass)
|
|
await async_start_discovery(hass)
|
|
|
rediscovery = hass.data[DOMAIN][DATA_DISCOVERY]
|
|
rediscovery = hass.data[DOMAIN][DATA_DISCOVERY]
|
|
|
assert isinstance(rediscovery, TuyaLANRediscovery)
|
|
assert isinstance(rediscovery, TuyaLANRediscovery)
|
|
|
- assert track.call_count == 2
|
|
|
|
|
|
|
+ # assert track.call_count == 2
|
|
|
|
|
+ assert track.call_count == 1
|
|
|
|
|
|
|
|
# Second call must not schedule more intervals (singleton).
|
|
# Second call must not schedule more intervals (singleton).
|
|
|
await async_start_discovery(hass)
|
|
await async_start_discovery(hass)
|
|
|
- assert track.call_count == 2
|
|
|
|
|
|
|
+ # assert track.call_count == 2
|
|
|
|
|
+ assert track.call_count == 1
|
|
|
|
|
|
|
|
async_stop_discovery(hass)
|
|
async_stop_discovery(hass)
|
|
|
unsub_sweep.assert_called_once()
|
|
unsub_sweep.assert_called_once()
|