Move manual configuration of MQTT button to the integration key (#72167)
Add button Co-authored-by: Erik Montnemery <erik@montnemery.com>
This commit is contained in:
parent
eac872331a
commit
3918059033
3 changed files with 39 additions and 4 deletions
|
@ -191,6 +191,7 @@ MQTT_WILL_BIRTH_SCHEMA = vol.Schema(
|
||||||
PLATFORM_CONFIG_SCHEMA_BASE = vol.Schema(
|
PLATFORM_CONFIG_SCHEMA_BASE = vol.Schema(
|
||||||
{
|
{
|
||||||
vol.Optional(Platform.ALARM_CONTROL_PANEL.value): cv.ensure_list,
|
vol.Optional(Platform.ALARM_CONTROL_PANEL.value): cv.ensure_list,
|
||||||
|
vol.Optional(Platform.BUTTON.value): cv.ensure_list,
|
||||||
vol.Optional(Platform.FAN.value): cv.ensure_list,
|
vol.Optional(Platform.FAN.value): cv.ensure_list,
|
||||||
vol.Optional(Platform.LIGHT.value): cv.ensure_list,
|
vol.Optional(Platform.LIGHT.value): cv.ensure_list,
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,6 +1,7 @@
|
||||||
"""Support for MQTT buttons."""
|
"""Support for MQTT buttons."""
|
||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
|
||||||
|
import asyncio
|
||||||
import functools
|
import functools
|
||||||
|
|
||||||
import voluptuous as vol
|
import voluptuous as vol
|
||||||
|
@ -26,15 +27,17 @@ from .const import (
|
||||||
from .mixins import (
|
from .mixins import (
|
||||||
MQTT_ENTITY_COMMON_SCHEMA,
|
MQTT_ENTITY_COMMON_SCHEMA,
|
||||||
MqttEntity,
|
MqttEntity,
|
||||||
|
async_get_platform_config_from_yaml,
|
||||||
async_setup_entry_helper,
|
async_setup_entry_helper,
|
||||||
async_setup_platform_helper,
|
async_setup_platform_helper,
|
||||||
|
warn_for_legacy_schema,
|
||||||
)
|
)
|
||||||
|
|
||||||
CONF_PAYLOAD_PRESS = "payload_press"
|
CONF_PAYLOAD_PRESS = "payload_press"
|
||||||
DEFAULT_NAME = "MQTT Button"
|
DEFAULT_NAME = "MQTT Button"
|
||||||
DEFAULT_PAYLOAD_PRESS = "PRESS"
|
DEFAULT_PAYLOAD_PRESS = "PRESS"
|
||||||
|
|
||||||
PLATFORM_SCHEMA = mqtt.MQTT_BASE_PLATFORM_SCHEMA.extend(
|
PLATFORM_SCHEMA_MODERN = mqtt.MQTT_BASE_SCHEMA.extend(
|
||||||
{
|
{
|
||||||
vol.Optional(CONF_COMMAND_TEMPLATE): cv.template,
|
vol.Optional(CONF_COMMAND_TEMPLATE): cv.template,
|
||||||
vol.Required(CONF_COMMAND_TOPIC): mqtt.valid_publish_topic,
|
vol.Required(CONF_COMMAND_TOPIC): mqtt.valid_publish_topic,
|
||||||
|
@ -45,7 +48,14 @@ PLATFORM_SCHEMA = mqtt.MQTT_BASE_PLATFORM_SCHEMA.extend(
|
||||||
}
|
}
|
||||||
).extend(MQTT_ENTITY_COMMON_SCHEMA.schema)
|
).extend(MQTT_ENTITY_COMMON_SCHEMA.schema)
|
||||||
|
|
||||||
DISCOVERY_SCHEMA = PLATFORM_SCHEMA.extend({}, extra=vol.REMOVE_EXTRA)
|
# Configuring MQTT Buttons under the button platform key is deprecated in HA Core 2022.6
|
||||||
|
PLATFORM_SCHEMA = vol.All(
|
||||||
|
cv.PLATFORM_SCHEMA.extend(PLATFORM_SCHEMA_MODERN.schema),
|
||||||
|
warn_for_legacy_schema(button.DOMAIN),
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
DISCOVERY_SCHEMA = PLATFORM_SCHEMA_MODERN.extend({}, extra=vol.REMOVE_EXTRA)
|
||||||
|
|
||||||
|
|
||||||
async def async_setup_platform(
|
async def async_setup_platform(
|
||||||
|
@ -54,7 +64,8 @@ async def async_setup_platform(
|
||||||
async_add_entities: AddEntitiesCallback,
|
async_add_entities: AddEntitiesCallback,
|
||||||
discovery_info: DiscoveryInfoType | None = None,
|
discovery_info: DiscoveryInfoType | None = None,
|
||||||
) -> None:
|
) -> None:
|
||||||
"""Set up MQTT button through configuration.yaml."""
|
"""Set up MQTT button configured under the fan platform key (deprecated)."""
|
||||||
|
# Deprecated in HA Core 2022.6
|
||||||
await async_setup_platform_helper(
|
await async_setup_platform_helper(
|
||||||
hass, button.DOMAIN, config, async_add_entities, _async_setup_entity
|
hass, button.DOMAIN, config, async_add_entities, _async_setup_entity
|
||||||
)
|
)
|
||||||
|
@ -65,7 +76,17 @@ async def async_setup_entry(
|
||||||
config_entry: ConfigEntry,
|
config_entry: ConfigEntry,
|
||||||
async_add_entities: AddEntitiesCallback,
|
async_add_entities: AddEntitiesCallback,
|
||||||
) -> None:
|
) -> None:
|
||||||
"""Set up MQTT button dynamically through MQTT discovery."""
|
"""Set up MQTT button through configuration.yaml and dynamically through MQTT discovery."""
|
||||||
|
# load and initialize platform config from configuration.yaml
|
||||||
|
await asyncio.gather(
|
||||||
|
*(
|
||||||
|
_async_setup_entity(hass, async_add_entities, config, config_entry)
|
||||||
|
for config in await async_get_platform_config_from_yaml(
|
||||||
|
hass, button.DOMAIN, PLATFORM_SCHEMA_MODERN
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
# setup for discovery
|
||||||
setup = functools.partial(
|
setup = functools.partial(
|
||||||
_async_setup_entity, hass, async_add_entities, config_entry=config_entry
|
_async_setup_entity, hass, async_add_entities, config_entry=config_entry
|
||||||
)
|
)
|
||||||
|
|
|
@ -30,6 +30,7 @@ from .test_common import (
|
||||||
help_test_setting_attribute_via_mqtt_json_message,
|
help_test_setting_attribute_via_mqtt_json_message,
|
||||||
help_test_setting_attribute_with_template,
|
help_test_setting_attribute_with_template,
|
||||||
help_test_setting_blocked_attribute_via_mqtt_json_message,
|
help_test_setting_blocked_attribute_via_mqtt_json_message,
|
||||||
|
help_test_setup_manual_entity_from_yaml,
|
||||||
help_test_unique_id,
|
help_test_unique_id,
|
||||||
help_test_update_with_json_attrs_bad_JSON,
|
help_test_update_with_json_attrs_bad_JSON,
|
||||||
help_test_update_with_json_attrs_not_dict,
|
help_test_update_with_json_attrs_not_dict,
|
||||||
|
@ -413,3 +414,15 @@ async def test_reloadable_late(hass, mqtt_client_mock, caplog, tmp_path):
|
||||||
domain = button.DOMAIN
|
domain = button.DOMAIN
|
||||||
config = DEFAULT_CONFIG[domain]
|
config = DEFAULT_CONFIG[domain]
|
||||||
await help_test_reloadable_late(hass, caplog, tmp_path, domain, config)
|
await help_test_reloadable_late(hass, caplog, tmp_path, domain, config)
|
||||||
|
|
||||||
|
|
||||||
|
async def test_setup_manual_entity_from_yaml(hass, caplog, tmp_path):
|
||||||
|
"""Test setup manual configured MQTT entity."""
|
||||||
|
platform = button.DOMAIN
|
||||||
|
config = copy.deepcopy(DEFAULT_CONFIG[platform])
|
||||||
|
config["name"] = "test"
|
||||||
|
del config["platform"]
|
||||||
|
await help_test_setup_manual_entity_from_yaml(
|
||||||
|
hass, caplog, tmp_path, platform, config
|
||||||
|
)
|
||||||
|
assert hass.states.get(f"{platform}.test") is not None
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue