Bump version to 2024.8.0b1

Update frontend to 20240802.0 (#123072 )
Do not raise repair issue about missing integration in safe mode (#123066 )
2025-09-19 18:09:48 +00:00 · 2024-08-02 17:46:01 +02:00 · 2024-08-02 17:45:50 +02:00 · 2024-08-02 17:45:47 +02:00 · 2024-08-02 17:45:43 +02:00 · 2024-08-02 17:45:39 +02:00
1643 changed files with 80156 additions and 18357 deletions
--- a/.github/workflows/builder.yml
+++ b/.github/workflows/builder.yml
@@ -190,7 +190,7 @@ jobs:
          echo "${{ github.sha }};${{ github.ref }};${{ github.event_name }};${{ github.actor }}" > rootfs/OFFICIAL_IMAGE

      - name: Login to GitHub Container Registry
-        uses: docker/login-action@v3.2.0
+        uses: docker/login-action@v3.3.0
        with:
          registry: ghcr.io
          username: ${{ github.repository_owner }}
@@ -256,7 +256,7 @@ jobs:
          fi

      - name: Login to GitHub Container Registry
-        uses: docker/login-action@v3.2.0
+        uses: docker/login-action@v3.3.0
        with:
          registry: ghcr.io
          username: ${{ github.repository_owner }}
@@ -329,14 +329,14 @@ jobs:

      - name: Login to DockerHub
        if: matrix.registry == 'docker.io/homeassistant'
-        uses: docker/login-action@v3.2.0
+        uses: docker/login-action@v3.3.0
        with:
          username: ${{ secrets.DOCKERHUB_USERNAME }}
          password: ${{ secrets.DOCKERHUB_TOKEN }}

      - name: Login to GitHub Container Registry
        if: matrix.registry == 'ghcr.io/home-assistant'
-        uses: docker/login-action@v3.2.0
+        uses: docker/login-action@v3.3.0
        with:
          registry: ghcr.io
          username: ${{ github.repository_owner }}
--- a/.github/workflows/ci.yaml
+++ b/.github/workflows/ci.yaml
@@ -86,7 +86,7 @@ jobs:
      tests_glob: ${{ steps.info.outputs.tests_glob }}
      tests: ${{ steps.info.outputs.tests }}
      skip_coverage: ${{ steps.info.outputs.skip_coverage }}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    steps:
      - name: Check out code from GitHub
        uses: actions/checkout@v4.1.7
@@ -218,7 +218,7 @@ jobs:

  pre-commit:
    name: Prepare pre-commit base
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    if: |
      github.event.inputs.pylint-only != 'true'
      && github.event.inputs.mypy-only != 'true'
@@ -266,7 +266,7 @@ jobs:

  lint-ruff-format:
    name: Check ruff-format
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    needs:
      - info
      - pre-commit
@@ -306,7 +306,7 @@ jobs:

  lint-ruff:
    name: Check ruff
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    needs:
      - info
      - pre-commit
@@ -345,7 +345,7 @@ jobs:
          RUFF_OUTPUT_FORMAT: github
  lint-other:
    name: Check other linters
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    needs:
      - info
      - pre-commit
@@ -437,7 +437,7 @@ jobs:

  base:
    name: Prepare dependencies
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    needs: info
    timeout-minutes: 60
    strategy:
@@ -514,7 +514,7 @@ jobs:

  hassfest:
    name: Check hassfest
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    if: |
      github.event.inputs.pylint-only != 'true'
      && github.event.inputs.mypy-only != 'true'
@@ -552,7 +552,7 @@ jobs:

  gen-requirements-all:
    name: Check all requirements
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    if: |
      github.event.inputs.pylint-only != 'true'
      && github.event.inputs.mypy-only != 'true'
@@ -584,7 +584,7 @@ jobs:

  audit-licenses:
    name: Audit licenses
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    needs:
      - info
      - base
@@ -624,7 +624,7 @@ jobs:

  pylint:
    name: Check pylint
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    timeout-minutes: 20
    if: |
      github.event.inputs.mypy-only != 'true'
@@ -669,7 +669,7 @@ jobs:

  pylint-tests:
    name: Check pylint on tests
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    timeout-minutes: 20
    if: |
      (github.event.inputs.mypy-only != 'true' || github.event.inputs.pylint-only == 'true')
@@ -714,7 +714,7 @@ jobs:

  mypy:
    name: Check mypy
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    if: |
      github.event.inputs.pylint-only != 'true'
      || github.event.inputs.mypy-only == 'true'
@@ -775,7 +775,7 @@ jobs:
          mypy homeassistant/components/${{ needs.info.outputs.integrations_glob }}

  prepare-pytest-full:
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    if: |
      (github.event_name != 'push' || github.event.repository.full_name == 'home-assistant/core')
      && github.event.inputs.lint-only != 'true'
@@ -825,7 +825,7 @@ jobs:
          overwrite: true

  pytest-full:
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    if: |
      (github.event_name != 'push' || github.event.repository.full_name == 'home-assistant/core')
      && github.event.inputs.lint-only != 'true'
@@ -904,6 +904,7 @@ jobs:
            cov_params+=(--cov-report=xml)
          fi

+          echo "Test group ${{ matrix.group }}: $(sed -n "${{ matrix.group }},1p" pytest_buckets.txt)"
          python3 -b -X dev -m pytest \
            -qq \
            --timeout=9 \
@@ -936,7 +937,7 @@ jobs:
          ./script/check_dirty

  pytest-mariadb:
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    services:
      mariadb:
        image: ${{ matrix.mariadb-group }}
@@ -1189,7 +1190,7 @@ jobs:
  coverage-full:
    name: Upload test coverage to Codecov (full suite)
    if: needs.info.outputs.skip_coverage != 'true'
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    needs:
      - info
      - pytest-full
@@ -1213,7 +1214,7 @@ jobs:
          version: v0.6.0

  pytest-partial:
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    if: |
      (github.event_name != 'push' || github.event.repository.full_name == 'home-assistant/core')
      && github.event.inputs.lint-only != 'true'
@@ -1328,7 +1329,7 @@ jobs:
  coverage-partial:
    name: Upload test coverage to Codecov (partial suite)
    if: needs.info.outputs.skip_coverage != 'true'
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
    needs:
      - info
      - pytest-partial
--- a/.github/workflows/codeql.yml
+++ b/.github/workflows/codeql.yml
@@ -24,11 +24,11 @@ jobs:
        uses: actions/checkout@v4.1.7

      - name: Initialize CodeQL
-        uses: github/codeql-action/init@v3.25.12
+        uses: github/codeql-action/init@v3.25.15
        with:
          languages: python

      - name: Perform CodeQL Analysis
-        uses: github/codeql-action/analyze@v3.25.12
+        uses: github/codeql-action/analyze@v3.25.15
        with:
          category: "/language:python"
--- a/.pre-commit-config.yaml
+++ b/.pre-commit-config.yaml
@@ -1,6 +1,6 @@
 repos:
  - repo: https://github.com/astral-sh/ruff-pre-commit
-    rev: v0.5.2
+    rev: v0.5.5
    hooks:
      - id: ruff
        args:
--- a/.strict-typing
+++ b/.strict-typing
@@ -120,6 +120,7 @@ homeassistant.components.bond.*
 homeassistant.components.braviatv.*
 homeassistant.components.brother.*
 homeassistant.components.browser.*
+homeassistant.components.bryant_evolution.*
 homeassistant.components.bthome.*
 homeassistant.components.button.*
 homeassistant.components.calendar.*
@@ -167,6 +168,7 @@ homeassistant.components.ecowitt.*
 homeassistant.components.efergy.*
 homeassistant.components.electrasmart.*
 homeassistant.components.electric_kiwi.*
+homeassistant.components.elevenlabs.*
 homeassistant.components.elgato.*
 homeassistant.components.elkm1.*
 homeassistant.components.emulated_hue.*
@@ -255,6 +257,7 @@ homeassistant.components.integration.*
 homeassistant.components.intent.*
 homeassistant.components.intent_script.*
 homeassistant.components.ios.*
+homeassistant.components.iotty.*
 homeassistant.components.ipp.*
 homeassistant.components.iqvia.*
 homeassistant.components.islamic_prayer_times.*
@@ -279,6 +282,7 @@ homeassistant.components.lidarr.*
 homeassistant.components.lifx.*
 homeassistant.components.light.*
 homeassistant.components.linear_garage_door.*
+homeassistant.components.linkplay.*
 homeassistant.components.litejet.*
 homeassistant.components.litterrobot.*
 homeassistant.components.local_ip.*
--- a/24
+++ b/24
@@ -197,7 +197,8 @@ build.json @home-assistant/supervisor
 /tests/components/bluemaestro/ @bdraco
 /homeassistant/components/blueprint/ @home-assistant/core
 /tests/components/blueprint/ @home-assistant/core
-/homeassistant/components/bluesound/ @thrawnarn
+/homeassistant/components/bluesound/ @thrawnarn @LouisChrist
+/tests/components/bluesound/ @thrawnarn @LouisChrist
 /homeassistant/components/bluetooth/ @bdraco
 /tests/components/bluetooth/ @bdraco
 /homeassistant/components/bluetooth_adapters/ @bdraco
@@ -220,6 +221,8 @@ build.json @home-assistant/supervisor
 /tests/components/brottsplatskartan/ @gjohansson-ST
 /homeassistant/components/brunt/ @eavanvalkenburg
 /tests/components/brunt/ @eavanvalkenburg
+/homeassistant/components/bryant_evolution/ @danielsmyers
+/tests/components/bryant_evolution/ @danielsmyers
 /homeassistant/components/bsblan/ @liudger
 /tests/components/bsblan/ @liudger
 /homeassistant/components/bt_smarthub/ @typhoon2099
@@ -373,6 +376,8 @@ build.json @home-assistant/supervisor
 /tests/components/electrasmart/ @jafar-atili
 /homeassistant/components/electric_kiwi/ @mikey0000
 /tests/components/electric_kiwi/ @mikey0000
+/homeassistant/components/elevenlabs/ @sorgfresser
+/tests/components/elevenlabs/ @sorgfresser
 /homeassistant/components/elgato/ @frenck
 /tests/components/elgato/ @frenck
 /homeassistant/components/elkm1/ @gwww @bdraco
@@ -384,6 +389,7 @@ build.json @home-assistant/supervisor
 /tests/components/elvia/ @ludeeus
 /homeassistant/components/emby/ @mezz64
 /homeassistant/components/emoncms/ @borpin @alexandrecuer
+/tests/components/emoncms/ @borpin @alexandrecuer
 /homeassistant/components/emonitor/ @bdraco
 /tests/components/emonitor/ @bdraco
 /homeassistant/components/emulated_hue/ @bdraco @Tho85
@@ -505,6 +511,7 @@ build.json @home-assistant/supervisor
 /homeassistant/components/generic_hygrostat/ @Shulyaka
 /tests/components/generic_hygrostat/ @Shulyaka
 /homeassistant/components/geniushub/ @manzanotti
+/tests/components/geniushub/ @manzanotti
 /homeassistant/components/geo_json_events/ @exxamalte
 /tests/components/geo_json_events/ @exxamalte
 /homeassistant/components/geo_location/ @home-assistant/core
@@ -695,6 +702,8 @@ build.json @home-assistant/supervisor
 /tests/components/ios/ @robbiet480
 /homeassistant/components/iotawatt/ @gtdiehl @jyavenard
 /tests/components/iotawatt/ @gtdiehl @jyavenard
+/homeassistant/components/iotty/ @pburgio
+/tests/components/iotty/ @pburgio
 /homeassistant/components/iperf3/ @rohankapoorcom
 /homeassistant/components/ipma/ @dgomes
 /tests/components/ipma/ @dgomes
@@ -703,6 +712,8 @@ build.json @home-assistant/supervisor
 /homeassistant/components/iqvia/ @bachya
 /tests/components/iqvia/ @bachya
 /homeassistant/components/irish_rail_transport/ @ttroy50
+/homeassistant/components/iron_os/ @tr4nt0r
+/tests/components/iron_os/ @tr4nt0r
 /homeassistant/components/isal/ @bdraco
 /tests/components/isal/ @bdraco
 /homeassistant/components/islamic_prayer_times/ @engrbm87 @cpfair
@@ -791,6 +802,8 @@ build.json @home-assistant/supervisor
 /tests/components/light/ @home-assistant/core
 /homeassistant/components/linear_garage_door/ @IceBotYT
 /tests/components/linear_garage_door/ @IceBotYT
+/homeassistant/components/linkplay/ @Velleman
+/tests/components/linkplay/ @Velleman
 /homeassistant/components/linux_battery/ @fabaff
 /homeassistant/components/litejet/ @joncar
 /tests/components/litejet/ @joncar
@@ -833,7 +846,8 @@ build.json @home-assistant/supervisor
 /tests/components/lyric/ @timmo001
 /homeassistant/components/madvr/ @iloveicedgreentea
 /tests/components/madvr/ @iloveicedgreentea
-/homeassistant/components/mastodon/ @fabaff
+/homeassistant/components/mastodon/ @fabaff @andrew-codechimp
+/tests/components/mastodon/ @fabaff @andrew-codechimp
 /homeassistant/components/matrix/ @PaarthShah
 /tests/components/matrix/ @PaarthShah
 /homeassistant/components/matter/ @home-assistant/matter
@@ -1039,8 +1053,8 @@ build.json @home-assistant/supervisor
 /tests/components/otbr/ @home-assistant/core
 /homeassistant/components/ourgroceries/ @OnFreund
 /tests/components/ourgroceries/ @OnFreund
-/homeassistant/components/overkiz/ @imicknl @vlebourl @tetienne @nyroDev @tronix117
-/tests/components/overkiz/ @imicknl @vlebourl @tetienne @nyroDev @tronix117
+/homeassistant/components/overkiz/ @imicknl @vlebourl @tetienne @nyroDev @tronix117 @alexfp14
+/tests/components/overkiz/ @imicknl @vlebourl @tetienne @nyroDev @tronix117 @alexfp14
 /homeassistant/components/ovo_energy/ @timmo001
 /tests/components/ovo_energy/ @timmo001
 /homeassistant/components/p1_monitor/ @klaasnicolaas
@@ -1432,6 +1446,8 @@ build.json @home-assistant/supervisor
 /tests/components/tellduslive/ @fredrike
 /homeassistant/components/template/ @PhracturedBlue @tetienne @home-assistant/core
 /tests/components/template/ @PhracturedBlue @tetienne @home-assistant/core
+/homeassistant/components/tesla_fleet/ @Bre77
+/tests/components/tesla_fleet/ @Bre77
 /homeassistant/components/tesla_wall_connector/ @einarhauks
 /tests/components/tesla_wall_connector/ @einarhauks
 /homeassistant/components/teslemetry/ @Bre77
--- a/2
+++ b/2
@@ -12,7 +12,7 @@ ENV \
 ARG QEMU_CPU

 # Install uv
-RUN pip3 install uv==0.2.13
+RUN pip3 install uv==0.2.27

 WORKDIR /usr/src

--- a/homeassistant/bootstrap.py
+++ b/homeassistant/bootstrap.py
@@ -223,8 +223,10 @@ CRITICAL_INTEGRATIONS = {
 SETUP_ORDER = (
    # Load logging and http deps as soon as possible
    ("logging, http deps", LOGGING_AND_HTTP_DEPS_INTEGRATIONS),
-    # Setup frontend and recorder
-    ("frontend, recorder", {*FRONTEND_INTEGRATIONS, *RECORDER_INTEGRATIONS}),
+    # Setup frontend
+    ("frontend", FRONTEND_INTEGRATIONS),
+    # Setup recorder
+    ("recorder", RECORDER_INTEGRATIONS),
    # Start up debuggers. Start these first in case they want to wait.
    ("debugger", DEBUGGER_INTEGRATIONS),
 )
@@ -906,7 +908,13 @@ async def _async_resolve_domains_to_setup(
            await asyncio.gather(*resolve_dependencies_tasks)

        for itg in integrations_to_process:
-            for dep in itg.all_dependencies:
+            try:
+                all_deps = itg.all_dependencies
+            except RuntimeError:
+                # Integration.all_dependencies raises RuntimeError if
+                # dependencies could not be resolved
+                continue
+            for dep in all_deps:
                if dep in domains_to_setup:
                    continue
                domains_to_setup.add(dep)
--- a/homeassistant/brands/logitech.json
+++ b/homeassistant/brands/logitech.json
@@ -1,5 +1,5 @@
 {
  "domain": "logitech",
  "name": "Logitech",
-  "integrations": ["harmony", "ue_smart_radio", "squeezebox"]
+  "integrations": ["harmony", "squeezebox"]
 }
--- a/homeassistant/brands/tesla.json
+++ b/homeassistant/brands/tesla.json
@@ -1,5 +1,5 @@
 {
  "domain": "tesla",
  "name": "Tesla",
-  "integrations": ["powerwall", "tesla_wall_connector"]
+  "integrations": ["powerwall", "tesla_wall_connector", "tesla_fleet"]
 }
--- a/homeassistant/components/advantage_air/climate.py
+++ b/homeassistant/components/advantage_air/climate.py
@@ -206,7 +206,8 @@ class AdvantageAirAC(AdvantageAirAcEntity, ClimateEntity):
    async def async_set_hvac_mode(self, hvac_mode: HVACMode) -> None:
        """Set the HVAC Mode and State."""
        if hvac_mode == HVACMode.OFF:
-            return await self.async_turn_off()
+            await self.async_turn_off()
+            return
        if hvac_mode == HVACMode.HEAT_COOL and self.preset_mode != ADVANTAGE_AIR_MYAUTO:
            raise ServiceValidationError("Heat/Cool is not supported in this mode")
        await self.async_update_ac(
--- a/homeassistant/components/aemet/manifest.json
+++ b/homeassistant/components/aemet/manifest.json
@@ -6,5 +6,5 @@
  "documentation": "https://www.home-assistant.io/integrations/aemet",
  "iot_class": "cloud_polling",
  "loggers": ["aemet_opendata"],
-  "requirements": ["AEMET-OpenData==0.5.2"]
+  "requirements": ["AEMET-OpenData==0.5.3"]
 }
--- a/homeassistant/components/airgradient/init.py
+++ b/homeassistant/components/airgradient/init.py
@@ -4,7 +4,7 @@ from __future__ import annotations

 from dataclasses import dataclass

-from airgradient import AirGradientClient
+from airgradient import AirGradientClient, get_model_name

 from homeassistant.config_entries import ConfigEntry
 from homeassistant.const import CONF_HOST, Platform
@@ -35,7 +35,7 @@ class AirGradientData:
 type AirGradientConfigEntry = ConfigEntry[AirGradientData]


-async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+async def async_setup_entry(hass: HomeAssistant, entry: AirGradientConfigEntry) -> bool:
    """Set up Airgradient from a config entry."""

    client = AirGradientClient(
@@ -53,7 +53,8 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
        config_entry_id=entry.entry_id,
        identifiers={(DOMAIN, measurement_coordinator.serial_number)},
        manufacturer="AirGradient",
-        model=measurement_coordinator.data.model,
+        model=get_model_name(measurement_coordinator.data.model),
+        model_id=measurement_coordinator.data.model,
        serial_number=measurement_coordinator.data.serial_number,
        sw_version=measurement_coordinator.data.firmware_version,
    )
@@ -68,6 +69,8 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
    return True


-async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+async def async_unload_entry(
+    hass: HomeAssistant, entry: AirGradientConfigEntry
+) -> bool:
    """Unload a config entry."""
    return await hass.config_entries.async_unload_platforms(entry, PLATFORMS)
--- a/homeassistant/components/airgradient/config_flow.py
+++ b/homeassistant/components/airgradient/config_flow.py
@@ -2,9 +2,13 @@

 from typing import Any

-from airgradient import AirGradientClient, AirGradientError, ConfigurationControl
+from airgradient import (
+    AirGradientClient,
+    AirGradientError,
+    AirGradientParseError,
+    ConfigurationControl,
+)
 from awesomeversion import AwesomeVersion
-from mashumaro import MissingField
 import voluptuous as vol

 from homeassistant.components import zeroconf
@@ -83,10 +87,10 @@ class AirGradientConfigFlow(ConfigFlow, domain=DOMAIN):
            self.client = AirGradientClient(user_input[CONF_HOST], session=session)
            try:
                current_measures = await self.client.get_current_measures()
+            except AirGradientParseError:
+                return self.async_abort(reason="invalid_version")
            except AirGradientError:
                errors["base"] = "cannot_connect"
-            except MissingField:
-                return self.async_abort(reason="invalid_version")
            else:
                await self.async_set_unique_id(current_measures.serial_number)
                self._abort_if_unique_id_configured()
--- a/homeassistant/components/airgradient/coordinator.py
+++ b/homeassistant/components/airgradient/coordinator.py
@@ -19,7 +19,6 @@ if TYPE_CHECKING:
 class AirGradientCoordinator[_DataT](DataUpdateCoordinator[_DataT]):
    """Class to manage fetching AirGradient data."""

-    _update_interval: timedelta
    config_entry: AirGradientConfigEntry

    def __init__(self, hass: HomeAssistant, client: AirGradientClient) -> None:
@@ -28,7 +27,7 @@ class AirGradientCoordinator[_DataT](DataUpdateCoordinator[_DataT]):
            hass,
            logger=LOGGER,
            name=f"AirGradient {client.host}",
-            update_interval=self._update_interval,
+            update_interval=timedelta(minutes=1),
        )
        self.client = client
        assert self.config_entry.unique_id
@@ -47,8 +46,6 @@ class AirGradientCoordinator[_DataT](DataUpdateCoordinator[_DataT]):
 class AirGradientMeasurementCoordinator(AirGradientCoordinator[Measures]):
    """Class to manage fetching AirGradient data."""

-    _update_interval = timedelta(minutes=1)
-
    async def _update_data(self) -> Measures:
        return await self.client.get_current_measures()

@@ -56,7 +53,5 @@ class AirGradientMeasurementCoordinator(AirGradientCoordinator[Measures]):
 class AirGradientConfigCoordinator(AirGradientCoordinator[Config]):
    """Class to manage fetching AirGradient data."""

-    _update_interval = timedelta(minutes=5)
-
    async def _update_data(self) -> Config:
        return await self.client.get_config()
--- a/homeassistant/components/airgradient/manifest.json
+++ b/homeassistant/components/airgradient/manifest.json
@@ -6,6 +6,6 @@
  "documentation": "https://www.home-assistant.io/integrations/airgradient",
  "integration_type": "device",
  "iot_class": "local_polling",
-  "requirements": ["airgradient==0.6.1"],
+  "requirements": ["airgradient==0.7.1"],
  "zeroconf": ["_airgradient._tcp.local."]
 }
--- a/homeassistant/components/airtouch4/climate.py
+++ b/homeassistant/components/airtouch4/climate.py
@@ -156,7 +156,8 @@ class AirtouchAC(CoordinatorEntity, ClimateEntity):
            raise ValueError(f"Unsupported HVAC mode: {hvac_mode}")

        if hvac_mode == HVACMode.OFF:
-            return await self.async_turn_off()
+            await self.async_turn_off()
+            return
        await self._airtouch.SetCoolingModeForAc(
            self._ac_number, HA_STATE_TO_AT[hvac_mode]
        )
@@ -262,7 +263,8 @@ class AirtouchGroup(CoordinatorEntity, ClimateEntity):
            raise ValueError(f"Unsupported HVAC mode: {hvac_mode}")

        if hvac_mode == HVACMode.OFF:
-            return await self.async_turn_off()
+            await self.async_turn_off()
+            return
        if self.hvac_mode == HVACMode.OFF:
            await self.async_turn_on()
        self._unit = self._airtouch.GetGroups()[self._group_number]
--- a/homeassistant/components/airtouch5/init.py
+++ b/homeassistant/components/airtouch5/init.py
@@ -11,7 +11,7 @@ from homeassistant.exceptions import ConfigEntryNotReady

 from .const import DOMAIN

-PLATFORMS: list[Platform] = [Platform.CLIMATE]
+PLATFORMS: list[Platform] = [Platform.CLIMATE, Platform.COVER]

 type Airtouch5ConfigEntry = ConfigEntry[Airtouch5SimpleClient]

--- a/homeassistant/components/airtouch5/climate.py
+++ b/homeassistant/components/airtouch5/climate.py
@@ -121,6 +121,7 @@ class Airtouch5ClimateEntity(ClimateEntity, Airtouch5Entity):
    """Base class for Airtouch5 Climate Entities."""

    _attr_temperature_unit = UnitOfTemperature.CELSIUS
+    _attr_translation_key = DOMAIN
    _attr_target_temperature_step = 1
    _attr_name = None
    _enable_turn_on_off_backwards_compatibility = False
--- a/homeassistant/components/airtouch5/cover.py
+++ b/homeassistant/components/airtouch5/cover.py
@@ -0,0 +1,134 @@
+"""Representation of the Damper for AirTouch 5 Devices."""
+
+import logging
+from typing import Any
+
+from airtouch5py.airtouch5_simple_client import Airtouch5SimpleClient
+from airtouch5py.packets.zone_control import (
+    ZoneControlZone,
+    ZoneSettingPower,
+    ZoneSettingValue,
+)
+from airtouch5py.packets.zone_name import ZoneName
+from airtouch5py.packets.zone_status import ZoneStatusZone
+
+from homeassistant.components.cover import (
+    ATTR_POSITION,
+    CoverDeviceClass,
+    CoverEntity,
+    CoverEntityFeature,
+)
+from homeassistant.core import HomeAssistant, callback
+from homeassistant.helpers.device_registry import DeviceInfo
+from homeassistant.helpers.entity_platform import AddEntitiesCallback
+
+from . import Airtouch5ConfigEntry
+from .const import DOMAIN
+from .entity import Airtouch5Entity
+
+_LOGGER = logging.getLogger(__name__)
+
+
+async def async_setup_entry(
+    hass: HomeAssistant,
+    config_entry: Airtouch5ConfigEntry,
+    async_add_entities: AddEntitiesCallback,
+) -> None:
+    """Set up the Airtouch 5 Cover entities."""
+    client = config_entry.runtime_data
+
+    # Each zone has a cover for its open percentage
+    async_add_entities(
+        Airtouch5ZoneOpenPercentage(
+            client, zone, client.latest_zone_status[zone.zone_number].has_sensor
+        )
+        for zone in client.zones
+    )
+
+
+class Airtouch5ZoneOpenPercentage(CoverEntity, Airtouch5Entity):
+    """How open the damper is in each zone."""
+
+    _attr_device_class = CoverDeviceClass.DAMPER
+    _attr_translation_key = "damper"
+
+    # Zones with temperature sensors shouldn't be manually controlled.
+    # We allow it but warn the user in the integration documentation.
+    _attr_supported_features = (
+        CoverEntityFeature.SET_POSITION
+        | CoverEntityFeature.OPEN
+        | CoverEntityFeature.CLOSE
+    )
+
+    def __init__(
+        self, client: Airtouch5SimpleClient, zone_name: ZoneName, has_sensor: bool
+    ) -> None:
+        """Initialise the Cover Entity."""
+        super().__init__(client)
+        self._zone_name = zone_name
+
+        self._attr_unique_id = f"zone_{zone_name.zone_number}_open_percentage"
+        self._attr_device_info = DeviceInfo(
+            identifiers={(DOMAIN, f"zone_{zone_name.zone_number}")},
+            name=zone_name.zone_name,
+            manufacturer="Polyaire",
+            model="AirTouch 5",
+        )
+
+    @callback
+    def _async_update_attrs(self, data: dict[int, ZoneStatusZone]) -> None:
+        if self._zone_name.zone_number not in data:
+            return
+        status = data[self._zone_name.zone_number]
+
+        self._attr_current_cover_position = int(status.open_percentage * 100)
+        if status.open_percentage == 0:
+            self._attr_is_closed = True
+        else:
+            self._attr_is_closed = False
+        self.async_write_ha_state()
+
+    async def async_added_to_hass(self) -> None:
+        """Add data updated listener after this object has been initialized."""
+        await super().async_added_to_hass()
+        self._client.zone_status_callbacks.append(self._async_update_attrs)
+        self._async_update_attrs(self._client.latest_zone_status)
+
+    async def async_will_remove_from_hass(self) -> None:
+        """Remove data updated listener after this object has been initialized."""
+        await super().async_will_remove_from_hass()
+        self._client.zone_status_callbacks.remove(self._async_update_attrs)
+
+    async def async_open_cover(self, **kwargs: Any) -> None:
+        """Open the damper."""
+        await self._set_cover_position(100)
+
+    async def async_close_cover(self, **kwargs: Any) -> None:
+        """Close damper."""
+        await self._set_cover_position(0)
+
+    async def async_set_cover_position(self, **kwargs: Any) -> None:
+        """Update the damper to a specific position."""
+
+        if (position := kwargs.get(ATTR_POSITION)) is None:
+            _LOGGER.debug("Argument `position` is missing in set_cover_position")
+            return
+        await self._set_cover_position(position)
+
+    async def _set_cover_position(self, position_percent: float) -> None:
+        power: ZoneSettingPower
+
+        if position_percent == 0:
+            power = ZoneSettingPower.SET_TO_OFF
+        else:
+            power = ZoneSettingPower.SET_TO_ON
+
+        zcz = ZoneControlZone(
+            self._zone_name.zone_number,
+            ZoneSettingValue.SET_OPEN_PERCENTAGE,
+            power,
+            position_percent / 100.0,
+        )
+
+        packet = self._client.data_packet_factory.zone_control([zcz])
+        await self._client.send_packet(packet)
--- a/homeassistant/components/airtouch5/entity.py
+++ b/homeassistant/components/airtouch5/entity.py
@@ -6,15 +6,12 @@ from airtouch5py.airtouch5_simple_client import Airtouch5SimpleClient
 from homeassistant.core import callback
 from homeassistant.helpers.entity import Entity

-from .const import DOMAIN
-

 class Airtouch5Entity(Entity):
    """Base class for Airtouch5 entities."""

    _attr_should_poll = False
    _attr_has_entity_name = True
-    _attr_translation_key = DOMAIN

    def __init__(self, client: Airtouch5SimpleClient) -> None:
        """Initialise the Entity."""
--- a/homeassistant/components/airtouch5/strings.json
+++ b/homeassistant/components/airtouch5/strings.json
@@ -27,6 +27,11 @@
          }
        }
      }
+    },
+    "cover": {
+      "damper": {
+        "name": "[%key:component::cover::entity_component::damper::name%]"
+      }
    }
  }
 }
--- a/homeassistant/components/airzone/manifest.json
+++ b/homeassistant/components/airzone/manifest.json
@@ -11,5 +11,5 @@
  "documentation": "https://www.home-assistant.io/integrations/airzone",
  "iot_class": "local_polling",
  "loggers": ["aioairzone"],
-  "requirements": ["aioairzone==0.8.0"]
+  "requirements": ["aioairzone==0.8.1"]
 }
--- a/homeassistant/components/airzone_cloud/binary_sensor.py
+++ b/homeassistant/components/airzone_cloud/binary_sensor.py
@@ -14,6 +14,7 @@ from aioairzone_cloud.const import (
    AZD_FLOOR_DEMAND,
    AZD_PROBLEMS,
    AZD_SYSTEMS,
+    AZD_THERMOSTAT_BATTERY_LOW,
    AZD_WARNINGS,
    AZD_ZONES,
 )
@@ -88,6 +89,10 @@ ZONE_BINARY_SENSOR_TYPES: Final[tuple[AirzoneBinarySensorEntityDescription, ...]
        key=AZD_AQ_ACTIVE,
        translation_key="air_quality_active",
    ),
+    AirzoneBinarySensorEntityDescription(
+        device_class=BinarySensorDeviceClass.BATTERY,
+        key=AZD_THERMOSTAT_BATTERY_LOW,
+    ),
    AirzoneBinarySensorEntityDescription(
        device_class=BinarySensorDeviceClass.RUNNING,
        key=AZD_FLOOR_DEMAND,
--- a/homeassistant/components/airzone_cloud/entity.py
+++ b/homeassistant/components/airzone_cloud/entity.py
@@ -13,9 +13,12 @@ from aioairzone_cloud.const import (
    AZD_GROUPS,
    AZD_HOT_WATERS,
    AZD_INSTALLATIONS,
+    AZD_MODEL,
    AZD_NAME,
    AZD_SYSTEM_ID,
    AZD_SYSTEMS,
+    AZD_THERMOSTAT_FW,
+    AZD_THERMOSTAT_MODEL,
    AZD_WEBSERVER,
    AZD_WEBSERVERS,
    AZD_ZONES,
@@ -69,6 +72,7 @@ class AirzoneAidooEntity(AirzoneEntity):
        self._attr_device_info = DeviceInfo(
            identifiers={(DOMAIN, aidoo_id)},
            manufacturer=MANUFACTURER,
+            model=aidoo_data[AZD_MODEL],
            name=aidoo_data[AZD_NAME],
            via_device=(DOMAIN, aidoo_data[AZD_WEBSERVER]),
        )
@@ -111,6 +115,7 @@ class AirzoneGroupEntity(AirzoneEntity):

        self._attr_device_info = DeviceInfo(
            identifiers={(DOMAIN, group_id)},
+            model="Group",
            manufacturer=MANUFACTURER,
            name=group_data[AZD_NAME],
        )
@@ -154,6 +159,7 @@ class AirzoneHotWaterEntity(AirzoneEntity):
        self._attr_device_info = DeviceInfo(
            identifiers={(DOMAIN, dhw_id)},
            manufacturer=MANUFACTURER,
+            model="Hot Water",
            name=dhw_data[AZD_NAME],
            via_device=(DOMAIN, dhw_data[AZD_WEBSERVER]),
        )
@@ -195,6 +201,7 @@ class AirzoneInstallationEntity(AirzoneEntity):
        self._attr_device_info = DeviceInfo(
            identifiers={(DOMAIN, inst_id)},
            manufacturer=MANUFACTURER,
+            model="Installation",
            name=inst_data[AZD_NAME],
        )

@@ -240,9 +247,11 @@ class AirzoneSystemEntity(AirzoneEntity):

        self._attr_device_info = DeviceInfo(
            identifiers={(DOMAIN, system_id)},
+            model=system_data.get(AZD_MODEL),
            manufacturer=MANUFACTURER,
            name=system_data[AZD_NAME],
            via_device=(DOMAIN, system_data[AZD_WEBSERVER]),
+            sw_version=system_data.get(AZD_FIRMWARE),
        )

    def get_airzone_value(self, key: str) -> Any:
@@ -270,6 +279,7 @@ class AirzoneWebServerEntity(AirzoneEntity):
        self._attr_device_info = DeviceInfo(
            connections={(dr.CONNECTION_NETWORK_MAC, ws_id)},
            identifiers={(DOMAIN, ws_id)},
+            model="WebServer",
            manufacturer=MANUFACTURER,
            name=ws_data[AZD_NAME],
            sw_version=ws_data[AZD_FIRMWARE],
@@ -300,9 +310,11 @@ class AirzoneZoneEntity(AirzoneEntity):

        self._attr_device_info = DeviceInfo(
            identifiers={(DOMAIN, zone_id)},
+            model=zone_data.get(AZD_THERMOSTAT_MODEL),
            manufacturer=MANUFACTURER,
            name=zone_data[AZD_NAME],
            via_device=(DOMAIN, self.system_id),
+            sw_version=zone_data.get(AZD_THERMOSTAT_FW),
        )

    def get_airzone_value(self, key: str) -> Any:
--- a/homeassistant/components/airzone_cloud/icons.json
+++ b/homeassistant/components/airzone_cloud/icons.json
@@ -0,0 +1,15 @@
+{
+  "entity": {
+    "sensor": {
+      "cpu_usage": {
+        "default": "mdi:cpu-32-bit"
+      },
+      "free_memory": {
+        "default": "mdi:memory"
+      },
+      "thermostat_coverage": {
+        "default": "mdi:signal"
+      }
+    }
+  }
+}
--- a/homeassistant/components/airzone_cloud/manifest.json
+++ b/homeassistant/components/airzone_cloud/manifest.json
@@ -6,5 +6,5 @@
  "documentation": "https://www.home-assistant.io/integrations/airzone_cloud",
  "iot_class": "cloud_push",
  "loggers": ["aioairzone_cloud"],
-  "requirements": ["aioairzone-cloud==0.5.4"]
+  "requirements": ["aioairzone-cloud==0.6.1"]
 }
--- a/homeassistant/components/airzone_cloud/sensor.py
+++ b/homeassistant/components/airzone_cloud/sensor.py
@@ -10,8 +10,12 @@ from aioairzone_cloud.const import (
    AZD_AQ_PM_1,
    AZD_AQ_PM_2P5,
    AZD_AQ_PM_10,
+    AZD_CPU_USAGE,
    AZD_HUMIDITY,
+    AZD_MEMORY_FREE,
    AZD_TEMP,
+    AZD_THERMOSTAT_BATTERY,
+    AZD_THERMOSTAT_COVERAGE,
    AZD_WEBSERVERS,
    AZD_WIFI_RSSI,
    AZD_ZONES,
@@ -28,6 +32,7 @@ from homeassistant.const import (
    PERCENTAGE,
    SIGNAL_STRENGTH_DECIBELS_MILLIWATT,
    EntityCategory,
+    UnitOfInformation,
    UnitOfTemperature,
 )
 from homeassistant.core import HomeAssistant, callback
@@ -52,6 +57,22 @@ AIDOO_SENSOR_TYPES: Final[tuple[SensorEntityDescription, ...]] = (
 )

 WEBSERVER_SENSOR_TYPES: Final[tuple[SensorEntityDescription, ...]] = (
+    SensorEntityDescription(
+        entity_category=EntityCategory.DIAGNOSTIC,
+        entity_registry_enabled_default=False,
+        key=AZD_CPU_USAGE,
+        native_unit_of_measurement=PERCENTAGE,
+        state_class=SensorStateClass.MEASUREMENT,
+        translation_key="cpu_usage",
+    ),
+    SensorEntityDescription(
+        entity_category=EntityCategory.DIAGNOSTIC,
+        entity_registry_enabled_default=False,
+        key=AZD_MEMORY_FREE,
+        native_unit_of_measurement=UnitOfInformation.BYTES,
+        state_class=SensorStateClass.MEASUREMENT,
+        translation_key="free_memory",
+    ),
    SensorEntityDescription(
        device_class=SensorDeviceClass.SIGNAL_STRENGTH,
        entity_category=EntityCategory.DIAGNOSTIC,
@@ -98,6 +119,20 @@ ZONE_SENSOR_TYPES: Final[tuple[SensorEntityDescription, ...]] = (
        native_unit_of_measurement=PERCENTAGE,
        state_class=SensorStateClass.MEASUREMENT,
    ),
+    SensorEntityDescription(
+        device_class=SensorDeviceClass.BATTERY,
+        key=AZD_THERMOSTAT_BATTERY,
+        native_unit_of_measurement=PERCENTAGE,
+        state_class=SensorStateClass.MEASUREMENT,
+    ),
+    SensorEntityDescription(
+        entity_category=EntityCategory.DIAGNOSTIC,
+        entity_registry_enabled_default=False,
+        key=AZD_THERMOSTAT_COVERAGE,
+        native_unit_of_measurement=PERCENTAGE,
+        state_class=SensorStateClass.MEASUREMENT,
+        translation_key="thermostat_coverage",
+    ),
 )


--- a/homeassistant/components/airzone_cloud/strings.json
+++ b/homeassistant/components/airzone_cloud/strings.json
@@ -37,6 +37,17 @@
          "auto": "Auto"
        }
      }
+    },
+    "sensor": {
+      "cpu_usage": {
+        "name": "CPU usage"
+      },
+      "free_memory": {
+        "name": "Free memory"
+      },
+      "thermostat_coverage": {
+        "name": "Signal percentage"
+      }
    }
  }
 }
