Merge branch 'dev' into copilot/update-cover-component-triggers

tests/components/bmp581_i2c/common.yaml

@@ -1,5 +1,5 @@
 sensor:
-  - platform: bmp581
+  - platform: bmp581_i2c
     i2c_id: i2c_bus
     temperature:
       name: BMP581 Temperature

tests/components/http_request/test-custom-ca.esp32-idf.yaml

@@ -0,0 +1,7 @@
+substitutions:
+  verify_ssl: "true"
+
+http_request:
+  ca_certificate_path: $component_dir/test_ca.pem
+
+<<: !include common.yaml

tests/components/http_request/test_ca.pem

@@ -0,0 +1,10 @@
+-----BEGIN CERTIFICATE-----
+MIIBkTCB+wIJAKHBfpegPjMCMA0GCSqGSIb3DQEBCwUAMBExDzANBgNVBAMMBnVu
+dXNlZDAeFw0yNDAxMDEwMDAwMDBaFw0yNTAxMDEwMDAwMDBaMBExDzANBgNVBAMM
+BnVudXNlZDBcMA0GCSqGSIb3DQEBAQUAA0sAMEgCQQC5mMUB1hOgLmlnXtsvcGMP
+XkhAqZaR0dDPW5OS8VEopWLJCX9Y0cvNCqiDI8cnP8pP8XJGU1hGLvA5PJzWnWZz
+AgMBAAGjUzBRMB0GA1UdDgQWBBR5oQ9KqFeZOdBuAJrXxEP0dqzPtTAfBgNVHSME
+GDAWgBR5oQ9KqFeZOdBuAJrXxEP0dqzPtTAPBgNVHRMBAf8EBTADAQH/MA0GCSqG
+SIb3DQEBCwUAA0EAKqZFf6+f8FPDbKyPCpssquojgn7fEXqr/I/yz0R5CowGdMms
+H3WH3aKP4lLSHdPTBtfIoJi3gEIZjFxp3S1TWw==
+-----END CERTIFICATE-----

tests/components/lvgl/lvgl-package.yaml

@@ -197,6 +197,9 @@ lvgl:
         - lvgl.label.update:
             id: msgbox_label
             text: Unloaded
+        - lvgl.label.update:
+            id: msgbox_label
+            text: "" # Empty text
       on_all_events:
         logger.log:
           format: "Event %s"

tests/components/sy6970/common.yaml

@@ -0,0 +1,57 @@
+sy6970:
+  id: sy6970_component
+  i2c_id: i2c_bus
+  address: 0x6A
+  enable_status_led: true
+  input_current_limit: 1000
+  charge_voltage: 4200
+  charge_current: 500
+  precharge_current: 128
+  charge_enabled: true
+  enable_adc: true
+  update_interval: 5s
+
+sensor:
+  - platform: sy6970
+    sy6970_id: sy6970_component
+    vbus_voltage:
+      name: "VBUS Voltage"
+      id: vbus_voltage_sensor
+    battery_voltage:
+      name: "Battery Voltage"
+      id: battery_voltage_sensor
+    system_voltage:
+      name: "System Voltage"
+      id: system_voltage_sensor
+    charge_current:
+      name: "Charge Current"
+      id: charge_current_sensor
+    precharge_current:
+      name: "Precharge Current"
+      id: precharge_current_sensor
+
+binary_sensor:
+  - platform: sy6970
+    sy6970_id: sy6970_component
+    vbus_connected:
+      name: "VBUS Connected"
+      id: vbus_connected_binary
+    charging:
+      name: "Charging"
+      id: charging_binary
+    charge_done:
+      name: "Charge Done"
+      id: charge_done_binary
+
+text_sensor:
+  - platform: sy6970
+    sy6970_id: sy6970_component
+    bus_status:
+      name: "Bus Status"
+      id: bus_status_text
+    charge_status:
+      name: "Charge Status"
+      id: charge_status_text
+    ntc_status:
+      name: "NTC Status"
+      id: ntc_status_text

tests/components/sy6970/test.esp32-idf.yaml

