[pull] dev from home-assistant:dev

homeassistant/components/analytics/analytics.py

@@ -534,6 +534,10 @@ async def send_snapshot(self, _: datetime | None = None) -> None:
 
         payload = await _async_snapshot_payload(self._hass)
 
+        if not payload:
+            LOGGER.info("Skipping snapshot submission, no data to send")
+            return
+
         headers = {
             "Content-Type": "application/json",
             "User-Agent": f"home-assistant/{HA_VERSION}",

homeassistant/components/control4/climate.py

@@ -75,11 +75,12 @@
 
 HA_TO_C4_HVAC_MODE = {v: k for k, v in C4_TO_HA_HVAC_MODE.items()}
 
-# Map the five known Control4 HVAC states to Home Assistant HVAC actions
+# Map Control4 HVAC states to Home Assistant HVAC actions
 C4_TO_HA_HVAC_ACTION = {
     "off": HVACAction.OFF,
     "heat": HVACAction.HEATING,
     "cool": HVACAction.COOLING,
+    "idle": HVACAction.IDLE,
     "dry": HVACAction.DRYING,
     "fan": HVACAction.FAN,
 }
@@ -292,8 +293,14 @@ def hvac_action(self) -> HVACAction | None:
         c4_state = data.get(CONTROL4_HVAC_STATE)
         if c4_state is None:
             return None
-        # Convert state to lowercase for mapping
         action = C4_TO_HA_HVAC_ACTION.get(str(c4_state).lower())
+        # Substring match for multi-stage systems that report
+        # e.g. "Stage 1 Heat", "Stage 2 Cool"
+        if action is None:
+            if "heat" in str(c4_state).lower():
+                action = HVACAction.HEATING
+            elif "cool" in str(c4_state).lower():
+                action = HVACAction.COOLING
         if action is None:
             _LOGGER.debug("Unknown HVAC state received from Control4: %s", c4_state)
         return action

homeassistant/components/demo/vacuum.py

@@ -7,15 +7,19 @@
 
 from homeassistant.components.vacuum import (
     ATTR_CLEANED_AREA,
+    Segment,
     StateVacuumEntity,
     VacuumActivity,
     VacuumEntityFeature,
 )
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import HomeAssistant
 from homeassistant.helpers import event
+from homeassistant.helpers.device_registry import DeviceInfo
 from homeassistant.helpers.entity_platform import AddConfigEntryEntitiesCallback
 
+from . import DOMAIN
+
 SUPPORT_MINIMAL_SERVICES = VacuumEntityFeature.TURN_ON | VacuumEntityFeature.TURN_OFF
 
 SUPPORT_BASIC_SERVICES = (
@@ -45,9 +49,17 @@
     | VacuumEntityFeature.LOCATE
     | VacuumEntityFeature.MAP
     | VacuumEntityFeature.CLEAN_SPOT
+    | VacuumEntityFeature.CLEAN_AREA
 )
 
 FAN_SPEEDS = ["min", "medium", "high", "max"]
+DEMO_SEGMENTS = [
+    Segment(id="living_room", name="Living room"),
+    Segment(id="kitchen", name="Kitchen"),
+    Segment(id="bedroom_1", name="Master bedroom", group="Bedrooms"),
+    Segment(id="bedroom_2", name="Guest bedroom", group="Bedrooms"),
+    Segment(id="bathroom", name="Bathroom"),
+]
 DEMO_VACUUM_COMPLETE = "Demo vacuum 0 ground floor"
 DEMO_VACUUM_MOST = "Demo vacuum 1 first floor"
 DEMO_VACUUM_BASIC = "Demo vacuum 2 second floor"
@@ -63,25 +75,33 @@ async def async_setup_entry(
     """Set up the Demo config entry."""
     async_add_entities(
         [
-            StateDemoVacuum(DEMO_VACUUM_COMPLETE, SUPPORT_ALL_SERVICES),
-            StateDemoVacuum(DEMO_VACUUM_MOST, SUPPORT_MOST_SERVICES),
-            StateDemoVacuum(DEMO_VACUUM_BASIC, SUPPORT_BASIC_SERVICES),
-            StateDemoVacuum(DEMO_VACUUM_MINIMAL, SUPPORT_MINIMAL_SERVICES),
-            StateDemoVacuum(DEMO_VACUUM_NONE, VacuumEntityFeature(0)),
+            StateDemoVacuum("vacuum_1", DEMO_VACUUM_COMPLETE, SUPPORT_ALL_SERVICES),
+            StateDemoVacuum("vacuum_2", DEMO_VACUUM_MOST, SUPPORT_MOST_SERVICES),
+            StateDemoVacuum("vacuum_3", DEMO_VACUUM_BASIC, SUPPORT_BASIC_SERVICES),
+            StateDemoVacuum("vacuum_4", DEMO_VACUUM_MINIMAL, SUPPORT_MINIMAL_SERVICES),
+            StateDemoVacuum("vacuum_5", DEMO_VACUUM_NONE, VacuumEntityFeature(0)),
         ]
     )
 
 
 class StateDemoVacuum(StateVacuumEntity):
     """Representation of a demo vacuum supporting states."""
 
+    _attr_has_entity_name = True
+    _attr_name = None
     _attr_should_poll = False
     _attr_translation_key = "model_s"
 
-    def __init__(self, name: str, supported_features: VacuumEntityFeature) -> None:
+    def __init__(
+        self, unique_id: str, name: str, supported_features: VacuumEntityFeature
+    ) -> None:
         """Initialize the vacuum."""
-        self._attr_name = name
+        self._attr_unique_id = unique_id
         self._attr_supported_features = supported_features
+        self._attr_device_info = DeviceInfo(
+            identifiers={(DOMAIN, unique_id)},
+            name=name,
+        )
         self._attr_activity = VacuumActivity.DOCKED
         self._fan_speed = FAN_SPEEDS[1]
         self._cleaned_area: float = 0
@@ -163,6 +183,16 @@ async def async_send_command(
         self._attr_activity = VacuumActivity.IDLE
         self.async_write_ha_state()
 
+    async def async_get_segments(self) -> list[Segment]:
+        """Get the list of segments."""
+        return DEMO_SEGMENTS
+
+    async def async_clean_segments(self, segment_ids: list[str], **kwargs: Any) -> None:
+        """Clean the specified segments."""
+        self._attr_activity = VacuumActivity.CLEANING
+        self._cleaned_area += len(segment_ids) * 0.7
+        self.async_write_ha_state()
+
     def __set_state_to_dock(self, _: datetime) -> None:
         self._attr_activity = VacuumActivity.DOCKED
         self.schedule_update_ha_state()

homeassistant/components/dialogflow/strings.json

@@ -2,13 +2,18 @@
   "config": {
     "abort": {
       "cloud_not_connected": "[%key:common::config_flow::abort::cloud_not_connected%]",
+      "reconfigure_successful": "**Reconfiguration was successful**\n\nGo to the [webhook service of Dialogflow]({dialogflow_url}) and update the webhook with following settings:\n\n- URL: `{webhook_url}`\n- Method: POST\n- Content Type: application/json\n\nSee [the documentation]({docs_url}) for further details.",
       "single_instance_allowed": "[%key:common::config_flow::abort::single_instance_allowed%]",
       "webhook_not_internet_accessible": "[%key:common::config_flow::abort::webhook_not_internet_accessible%]"
     },
     "create_entry": {
       "default": "To send events to Home Assistant, you will need to set up the [webhook service of Dialogflow]({dialogflow_url}).\n\nFill in the following info:\n\n- URL: `{webhook_url}`\n- Method: POST\n- Content Type: application/json\n\nSee [the documentation]({docs_url}) for further details."
     },
     "step": {
+      "reconfigure": {
+        "description": "Are you sure you want to reconfigure Dialogflow?",
+        "title": "Reconfigure Dialogflow webhook"
+      },
       "user": {
         "description": "Are you sure you want to set up Dialogflow?",
         "title": "Set up the Dialogflow webhook"

homeassistant/components/duckdns/strings.json

@@ -16,7 +16,7 @@
         "data_description": {
           "access_token": "[%key:component::duckdns::config::step::user::data_description::access_token%]"
         },
-        "title": "Re-configure {name}"
+        "title": "Reconfigure {name}"
       },
       "user": {
         "data": {

homeassistant/components/ecovacs/controller.py

@@ -2,6 +2,7 @@
 
 from __future__ import annotations
 
+import asyncio
 from collections.abc import Mapping
 from functools import partial
 import logging
@@ -80,11 +81,22 @@ async def initialize(self) -> None:
         try:
             devices = await self._api_client.get_devices()
             credentials = await self._authenticator.authenticate()
-            for device_info in devices.mqtt:
-                device = Device(device_info, self._authenticator)
+
+            if devices.mqtt:
                 mqtt = await self._get_mqtt_client()
-                await device.initialize(mqtt)
-                self._devices.append(device)
+                mqtt_devices = [
+                    Device(info, self._authenticator) for info in devices.mqtt
+                ]
+                async with asyncio.TaskGroup() as tg:
+
+                    async def _init(device: Device) -> None:
+                        """Initialize MQTT device."""
+                        await device.initialize(mqtt)
+                        self._devices.append(device)
+
+                    for device in mqtt_devices:
+                        tg.create_task(_init(device))
+
             for device_config in devices.xmpp:
                 bot = VacBot(
                     credentials.user_id,

homeassistant/components/geofency/strings.json

@@ -2,13 +2,18 @@
   "config": {
     "abort": {
       "cloud_not_connected": "[%key:common::config_flow::abort::cloud_not_connected%]",
+      "reconfigure_successful": "**Reconfiguration was successful**\n\nGo to the webhook feature in Geofency and update the webhook with the following settings:\n\n- URL: `{webhook_url}`\n- Method: POST\n\nSee [the documentation]({docs_url}) for further details.",
       "single_instance_allowed": "[%key:common::config_flow::abort::single_instance_allowed%]",
       "webhook_not_internet_accessible": "[%key:common::config_flow::abort::webhook_not_internet_accessible%]"
     },
     "create_entry": {
       "default": "To send events to Home Assistant, you will need to set up the webhook feature in Geofency.\n\nFill in the following info:\n\n- URL: `{webhook_url}`\n- Method: POST\n\nSee [the documentation]({docs_url}) for further details."
     },
     "step": {
+      "reconfigure": {
+        "description": "Are you sure you want to reconfigure the Geofency webhook?",
+        "title": "Reconfigure Geofency webhook"
+      },
       "user": {
         "description": "Are you sure you want to set up the Geofency webhook?",
         "title": "Set up the Geofency webhook"

homeassistant/components/gpslogger/strings.json

@@ -2,13 +2,18 @@
   "config": {
     "abort": {
       "cloud_not_connected": "[%key:common::config_flow::abort::cloud_not_connected%]",
+      "reconfigure_successful": "**Reconfiguration was successful**\n\nGo to the webhook feature in GPSLogger and update the webhook with the following settings:\n\n- URL: `{webhook_url}`\n- Method: POST\n\nSee [the documentation]({docs_url}) for further details.",
       "single_instance_allowed": "[%key:common::config_flow::abort::single_instance_allowed%]",
       "webhook_not_internet_accessible": "[%key:common::config_flow::abort::webhook_not_internet_accessible%]"
     },
     "create_entry": {
       "default": "To send events to Home Assistant, you will need to set up the webhook feature in GPSLogger.\n\nFill in the following info:\n\n- URL: `{webhook_url}`\n- Method: POST\n\nSee [the documentation]({docs_url}) for further details."
     },
     "step": {
+      "reconfigure": {
+        "description": "Are you sure you want to reconfigure the GPSLogger webhook?",
+        "title": "Reconfigure GPSLogger webhook"
+      },
       "user": {
         "description": "Are you sure you want to set up the GPSLogger webhook?",
         "title": "Set up the GPSLogger webhook"

homeassistant/components/hdfury/__init__.py

@@ -7,6 +7,7 @@
 
 PLATFORMS = [
     Platform.BUTTON,
+    Platform.NUMBER,
     Platform.SELECT,
     Platform.SENSOR,
     Platform.SWITCH,

homeassistant/components/hdfury/icons.json

@@ -5,6 +5,14 @@
         "default": "mdi:connection"
       }
     },
+    "number": {
+      "oled_fade": {
+        "default": "mdi:cellphone-information"
+      },
+      "reboot_timer": {
+        "default": "mdi:timer-refresh"
+      }
+    },
     "select": {
       "opmode": {
         "default": "mdi:cogs"

homeassistant/components/hdfury/number.py

@@ -0,0 +1,101 @@
+"""Number platform for HDFury Integration."""
+
+from collections.abc import Awaitable, Callable
+from dataclasses import dataclass
+
+from hdfury import HDFuryAPI, HDFuryError
+
+from homeassistant.components.number import (
+    NumberDeviceClass,
+    NumberEntity,
+    NumberEntityDescription,
+    NumberMode,
+)
+from homeassistant.const import EntityCategory, UnitOfTime
+from homeassistant.core import HomeAssistant
+from homeassistant.exceptions import HomeAssistantError
+from homeassistant.helpers.entity_platform import AddConfigEntryEntitiesCallback
+
+from .const import DOMAIN
+from .coordinator import HDFuryConfigEntry
+from .entity import HDFuryEntity
+
+PARALLEL_UPDATES = 1
+
+
+@dataclass(kw_only=True, frozen=True)
+class HDFuryNumberEntityDescription(NumberEntityDescription):
+    """Description for HDFury number entities."""
+
+    set_value_fn: Callable[[HDFuryAPI, str], Awaitable[None]]
+
+
+NUMBERS: tuple[HDFuryNumberEntityDescription, ...] = (
+    HDFuryNumberEntityDescription(
+        key="oledfade",
+        translation_key="oled_fade",
+        mode=NumberMode.BOX,
+        native_min_value=1,
+        native_max_value=100,
+        native_step=1,
+        device_class=NumberDeviceClass.DURATION,
+        native_unit_of_measurement=UnitOfTime.SECONDS,
+        entity_category=EntityCategory.CONFIG,
+        set_value_fn=lambda client, value: client.set_oled_fade(value),
+    ),
+    HDFuryNumberEntityDescription(
+        key="reboottimer",
+        translation_key="reboot_timer",
+        mode=NumberMode.BOX,
+        native_min_value=0,
+        native_max_value=100,
+        native_step=1,
+        device_class=NumberDeviceClass.DURATION,
+        native_unit_of_measurement=UnitOfTime.HOURS,
+        entity_category=EntityCategory.CONFIG,
+        set_value_fn=lambda client, value: client.set_reboot_timer(value),
+    ),
+)
+
+
+async def async_setup_entry(
+    hass: HomeAssistant,
+    entry: HDFuryConfigEntry,
+    async_add_entities: AddConfigEntryEntitiesCallback,
+) -> None:
+    """Set up numbers using the platform schema."""
+
+    coordinator = entry.runtime_data
+
+    async_add_entities(
+        HDFuryNumber(coordinator, description)
+        for description in NUMBERS
+        if description.key in coordinator.data.config
+    )
+
+
+class HDFuryNumber(HDFuryEntity, NumberEntity):
+    """Base HDFury Number Class."""
+
+    entity_description: HDFuryNumberEntityDescription
+
+    @property
+    def native_value(self) -> float:
+        """Return the current number value."""
+
+        return float(self.coordinator.data.config[self.entity_description.key])
+
+    async def async_set_native_value(self, value: float) -> None:
+        """Set Number Value Event."""
+
+        try:
+            await self.entity_description.set_value_fn(
+                self.coordinator.client, str(int(value))
+            )
+        except HDFuryError as error:
+            raise HomeAssistantError(
+                translation_domain=DOMAIN,
+                translation_key="communication_error",
+            ) from error
+
+        await self.coordinator.async_request_refresh()

homeassistant/components/hdfury/strings.json

@@ -40,6 +40,14 @@
         "name": "Issue hotplug"
       }
     },
+    "number": {
+      "oled_fade": {
+        "name": "OLED fade timer"
+      },
+      "reboot_timer": {
+        "name": "Restart timer"
+      }
+    },
     "select": {
       "opmode": {
         "name": "Operation mode",

homeassistant/components/hko/coordinator.py

@@ -119,7 +119,7 @@ def _convert_current(self, data: dict[str, Any]) -> dict[str, Any]:
                     for item in data[API_TEMPERATURE][API_DATA]
                     if item[API_PLACE] == self.location
                 ),
-                0,
+                None,
             ),
         }