--- a/homeassistant/components/amcrest/camera.py
+++ b/homeassistant/components/amcrest/camera.py
@@ -8,6 +8,7 @@ from datetime import timedelta
 import logging
 from typing import TYPE_CHECKING, Any

+import aiohttp
 from aiohttp import web
 from amcrest import AmcrestError
 from haffmpeg.camera import CameraMjpeg
@@ -244,7 +245,9 @@ class AmcrestCam(Camera):
            websession = async_get_clientsession(self.hass)
            streaming_url = self._api.mjpeg_url(typeno=self._resolution)
            stream_coro = websession.get(
-                streaming_url, auth=self._token, timeout=CAMERA_WEB_SESSION_TIMEOUT
+                streaming_url,
+                auth=self._token,
+                timeout=aiohttp.ClientTimeout(total=CAMERA_WEB_SESSION_TIMEOUT),
            )

            return await async_aiohttp_proxy_web(self.hass, request, stream_coro)
--- a/homeassistant/components/apcupsd/const.py
+++ b/homeassistant/components/apcupsd/const.py
@@ -4,3 +4,6 @@ from typing import Final

 DOMAIN: Final = "apcupsd"
 CONNECTION_TIMEOUT: int = 10
+
+# Field name of last self test retrieved from apcupsd.
+LASTSTEST: Final = "laststest"
--- a/homeassistant/components/apcupsd/sensor.py
+++ b/homeassistant/components/apcupsd/sensor.py
@@ -13,6 +13,7 @@ from homeassistant.components.sensor import (
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.const import (
    PERCENTAGE,
+    STATE_UNKNOWN,
    UnitOfApparentPower,
    UnitOfElectricCurrent,
    UnitOfElectricPotential,
@@ -25,7 +26,7 @@ from homeassistant.core import HomeAssistant, callback
 from homeassistant.helpers.entity_platform import AddEntitiesCallback
 from homeassistant.helpers.update_coordinator import CoordinatorEntity

-from .const import DOMAIN
+from .const import DOMAIN, LASTSTEST
 from .coordinator import APCUPSdCoordinator

 PARALLEL_UPDATES = 0
@@ -156,8 +157,8 @@ SENSORS: dict[str, SensorEntityDescription] = {
        device_class=SensorDeviceClass.TEMPERATURE,
        state_class=SensorStateClass.MEASUREMENT,
    ),
-    "laststest": SensorEntityDescription(
-        key="laststest",
+    LASTSTEST: SensorEntityDescription(
+        key=LASTSTEST,
        translation_key="last_self_test",
    ),
    "lastxfer": SensorEntityDescription(
@@ -417,7 +418,12 @@ async def async_setup_entry(
    available_resources: set[str] = {k.lower() for k, _ in coordinator.data.items()}

    entities = []
-    for resource in available_resources:
+
+    # "laststest" is a special sensor that only appears when the APC UPS daemon has done a
+    # periodical (or manual) self test since last daemon restart. It might not be available
+    # when we set up the integration, and we do not know if it would ever be available. Here we
+    # add it anyway and mark it as unknown initially.
+    for resource in available_resources | {LASTSTEST}:
        if resource not in SENSORS:
            _LOGGER.warning("Invalid resource from APCUPSd: %s", resource.upper())
            continue
@@ -473,6 +479,14 @@ class APCUPSdSensor(CoordinatorEntity[APCUPSdCoordinator], SensorEntity):
    def _update_attrs(self) -> None:
        """Update sensor attributes based on coordinator data."""
        key = self.entity_description.key.upper()
+        # For most sensors the key will always be available for each refresh. However, some sensors
+        # (e.g., "laststest") will only appear after certain event occurs (e.g., a self test is
+        # performed) and may disappear again after certain event. So we mark the state as "unknown"
+        # when it becomes unknown after such events.
+        if key not in self.coordinator.data:
+            self._attr_native_value = STATE_UNKNOWN
+            return
+
        self._attr_native_value, inferred_unit = infer_unit(self.coordinator.data[key])
        if not self.native_unit_of_measurement:
            self._attr_native_unit_of_measurement = inferred_unit
--- a/homeassistant/components/api/init.py
+++ b/homeassistant/components/api/init.py
@@ -45,7 +45,7 @@ from homeassistant.exceptions import (
    TemplateError,
    Unauthorized,
 )
-from homeassistant.helpers import config_validation as cv, template
+from homeassistant.helpers import config_validation as cv, recorder, template
 from homeassistant.helpers.json import json_dumps, json_fragment
 from homeassistant.helpers.service import async_get_all_descriptions
 from homeassistant.helpers.typing import ConfigType
@@ -119,7 +119,10 @@ class APICoreStateView(HomeAssistantView):
        to check if Home Assistant is running.
        """
        hass = request.app[KEY_HASS]
-        return self.json({"state": hass.state.value})
+        migration = recorder.async_migration_in_progress(hass)
+        live = recorder.async_migration_is_live(hass)
+        recorder_state = {"migration_in_progress": migration, "migration_is_live": live}
+        return self.json({"state": hass.state.value, "recorder_state": recorder_state})


 class APIEventStream(HomeAssistantView):
@@ -387,6 +390,27 @@ class APIDomainServicesView(HomeAssistantView):
            )

        context = self.context(request)
+        if not hass.services.has_service(domain, service):
+            raise HTTPBadRequest from ServiceNotFound(domain, service)
+
+        if response_requested := "return_response" in request.query:
+            if (
+                hass.services.supports_response(domain, service)
+                is ha.SupportsResponse.NONE
+            ):
+                return self.json_message(
+                    "Service does not support responses. Remove return_response from request.",
+                    HTTPStatus.BAD_REQUEST,
+                )
+        elif (
+            hass.services.supports_response(domain, service) is ha.SupportsResponse.ONLY
+        ):
+            return self.json_message(
+                "Service call requires responses but caller did not ask for responses. "
+                "Add ?return_response to query parameters.",
+                HTTPStatus.BAD_REQUEST,
+            )
+
        changed_states: list[json_fragment] = []

        @ha.callback
@@ -403,13 +427,14 @@ class APIDomainServicesView(HomeAssistantView):

        try:
            # shield the service call from cancellation on connection drop
-            await shield(
+            response = await shield(
                hass.services.async_call(
                    domain,
                    service,
                    data,  # type: ignore[arg-type]
                    blocking=True,
                    context=context,
+                    return_response=response_requested,
                )
            )
        except (vol.Invalid, ServiceNotFound) as ex:
@@ -417,6 +442,11 @@ class APIDomainServicesView(HomeAssistantView):
        finally:
            cancel_listen()

+        if response_requested:
+            return self.json(
+                {"changed_states": changed_states, "service_response": response}
+            )
+
        return self.json(changed_states)


--- a/homeassistant/components/apple_tv/init.py
+++ b/homeassistant/components/apple_tv/init.py
@@ -60,6 +60,7 @@ AUTH_EXCEPTIONS = (
    exceptions.NoCredentialsError,
 )
 CONNECTION_TIMEOUT_EXCEPTIONS = (
+    OSError,
    asyncio.CancelledError,
    TimeoutError,
    exceptions.ConnectionLostError,
--- a/homeassistant/components/apsystems/init.py
+++ b/homeassistant/components/apsystems/init.py
@@ -7,12 +7,13 @@ from dataclasses import dataclass
 from APsystemsEZ1 import APsystemsEZ1M

 from homeassistant.config_entries import ConfigEntry
-from homeassistant.const import CONF_IP_ADDRESS, Platform
+from homeassistant.const import CONF_IP_ADDRESS, CONF_PORT, Platform
 from homeassistant.core import HomeAssistant

+from .const import DEFAULT_PORT
 from .coordinator import ApSystemsDataCoordinator

-PLATFORMS: list[Platform] = [Platform.NUMBER, Platform.SENSOR]
+PLATFORMS: list[Platform] = [Platform.NUMBER, Platform.SENSOR, Platform.SWITCH]


@dataclass
@@ -28,7 +29,11 @@ type ApSystemsConfigEntry = ConfigEntry[ApSystemsData]

 async def async_setup_entry(hass: HomeAssistant, entry: ApSystemsConfigEntry) -> bool:
    """Set up this integration using UI."""
-    api = APsystemsEZ1M(ip_address=entry.data[CONF_IP_ADDRESS], timeout=8)
+    api = APsystemsEZ1M(
+        ip_address=entry.data[CONF_IP_ADDRESS],
+        port=entry.data.get(CONF_PORT, DEFAULT_PORT),
+        timeout=8,
+    )
    coordinator = ApSystemsDataCoordinator(hass, api)
    await coordinator.async_config_entry_first_refresh()
    assert entry.unique_id
--- a/homeassistant/components/apsystems/config_flow.py
+++ b/homeassistant/components/apsystems/config_flow.py
@@ -7,14 +7,16 @@ from APsystemsEZ1 import APsystemsEZ1M
 import voluptuous as vol

 from homeassistant.config_entries import ConfigFlow, ConfigFlowResult
-from homeassistant.const import CONF_IP_ADDRESS
+from homeassistant.const import CONF_IP_ADDRESS, CONF_PORT
 from homeassistant.helpers.aiohttp_client import async_get_clientsession
+import homeassistant.helpers.config_validation as cv

-from .const import DOMAIN
+from .const import DEFAULT_PORT, DOMAIN

 DATA_SCHEMA = vol.Schema(
    {
-        vol.Required(CONF_IP_ADDRESS): str,
+        vol.Required(CONF_IP_ADDRESS): cv.string,
+        vol.Optional(CONF_PORT): cv.port,
    }
 )

@@ -32,7 +34,11 @@ class APsystemsLocalAPIFlow(ConfigFlow, domain=DOMAIN):

        if user_input is not None:
            session = async_get_clientsession(self.hass, False)
-            api = APsystemsEZ1M(user_input[CONF_IP_ADDRESS], session=session)
+            api = APsystemsEZ1M(
+                ip_address=user_input[CONF_IP_ADDRESS],
+                port=user_input.get(CONF_PORT, DEFAULT_PORT),
+                session=session,
+            )
            try:
                device_info = await api.get_device_info()
            except (TimeoutError, ClientConnectionError):
--- a/homeassistant/components/apsystems/const.py
+++ b/homeassistant/components/apsystems/const.py
@@ -4,3 +4,4 @@ from logging import Logger, getLogger

 LOGGER: Logger = getLogger(__package__)
 DOMAIN = "apsystems"
+DEFAULT_PORT = 8050
--- a/homeassistant/components/apsystems/strings.json
+++ b/homeassistant/components/apsystems/strings.json
@@ -3,7 +3,11 @@
    "step": {
      "user": {
        "data": {
-          "ip_address": "[%key:common::config_flow::data::ip%]"
+          "ip_address": "[%key:common::config_flow::data::ip%]",
+          "port": "[%key:common::config_flow::data::port%]"
+        },
+        "data_description": {
+          "port": "The integration will default to 8050, if not set, which should be suitable for most installs"
        }
      }
    },
@@ -16,18 +20,43 @@
  },
  "entity": {
    "sensor": {
-      "total_power": { "name": "Total power" },
-      "total_power_p1": { "name": "Power of P1" },
-      "total_power_p2": { "name": "Power of P2" },
-      "lifetime_production": { "name": "Total lifetime production" },
-      "lifetime_production_p1": { "name": "Lifetime production of P1" },
-      "lifetime_production_p2": { "name": "Lifetime production of P2" },
-      "today_production": { "name": "Production of today" },
-      "today_production_p1": { "name": "Production of today from P1" },
-      "today_production_p2": { "name": "Production of today from P2" }
+      "total_power": {
+        "name": "Total power"
+      },
+      "total_power_p1": {
+        "name": "Power of P1"
+      },
+      "total_power_p2": {
+        "name": "Power of P2"
+      },
+      "lifetime_production": {
+        "name": "Total lifetime production"
+      },
+      "lifetime_production_p1": {
+        "name": "Lifetime production of P1"
+      },
+      "lifetime_production_p2": {
+        "name": "Lifetime production of P2"
+      },
+      "today_production": {
+        "name": "Production of today"
+      },
+      "today_production_p1": {
+        "name": "Production of today from P1"
+      },
+      "today_production_p2": {
+        "name": "Production of today from P2"
+      }
    },
    "number": {
-      "max_output": { "name": "Max output" }
+      "max_output": {
+        "name": "Max output"
+      }
+    },
+    "switch": {
+      "inverter_status": {
+        "name": "Inverter status"
+      }
    }
  }
 }
--- a/homeassistant/components/apsystems/switch.py
+++ b/homeassistant/components/apsystems/switch.py
@@ -0,0 +1,56 @@
+"""The power switch which can be toggled via the APsystems local API integration."""
+
+from __future__ import annotations
+
+from typing import Any
+
+from aiohttp.client_exceptions import ClientConnectionError
+from APsystemsEZ1 import Status
+
+from homeassistant.components.switch import SwitchDeviceClass, SwitchEntity
+from homeassistant.core import HomeAssistant
+from homeassistant.helpers.entity_platform import AddEntitiesCallback
+
+from . import ApSystemsConfigEntry, ApSystemsData
+from .entity import ApSystemsEntity
+
+
+async def async_setup_entry(
+    hass: HomeAssistant,
+    config_entry: ApSystemsConfigEntry,
+    add_entities: AddEntitiesCallback,
+) -> None:
+    """Set up the switch platform."""
+
+    add_entities([ApSystemsInverterSwitch(config_entry.runtime_data)], True)
+
+
+class ApSystemsInverterSwitch(ApSystemsEntity, SwitchEntity):
+    """The switch class for APSystems switches."""
+
+    _attr_device_class = SwitchDeviceClass.SWITCH
+    _attr_translation_key = "inverter_status"
+
+    def __init__(self, data: ApSystemsData) -> None:
+        """Initialize the switch."""
+        super().__init__(data)
+        self._api = data.coordinator.api
+        self._attr_unique_id = f"{data.device_id}_inverter_status"
+
+    async def async_update(self) -> None:
+        """Update switch status and availability."""
+        try:
+            status = await self._api.get_device_power_status()
+        except (TimeoutError, ClientConnectionError):
+            self._attr_available = False
+        else:
+            self._attr_available = True
+            self._attr_is_on = status == Status.normal
+
+    async def async_turn_on(self, **kwargs: Any) -> None:
+        """Turn the switch on."""
+        await self._api.set_device_power_status(0)
+
+    async def async_turn_off(self, **kwargs: Any) -> None:
+        """Turn the switch off."""
+        await self._api.set_device_power_status(1)
--- a/homeassistant/components/aseko_pool_live/entity.py
+++ b/homeassistant/components/aseko_pool_live/entity.py
@@ -19,7 +19,10 @@ class AsekoEntity(CoordinatorEntity[AsekoDataUpdateCoordinator]):
        super().__init__(coordinator)
        self._unit = unit

-        self._device_model = f"ASIN AQUA {self._unit.type}"
+        if self._unit.type == "Remote":
+            self._device_model = "ASIN Pool"
+        else:
+            self._device_model = f"ASIN AQUA {self._unit.type}"
        self._device_name = self._unit.name if self._unit.name else self._device_model

        self._attr_device_info = DeviceInfo(
--- a/homeassistant/components/aseko_pool_live/manifest.json
+++ b/homeassistant/components/aseko_pool_live/manifest.json
@@ -6,5 +6,5 @@
  "documentation": "https://www.home-assistant.io/integrations/aseko_pool_live",
  "iot_class": "cloud_polling",
  "loggers": ["aioaseko"],
-  "requirements": ["aioaseko==0.1.1"]
+  "requirements": ["aioaseko==0.2.0"]
 }
--- a/homeassistant/components/assist_pipeline/init.py
+++ b/homeassistant/components/assist_pipeline/init.py
@@ -16,6 +16,10 @@ from .const import (
    DATA_LAST_WAKE_UP,
    DOMAIN,
    EVENT_RECORDING,
+    SAMPLE_CHANNELS,
+    SAMPLE_RATE,
+    SAMPLE_WIDTH,
+    SAMPLES_PER_CHUNK,
 )
 from .error import PipelineNotFound
 from .pipeline import (
@@ -53,6 +57,10 @@ __all__ = (
    "PipelineNotFound",
    "WakeWordSettings",
    "EVENT_RECORDING",
+    "SAMPLES_PER_CHUNK",
+    "SAMPLE_RATE",
+    "SAMPLE_WIDTH",
+    "SAMPLE_CHANNELS",
 )

 CONFIG_SCHEMA = vol.Schema(
--- a/homeassistant/components/assist_pipeline/audio_enhancer.py
+++ b/homeassistant/components/assist_pipeline/audio_enhancer.py
@@ -0,0 +1,72 @@
+"""Audio enhancement for Assist."""
+
+from abc import ABC, abstractmethod
+from dataclasses import dataclass
+import logging
+
+from pymicro_vad import MicroVad
+
+from .const import BYTES_PER_CHUNK
+
+_LOGGER = logging.getLogger(__name__)
+
+
+@dataclass(frozen=True, slots=True)
+class EnhancedAudioChunk:
+    """Enhanced audio chunk and metadata."""
+
+    audio: bytes
+    """Raw PCM audio @ 16Khz with 16-bit mono samples"""
+
+    timestamp_ms: int
+    """Timestamp relative to start of audio stream (milliseconds)"""
+
+    is_speech: bool | None
+    """True if audio chunk likely contains speech, False if not, None if unknown"""
+
+
+class AudioEnhancer(ABC):
+    """Base class for audio enhancement."""
+
+    def __init__(
+        self, auto_gain: int, noise_suppression: int, is_vad_enabled: bool
+    ) -> None:
+        """Initialize audio enhancer."""
+        self.auto_gain = auto_gain
+        self.noise_suppression = noise_suppression
+        self.is_vad_enabled = is_vad_enabled
+
+    @abstractmethod
+    def enhance_chunk(self, audio: bytes, timestamp_ms: int) -> EnhancedAudioChunk:
+        """Enhance chunk of PCM audio @ 16Khz with 16-bit mono samples."""
+
+
+class MicroVadEnhancer(AudioEnhancer):
+    """Audio enhancer that just runs microVAD."""
+
+    def __init__(
+        self, auto_gain: int, noise_suppression: int, is_vad_enabled: bool
+    ) -> None:
+        """Initialize audio enhancer."""
+        super().__init__(auto_gain, noise_suppression, is_vad_enabled)
+
+        self.vad: MicroVad | None = None
+        self.threshold = 0.5
+
+        if self.is_vad_enabled:
+            self.vad = MicroVad()
+            _LOGGER.debug("Initialized microVAD with threshold=%s", self.threshold)
+
+    def enhance_chunk(self, audio: bytes, timestamp_ms: int) -> EnhancedAudioChunk:
+        """Enhance 10ms chunk of PCM audio @ 16Khz with 16-bit mono samples."""
+        is_speech: bool | None = None
+
+        if self.vad is not None:
+            # Run VAD
+            assert len(audio) == BYTES_PER_CHUNK
+            speech_prob = self.vad.Process10ms(audio)
+            is_speech = speech_prob > self.threshold
+
+        return EnhancedAudioChunk(
+            audio=audio, timestamp_ms=timestamp_ms, is_speech=is_speech
+        )
--- a/homeassistant/components/assist_pipeline/const.py
+++ b/homeassistant/components/assist_pipeline/const.py
@@ -15,3 +15,10 @@ DATA_LAST_WAKE_UP = f"{DOMAIN}.last_wake_up"
 WAKE_WORD_COOLDOWN = 2  # seconds

 EVENT_RECORDING = f"{DOMAIN}_recording"
+
+SAMPLE_RATE = 16000  # hertz
+SAMPLE_WIDTH = 2  # bytes
+SAMPLE_CHANNELS = 1  # mono
+MS_PER_CHUNK = 10
+SAMPLES_PER_CHUNK = SAMPLE_RATE // (1000 // MS_PER_CHUNK)  # 10 ms @ 16Khz
+BYTES_PER_CHUNK = SAMPLES_PER_CHUNK * SAMPLE_WIDTH * SAMPLE_CHANNELS  # 16-bit
--- a/homeassistant/components/assist_pipeline/manifest.json
+++ b/homeassistant/components/assist_pipeline/manifest.json
@@ -6,5 +6,5 @@
  "documentation": "https://www.home-assistant.io/integrations/assist_pipeline",
  "iot_class": "local_push",
  "quality_scale": "internal",
-  "requirements": ["webrtc-noise-gain==1.2.3"]
+  "requirements": ["pymicro-vad==1.0.1"]
 }
--- a/homeassistant/components/assist_pipeline/pipeline.py
+++ b/homeassistant/components/assist_pipeline/pipeline.py
@@ -13,14 +13,11 @@ from pathlib import Path
 from queue import Empty, Queue
 from threading import Thread
 import time
-from typing import TYPE_CHECKING, Any, Final, Literal, cast
+from typing import Any, Literal, cast
 import wave

 import voluptuous as vol

-if TYPE_CHECKING:
-    from webrtc_noise_gain import AudioProcessor
-
 from homeassistant.components import (
    conversation,
    media_source,
@@ -52,12 +49,19 @@ from homeassistant.util import (
 )
 from homeassistant.util.limited_size_dict import LimitedSizeDict

+from .audio_enhancer import AudioEnhancer, EnhancedAudioChunk, MicroVadEnhancer
 from .const import (
+    BYTES_PER_CHUNK,
    CONF_DEBUG_RECORDING_DIR,
    DATA_CONFIG,
    DATA_LAST_WAKE_UP,
    DATA_MIGRATIONS,
    DOMAIN,
+    MS_PER_CHUNK,
+    SAMPLE_CHANNELS,
+    SAMPLE_RATE,
+    SAMPLE_WIDTH,
+    SAMPLES_PER_CHUNK,
    WAKE_WORD_COOLDOWN,
 )
 from .error import (
@@ -111,9 +115,6 @@ STORED_PIPELINE_RUNS = 10

 SAVE_DELAY = 10

-AUDIO_PROCESSOR_SAMPLES: Final = 160  # 10 ms @ 16 Khz
-AUDIO_PROCESSOR_BYTES: Final = AUDIO_PROCESSOR_SAMPLES * 2  # 16-bit samples
-

@callback
 def _async_resolve_default_pipeline_settings(
@@ -503,8 +504,8 @@ class AudioSettings:
    is_vad_enabled: bool = True
    """True if VAD is used to determine the end of the voice command."""

-    is_chunking_enabled: bool = True
-    """True if audio is automatically split into 10 ms chunks (required for VAD, etc.)"""
+    silence_seconds: float = 0.5
+    """Seconds of silence after voice command has ended."""

    def __post_init__(self) -> None:
        """Verify settings post-initialization."""
@@ -514,9 +515,6 @@ class AudioSettings:
        if (self.auto_gain_dbfs < 0) or (self.auto_gain_dbfs > 31):
            raise ValueError("auto_gain_dbfs must be in [0, 31]")

-        if self.needs_processor and (not self.is_chunking_enabled):
-            raise ValueError("Chunking must be enabled for audio processing")
-
    @property
    def needs_processor(self) -> bool:
        """True if an audio processor is needed."""
@@ -527,20 +525,6 @@ class AudioSettings:
        )


-@dataclass(frozen=True, slots=True)
-class ProcessedAudioChunk:
-    """Processed audio chunk and metadata."""
-
-    audio: bytes
-    """Raw PCM audio @ 16Khz with 16-bit mono samples"""
-
-    timestamp_ms: int
-    """Timestamp relative to start of audio stream (milliseconds)"""
-
-    is_speech: bool | None
-    """True if audio chunk likely contains speech, False if not, None if unknown"""
-
-
@dataclass
 class PipelineRun:
    """Running context for a pipeline."""
@@ -573,10 +557,12 @@ class PipelineRun:
    debug_recording_queue: Queue[str | bytes | None] | None = None
    """Queue to communicate with debug recording thread"""

-    audio_processor: AudioProcessor | None = None
+    audio_enhancer: AudioEnhancer | None = None
    """VAD/noise suppression/auto gain"""

-    audio_processor_buffer: AudioBuffer = field(init=False, repr=False)
+    audio_chunking_buffer: AudioBuffer = field(
+        default_factory=lambda: AudioBuffer(BYTES_PER_CHUNK)
+    )
    """Buffer used when splitting audio into chunks for audio processing"""

    _device_id: str | None = None
@@ -601,17 +587,12 @@ class PipelineRun:
        pipeline_data.pipeline_runs.add_run(self)

        # Initialize with audio settings
-        self.audio_processor_buffer = AudioBuffer(AUDIO_PROCESSOR_BYTES)
-        if self.audio_settings.needs_processor:
-            # Delay import of webrtc so HA start up is not crashing
-            # on older architectures (armhf).
-            #
-            # pylint: disable=import-outside-toplevel
-            from webrtc_noise_gain import AudioProcessor
-
-            self.audio_processor = AudioProcessor(
+        if self.audio_settings.needs_processor and (self.audio_enhancer is None):
+            # Default audio enhancer
+            self.audio_enhancer = MicroVadEnhancer(
                self.audio_settings.auto_gain_dbfs,
                self.audio_settings.noise_suppression_level,
+                self.audio_settings.is_vad_enabled,
            )

    def __eq__(self, other: object) -> bool:
@@ -688,8 +669,8 @@ class PipelineRun:

    async def wake_word_detection(
        self,
-        stream: AsyncIterable[ProcessedAudioChunk],
-        audio_chunks_for_stt: list[ProcessedAudioChunk],
+        stream: AsyncIterable[EnhancedAudioChunk],
+        audio_chunks_for_stt: list[EnhancedAudioChunk],
    ) -> wake_word.DetectionResult | None:
        """Run wake-word-detection portion of pipeline. Returns detection result."""
        metadata_dict = asdict(
@@ -732,10 +713,11 @@ class PipelineRun:
        # Audio chunk buffer. This audio will be forwarded to speech-to-text
        # after wake-word-detection.
        num_audio_chunks_to_buffer = int(
-            (wake_word_settings.audio_seconds_to_buffer * 16000)
-            / AUDIO_PROCESSOR_SAMPLES
+            (wake_word_settings.audio_seconds_to_buffer * SAMPLE_RATE)
+            / SAMPLES_PER_CHUNK
        )
-        stt_audio_buffer: deque[ProcessedAudioChunk] | None = None
+
+        stt_audio_buffer: deque[EnhancedAudioChunk] | None = None
        if num_audio_chunks_to_buffer > 0:
            stt_audio_buffer = deque(maxlen=num_audio_chunks_to_buffer)

@@ -797,7 +779,7 @@ class PipelineRun:
                # speech-to-text so the user does not have to pause before
                # speaking the voice command.
                audio_chunks_for_stt.extend(
-                    ProcessedAudioChunk(
+                    EnhancedAudioChunk(
                        audio=chunk_ts[0], timestamp_ms=chunk_ts[1], is_speech=False
                    )
                    for chunk_ts in result.queued_audio
@@ -819,18 +801,17 @@ class PipelineRun:

    async def _wake_word_audio_stream(
        self,
-        audio_stream: AsyncIterable[ProcessedAudioChunk],
-        stt_audio_buffer: deque[ProcessedAudioChunk] | None,
+        audio_stream: AsyncIterable[EnhancedAudioChunk],
+        stt_audio_buffer: deque[EnhancedAudioChunk] | None,
        wake_word_vad: VoiceActivityTimeout | None,
-        sample_rate: int = 16000,
-        sample_width: int = 2,
+        sample_rate: int = SAMPLE_RATE,
+        sample_width: int = SAMPLE_WIDTH,
    ) -> AsyncIterable[tuple[bytes, int]]:
        """Yield audio chunks with timestamps (milliseconds since start of stream).

        Adds audio to a ring buffer that will be forwarded to speech-to-text after
        detection. Times out if VAD detects enough silence.
        """
-        chunk_seconds = AUDIO_PROCESSOR_SAMPLES / sample_rate
        async for chunk in audio_stream:
            if self.abort_wake_word_detection:
                raise WakeWordDetectionAborted
@@ -845,6 +826,7 @@ class PipelineRun:
                stt_audio_buffer.append(chunk)

            if wake_word_vad is not None:
+                chunk_seconds = (len(chunk.audio) // sample_width) / sample_rate
                if not wake_word_vad.process(chunk_seconds, chunk.is_speech):
                    raise WakeWordTimeoutError(
                        code="wake-word-timeout", message="Wake word was not detected"
@@ -881,7 +863,7 @@ class PipelineRun:
    async def speech_to_text(
        self,
        metadata: stt.SpeechMetadata,
-        stream: AsyncIterable[ProcessedAudioChunk],
+        stream: AsyncIterable[EnhancedAudioChunk],
    ) -> str:
        """Run speech-to-text portion of pipeline. Returns the spoken text."""
        # Create a background task to prepare the conversation agent
@@ -916,7 +898,9 @@ class PipelineRun:
            # Transcribe audio stream
            stt_vad: VoiceCommandSegmenter | None = None
            if self.audio_settings.is_vad_enabled:
-                stt_vad = VoiceCommandSegmenter()
+                stt_vad = VoiceCommandSegmenter(
+                    silence_seconds=self.audio_settings.silence_seconds
+                )

            result = await self.stt_provider.async_process_audio_stream(
                metadata,
@@ -957,18 +941,18 @@ class PipelineRun:

    async def _speech_to_text_stream(
        self,
-        audio_stream: AsyncIterable[ProcessedAudioChunk],
+        audio_stream: AsyncIterable[EnhancedAudioChunk],
        stt_vad: VoiceCommandSegmenter | None,
-        sample_rate: int = 16000,
-        sample_width: int = 2,
+        sample_rate: int = SAMPLE_RATE,
+        sample_width: int = SAMPLE_WIDTH,
    ) -> AsyncGenerator[bytes]:
        """Yield audio chunks until VAD detects silence or speech-to-text completes."""
-        chunk_seconds = AUDIO_PROCESSOR_SAMPLES / sample_rate
        sent_vad_start = False
        async for chunk in audio_stream:
            self._capture_chunk(chunk.audio)

            if stt_vad is not None:
+                chunk_seconds = (len(chunk.audio) // sample_width) / sample_rate
                if not stt_vad.process(chunk_seconds, chunk.is_speech):
                    # Silence detected at the end of voice command
                    self.process_event(
@@ -1072,8 +1056,8 @@ class PipelineRun:
            tts_options[tts.ATTR_PREFERRED_FORMAT] = self.tts_audio_output
            if self.tts_audio_output == "wav":
                # 16 Khz, 16-bit mono
-                tts_options[tts.ATTR_PREFERRED_SAMPLE_RATE] = 16000
-                tts_options[tts.ATTR_PREFERRED_SAMPLE_CHANNELS] = 1
+                tts_options[tts.ATTR_PREFERRED_SAMPLE_RATE] = SAMPLE_RATE
+                tts_options[tts.ATTR_PREFERRED_SAMPLE_CHANNELS] = SAMPLE_CHANNELS

        try:
            options_supported = await tts.async_support_options(
@@ -1218,53 +1202,31 @@ class PipelineRun:
        self.debug_recording_thread = None

    async def process_volume_only(
-        self,
-        audio_stream: AsyncIterable[bytes],
-        sample_rate: int = 16000,
-        sample_width: int = 2,
-    ) -> AsyncGenerator[ProcessedAudioChunk]:
+        self, audio_stream: AsyncIterable[bytes]
+    ) -> AsyncGenerator[EnhancedAudioChunk]:
        """Apply volume transformation only (no VAD/audio enhancements) with optional chunking."""
-        ms_per_sample = sample_rate // 1000
-        ms_per_chunk = (AUDIO_PROCESSOR_SAMPLES // sample_width) // ms_per_sample
        timestamp_ms = 0
-
        async for chunk in audio_stream:
            if self.audio_settings.volume_multiplier != 1.0:
                chunk = _multiply_volume(chunk, self.audio_settings.volume_multiplier)

-            if self.audio_settings.is_chunking_enabled:
-                # 10 ms chunking
-                for chunk_10ms in chunk_samples(
-                    chunk, AUDIO_PROCESSOR_BYTES, self.audio_processor_buffer
-                ):
-                    yield ProcessedAudioChunk(
-                        audio=chunk_10ms,
-                        timestamp_ms=timestamp_ms,
-                        is_speech=None,  # no VAD
-                    )
-                    timestamp_ms += ms_per_chunk
-            else:
-                # No chunking
-                yield ProcessedAudioChunk(
-                    audio=chunk,
+            for sub_chunk in chunk_samples(
+                chunk, BYTES_PER_CHUNK, self.audio_chunking_buffer
+            ):
+                yield EnhancedAudioChunk(
+                    audio=sub_chunk,
                    timestamp_ms=timestamp_ms,
                    is_speech=None,  # no VAD
                )
-                timestamp_ms += (len(chunk) // sample_width) // ms_per_sample
+                timestamp_ms += MS_PER_CHUNK

    async def process_enhance_audio(
-        self,
-        audio_stream: AsyncIterable[bytes],
-        sample_rate: int = 16000,
-        sample_width: int = 2,
-    ) -> AsyncGenerator[ProcessedAudioChunk]:
-        """Split audio into 10 ms chunks and apply VAD/noise suppression/auto gain/volume transformation."""
-        assert self.audio_processor is not None
+        self, audio_stream: AsyncIterable[bytes]
+    ) -> AsyncGenerator[EnhancedAudioChunk]:
+        """Split audio into chunks and apply VAD/noise suppression/auto gain/volume transformation."""
+        assert self.audio_enhancer is not None

-        ms_per_sample = sample_rate // 1000
-        ms_per_chunk = (AUDIO_PROCESSOR_SAMPLES // sample_width) // ms_per_sample
        timestamp_ms = 0
-
        async for dirty_samples in audio_stream:
            if self.audio_settings.volume_multiplier != 1.0:
                # Static gain
@@ -1272,18 +1234,12 @@ class PipelineRun:
                    dirty_samples, self.audio_settings.volume_multiplier
                )

-            # Split into 10ms chunks for audio enhancements/VAD
-            for dirty_10ms_chunk in chunk_samples(
-                dirty_samples, AUDIO_PROCESSOR_BYTES, self.audio_processor_buffer
+            # Split into chunks for audio enhancements/VAD
+            for dirty_chunk in chunk_samples(
+                dirty_samples, BYTES_PER_CHUNK, self.audio_chunking_buffer
            ):
-                ap_result = self.audio_processor.Process10ms(dirty_10ms_chunk)
-                yield ProcessedAudioChunk(
-                    audio=ap_result.audio,
-                    timestamp_ms=timestamp_ms,
-                    is_speech=ap_result.is_speech,
-                )
-
-                timestamp_ms += ms_per_chunk
+                yield self.audio_enhancer.enhance_chunk(dirty_chunk, timestamp_ms)
+                timestamp_ms += MS_PER_CHUNK


 def _multiply_volume(chunk: bytes, volume_multiplier: float) -> bytes:
@@ -1323,9 +1279,9 @@ def _pipeline_debug_recording_thread_proc(

                wav_path = run_recording_dir / f"{message}.wav"
                wav_writer = wave.open(str(wav_path), "wb")
-                wav_writer.setframerate(16000)
-                wav_writer.setsampwidth(2)
-                wav_writer.setnchannels(1)
+                wav_writer.setframerate(SAMPLE_RATE)
+                wav_writer.setsampwidth(SAMPLE_WIDTH)
+                wav_writer.setnchannels(SAMPLE_CHANNELS)
            elif isinstance(message, bytes):
                # Chunk of 16-bit mono audio at 16Khz
                if wav_writer is not None:
@@ -1368,8 +1324,8 @@ class PipelineInput:
        """Run pipeline."""
        self.run.start(device_id=self.device_id)
        current_stage: PipelineStage | None = self.run.start_stage
-        stt_audio_buffer: list[ProcessedAudioChunk] = []
-        stt_processed_stream: AsyncIterable[ProcessedAudioChunk] | None = None
+        stt_audio_buffer: list[EnhancedAudioChunk] = []
+        stt_processed_stream: AsyncIterable[EnhancedAudioChunk] | None = None

        if self.stt_stream is not None:
            if self.run.audio_settings.needs_processor:
@@ -1423,7 +1379,7 @@ class PipelineInput:
                    # Send audio in the buffer first to speech-to-text, then move on to stt_stream.
                    # This is basically an async itertools.chain.
                    async def buffer_then_audio_stream() -> (
-                        AsyncGenerator[ProcessedAudioChunk]
+                        AsyncGenerator[EnhancedAudioChunk]
                    ):
                        # Buffered audio
                        for chunk in stt_audio_buffer:
--- a/homeassistant/components/assist_pipeline/vad.py
+++ b/homeassistant/components/assist_pipeline/vad.py
@@ -2,11 +2,13 @@

 from __future__ import annotations

-from abc import ABC, abstractmethod
-from collections.abc import Iterable
+from collections.abc import Callable, Iterable
 from dataclasses import dataclass
 from enum import StrEnum
-from typing import Final, cast
+import logging
+from typing import Final
+
+_LOGGER = logging.getLogger(__name__)

 _SAMPLE_RATE: Final = 16000  # Hz
 _SAMPLE_WIDTH: Final = 2  # bytes
@@ -32,44 +34,6 @@ class VadSensitivity(StrEnum):
        return 1.0


-class VoiceActivityDetector(ABC):
-    """Base class for voice activity detectors (VAD)."""
-
-    @abstractmethod
-    def is_speech(self, chunk: bytes) -> bool:
-        """Return True if audio chunk contains speech."""
-
-    @property
-    @abstractmethod
-    def samples_per_chunk(self) -> int | None:
-        """Return number of samples per chunk or None if chunking is not required."""
-
-
-class WebRtcVad(VoiceActivityDetector):
-    """Voice activity detector based on webrtc."""
-
-    def __init__(self) -> None:
-        """Initialize webrtcvad."""
-        # Delay import of webrtc so HA start up is not crashing
-        # on older architectures (armhf).
-        #
-        # pylint: disable=import-outside-toplevel
-        from webrtc_noise_gain import AudioProcessor
-
-        # Just VAD: no noise suppression or auto gain
-        self._audio_processor = AudioProcessor(0, 0)
-
-    def is_speech(self, chunk: bytes) -> bool:
-        """Return True if audio chunk contains speech."""
-        result = self._audio_processor.Process10ms(chunk)
-        return cast(bool, result.is_speech)
-
-    @property
-    def samples_per_chunk(self) -> int | None:
-        """Return 10 ms."""
-        return int(0.01 * _SAMPLE_RATE)  # 10 ms
-
-
 class AudioBuffer:
    """Fixed-sized audio buffer with variable internal length."""

@@ -116,7 +80,7 @@ class VoiceCommandSegmenter:
    speech_seconds: float = 0.3
    """Seconds of speech before voice command has started."""

-    silence_seconds: float = 0.5
+    silence_seconds: float = 1.0
    """Seconds of silence after voice command has ended."""

    timeout_seconds: float = 15.0
@@ -159,6 +123,10 @@ class VoiceCommandSegmenter:
        """
        self._timeout_seconds_left -= chunk_seconds
        if self._timeout_seconds_left <= 0:
+            _LOGGER.warning(
+                "VAD end of speech detection timed out after %s seconds",
+                self.timeout_seconds,
+            )
            self.reset()
            return False

@@ -169,29 +137,38 @@ class VoiceCommandSegmenter:
                if self._speech_seconds_left <= 0:
                    # Inside voice command
                    self.in_command = True
+                    self._silence_seconds_left = self.silence_seconds
+                    _LOGGER.debug("Voice command started")
            else:
                # Reset if enough silence
                self._reset_seconds_left -= chunk_seconds
                if self._reset_seconds_left <= 0:
                    self._speech_seconds_left = self.speech_seconds
+                    self._reset_seconds_left = self.reset_seconds
        elif not is_speech:
+            # Silence in command
            self._reset_seconds_left = self.reset_seconds
            self._silence_seconds_left -= chunk_seconds
            if self._silence_seconds_left <= 0:
+                # Command finished successfully
                self.reset()
+                _LOGGER.debug("Voice command finished")
                return False
        else:
-            # Reset if enough speech
+            # Speech in command.
+            # Reset silence counter if enough speech.
            self._reset_seconds_left -= chunk_seconds
            if self._reset_seconds_left <= 0:
                self._silence_seconds_left = self.silence_seconds
+                self._reset_seconds_left = self.reset_seconds

        return True

    def process_with_vad(
        self,
        chunk: bytes,
-        vad: VoiceActivityDetector,
+        vad_samples_per_chunk: int | None,
+        vad_is_speech: Callable[[bytes], bool],
        leftover_chunk_buffer: AudioBuffer | None,
    ) -> bool:
        """Process an audio chunk using an external VAD.
@@ -200,20 +177,20 @@ class VoiceCommandSegmenter:

        Returns False when voice command is finished.
        """
-        if vad.samples_per_chunk is None:
+        if vad_samples_per_chunk is None:
            # No chunking
            chunk_seconds = (len(chunk) // _SAMPLE_WIDTH) / _SAMPLE_RATE
-            is_speech = vad.is_speech(chunk)
+            is_speech = vad_is_speech(chunk)
            return self.process(chunk_seconds, is_speech)

        if leftover_chunk_buffer is None:
            raise ValueError("leftover_chunk_buffer is required when vad uses chunking")

        # With chunking
-        seconds_per_chunk = vad.samples_per_chunk / _SAMPLE_RATE
-        bytes_per_chunk = vad.samples_per_chunk * _SAMPLE_WIDTH
+        seconds_per_chunk = vad_samples_per_chunk / _SAMPLE_RATE
+        bytes_per_chunk = vad_samples_per_chunk * _SAMPLE_WIDTH
        for vad_chunk in chunk_samples(chunk, bytes_per_chunk, leftover_chunk_buffer):
-            is_speech = vad.is_speech(vad_chunk)
+            is_speech = vad_is_speech(vad_chunk)
            if not self.process(seconds_per_chunk, is_speech):
                return False

--- a/homeassistant/components/assist_pipeline/websocket_api.py
+++ b/homeassistant/components/assist_pipeline/websocket_api.py
@@ -24,6 +24,9 @@ from .const import (
    DEFAULT_WAKE_WORD_TIMEOUT,
    DOMAIN,
    EVENT_RECORDING,
+    SAMPLE_CHANNELS,
+    SAMPLE_RATE,
+    SAMPLE_WIDTH,
 )
 from .error import PipelineNotFound
 from .pipeline import (
@@ -92,7 +95,6 @@ def async_register_websocket_api(hass: HomeAssistant) -> None:
                            vol.Optional("volume_multiplier"): float,
                            # Advanced use cases/testing
                            vol.Optional("no_vad"): bool,
-                            vol.Optional("no_chunking"): bool,
                        }
                    },
                    extra=vol.ALLOW_EXTRA,
@@ -170,9 +172,14 @@ async def websocket_run(

            # Yield until we receive an empty chunk
            while chunk := await audio_queue.get():
-                if incoming_sample_rate != 16000:
+                if incoming_sample_rate != SAMPLE_RATE:
                    chunk, state = audioop.ratecv(
-                        chunk, 2, 1, incoming_sample_rate, 16000, state
+                        chunk,
+                        SAMPLE_WIDTH,
+                        SAMPLE_CHANNELS,
+                        incoming_sample_rate,
+                        SAMPLE_RATE,
+                        state,
                    )
                yield chunk

@@ -206,7 +213,6 @@ async def websocket_run(
            auto_gain_dbfs=msg_input.get("auto_gain_dbfs", 0),
            volume_multiplier=msg_input.get("volume_multiplier", 1.0),
            is_vad_enabled=not msg_input.get("no_vad", False),
-            is_chunking_enabled=not msg_input.get("no_chunking", False),
        )
    elif start_stage == PipelineStage.INTENT:
        # Input to conversation agent
@@ -424,9 +430,9 @@ def websocket_list_languages(
    connection.send_result(
        msg["id"],
        {
-            "languages": sorted(pipeline_languages)
-            if pipeline_languages
-            else pipeline_languages
+            "languages": (
+                sorted(pipeline_languages) if pipeline_languages else pipeline_languages
+            )
        },
    )

--- a/homeassistant/components/august/binary_sensor.py
+++ b/homeassistant/components/august/binary_sensor.py
@@ -81,6 +81,7 @@ SENSOR_TYPES_VIDEO_DOORBELL = (
 SENSOR_TYPES_DOORBELL: tuple[AugustDoorbellBinarySensorEntityDescription, ...] = (
    AugustDoorbellBinarySensorEntityDescription(
        key="ding",
+        translation_key="ding",
        device_class=BinarySensorDeviceClass.OCCUPANCY,
        value_fn=retrieve_ding_activity,
        is_time_based=True,
--- a/homeassistant/components/august/const.py
+++ b/homeassistant/components/august/const.py
@@ -16,8 +16,6 @@ NOTIFICATION_TITLE = "August"

 MANUFACTURER = "August Home Inc."

-DEFAULT_AUGUST_CONFIG_FILE = ".august.conf"
-
 DEFAULT_NAME = "August"
 DOMAIN = "august"

--- a/homeassistant/components/august/strings.json
+++ b/homeassistant/components/august/strings.json
@@ -40,6 +40,9 @@
  },
  "entity": {
    "binary_sensor": {
+      "ding": {
+        "name": "Doorbell ding"
+      },
      "image_capture": {
        "name": "Image capture"
      }
--- a/homeassistant/components/auth/indieauth.py
+++ b/homeassistant/components/auth/indieauth.py
@@ -94,7 +94,7 @@ async def fetch_redirect_uris(hass: HomeAssistant, url: str) -> list[str]:
    try:
        async with (
            aiohttp.ClientSession() as session,
-            session.get(url, timeout=5) as resp,
+            session.get(url, timeout=aiohttp.ClientTimeout(total=5)) as resp,
        ):
            async for data in resp.content.iter_chunked(1024):
                parser.feed(data.decode())
--- a/homeassistant/components/axis/init.py
+++ b/homeassistant/components/axis/init.py
@@ -7,7 +7,7 @@ from homeassistant.const import EVENT_HOMEASSISTANT_STOP
 from homeassistant.core import HomeAssistant
 from homeassistant.exceptions import ConfigEntryAuthFailed, ConfigEntryNotReady

-from .const import DOMAIN as AXIS_DOMAIN, PLATFORMS
+from .const import PLATFORMS
 from .errors import AuthenticationRequired, CannotConnect
 from .hub import AxisHub, get_axis_api

@@ -18,8 +18,6 @@ type AxisConfigEntry = ConfigEntry[AxisHub]

 async def async_setup_entry(hass: HomeAssistant, config_entry: AxisConfigEntry) -> bool:
    """Set up the Axis integration."""
-    hass.data.setdefault(AXIS_DOMAIN, {})
-
    try:
        api = await get_axis_api(hass, config_entry.data)
    except CannotConnect as err:
--- a/homeassistant/components/azure_data_explorer/init.py
+++ b/homeassistant/components/azure_data_explorer/init.py
@@ -18,7 +18,7 @@ from homeassistant.core import Event, HomeAssistant, State
 from homeassistant.exceptions import ConfigEntryError
 from homeassistant.helpers.entityfilter import FILTER_SCHEMA
 from homeassistant.helpers.event import async_call_later
-from homeassistant.helpers.json import JSONEncoder
+from homeassistant.helpers.json import ExtendedJSONEncoder
 from homeassistant.helpers.typing import ConfigType
 from homeassistant.util.dt import utcnow

@@ -203,9 +203,7 @@ class AzureDataExplorer:
            return None, dropped
        if (utcnow() - time_fired).seconds > DEFAULT_MAX_DELAY + self._send_interval:
            return None, dropped + 1
-        if "\n" in state.state:
-            return None, dropped + 1

-        json_event = json.dumps(obj=state, cls=JSONEncoder)
+        json_event = json.dumps(obj=state, cls=ExtendedJSONEncoder)

        return (json_event, dropped)
--- a/homeassistant/components/azure_data_explorer/client.py
+++ b/homeassistant/components/azure_data_explorer/client.py
@@ -68,7 +68,7 @@ class AzureDataExplorerClient:
            # Queued is the only option supported on free tier of ADX
            self.write_client = QueuedIngestClient(kcsb_ingest)
        else:
-            self.write_client = ManagedStreamingIngestClient.from_dm_kcsb(kcsb_ingest)
+            self.write_client = ManagedStreamingIngestClient(kcsb_ingest)

        self.query_client = KustoClient(kcsb_query)

--- a/homeassistant/components/azure_data_explorer/manifest.json
+++ b/homeassistant/components/azure_data_explorer/manifest.json
@@ -6,5 +6,5 @@
  "documentation": "https://www.home-assistant.io/integrations/azure_data_explorer",
  "iot_class": "cloud_push",
  "loggers": ["azure"],
-  "requirements": ["azure-kusto-ingest==3.1.0", "azure-kusto-data[aio]==3.1.0"]
+  "requirements": ["azure-kusto-ingest==4.5.1", "azure-kusto-data[aio]==4.5.1"]
 }
--- a/homeassistant/components/baf/fan.py
+++ b/homeassistant/components/baf/fan.py
@@ -43,7 +43,10 @@ class BAFFan(BAFEntity, FanEntity):
        FanEntityFeature.SET_SPEED
        | FanEntityFeature.DIRECTION
        | FanEntityFeature.PRESET_MODE
+        | FanEntityFeature.TURN_OFF
+        | FanEntityFeature.TURN_ON
    )
+    _enable_turn_on_off_backwards_compatibility = False
    _attr_preset_modes = [PRESET_MODE_AUTO]
    _attr_speed_count = SPEED_COUNT
    _attr_name = None
--- a/homeassistant/components/balboa/fan.py
+++ b/homeassistant/components/balboa/fan.py
@@ -32,7 +32,12 @@ async def async_setup_entry(
 class BalboaPumpFanEntity(BalboaEntity, FanEntity):
    """Representation of a Balboa Spa pump fan entity."""

-    _attr_supported_features = FanEntityFeature.SET_SPEED
+    _attr_supported_features = (
+        FanEntityFeature.SET_SPEED
+        | FanEntityFeature.TURN_OFF
+        | FanEntityFeature.TURN_ON
+    )
+    _enable_turn_on_off_backwards_compatibility = False
    _attr_translation_key = "pump"

    def __init__(self, control: SpaControl) -> None:
--- a/homeassistant/components/bang_olufsen/config_flow.py
+++ b/homeassistant/components/bang_olufsen/config_flow.py
@@ -135,6 +135,15 @@ class BangOlufsenConfigFlowHandler(ConfigFlow, domain=DOMAIN):
        except AddressValueError:
            return self.async_abort(reason="ipv6_address")

+        # Check connection to ensure valid address is received
+        self._client = MozartClient(self._host)
+
+        async with self._client:
+            try:
+                await self._client.get_beolink_self(_request_timeout=3)
+            except (ClientConnectorError, TimeoutError):
+                return self.async_abort(reason="invalid_address")
+
        self._model = discovery_info.hostname[:-16].replace("-", " ")
        self._serial_number = discovery_info.properties[ATTR_SERIAL_NUMBER]
        self._beolink_jid = f"{discovery_info.properties[ATTR_TYPE_NUMBER]}.{discovery_info.properties[ATTR_ITEM_NUMBER]}.{self._serial_number}@products.bang-olufsen.com"
--- a/homeassistant/components/blueprint/importer.py
+++ b/homeassistant/components/blueprint/importer.py
@@ -245,14 +245,36 @@ async def fetch_blueprint_from_website_url(
    return ImportedBlueprint(suggested_filename, raw_yaml, blueprint)


+async def fetch_blueprint_from_generic_url(
+    hass: HomeAssistant, url: str
+) -> ImportedBlueprint:
+    """Get a blueprint from a generic website."""
+    session = aiohttp_client.async_get_clientsession(hass)
+
+    resp = await session.get(url, raise_for_status=True)
+    raw_yaml = await resp.text()
+    data = yaml.parse_yaml(raw_yaml)
+
+    assert isinstance(data, dict)
+    blueprint = Blueprint(data)
+
+    parsed_import_url = yarl.URL(url)
+    suggested_filename = f"{parsed_import_url.host}/{parsed_import_url.parts[-1][:-5]}"
+    return ImportedBlueprint(suggested_filename, raw_yaml, blueprint)
+
+
+FETCH_FUNCTIONS = (
+    fetch_blueprint_from_community_post,
+    fetch_blueprint_from_github_url,
+    fetch_blueprint_from_github_gist_url,
+    fetch_blueprint_from_website_url,
+    fetch_blueprint_from_generic_url,
+)
+
+
 async def fetch_blueprint_from_url(hass: HomeAssistant, url: str) -> ImportedBlueprint:
    """Get a blueprint from a url."""
-    for func in (
-        fetch_blueprint_from_community_post,
-        fetch_blueprint_from_github_url,
-        fetch_blueprint_from_github_gist_url,
-        fetch_blueprint_from_website_url,
-    ):
+    for func in FETCH_FUNCTIONS:
        with suppress(UnsupportedUrl):
            imported_bp = await func(hass, url)
            imported_bp.blueprint.update_metadata(source_url=url)
--- a/homeassistant/components/blueprint/models.py
+++ b/homeassistant/components/blueprint/models.py
@@ -21,7 +21,7 @@ from homeassistant.const import (
    CONF_PATH,
    __version__,
 )
-from homeassistant.core import DOMAIN as HA_DOMAIN, HomeAssistant, callback
+from homeassistant.core import DOMAIN as HOMEASSISTANT_DOMAIN, HomeAssistant, callback
 from homeassistant.exceptions import HomeAssistantError
 from homeassistant.util import yaml

@@ -372,7 +372,7 @@ class DomainBlueprints:

            shutil.copytree(
                integration.file_path / BLUEPRINT_FOLDER,
-                self.blueprint_folder / HA_DOMAIN,
+                self.blueprint_folder / HOMEASSISTANT_DOMAIN,
            )

        await self.hass.async_add_executor_job(populate)
--- a/homeassistant/components/bluesound/init.py
+++ b/homeassistant/components/bluesound/init.py
@@ -1 +1,70 @@
 """The bluesound component."""
+
+from dataclasses import dataclass
+
+import aiohttp
+from pyblu import Player, SyncStatus
+
+from homeassistant.config_entries import ConfigEntry
+from homeassistant.const import CONF_HOST, CONF_PORT, Platform
+from homeassistant.core import HomeAssistant
+from homeassistant.exceptions import ConfigEntryNotReady
+from homeassistant.helpers import config_validation as cv
+from homeassistant.helpers.aiohttp_client import async_get_clientsession
+from homeassistant.helpers.typing import ConfigType
+
+from .const import DOMAIN
+from .media_player import setup_services
+
+CONFIG_SCHEMA = cv.config_entry_only_config_schema(DOMAIN)
+
+PLATFORMS = [Platform.MEDIA_PLAYER]
+
+
+@dataclass
+class BluesoundData:
+    """Bluesound data class."""
+
+    player: Player
+    sync_status: SyncStatus
+
+
+type BluesoundConfigEntry = ConfigEntry[BluesoundData]
+
+
+async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
+    """Set up the Bluesound."""
+    if DOMAIN not in hass.data:
+        hass.data[DOMAIN] = []
+    setup_services(hass)
+
+    return True
+
+
+async def async_setup_entry(
+    hass: HomeAssistant, config_entry: BluesoundConfigEntry
+) -> bool:
+    """Set up the Bluesound entry."""
+    host = config_entry.data[CONF_HOST]
+    port = config_entry.data[CONF_PORT]
+    session = async_get_clientsession(hass)
+    async with Player(host, port, session=session, default_timeout=10) as player:
+        try:
+            sync_status = await player.sync_status(timeout=1)
+        except TimeoutError as ex:
+            raise ConfigEntryNotReady(
+                f"Timeout while connecting to {host}:{port}"
+            ) from ex
+        except aiohttp.ClientError as ex:
+            raise ConfigEntryNotReady(f"Error connecting to {host}:{port}") from ex
+
+    config_entry.runtime_data = BluesoundData(player, sync_status)
+
+    await hass.config_entries.async_forward_entry_setups(config_entry, PLATFORMS)
+
+    return True
+
+
+async def async_unload_entry(hass: HomeAssistant, config_entry: ConfigEntry) -> bool:
+    """Unload a config entry."""
+    return await hass.config_entries.async_unload_platforms(config_entry, PLATFORMS)
--- a/homeassistant/components/bluesound/config_flow.py
+++ b/homeassistant/components/bluesound/config_flow.py
@@ -0,0 +1,150 @@
+"""Config flow for bluesound."""
+
+import logging
+from typing import Any
+
+import aiohttp
+from pyblu import Player, SyncStatus
+import voluptuous as vol
+
+from homeassistant.components import zeroconf
+from homeassistant.config_entries import ConfigFlow, ConfigFlowResult
+from homeassistant.const import CONF_HOST, CONF_PORT
+from homeassistant.helpers.aiohttp_client import async_get_clientsession
+
+from .const import DOMAIN
+from .media_player import DEFAULT_PORT
+from .utils import format_unique_id
+
+_LOGGER = logging.getLogger(__name__)
+
+
+class BluesoundConfigFlow(ConfigFlow, domain=DOMAIN):
+    """Bluesound config flow."""
+
+    VERSION = 1
+    MINOR_VERSION = 1
+
+    def __init__(self) -> None:
+        """Initialize the config flow."""
+        self._host: str | None = None
+        self._port = DEFAULT_PORT
+        self._sync_status: SyncStatus | None = None
+
+    async def async_step_user(
+        self, user_input: dict[str, Any] | None = None
+    ) -> ConfigFlowResult:
+        """Handle a flow initiated by the user."""
+        errors: dict[str, str] = {}
+        if user_input is not None:
+            session = async_get_clientsession(self.hass)
+            async with Player(
+                user_input[CONF_HOST], user_input[CONF_PORT], session=session
+            ) as player:
+                try:
+                    sync_status = await player.sync_status(timeout=1)
+                except (TimeoutError, aiohttp.ClientError):
+                    errors["base"] = "cannot_connect"
+                else:
+                    await self.async_set_unique_id(
+                        format_unique_id(sync_status.mac, user_input[CONF_PORT])
+                    )
+                    self._abort_if_unique_id_configured(
+                        updates={
+                            CONF_HOST: user_input[CONF_HOST],
+                        }
+                    )
+
+                    return self.async_create_entry(
+                        title=sync_status.name,
+                        data=user_input,
+                    )
+
+        return self.async_show_form(
+            step_id="user",
+            errors=errors,
+            data_schema=vol.Schema(
+                {
+                    vol.Required(CONF_HOST): str,
+                    vol.Optional(CONF_PORT, default=11000): int,
+                }
+            ),
+        )
+
+    async def async_step_import(self, import_data: dict[str, Any]) -> ConfigFlowResult:
+        """Import bluesound config entry from configuration.yaml."""
+        session = async_get_clientsession(self.hass)
+        async with Player(
+            import_data[CONF_HOST], import_data[CONF_PORT], session=session
+        ) as player:
+            try:
+                sync_status = await player.sync_status(timeout=1)
+            except (TimeoutError, aiohttp.ClientError):
+                return self.async_abort(reason="cannot_connect")
+
+        await self.async_set_unique_id(
+            format_unique_id(sync_status.mac, import_data[CONF_PORT])
+        )
+        self._abort_if_unique_id_configured()
+
+        return self.async_create_entry(
+            title=sync_status.name,
+            data=import_data,
+        )
+
+    async def async_step_zeroconf(
+        self, discovery_info: zeroconf.ZeroconfServiceInfo
+    ) -> ConfigFlowResult:
+        """Handle a flow initialized by zeroconf discovery."""
+        if discovery_info.port is not None:
+            self._port = discovery_info.port
+
+        session = async_get_clientsession(self.hass)
+        try:
+            async with Player(
+                discovery_info.host, self._port, session=session
+            ) as player:
+                sync_status = await player.sync_status(timeout=1)
+        except (TimeoutError, aiohttp.ClientError):
+            return self.async_abort(reason="cannot_connect")
+
+        await self.async_set_unique_id(format_unique_id(sync_status.mac, self._port))
+
+        self._host = discovery_info.host
+        self._sync_status = sync_status
+
+        self._abort_if_unique_id_configured(
+            updates={
+                CONF_HOST: self._host,
+            }
+        )
+
+        self.context.update(
+            {
+                "title_placeholders": {"name": sync_status.name},
+                "configuration_url": f"http://{discovery_info.host}",
+            }
+        )
+        return await self.async_step_confirm()
+
+    async def async_step_confirm(self, user_input=None) -> ConfigFlowResult:
+        """Confirm the zeroconf setup."""
+        assert self._sync_status is not None
+        assert self._host is not None
+
+        if user_input is not None:
+            return self.async_create_entry(
+                title=self._sync_status.name,
+                data={
+                    CONF_HOST: self._host,
+                    CONF_PORT: self._port,
+                },
+            )
+
+        return self.async_show_form(
+            step_id="confirm",
+            description_placeholders={
+                "name": self._sync_status.name,
+                "host": self._host,
+            },
+        )
--- a/homeassistant/components/bluesound/const.py
+++ b/homeassistant/components/bluesound/const.py
@@ -1,7 +1,10 @@
 """Constants for the Bluesound HiFi wireless speakers and audio integrations component."""

 DOMAIN = "bluesound"
+INTEGRATION_TITLE = "Bluesound"
 SERVICE_CLEAR_TIMER = "clear_sleep_timer"
 SERVICE_JOIN = "join"
 SERVICE_SET_TIMER = "set_sleep_timer"
 SERVICE_UNJOIN = "unjoin"
+ATTR_BLUESOUND_GROUP = "bluesound_group"
+ATTR_MASTER = "master"
--- a/homeassistant/components/bluesound/manifest.json
+++ b/homeassistant/components/bluesound/manifest.json
@@ -1,8 +1,15 @@
 {
  "domain": "bluesound",
  "name": "Bluesound",
-  "codeowners": ["@thrawnarn"],
+  "after_dependencies": ["zeroconf"],
+  "codeowners": ["@thrawnarn", "@LouisChrist"],
+  "config_flow": true,
  "documentation": "https://www.home-assistant.io/integrations/bluesound",
  "iot_class": "local_polling",
-  "requirements": ["xmltodict==0.13.0"]
+  "requirements": ["pyblu==0.4.0"],
+  "zeroconf": [
+    {
+      "type": "_musc._tcp.local."
+    }
+  ]
 }
--- a/homeassistant/components/bluesound/media_player.py
+++ b/homeassistant/components/bluesound/media_player.py
--- a/homeassistant/components/bluesound/strings.json
+++ b/homeassistant/components/bluesound/strings.json
@@ -1,4 +1,30 @@
 {
+  "config": {
+    "step": {
+      "user": {
+        "data": {
+          "host": "[%key:common::config_flow::data::host%]",
+          "port": "[%key:common::config_flow::data::port%]"
+        },
+        "data_description": {
+          "host": "Hostname or IP address of your Bluesound player",
+          "port": "Port of your Bluesound player. This is usually 11000."
+        }
+      },
+      "confirm": {
+        "title": "Discover Bluesound player",
+        "description": "[%key:common::config_flow::description::confirm_setup%]"
+      }
+    },
+    "abort": {
+      "already_configured": "[%key:common::config_flow::abort::already_configured_service%]",
+      "cannot_connect": "[%key:common::config_flow::error::cannot_connect%]",
+      "already_in_progress": "[%key:common::config_flow::abort::already_in_progress%]"
+    },
+    "error": {
+      "cannot_connect": "[%key:common::config_flow::error::cannot_connect%]"
+    }
+  },
  "services": {
    "join": {
      "name": "Join",
--- a/homeassistant/components/bluesound/utils.py
+++ b/homeassistant/components/bluesound/utils.py
@@ -0,0 +1,8 @@
+"""Utility functions for the Bluesound component."""
+
+from homeassistant.helpers.device_registry import format_mac
+
+
+def format_unique_id(mac: str, port: int) -> str:
+    """Generate a unique ID based on the MAC address and port number."""
+    return f"{format_mac(mac)}-{port}"
--- a/homeassistant/components/bluetooth/manifest.json
+++ b/homeassistant/components/bluetooth/manifest.json
@@ -18,7 +18,7 @@
    "bleak-retry-connector==3.5.0",
    "bluetooth-adapters==0.19.3",
    "bluetooth-auto-recovery==1.4.2",
-    "bluetooth-data-tools==1.19.3",
+    "bluetooth-data-tools==1.19.4",
    "dbus-fast==2.22.1",
    "habluetooth==3.1.3"
  ]
--- a/homeassistant/components/bluetooth/match.py
+++ b/homeassistant/components/bluetooth/match.py
@@ -2,6 +2,7 @@

 from __future__ import annotations

+from collections import defaultdict
 from dataclasses import dataclass
 from fnmatch import translate
 from functools import lru_cache
@@ -173,10 +174,10 @@ class BluetoothMatcherIndexBase[

    def __init__(self) -> None:
        """Initialize the matcher index."""
-        self.local_name: dict[str, list[_T]] = {}
-        self.service_uuid: dict[str, list[_T]] = {}
-        self.service_data_uuid: dict[str, list[_T]] = {}
-        self.manufacturer_id: dict[int, list[_T]] = {}
+        self.local_name: defaultdict[str, list[_T]] = defaultdict(list)
+        self.service_uuid: defaultdict[str, list[_T]] = defaultdict(list)
+        self.service_data_uuid: defaultdict[str, list[_T]] = defaultdict(list)
+        self.manufacturer_id: defaultdict[int, list[_T]] = defaultdict(list)
        self.service_uuid_set: set[str] = set()
        self.service_data_uuid_set: set[str] = set()
        self.manufacturer_id_set: set[int] = set()
@@ -190,26 +191,22 @@ class BluetoothMatcherIndexBase[
        """
        # Local name is the cheapest to match since its just a dict lookup
        if LOCAL_NAME in matcher:
-            self.local_name.setdefault(
-                _local_name_to_index_key(matcher[LOCAL_NAME]), []
-            ).append(matcher)
+            self.local_name[_local_name_to_index_key(matcher[LOCAL_NAME])].append(
+                matcher
+            )
            return True

        # Manufacturer data is 2nd cheapest since its all ints
        if MANUFACTURER_ID in matcher:
-            self.manufacturer_id.setdefault(matcher[MANUFACTURER_ID], []).append(
-                matcher
-            )
+            self.manufacturer_id[matcher[MANUFACTURER_ID]].append(matcher)
            return True

        if SERVICE_UUID in matcher:
-            self.service_uuid.setdefault(matcher[SERVICE_UUID], []).append(matcher)
+            self.service_uuid[matcher[SERVICE_UUID]].append(matcher)
            return True

        if SERVICE_DATA_UUID in matcher:
-            self.service_data_uuid.setdefault(matcher[SERVICE_DATA_UUID], []).append(
-                matcher
-            )
+            self.service_data_uuid[matcher[SERVICE_DATA_UUID]].append(matcher)
            return True

        return False
@@ -260,32 +257,38 @@ class BluetoothMatcherIndexBase[
                if ble_device_matches(matcher, service_info)
            )

-        if self.service_data_uuid_set and service_info.service_data:
+        if (
+            (service_data_uuid_set := self.service_data_uuid_set)
+            and (service_data := service_info.service_data)
+            and (matched_uuids := service_data_uuid_set.intersection(service_data))
+        ):
            matches.extend(
                matcher
-                for service_data_uuid in self.service_data_uuid_set.intersection(
-                    service_info.service_data
-                )
+                for service_data_uuid in matched_uuids
                for matcher in self.service_data_uuid[service_data_uuid]
                if ble_device_matches(matcher, service_info)
            )

-        if self.manufacturer_id_set and service_info.manufacturer_data:
+        if (
+            (manufacturer_id_set := self.manufacturer_id_set)
+            and (manufacturer_data := service_info.manufacturer_data)
+            and (matched_ids := manufacturer_id_set.intersection(manufacturer_data))
+        ):
            matches.extend(
                matcher
-                for manufacturer_id in self.manufacturer_id_set.intersection(
-                    service_info.manufacturer_data
-                )
+                for manufacturer_id in matched_ids
                for matcher in self.manufacturer_id[manufacturer_id]
                if ble_device_matches(matcher, service_info)
            )

-        if self.service_uuid_set and service_info.service_uuids:
+        if (
+            (service_uuid_set := self.service_uuid_set)
+            and (service_uuids := service_info.service_uuids)
+            and (matched_uuids := service_uuid_set.intersection(service_uuids))
+        ):
            matches.extend(
                matcher
-                for service_uuid in self.service_uuid_set.intersection(
-                    service_info.service_uuids
-                )
+                for service_uuid in matched_uuids
                for matcher in self.service_uuid[service_uuid]
                if ble_device_matches(matcher, service_info)
            )
@@ -310,7 +313,9 @@ class BluetoothCallbackMatcherIndex(
    def __init__(self) -> None:
        """Initialize the matcher index."""
        super().__init__()
-        self.address: dict[str, list[BluetoothCallbackMatcherWithCallback]] = {}
+        self.address: defaultdict[str, list[BluetoothCallbackMatcherWithCallback]] = (
+            defaultdict(list)
+        )
        self.connectable: list[BluetoothCallbackMatcherWithCallback] = []

    def add_callback_matcher(
@@ -323,7 +328,7 @@ class BluetoothCallbackMatcherIndex(
        We put them in the bucket that they are most likely to match.
        """
        if ADDRESS in matcher:
-            self.address.setdefault(matcher[ADDRESS], []).append(matcher)
+            self.address[matcher[ADDRESS]].append(matcher)
            return

        if super().add(matcher):
--- a/homeassistant/components/bmw_connected_drive/manifest.json
+++ b/homeassistant/components/bmw_connected_drive/manifest.json
@@ -7,5 +7,5 @@
  "iot_class": "cloud_polling",
  "loggers": ["bimmer_connected"],
  "quality_scale": "platinum",
-  "requirements": ["bimmer-connected[china]==0.15.3"]
+  "requirements": ["bimmer-connected[china]==0.16.1"]
 }
--- a/homeassistant/components/bmw_connected_drive/strings.json
+++ b/homeassistant/components/bmw_connected_drive/strings.json
@@ -86,7 +86,8 @@
        "name": "Charging Mode",
        "state": {
          "immediate_charging": "Immediate charging",
-          "delayed_charging": "Delayed charging"
+          "delayed_charging": "Delayed charging",
+          "no_action": "No action"
        }
      }
    },
--- a/homeassistant/components/bond/fan.py
+++ b/homeassistant/components/bond/fan.py
@@ -69,7 +69,7 @@ class BondFan(BondEntity, FanEntity):
        super().__init__(data, device)
        if self._device.has_action(Action.BREEZE_ON):
            self._attr_preset_modes = [PRESET_MODE_BREEZE]
-        features = FanEntityFeature(0)
+        features = FanEntityFeature.TURN_OFF | FanEntityFeature.TURN_ON
        if self._device.supports_speed():
            features |= FanEntityFeature.SET_SPEED
        if self._device.supports_direction():
--- a/homeassistant/components/bring/init.py
+++ b/homeassistant/components/bring/init.py
@@ -4,8 +4,8 @@ from __future__ import annotations

 import logging

-from bring_api.bring import Bring
-from bring_api.exceptions import (
+from bring_api import (
+    Bring,
    BringAuthException,
    BringParseException,
    BringRequestException,
--- a/homeassistant/components/bring/config_flow.py
+++ b/homeassistant/components/bring/config_flow.py
@@ -6,9 +6,12 @@ from collections.abc import Mapping
 import logging
 from typing import Any

-from bring_api.bring import Bring
-from bring_api.exceptions import BringAuthException, BringRequestException
-from bring_api.types import BringAuthResponse
+from bring_api import (
+    Bring,
+    BringAuthException,
+    BringAuthResponse,
+    BringRequestException,
+)
 import voluptuous as vol

 from homeassistant.config_entries import ConfigFlow, ConfigFlowResult
@@ -58,7 +61,7 @@ class BringConfigFlow(ConfigFlow, domain=DOMAIN):
        ):
            self._abort_if_unique_id_configured()
            return self.async_create_entry(
-                title=self.info["name"] or user_input[CONF_EMAIL], data=user_input
+                title=self.info.get("name") or user_input[CONF_EMAIL], data=user_input
            )

        return self.async_show_form(
--- a/homeassistant/components/bring/coordinator.py
+++ b/homeassistant/components/bring/coordinator.py
@@ -5,8 +5,8 @@ from __future__ import annotations
 from datetime import timedelta
 import logging

-from bring_api.bring import Bring
-from bring_api.exceptions import (
+from bring_api import (
+    Bring,
    BringAuthException,
    BringParseException,
    BringRequestException,
--- a/homeassistant/components/bring/manifest.json
+++ b/homeassistant/components/bring/manifest.json
@@ -6,5 +6,5 @@
  "documentation": "https://www.home-assistant.io/integrations/bring",
  "integration_type": "service",
  "iot_class": "cloud_polling",
-  "requirements": ["bring-api==0.7.1"]
+  "requirements": ["bring-api==0.8.1"]
 }
--- a/homeassistant/components/bring/todo.py
+++ b/homeassistant/components/bring/todo.py
@@ -5,8 +5,12 @@ from __future__ import annotations
 from typing import TYPE_CHECKING
 import uuid

-from bring_api.exceptions import BringRequestException
-from bring_api.types import BringItem, BringItemOperation, BringNotificationType
+from bring_api import (
+    BringItem,
+    BringItemOperation,
+    BringNotificationType,
+    BringRequestException,
+)
 import voluptuous as vol

 from homeassistant.components.todo import (
--- a/homeassistant/components/broadlink/climate.py
+++ b/homeassistant/components/broadlink/climate.py
@@ -1,5 +1,6 @@
 """Support for Broadlink climate devices."""

+from enum import IntEnum
 from typing import Any

 from homeassistant.components.climate import (
@@ -19,6 +20,14 @@ from .device import BroadlinkDevice
 from .entity import BroadlinkEntity


+class SensorMode(IntEnum):
+    """Thermostat sensor modes."""
+
+    INNER_SENSOR_CONTROL = 0
+    OUTER_SENSOR_CONTROL = 1
+    INNER_SENSOR_CONTROL_OUTER_LIMIT = 2
+
+
 async def async_setup_entry(
    hass: HomeAssistant,
    config_entry: ConfigEntry,
@@ -50,6 +59,7 @@ class BroadlinkThermostat(BroadlinkEntity, ClimateEntity):
        super().__init__(device)
        self._attr_unique_id = device.unique_id
        self._attr_hvac_mode = None
+        self.sensor_mode = SensorMode.INNER_SENSOR_CONTROL

    async def async_set_temperature(self, **kwargs: Any) -> None:
        """Set new target temperature."""
@@ -61,6 +71,8 @@ class BroadlinkThermostat(BroadlinkEntity, ClimateEntity):
    @callback
    def _update_state(self, data: dict[str, Any]) -> None:
        """Update data."""
+        if (sensor := data.get("sensor")) is not None:
+            self.sensor_mode = SensorMode(sensor)
        if data.get("power"):
            if data.get("auto_mode"):
                self._attr_hvac_mode = HVACMode.AUTO
@@ -74,8 +86,10 @@ class BroadlinkThermostat(BroadlinkEntity, ClimateEntity):
        else:
            self._attr_hvac_mode = HVACMode.OFF
            self._attr_hvac_action = HVACAction.OFF
-
-        self._attr_current_temperature = data.get("room_temp")
+        if self.sensor_mode is SensorMode.OUTER_SENSOR_CONTROL:
+            self._attr_current_temperature = data.get("external_temp")
+        else:
+            self._attr_current_temperature = data.get("room_temp")
        self._attr_target_temperature = data.get("thermostat_temp")

    async def async_set_hvac_mode(self, hvac_mode: HVACMode) -> None:
@@ -85,7 +99,9 @@ class BroadlinkThermostat(BroadlinkEntity, ClimateEntity):
        else:
            await self._device.async_request(self._device.api.set_power, 1)
            mode = 0 if hvac_mode == HVACMode.HEAT else 1
-            await self._device.async_request(self._device.api.set_mode, mode, 0)
+            await self._device.async_request(
+                self._device.api.set_mode, mode, 0, self.sensor_mode.value
+            )

        self._attr_hvac_mode = hvac_mode
        self.async_write_ha_state()
--- a/homeassistant/components/bryant_evolution/init.py
+++ b/homeassistant/components/bryant_evolution/init.py
@@ -0,0 +1,84 @@
+"""The Bryant Evolution integration."""
+
+from __future__ import annotations
+
+import logging
+
+from evolutionhttp import BryantEvolutionLocalClient
+
+from homeassistant.config_entries import ConfigEntry
+from homeassistant.const import CONF_FILENAME, Platform
+from homeassistant.core import HomeAssistant
+from homeassistant.exceptions import ConfigEntryNotReady
+from homeassistant.helpers import device_registry as dr
+
+from . import names
+from .const import CONF_SYSTEM_ZONE, DOMAIN
+
+PLATFORMS: list[Platform] = [Platform.CLIMATE]
+
+type BryantEvolutionLocalClients = dict[tuple[int, int], BryantEvolutionLocalClient]
+type BryantEvolutionConfigEntry = ConfigEntry[BryantEvolutionLocalClients]
+_LOGGER = logging.getLogger(__name__)
+
+
+async def _can_reach_device(client: BryantEvolutionLocalClient) -> bool:
+    """Return whether we can reach the device at the given filename."""
+    # Verify that we can read current temperature to check that the
+    # (filename, system, zone) is valid.
+    return await client.read_current_temperature() is not None
+
+
+async def async_setup_entry(
+    hass: HomeAssistant, entry: BryantEvolutionConfigEntry
+) -> bool:
+    """Set up Bryant Evolution from a config entry."""
+
+    # Add a device for the SAM itself.
+    sam_uid = names.sam_device_uid(entry)
+    device_registry = dr.async_get(hass)
+    device_registry.async_get_or_create(
+        config_entry_id=entry.entry_id,
+        identifiers={(DOMAIN, sam_uid)},
+        manufacturer="Bryant",
+        name="System Access Module",
+    )
+
+    # Add a device for each system.
+    for sys_id in (1, 2):
+        if not any(sz[0] == sys_id for sz in entry.data[CONF_SYSTEM_ZONE]):
+            _LOGGER.debug(
+                "Skipping system %s because it is not configured for this integration: %s",
+                sys_id,
+                entry.data[CONF_SYSTEM_ZONE],
+            )
+            continue
+        device_registry.async_get_or_create(
+            config_entry_id=entry.entry_id,
+            identifiers={(DOMAIN, names.system_device_uid(sam_uid, sys_id))},
+            via_device=(DOMAIN, names.sam_device_uid(entry)),
+            manufacturer="Bryant",
+            name=f"System {sys_id}",
+        )
+
+    # Create a client for every zone.
+    entry.runtime_data = {}
+    for sz in entry.data[CONF_SYSTEM_ZONE]:
+        try:
+            client = await BryantEvolutionLocalClient.get_client(
+                sz[0], sz[1], entry.data[CONF_FILENAME]
+            )
+            if not await _can_reach_device(client):
+                raise ConfigEntryNotReady
+            entry.runtime_data[tuple(sz)] = client
+        except FileNotFoundError as f:
+            raise ConfigEntryNotReady from f
+    await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)
+    return True
+
+
+async def async_unload_entry(
+    hass: HomeAssistant, entry: BryantEvolutionConfigEntry
+) -> bool:
+    """Unload a config entry."""
+    return await hass.config_entries.async_unload_platforms(entry, PLATFORMS)
--- a/homeassistant/components/bryant_evolution/climate.py
+++ b/homeassistant/components/bryant_evolution/climate.py
@@ -0,0 +1,252 @@
+"""Support for Bryant Evolution HVAC systems."""
+
+from datetime import timedelta
+import logging
+from typing import Any
+
+from evolutionhttp import BryantEvolutionLocalClient
+
+from homeassistant.components.climate import (
+    ClimateEntity,
+    ClimateEntityFeature,
+    HVACAction,
+    HVACMode,
+)
+from homeassistant.const import UnitOfTemperature
+from homeassistant.core import HomeAssistant
+from homeassistant.exceptions import HomeAssistantError
+from homeassistant.helpers.device_registry import DeviceInfo
+from homeassistant.helpers.entity import Entity
+from homeassistant.helpers.entity_platform import AddEntitiesCallback
+
+from . import BryantEvolutionConfigEntry, names
+from .const import CONF_SYSTEM_ZONE, DOMAIN
+
+_LOGGER = logging.getLogger(__name__)
+
+
+SCAN_INTERVAL = timedelta(seconds=60)
+
+
+async def async_setup_entry(
+    hass: HomeAssistant,
+    config_entry: BryantEvolutionConfigEntry,
+    async_add_entities: AddEntitiesCallback,
+) -> None:
+    """Set up a config entry."""
+
+    # Add a climate entity for each system/zone.
+    sam_uid = names.sam_device_uid(config_entry)
+    entities: list[Entity] = []
+    for sz in config_entry.data[CONF_SYSTEM_ZONE]:
+        system_id = sz[0]
+        zone_id = sz[1]
+        client = config_entry.runtime_data.get(tuple(sz))
+        climate = BryantEvolutionClimate(
+            client,
+            system_id,
+            zone_id,
+            sam_uid,
+        )
+        entities.append(climate)
+    async_add_entities(entities, update_before_add=True)
+
+
+class BryantEvolutionClimate(ClimateEntity):
+    """ClimateEntity for Bryant Evolution HVAC systems.
+
+    Design note: this class updates using polling. However, polling
+    is very slow (~1500 ms / parameter). To improve the user
+    experience on updates, we also locally update this instance and
+    call async_write_ha_state as well.
+    """
+
+    _attr_has_entity_name = True
+    _attr_temperature_unit = UnitOfTemperature.FAHRENHEIT
+    _attr_supported_features = (
+        ClimateEntityFeature.TARGET_TEMPERATURE
+        | ClimateEntityFeature.TARGET_TEMPERATURE_RANGE
+        | ClimateEntityFeature.FAN_MODE
+        | ClimateEntityFeature.TURN_ON
+        | ClimateEntityFeature.TURN_OFF
+    )
+    _attr_hvac_modes = [
+        HVACMode.HEAT,
+        HVACMode.COOL,
+        HVACMode.HEAT_COOL,
+        HVACMode.OFF,
+    ]
+    _attr_fan_modes = ["auto", "low", "med", "high"]
+    _enable_turn_on_off_backwards_compatibility = False
+
+    def __init__(
+        self,
+        client: BryantEvolutionLocalClient,
+        system_id: int,
+        zone_id: int,
+        sam_uid: str,
+    ) -> None:
+        """Initialize an entity from parts."""
+        self._client = client
+        self._attr_name = None
+        self._attr_unique_id = names.zone_entity_uid(sam_uid, system_id, zone_id)
+        self._attr_device_info = DeviceInfo(
+            identifiers={(DOMAIN, self._attr_unique_id)},
+            manufacturer="Bryant",
+            via_device=(DOMAIN, names.system_device_uid(sam_uid, system_id)),
+            name=f"System {system_id} Zone {zone_id}",
+        )
+
+    async def async_update(self) -> None:
+        """Update the entity state."""
+        self._attr_current_temperature = await self._client.read_current_temperature()
+        if (fan_mode := await self._client.read_fan_mode()) is not None:
+            self._attr_fan_mode = fan_mode.lower()
+        else:
+            self._attr_fan_mode = None
+        self._attr_target_temperature = None
+        self._attr_target_temperature_high = None
+        self._attr_target_temperature_low = None
+        self._attr_hvac_mode = await self._read_hvac_mode()
+
+        # Set target_temperature or target_temperature_{high, low} based on mode.
+        match self._attr_hvac_mode:
+            case HVACMode.HEAT:
+                self._attr_target_temperature = (
+                    await self._client.read_heating_setpoint()
+                )
+            case HVACMode.COOL:
+                self._attr_target_temperature = (
+                    await self._client.read_cooling_setpoint()
+                )
+            case HVACMode.HEAT_COOL:
+                self._attr_target_temperature_high = (
+                    await self._client.read_cooling_setpoint()
+                )
+                self._attr_target_temperature_low = (
+                    await self._client.read_heating_setpoint()
+                )
+            case HVACMode.OFF:
+                pass
+            case _:
+                _LOGGER.error("Unknown HVAC mode %s", self._attr_hvac_mode)
+
+        # Note: depends on current temperature and target temperature low read
+        # above.
+        self._attr_hvac_action = await self._read_hvac_action()
+
+    async def _read_hvac_mode(self) -> HVACMode:
+        mode_and_active = await self._client.read_hvac_mode()
+        if not mode_and_active:
+            raise HomeAssistantError(
+                translation_domain=DOMAIN, translation_key="failed_to_read_hvac_mode"
+            )
+        mode = mode_and_active[0]
+        mode_enum = {
+            "HEAT": HVACMode.HEAT,
+            "COOL": HVACMode.COOL,
+            "AUTO": HVACMode.HEAT_COOL,
+            "OFF": HVACMode.OFF,
+        }.get(mode.upper())
+        if mode_enum is None:
+            raise HomeAssistantError(
+                translation_domain=DOMAIN,
+                translation_key="failed_to_parse_hvac_mode",
+                translation_placeholders={"mode": mode},
+            )
+        return mode_enum
+
+    async def _read_hvac_action(self) -> HVACAction:
+        """Return the current running hvac operation."""
+        mode_and_active = await self._client.read_hvac_mode()
+        if not mode_and_active:
+            raise HomeAssistantError(
+                translation_domain=DOMAIN, translation_key="failed_to_read_hvac_action"
+            )
+        mode, is_active = mode_and_active
+        if not is_active:
+            return HVACAction.OFF
+        match mode.upper():
+            case "HEAT":
+                return HVACAction.HEATING
+            case "COOL":
+                return HVACAction.COOLING
+            case "OFF":
+                return HVACAction.OFF
+            case "AUTO":
+                # In AUTO, we need to figure out what the actual action is
+                # based on the setpoints.
+                if (
+                    self.current_temperature is not None
+                    and self.target_temperature_low is not None
+                ):
+                    if self.current_temperature > self.target_temperature_low:
+                        # If the system is on and the current temperature is
+                        # higher than the point at which heating would activate,
+                        # then we must be cooling.
+                        return HVACAction.COOLING
+                    return HVACAction.HEATING
+        raise HomeAssistantError(
+            translation_domain=DOMAIN,
+            translation_key="failed_to_parse_hvac_mode",
+            translation_placeholders={
+                "mode_and_active": mode_and_active,
+                "current_temperature": str(self.current_temperature),
+                "target_temperature_low": str(self.target_temperature_low),
+            },
+        )
+
+    async def async_set_hvac_mode(self, hvac_mode: HVACMode) -> None:
+        """Set new target hvac mode."""
+        if hvac_mode == HVACMode.HEAT_COOL:
+            hvac_mode = HVACMode.AUTO
+        if not await self._client.set_hvac_mode(hvac_mode):
+            raise HomeAssistantError(
+                translation_domain=DOMAIN, translation_key="failed_to_set_hvac_mode"
+            )
+        self._attr_hvac_mode = hvac_mode
+        self._async_write_ha_state()
+
+    async def async_set_temperature(self, **kwargs: Any) -> None:
+        """Set new target temperature."""
+        if kwargs.get("target_temp_high"):
+            temp = int(kwargs["target_temp_high"])
+            if not await self._client.set_cooling_setpoint(temp):
+                raise HomeAssistantError(
+                    translation_domain=DOMAIN, translation_key="failed_to_set_clsp"
+                )
+            self._attr_target_temperature_high = temp
+
+        if kwargs.get("target_temp_low"):
+            temp = int(kwargs["target_temp_low"])
+            if not await self._client.set_heating_setpoint(temp):
+                raise HomeAssistantError(
+                    translation_domain=DOMAIN, translation_key="failed_to_set_htsp"
+                )
+            self._attr_target_temperature_low = temp
+
+        if kwargs.get("temperature"):
+            temp = int(kwargs["temperature"])
+            fn = (
+                self._client.set_heating_setpoint
+                if self.hvac_mode == HVACMode.HEAT
+                else self._client.set_cooling_setpoint
+            )
+            if not await fn(temp):
+                raise HomeAssistantError(
+                    translation_domain=DOMAIN, translation_key="failed_to_set_temp"
+                )
+            self._attr_target_temperature = temp
+
+        # If we get here, we must have changed something unless HA allowed an
+        # invalid service call (without any recognized kwarg).
+        self._async_write_ha_state()
+
+    async def async_set_fan_mode(self, fan_mode: str) -> None:
+        """Set new target fan mode."""
+        if not await self._client.set_fan_mode(fan_mode):
+            raise HomeAssistantError(
+                translation_domain=DOMAIN, translation_key="failed_to_set_fan_mode"
+            )
+        self._attr_fan_mode = fan_mode.lower()
+        self.async_write_ha_state()
--- a/homeassistant/components/bryant_evolution/config_flow.py
+++ b/homeassistant/components/bryant_evolution/config_flow.py
@@ -0,0 +1,87 @@
+"""Config flow for Bryant Evolution integration."""
+
+from __future__ import annotations
+
+import logging
+from typing import Any
+
+from evolutionhttp import BryantEvolutionLocalClient
+import voluptuous as vol
+
+from homeassistant.config_entries import ConfigFlow, ConfigFlowResult
+from homeassistant.const import CONF_FILENAME
+from homeassistant.helpers.typing import UNDEFINED
+
+from .const import CONF_SYSTEM_ZONE, DOMAIN
+
+_LOGGER = logging.getLogger(__name__)
+
+STEP_USER_DATA_SCHEMA = vol.Schema(
+    {
+        vol.Required(CONF_FILENAME, default="/dev/ttyUSB0"): str,
+    }
+)
+
+
+async def _enumerate_sz(tty: str) -> list[tuple[int, int]]:
+    """Return (system, zone) tuples for each system+zone accessible through tty."""
+    return [
+        (system_id, zone.zone_id)
+        for system_id in (1, 2)
+        for zone in await BryantEvolutionLocalClient.enumerate_zones(system_id, tty)
+    ]
+
+
+class BryantConfigFlow(ConfigFlow, domain=DOMAIN):
+    """Handle a config flow for Bryant Evolution."""
+
+    async def async_step_user(
+        self, user_input: dict[str, Any] | None = None
+    ) -> ConfigFlowResult:
+        """Handle the initial step."""
+        errors: dict[str, str] = {}
+        if user_input is not None:
+            try:
+                system_zone = await _enumerate_sz(user_input[CONF_FILENAME])
+            except FileNotFoundError:
+                _LOGGER.error("Could not open %s: not found", user_input[CONF_FILENAME])
+                errors["base"] = "cannot_connect"
+            else:
+                if len(system_zone) != 0:
+                    return self.async_create_entry(
+                        title=f"SAM at {user_input[CONF_FILENAME]}",
+                        data={
+                            CONF_FILENAME: user_input[CONF_FILENAME],
+                            CONF_SYSTEM_ZONE: system_zone,
+                        },
+                    )
+                errors["base"] = "cannot_connect"
+        return self.async_show_form(
+            step_id="user", data_schema=STEP_USER_DATA_SCHEMA, errors=errors
+        )
+
+    async def async_step_reconfigure(
+        self, user_input: dict[str, Any] | None = None
+    ) -> ConfigFlowResult:
+        """Handle integration reconfiguration."""
+        errors: dict[str, str] = {}
+        if user_input is not None:
+            system_zone = await _enumerate_sz(user_input[CONF_FILENAME])
+            if len(system_zone) != 0:
+                our_entry = self.hass.config_entries.async_get_entry(
+                    self.context["entry_id"]
+                )
+                assert our_entry is not None, "Could not find own entry"
+                return self.async_update_reload_and_abort(
+                    entry=our_entry,
+                    data={
+                        CONF_FILENAME: user_input[CONF_FILENAME],
+                        CONF_SYSTEM_ZONE: system_zone,
+                    },
+                    unique_id=UNDEFINED,
+                    reason="reconfigured",
+                )
+            errors["base"] = "cannot_connect"
+        return self.async_show_form(
+            step_id="reconfigure", data_schema=STEP_USER_DATA_SCHEMA, errors=errors
+        )
--- a/homeassistant/components/bryant_evolution/const.py
+++ b/homeassistant/components/bryant_evolution/const.py
@@ -0,0 +1,4 @@
+"""Constants for the Bryant Evolution integration."""
+
+DOMAIN = "bryant_evolution"
+CONF_SYSTEM_ZONE = "system_zone"
--- a/homeassistant/components/bryant_evolution/manifest.json
+++ b/homeassistant/components/bryant_evolution/manifest.json
@@ -0,0 +1,10 @@
+{
+  "domain": "bryant_evolution",
+  "name": "Bryant Evolution",
+  "codeowners": ["@danielsmyers"],
+  "config_flow": true,
+  "documentation": "https://www.home-assistant.io/integrations/bryant_evolution",
+  "integration_type": "device",
+  "iot_class": "local_polling",
+  "requirements": ["evolutionhttp==0.0.18"]
+}
--- a/homeassistant/components/bryant_evolution/names.py
+++ b/homeassistant/components/bryant_evolution/names.py
@@ -0,0 +1,18 @@
+"""Functions to generate names for devices and entities."""
+
+from homeassistant.config_entries import ConfigEntry
+
+
+def sam_device_uid(entry: ConfigEntry) -> str:
+    """Return the UID for the SAM device."""
+    return entry.entry_id
+
+
+def system_device_uid(sam_uid: str, system_id: int) -> str:
+    """Return the UID for a given system (e.g., 1) under a SAM."""
+    return f"{sam_uid}-S{system_id}"
+
+
+def zone_entity_uid(sam_uid: str, system_id: int, zone_id: int) -> str:
+    """Return the UID for a given system and zone (e.g., 1 and 2) under a SAM."""
+    return f"{sam_uid}-S{system_id}-Z{zone_id}"
--- a/homeassistant/components/bryant_evolution/strings.json
+++ b/homeassistant/components/bryant_evolution/strings.json
@@ -0,0 +1,48 @@
+{
+  "config": {
+    "step": {
+      "user": {
+        "data": {
+          "filename": "Serial port filename"
+        }
+      }
+    },
+    "error": {
+      "cannot_connect": "[%key:common::config_flow::error::cannot_connect%]",
+      "invalid_auth": "[%key:common::config_flow::error::invalid_auth%]",
+      "unknown": "[%key:common::config_flow::error::unknown%]"
+    },
+    "abort": {
+      "already_configured": "[%key:common::config_flow::abort::already_configured_device%]"
+    }
+  },
+  "exceptions": {
+    "failed_to_read_hvac_mode": {
+      "message": "Failed to read current HVAC mode"
+    },
+    "failed_to_parse_hvac_mode": {
+      "message": "Cannot parse response to HVACMode: {mode}"
+    },
+    "failed_to_read_hvac_action": {
+      "message": "Failed to read current HVAC action"
+    },
+    "failed_to_parse_hvac_action": {
+      "message": "Could not determine HVAC action: {mode_and_active}, {self.current_temperature}, {self.target_temperature_low}"
+    },
+    "failed_to_set_hvac_mode": {
+      "message": "Failed to set HVAC mode"
+    },
+    "failed_to_set_clsp": {
+      "message": "Failed to set cooling setpoint"
+    },
+    "failed_to_set_htsp": {
+      "message": "Failed to set heating setpoint"
+    },
+    "failed_to_set_temp": {
+      "message": "Failed to set temperature"
+    },
+    "failed_to_set_fan_mode": {
+      "message": "Failed to set fan mode"
+    }
+  }
+}
--- a/homeassistant/components/bthome/init.py
+++ b/homeassistant/components/bthome/init.py
@@ -2,6 +2,7 @@

 from __future__ import annotations

+from functools import partial
 import logging

 from bthome_ble import BTHomeBluetoothDeviceData, SensorUpdate
@@ -12,7 +13,6 @@ from homeassistant.components.bluetooth import (
    BluetoothScanningMode,
    BluetoothServiceInfoBleak,
 )
-from homeassistant.config_entries import ConfigEntry
 from homeassistant.const import Platform
 from homeassistant.core import HomeAssistant
 from homeassistant.helpers import device_registry as dr
@@ -29,6 +29,7 @@ from .const import (
    BTHomeBleEvent,
 )
 from .coordinator import BTHomePassiveBluetoothProcessorCoordinator
+from .types import BTHomeConfigEntry

 PLATFORMS: list[Platform] = [Platform.BINARY_SENSOR, Platform.EVENT, Platform.SENSOR]

@@ -37,16 +38,14 @@ _LOGGER = logging.getLogger(__name__)

 def process_service_info(
    hass: HomeAssistant,
-    entry: ConfigEntry,
-    data: BTHomeBluetoothDeviceData,
-    service_info: BluetoothServiceInfoBleak,
+    entry: BTHomeConfigEntry,
    device_registry: DeviceRegistry,
+    service_info: BluetoothServiceInfoBleak,
 ) -> SensorUpdate:
    """Process a BluetoothServiceInfoBleak, running side effects and returning sensor data."""
+    coordinator = entry.runtime_data
+    data = coordinator.device_data
    update = data.update(service_info)
-    coordinator: BTHomePassiveBluetoothProcessorCoordinator = hass.data[DOMAIN][
-        entry.entry_id
-    ]
    discovered_event_classes = coordinator.discovered_event_classes
    if entry.data.get(CONF_SLEEPY_DEVICE, False) != data.sleepy_device:
        hass.config_entries.async_update_entry(
@@ -117,7 +116,7 @@ def format_discovered_event_class(address: str) -> SignalType[str, BTHomeBleEven
    return SignalType(f"{DOMAIN}_discovered_event_class_{address}")


-async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+async def async_setup_entry(hass: HomeAssistant, entry: BTHomeConfigEntry) -> bool:
    """Set up BTHome Bluetooth from a config entry."""
    address = entry.unique_id
    assert address is not None
@@ -128,34 +127,26 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
    data = BTHomeBluetoothDeviceData(**kwargs)

    device_registry = dr.async_get(hass)
-    coordinator = hass.data.setdefault(DOMAIN, {})[entry.entry_id] = (
-        BTHomePassiveBluetoothProcessorCoordinator(
-            hass,
-            _LOGGER,
-            address=address,
-            mode=BluetoothScanningMode.PASSIVE,
-            update_method=lambda service_info: process_service_info(
-                hass, entry, data, service_info, device_registry
-            ),
-            device_data=data,
-            discovered_event_classes=set(
-                entry.data.get(CONF_DISCOVERED_EVENT_CLASSES, [])
-            ),
-            connectable=False,
-            entry=entry,
-        )
+    event_classes = set(entry.data.get(CONF_DISCOVERED_EVENT_CLASSES, ()))
+    coordinator = BTHomePassiveBluetoothProcessorCoordinator(
+        hass,
+        _LOGGER,
+        address=address,
+        mode=BluetoothScanningMode.PASSIVE,
+        update_method=partial(process_service_info, hass, entry, device_registry),
+        device_data=data,
+        discovered_event_classes=event_classes,
+        connectable=False,
+        entry=entry,
    )
+    entry.runtime_data = coordinator
    await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)

-    entry.async_on_unload(
-        coordinator.async_start()
-    )  # only start after all platforms have had a chance to subscribe
+    # only start after all platforms have had a chance to subscribe
+    entry.async_on_unload(coordinator.async_start())
    return True


-async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
+async def async_unload_entry(hass: HomeAssistant, entry: BTHomeConfigEntry) -> bool:
    """Unload a config entry."""
-    if unload_ok := await hass.config_entries.async_unload_platforms(entry, PLATFORMS):
-        hass.data[DOMAIN].pop(entry.entry_id)
-
-    return unload_ok
+    return await hass.config_entries.async_unload_platforms(entry, PLATFORMS)
--- a/homeassistant/components/bthome/binary_sensor.py
+++ b/homeassistant/components/bthome/binary_sensor.py
@@ -7,7 +7,6 @@ from bthome_ble import (
    SensorUpdate,
 )

-from homeassistant import config_entries
 from homeassistant.components.binary_sensor import (
    BinarySensorDeviceClass,
    BinarySensorEntity,
@@ -21,12 +20,9 @@ from homeassistant.core import HomeAssistant
 from homeassistant.helpers.entity_platform import AddEntitiesCallback
 from homeassistant.helpers.sensor import sensor_device_info_to_hass_device_info

-from .const import DOMAIN
-from .coordinator import (
-    BTHomePassiveBluetoothDataProcessor,
-    BTHomePassiveBluetoothProcessorCoordinator,
-)
+from .coordinator import BTHomePassiveBluetoothDataProcessor
 from .device import device_key_to_bluetooth_entity_key
+from .types import BTHomeConfigEntry

 BINARY_SENSOR_DESCRIPTIONS = {
    BTHomeBinarySensorDeviceClass.BATTERY: BinarySensorEntityDescription(
@@ -172,13 +168,11 @@ def sensor_update_to_bluetooth_data_update(

 async def async_setup_entry(
    hass: HomeAssistant,
-    entry: config_entries.ConfigEntry,
+    entry: BTHomeConfigEntry,
    async_add_entities: AddEntitiesCallback,
 ) -> None:
    """Set up the BTHome BLE binary sensors."""
-    coordinator: BTHomePassiveBluetoothProcessorCoordinator = hass.data[DOMAIN][
-        entry.entry_id
-    ]
+    coordinator = entry.runtime_data
    processor = BTHomePassiveBluetoothDataProcessor(
        sensor_update_to_bluetooth_data_update
    )
--- a/homeassistant/components/bthome/coordinator.py
+++ b/homeassistant/components/bthome/coordinator.py
@@ -13,10 +13,10 @@ from homeassistant.components.bluetooth.passive_update_processor import (
    PassiveBluetoothDataProcessor,
    PassiveBluetoothProcessorCoordinator,
 )
-from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import HomeAssistant

 from .const import CONF_SLEEPY_DEVICE
+from .types import BTHomeConfigEntry


 class BTHomePassiveBluetoothProcessorCoordinator(
@@ -33,7 +33,7 @@ class BTHomePassiveBluetoothProcessorCoordinator(
        update_method: Callable[[BluetoothServiceInfoBleak], SensorUpdate],
        device_data: BTHomeBluetoothDeviceData,
        discovered_event_classes: set[str],
-        entry: ConfigEntry,
+        entry: BTHomeConfigEntry,
        connectable: bool = False,
    ) -> None:
        """Initialize the BTHome Bluetooth Passive Update Processor Coordinator."""
--- a/homeassistant/components/bthome/event.py
+++ b/homeassistant/components/bthome/event.py
@@ -9,7 +9,6 @@ from homeassistant.components.event import (
    EventEntity,
    EventEntityDescription,
 )
-from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import HomeAssistant, callback
 from homeassistant.helpers import device_registry as dr, entity_registry as er
 from homeassistant.helpers.dispatcher import async_dispatcher_connect
@@ -24,7 +23,7 @@ from .const import (
    EVENT_TYPE,
    BTHomeBleEvent,
 )
-from .coordinator import BTHomePassiveBluetoothProcessorCoordinator
+from .types import BTHomeConfigEntry

 DESCRIPTIONS_BY_EVENT_CLASS = {
    EVENT_CLASS_BUTTON: EventEntityDescription(
@@ -103,13 +102,11 @@ class BTHomeEventEntity(EventEntity):

 async def async_setup_entry(
    hass: HomeAssistant,
-    entry: ConfigEntry,
+    entry: BTHomeConfigEntry,
    async_add_entities: AddEntitiesCallback,
 ) -> None:
    """Set up BTHome event."""
-    coordinator: BTHomePassiveBluetoothProcessorCoordinator = hass.data[DOMAIN][
-        entry.entry_id
-    ]
+    coordinator = entry.runtime_data
    address = coordinator.address
    ent_reg = er.async_get(hass)
    async_add_entities(
--- a/homeassistant/components/bthome/sensor.py
+++ b/homeassistant/components/bthome/sensor.py
@@ -9,7 +9,6 @@ from bthome_ble.const import (
    ExtendedSensorDeviceClass as BTHomeExtendedSensorDeviceClass,
 )

-from homeassistant import config_entries
 from homeassistant.components.bluetooth.passive_update_processor import (
    PassiveBluetoothDataUpdate,
    PassiveBluetoothProcessorEntity,
@@ -45,12 +44,9 @@ from homeassistant.core import HomeAssistant
 from homeassistant.helpers.entity_platform import AddEntitiesCallback
 from homeassistant.helpers.sensor import sensor_device_info_to_hass_device_info

-from .const import DOMAIN
-from .coordinator import (
-    BTHomePassiveBluetoothDataProcessor,
-    BTHomePassiveBluetoothProcessorCoordinator,
-)
+from .coordinator import BTHomePassiveBluetoothDataProcessor
 from .device import device_key_to_bluetooth_entity_key
+from .types import BTHomeConfigEntry

 SENSOR_DESCRIPTIONS = {
    # Acceleration (m/s²)
@@ -394,13 +390,11 @@ def sensor_update_to_bluetooth_data_update(

 async def async_setup_entry(
    hass: HomeAssistant,
-    entry: config_entries.ConfigEntry,
+    entry: BTHomeConfigEntry,
    async_add_entities: AddEntitiesCallback,
 ) -> None:
    """Set up the BTHome BLE sensors."""
-    coordinator: BTHomePassiveBluetoothProcessorCoordinator = hass.data[DOMAIN][
-        entry.entry_id
-    ]
+    coordinator = entry.runtime_data
    processor = BTHomePassiveBluetoothDataProcessor(
        sensor_update_to_bluetooth_data_update
    )
--- a/homeassistant/components/bthome/types.py
+++ b/homeassistant/components/bthome/types.py
@@ -0,0 +1,10 @@
+"""The BTHome Bluetooth integration."""
+
+from typing import TYPE_CHECKING
+
+from homeassistant.config_entries import ConfigEntry
+
+if TYPE_CHECKING:
+    from .coordinator import BTHomePassiveBluetoothProcessorCoordinator
+
+type BTHomeConfigEntry = ConfigEntry[BTHomePassiveBluetoothProcessorCoordinator]
--- a/homeassistant/components/buienradar/camera.py
+++ b/homeassistant/components/buienradar/camera.py
@@ -115,7 +115,9 @@ class BuienradarCam(Camera):
            headers = {}

        try:
-            async with session.get(url, timeout=5, headers=headers) as res:
+            async with session.get(
+                url, timeout=aiohttp.ClientTimeout(total=5), headers=headers
+            ) as res:
                res.raise_for_status()

                if res.status == 304:
--- a/homeassistant/components/buienradar/strings.json
+++ b/homeassistant/components/buienradar/strings.json
@@ -19,9 +19,9 @@
    "step": {
      "init": {
        "data": {
-          "country_code": "Country code of the country to display camera images.",
-          "delta": "Time interval in seconds between camera image updates",
-          "timeframe": "Minutes to look ahead for precipitation forecast"
+          "country_code": "Country to display camera images for.",
+          "delta": "Interval between camera image updates",
+          "timeframe": "Time to look ahead for precipitation forecast"
        }
      }
    }
--- a/homeassistant/components/cast/helpers.py
+++ b/homeassistant/components/cast/helpers.py
@@ -248,7 +248,7 @@ async def _fetch_playlist(hass, url, supported_content_types):
    """Fetch a playlist from the given url."""
    try:
        session = aiohttp_client.async_get_clientsession(hass, verify_ssl=False)
-        async with session.get(url, timeout=5) as resp:
+        async with session.get(url, timeout=aiohttp.ClientTimeout(total=5)) as resp:
            charset = resp.charset or "utf-8"
            if resp.content_type in supported_content_types:
                raise PlaylistSupported
--- a/homeassistant/components/climate/init.py
+++ b/homeassistant/components/climate/init.py
@@ -914,12 +914,37 @@ async def async_service_temperature_set(
    """Handle set temperature service."""
    hass = entity.hass
    kwargs = {}
+    min_temp = entity.min_temp
+    max_temp = entity.max_temp
+    temp_unit = entity.temperature_unit

    for value, temp in service_call.data.items():
        if value in CONVERTIBLE_ATTRIBUTE:
-            kwargs[value] = TemperatureConverter.convert(
-                temp, hass.config.units.temperature_unit, entity.temperature_unit
+            kwargs[value] = check_temp = TemperatureConverter.convert(
+                temp, hass.config.units.temperature_unit, temp_unit
            )
+
+            _LOGGER.debug(
+                "Check valid temperature %d %s (%d %s) in range %d %s - %d %s",
+                check_temp,
+                entity.temperature_unit,
+                temp,
+                hass.config.units.temperature_unit,
+                min_temp,
+                temp_unit,
+                max_temp,
+                temp_unit,
+            )
+            if check_temp < min_temp or check_temp > max_temp:
+                raise ServiceValidationError(
+                    translation_domain=DOMAIN,
+                    translation_key="temp_out_of_range",
+                    translation_placeholders={
+                        "check_temp": str(check_temp),
+                        "min_temp": str(min_temp),
+                        "max_temp": str(max_temp),
+                    },
+                )
        else:
            kwargs[value] = temp

--- a/homeassistant/components/climate/reproduce_state.py
+++ b/homeassistant/components/climate/reproduce_state.py
@@ -10,7 +10,6 @@ from homeassistant.const import ATTR_TEMPERATURE
 from homeassistant.core import Context, HomeAssistant, State

 from .const import (
-    ATTR_AUX_HEAT,
    ATTR_FAN_MODE,
    ATTR_HUMIDITY,
    ATTR_HVAC_MODE,
@@ -20,7 +19,6 @@ from .const import (
    ATTR_TARGET_TEMP_LOW,
    DOMAIN,
    HVAC_MODES,
-    SERVICE_SET_AUX_HEAT,
    SERVICE_SET_FAN_MODE,
    SERVICE_SET_HUMIDITY,
    SERVICE_SET_HVAC_MODE,
@@ -56,9 +54,6 @@ async def _async_reproduce_states(
    if state.state in HVAC_MODES:
        await call_service(SERVICE_SET_HVAC_MODE, [], {ATTR_HVAC_MODE: state.state})

-    if ATTR_AUX_HEAT in state.attributes:
-        await call_service(SERVICE_SET_AUX_HEAT, [ATTR_AUX_HEAT])
-
    if (
        (ATTR_TEMPERATURE in state.attributes)
        or (ATTR_TARGET_TEMP_HIGH in state.attributes)
--- a/homeassistant/components/climate/strings.json
+++ b/homeassistant/components/climate/strings.json
@@ -266,6 +266,9 @@
    },
    "not_valid_fan_mode": {
      "message": "Fan mode {mode} is not valid. Valid fan modes are: {modes}."
+    },
+    "temp_out_of_range": {
+      "message": "Provided temperature {check_temp} is not valid. Accepted range is {min_temp} to {max_temp}."
    }
  }
 }
--- a/homeassistant/components/cloud/prefs.py
+++ b/homeassistant/components/cloud/prefs.py
@@ -6,7 +6,7 @@ from collections.abc import Callable, Coroutine
 from typing import Any
 import uuid

-from hass_nabucasa.voice import MAP_VOICE
+from hass_nabucasa.voice import MAP_VOICE, Gender

 from homeassistant.auth.const import GROUP_ID_ADMIN
 from homeassistant.auth.models import User
@@ -91,8 +91,8 @@ class CloudPreferencesStore(Store):
                # The new second item is the voice name.
                default_tts_voice = old_data.get(PREF_TTS_DEFAULT_VOICE)
                if default_tts_voice and (voice_item_two := default_tts_voice[1]) in (
-                    "female",
-                    "male",
+                    Gender.FEMALE,
+                    Gender.MALE,
                ):
                    language: str = default_tts_voice[0]
                    if voice := MAP_VOICE.get((language, voice_item_two)):
--- a/homeassistant/components/comfoconnect/init.py
+++ b/homeassistant/components/comfoconnect/init.py
@@ -13,7 +13,7 @@ from homeassistant.const import (
    EVENT_HOMEASSISTANT_STOP,
    Platform,
 )
-from homeassistant.core import HomeAssistant
+from homeassistant.core import Event, HomeAssistant
 from homeassistant.helpers import discovery
 import homeassistant.helpers.config_validation as cv
 from homeassistant.helpers.dispatcher import dispatcher_send
@@ -76,7 +76,7 @@ def setup(hass: HomeAssistant, config: ConfigType) -> bool:
    ccb.connect()

    # Schedule disconnect on shutdown
-    def _shutdown(_event):
+    def _shutdown(_event: Event) -> None:
        ccb.disconnect()

    hass.bus.listen_once(EVENT_HOMEASSISTANT_STOP, _shutdown)
@@ -90,7 +90,15 @@ def setup(hass: HomeAssistant, config: ConfigType) -> bool:
 class ComfoConnectBridge:
    """Representation of a ComfoConnect bridge."""

-    def __init__(self, hass, bridge, name, token, friendly_name, pin):
+    def __init__(
+        self,
+        hass: HomeAssistant,
+        bridge: Bridge,
+        name: str,
+        token: str,
+        friendly_name: str,
+        pin: int,
+    ) -> None:
        """Initialize the ComfoConnect bridge."""
        self.name = name
        self.hass = hass
@@ -104,17 +112,17 @@ class ComfoConnectBridge:
        )
        self.comfoconnect.callback_sensor = self.sensor_callback

-    def connect(self):
+    def connect(self) -> None:
        """Connect with the bridge."""
        _LOGGER.debug("Connecting with bridge")
        self.comfoconnect.connect(True)

-    def disconnect(self):
+    def disconnect(self) -> None:
        """Disconnect from the bridge."""
        _LOGGER.debug("Disconnecting from bridge")
        self.comfoconnect.disconnect()

-    def sensor_callback(self, var, value):
+    def sensor_callback(self, var: str, value: str) -> None:
        """Notify listeners that we have received an update."""
        _LOGGER.debug("Received update for %s: %s", var, value)
        dispatcher_send(
--- a/Show More
+++ b/Show More