@@ -0,0 +1,4 @@
+packages:
+  i2c: !include ../../test_build_components/common/i2c/esp32-idf.yaml
+
+<<: !include common.yaml

tests/components/text_sensor/common.yaml

@@ -64,3 +64,16 @@ text_sensor:
           - suffix -> SUFFIX
       - map:
           - PREFIX text SUFFIX -> mapped
+
+  - platform: template
+    name: "Test Lambda Filter"
+    id: test_lambda_filter
+    filters:
+      - lambda: |-
+          return {"[" + x + "]"};
+      - to_upper
+      - lambda: |-
+          if (x.length() > 10) {
+            return {x.substr(0, 10) + "..."};
+          }
+          return {x};

tests/integration/fixtures/text_sensor_raw_state.yaml

@@ -56,6 +56,36 @@ text_sensor:
       - prepend: "["
       - append: "]"
 
+  - platform: template
+    name: "To Lower Sensor"
+    id: to_lower_sensor
+    filters:
+      - to_lower
+
+  - platform: template
+    name: "Lambda Sensor"
+    id: lambda_sensor
+    filters:
+      - lambda: |-
+          return {"[" + x + "]"};
+
+  - platform: template
+    name: "Lambda Raw State Sensor"
+    id: lambda_raw_state_sensor
+    filters:
+      - lambda: |-
+          return {x + " MODIFIED"};
+
+  - platform: template
+    name: "Lambda Skip Sensor"
+    id: lambda_skip_sensor
+    filters:
+      - lambda: |-
+          if (x == "skip") {
+            return {};
+          }
+          return {x + " passed"};
+
 # Button to publish values and log raw_state vs state
 button:
   - platform: template
@@ -179,3 +209,73 @@ button:
           format: "CHAINED: state='%s'"
           args:
             - id(chained_sensor).state.c_str()
+
+  - platform: template
+    name: "Test To Lower Button"
+    id: test_to_lower_button
+    on_press:
+      - text_sensor.template.publish:
+          id: to_lower_sensor
+          state: "HELLO WORLD"
+      - delay: 50ms
+      - logger.log:
+          format: "TO_LOWER: state='%s'"
+          args:
+            - id(to_lower_sensor).state.c_str()
+
+  - platform: template
+    name: "Test Lambda Button"
+    id: test_lambda_button
+    on_press:
+      - text_sensor.template.publish:
+          id: lambda_sensor
+          state: "test"
+      - delay: 50ms
+      - logger.log:
+          format: "LAMBDA: state='%s'"
+          args:
+            - id(lambda_sensor).state.c_str()
+
+  - platform: template
+    name: "Test Lambda Pass Button"
+    id: test_lambda_pass_button
+    on_press:
+      - text_sensor.template.publish:
+          id: lambda_skip_sensor
+          state: "value"
+      - delay: 50ms
+      - logger.log:
+          format: "LAMBDA_PASS: state='%s'"
+          args:
+            - id(lambda_skip_sensor).state.c_str()
+
+  - platform: template
+    name: "Test Lambda Skip Button"
+    id: test_lambda_skip_button
+    on_press:
+      - text_sensor.template.publish:
+          id: lambda_skip_sensor
+          state: "skip"
+      - delay: 50ms
+      # When lambda returns {}, the value should NOT be published
+      # so state should remain from previous publish (or empty if first)
+      - logger.log:
+          format: "LAMBDA_SKIP: state='%s'"
+          args:
+            - id(lambda_skip_sensor).state.c_str()
+
+  - platform: template
+    name: "Test Lambda Raw State Button"
+    id: test_lambda_raw_state_button
+    on_press:
+      - text_sensor.template.publish:
+          id: lambda_raw_state_sensor
+          state: "original"
+      - delay: 50ms
+      # Verify raw_state is preserved (not mutated) after lambda filter
+      # state should be "original MODIFIED", raw_state should be "original"
+      - logger.log:
+          format: "LAMBDA_RAW_STATE: state='%s' raw_state='%s'"
+          args:
+            - id(lambda_raw_state_sensor).state.c_str()
+            - id(lambda_raw_state_sensor).get_raw_state().c_str()

