From 463003fc339cf246416673b522d504ad5fb8e0e9 Mon Sep 17 00:00:00 2001 From: epenet <6771947+epenet@users.noreply.github.com> Date: Mon, 23 Feb 2026 08:28:23 +0100 Subject: [PATCH] Add test for Tuya event (#163812) --- tests/components/tuya/test_event.py | 60 ++++++++++++++++++++++++++++- 1 file changed, 59 insertions(+), 1 deletion(-) diff --git a/tests/components/tuya/test_event.py b/tests/components/tuya/test_event.py index 254f779040d..01b5a4cc4c7 100644 --- a/tests/components/tuya/test_event.py +++ b/tests/components/tuya/test_event.py @@ -5,11 +5,12 @@ from __future__ import annotations import base64 from unittest.mock import patch +from freezegun.api import FrozenDateTimeFactory import pytest from syrupy.assertion import SnapshotAssertion from tuya_sharing import CustomerDevice, Manager -from homeassistant.const import Platform +from homeassistant.const import STATE_UNAVAILABLE, STATE_UNKNOWN, Platform from homeassistant.core import HomeAssistant from homeassistant.helpers import entity_registry as er @@ -83,3 +84,60 @@ async def test_alarm_message_event( state = hass.states.get(entity_id) assert state.attributes == snapshot assert state.attributes["message"] + + +@pytest.mark.parametrize( + "mock_device_code", + ["wxkg_l8yaz4um5b3pwyvf"], +) +@patch("homeassistant.components.tuya.PLATFORMS", [Platform.EVENT]) +@pytest.mark.freeze_time("2024-01-01") +async def test_selective_state_update( + hass: HomeAssistant, + mock_manager: Manager, + mock_config_entry: MockConfigEntry, + mock_device: CustomerDevice, + mock_listener: MockDeviceListener, + freezer: FrozenDateTimeFactory, +) -> None: + """Ensure event is only triggered when device reports actual data.""" + entity_id = "event.bathroom_smart_switch_button_1" + await initialize_entry(hass, mock_manager, mock_config_entry, mock_device) + + # Initial state is unknown + assert hass.states.get(entity_id).state == STATE_UNKNOWN + + # Device receives a data update - event gets triggered and state gets updated + freezer.tick(10) + await mock_listener.async_send_device_update( + hass, mock_device, {"switch_mode1": "click"} + ) + assert hass.states.get(entity_id).state == "2024-01-01T00:00:10.000+00:00" + + # Device goes offline + freezer.tick(10) + mock_device.online = False + await mock_listener.async_send_device_update(hass, mock_device, None) + assert hass.states.get(entity_id).state == STATE_UNAVAILABLE + + # Device comes back online - state should go back to last known value, + # not new datetime since no new data update has come in + freezer.tick(10) + mock_device.online = True + await mock_listener.async_send_device_update(hass, mock_device, None) + assert hass.states.get(entity_id).state == "2024-01-01T00:00:10.000+00:00" + + # Device receives a new data update - event gets triggered and state gets updated + freezer.tick(10) + await mock_listener.async_send_device_update( + hass, mock_device, {"switch_mode1": "click"} + ) + assert hass.states.get(entity_id).state == "2024-01-01T00:00:40.000+00:00" + + # Device receives a data update on a different datapoint - event doesn't + # get triggered and state doesn't get updated + freezer.tick(10) + await mock_listener.async_send_device_update( + hass, mock_device, {"switch_mode2": "click"} + ) + assert hass.states.get(entity_id).state == "2024-01-01T00:00:40.000+00:00"