tests/integration/test_text_sensor_raw_state.py

@@ -42,6 +42,11 @@ async def test_text_sensor_raw_state(
     map_off_future: asyncio.Future[str] = loop.create_future()
     map_unknown_future: asyncio.Future[str] = loop.create_future()
     chained_future: asyncio.Future[str] = loop.create_future()
+    to_lower_future: asyncio.Future[str] = loop.create_future()
+    lambda_future: asyncio.Future[str] = loop.create_future()
+    lambda_pass_future: asyncio.Future[str] = loop.create_future()
+    lambda_skip_future: asyncio.Future[str] = loop.create_future()
+    lambda_raw_state_future: asyncio.Future[tuple[str, str]] = loop.create_future()
 
     # Patterns to match log output
     # NO_FILTER: state='hello world' raw_state='hello world'
@@ -58,6 +63,13 @@ async def test_text_sensor_raw_state(
     map_off_pattern = re.compile(r"MAP_OFF: state='([^']*)'")
     map_unknown_pattern = re.compile(r"MAP_UNKNOWN: state='([^']*)'")
     chained_pattern = re.compile(r"CHAINED: state='([^']*)'")
+    to_lower_pattern = re.compile(r"TO_LOWER: state='([^']*)'")
+    lambda_pattern = re.compile(r"LAMBDA: state='([^']*)'")
+    lambda_pass_pattern = re.compile(r"LAMBDA_PASS: state='([^']*)'")
+    lambda_skip_pattern = re.compile(r"LAMBDA_SKIP: state='([^']*)'")
+    lambda_raw_state_pattern = re.compile(
+        r"LAMBDA_RAW_STATE: state='([^']*)' raw_state='([^']*)'"
+    )
 
     def check_output(line: str) -> None:
         """Check log output for expected messages."""
@@ -92,6 +104,27 @@ async def test_text_sensor_raw_state(
         if not chained_future.done() and (match := chained_pattern.search(line)):
             chained_future.set_result(match.group(1))
 
+        if not to_lower_future.done() and (match := to_lower_pattern.search(line)):
+            to_lower_future.set_result(match.group(1))
+
+        if not lambda_future.done() and (match := lambda_pattern.search(line)):
+            lambda_future.set_result(match.group(1))
+
+        if not lambda_pass_future.done() and (
+            match := lambda_pass_pattern.search(line)
+        ):
+            lambda_pass_future.set_result(match.group(1))
+
+        if not lambda_skip_future.done() and (
+            match := lambda_skip_pattern.search(line)
+        ):
+            lambda_skip_future.set_result(match.group(1))
+
+        if not lambda_raw_state_future.done() and (
+            match := lambda_raw_state_pattern.search(line)
+        ):
+            lambda_raw_state_future.set_result((match.group(1), match.group(2)))
+
     async with (
         run_compiled(yaml_config, line_callback=check_output),
         api_client_connected() as client,
@@ -272,3 +305,111 @@ async def test_text_sensor_raw_state(
             pytest.fail("Timeout waiting for CHAINED log message")
 
         assert state == "[value]", f"Chained failed: expected '[value]', got '{state}'"
+
+        # Test 10: to_lower filter
+        # "HELLO WORLD" -> "hello world"
+        to_lower_button = next(
+            (e for e in entities if "test_to_lower_button" in e.object_id.lower()),
+            None,
+        )
+        assert to_lower_button is not None, "Test To Lower Button not found"
+        client.button_command(to_lower_button.key)
+
+        try:
+            state = await asyncio.wait_for(to_lower_future, timeout=5.0)
+        except TimeoutError:
+            pytest.fail("Timeout waiting for TO_LOWER log message")
+
+        assert state == "hello world", (
+            f"to_lower failed: expected 'hello world', got '{state}'"
+        )
+
+        # Test 11: Lambda filter
+        # "test" -> "[test]"
+        lambda_button = next(
+            (e for e in entities if "test_lambda_button" in e.object_id.lower()),
+            None,
+        )
+        assert lambda_button is not None, "Test Lambda Button not found"
+        client.button_command(lambda_button.key)
+
+        try:
+            state = await asyncio.wait_for(lambda_future, timeout=5.0)
+        except TimeoutError:
+            pytest.fail("Timeout waiting for LAMBDA log message")
+
+        assert state == "[test]", f"Lambda failed: expected '[test]', got '{state}'"
+
+        # Test 12: Lambda filter - value passes through
+        # "value" -> "value passed"
+        lambda_pass_button = next(
+            (e for e in entities if "test_lambda_pass_button" in e.object_id.lower()),
+            None,
+        )
+        assert lambda_pass_button is not None, "Test Lambda Pass Button not found"
+        client.button_command(lambda_pass_button.key)
+
+        try:
+            state = await asyncio.wait_for(lambda_pass_future, timeout=5.0)
+        except TimeoutError:
+            pytest.fail("Timeout waiting for LAMBDA_PASS log message")
+
+        assert state == "value passed", (
+            f"Lambda pass failed: expected 'value passed', got '{state}'"
+        )
+
+        # Test 13: Lambda filter - skip publishing (return {})
+        # "skip" -> no publish, state remains "value passed" from previous test
+        lambda_skip_button = next(
+            (e for e in entities if "test_lambda_skip_button" in e.object_id.lower()),
+            None,
+        )
+        assert lambda_skip_button is not None, "Test Lambda Skip Button not found"
+        client.button_command(lambda_skip_button.key)
+
+        try:
+            state = await asyncio.wait_for(lambda_skip_future, timeout=5.0)
+        except TimeoutError:
+            pytest.fail("Timeout waiting for LAMBDA_SKIP log message")
+
+        # When lambda returns {}, value should NOT be published
+        # State remains from previous successful publish ("value passed")
+        assert state == "value passed", (
+            f"Lambda skip failed: expected 'value passed' (unchanged), got '{state}'"
+        )
+
+        # Test 14: Lambda filter - verify raw_state is preserved (not mutated)
+        # This is critical to verify the in-place mutation optimization is safe
+        # "original" -> state="original MODIFIED", raw_state="original"
+        lambda_raw_state_button = next(
+            (
+                e
+                for e in entities
+                if "test_lambda_raw_state_button" in e.object_id.lower()
+            ),
+            None,
+        )
+        assert lambda_raw_state_button is not None, (
+            "Test Lambda Raw State Button not found"
+        )
+        client.button_command(lambda_raw_state_button.key)
+
+        try:
+            state, raw_state = await asyncio.wait_for(
+                lambda_raw_state_future, timeout=5.0
+            )
+        except TimeoutError:
+            pytest.fail("Timeout waiting for LAMBDA_RAW_STATE log message")
+
+        assert state == "original MODIFIED", (
+            f"Lambda raw_state test failed: expected state='original MODIFIED', "
+            f"got '{state}'"
+        )
+        assert raw_state == "original", (
+            f"Lambda raw_state test failed: raw_state was mutated! "
+            f"Expected 'original', got '{raw_state}'"
+        )
+        assert state != raw_state, (
+            f"Lambda filter should modify state but preserve raw_state. "
+            f"state='{state}', raw_state='{raw_state}'"
+        )

tests/unit_tests/test_espota2.py

@@ -192,6 +192,20 @@ def test_check_error_unexpected_response() -> None:
         espota2.check_error([0x7F], [espota2.RESPONSE_OK, espota2.RESPONSE_AUTH_OK])
 
 
+def test_check_error_empty_data() -> None:
+    """Test check_error raises error when device closes connection without responding."""
+    with pytest.raises(
+        espota2.OTAError, match="Device closed connection without responding"
+    ):
+        espota2.check_error([], [espota2.RESPONSE_OK])
+
+    # Also test with empty bytes
+    with pytest.raises(
+        espota2.OTAError, match="Device closed connection without responding"
+    ):
+        espota2.check_error(b"", [espota2.RESPONSE_OK])
+
+
 def test_send_check_with_various_data_types(mock_socket: Mock) -> None:
     """Test send_check handles different data types."""