mirror of
https://github.com/home-assistant/core.git
synced 2025-07-25 22:27:07 +00:00
Make mqtt device_tracker state_topic optional when json_attribute_topic is used (#93322)
* Make device_tracker state_topic optional * No state_topic needed
This commit is contained in:
parent
4d44d60e73
commit
a81fe517c1
@ -28,17 +28,18 @@ from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
|||||||
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
||||||
|
|
||||||
from . import subscription
|
from . import subscription
|
||||||
from .config import MQTT_RO_SCHEMA
|
from .config import MQTT_BASE_SCHEMA
|
||||||
from .const import CONF_PAYLOAD_RESET, CONF_QOS, CONF_STATE_TOPIC
|
from .const import CONF_PAYLOAD_RESET, CONF_QOS, CONF_STATE_TOPIC
|
||||||
from .debug_info import log_messages
|
from .debug_info import log_messages
|
||||||
from .mixins import (
|
from .mixins import (
|
||||||
|
CONF_JSON_ATTRS_TOPIC,
|
||||||
MQTT_ENTITY_COMMON_SCHEMA,
|
MQTT_ENTITY_COMMON_SCHEMA,
|
||||||
MqttEntity,
|
MqttEntity,
|
||||||
async_setup_entry_helper,
|
async_setup_entry_helper,
|
||||||
warn_for_legacy_schema,
|
warn_for_legacy_schema,
|
||||||
)
|
)
|
||||||
from .models import MqttValueTemplate, ReceiveMessage, ReceivePayloadType
|
from .models import MqttValueTemplate, ReceiveMessage, ReceivePayloadType
|
||||||
from .util import get_mqtt_data
|
from .util import get_mqtt_data, valid_subscribe_topic
|
||||||
|
|
||||||
CONF_PAYLOAD_HOME = "payload_home"
|
CONF_PAYLOAD_HOME = "payload_home"
|
||||||
CONF_PAYLOAD_NOT_HOME = "payload_not_home"
|
CONF_PAYLOAD_NOT_HOME = "payload_not_home"
|
||||||
@ -47,8 +48,20 @@ CONF_SOURCE_TYPE = "source_type"
|
|||||||
DEFAULT_PAYLOAD_RESET = "None"
|
DEFAULT_PAYLOAD_RESET = "None"
|
||||||
DEFAULT_SOURCE_TYPE = SourceType.GPS
|
DEFAULT_SOURCE_TYPE = SourceType.GPS
|
||||||
|
|
||||||
PLATFORM_SCHEMA_MODERN = MQTT_RO_SCHEMA.extend(
|
|
||||||
|
def valid_config(config: ConfigType) -> ConfigType:
|
||||||
|
"""Check if there is a state topic or json_attributes_topic."""
|
||||||
|
if CONF_STATE_TOPIC not in config and CONF_JSON_ATTRS_TOPIC not in config:
|
||||||
|
raise vol.MultipleInvalid(
|
||||||
|
f"Invalid device tracker config, missing {CONF_STATE_TOPIC} or {CONF_JSON_ATTRS_TOPIC}, got: {config}"
|
||||||
|
)
|
||||||
|
return config
|
||||||
|
|
||||||
|
|
||||||
|
PLATFORM_SCHEMA_MODERN_BASE = MQTT_BASE_SCHEMA.extend(
|
||||||
{
|
{
|
||||||
|
vol.Optional(CONF_STATE_TOPIC): valid_subscribe_topic,
|
||||||
|
vol.Optional(CONF_VALUE_TEMPLATE): cv.template,
|
||||||
vol.Optional(CONF_NAME): cv.string,
|
vol.Optional(CONF_NAME): cv.string,
|
||||||
vol.Optional(CONF_PAYLOAD_HOME, default=STATE_HOME): cv.string,
|
vol.Optional(CONF_PAYLOAD_HOME, default=STATE_HOME): cv.string,
|
||||||
vol.Optional(CONF_PAYLOAD_NOT_HOME, default=STATE_NOT_HOME): cv.string,
|
vol.Optional(CONF_PAYLOAD_NOT_HOME, default=STATE_NOT_HOME): cv.string,
|
||||||
@ -56,10 +69,14 @@ PLATFORM_SCHEMA_MODERN = MQTT_RO_SCHEMA.extend(
|
|||||||
vol.Optional(CONF_SOURCE_TYPE, default=DEFAULT_SOURCE_TYPE): vol.In(
|
vol.Optional(CONF_SOURCE_TYPE, default=DEFAULT_SOURCE_TYPE): vol.In(
|
||||||
SOURCE_TYPES
|
SOURCE_TYPES
|
||||||
),
|
),
|
||||||
}
|
},
|
||||||
).extend(MQTT_ENTITY_COMMON_SCHEMA.schema)
|
).extend(MQTT_ENTITY_COMMON_SCHEMA.schema)
|
||||||
|
PLATFORM_SCHEMA_MODERN = vol.All(PLATFORM_SCHEMA_MODERN_BASE, valid_config)
|
||||||
|
|
||||||
DISCOVERY_SCHEMA = PLATFORM_SCHEMA_MODERN.extend({}, extra=vol.REMOVE_EXTRA)
|
|
||||||
|
DISCOVERY_SCHEMA = vol.All(
|
||||||
|
PLATFORM_SCHEMA_MODERN_BASE.extend({}, extra=vol.REMOVE_EXTRA), valid_config
|
||||||
|
)
|
||||||
|
|
||||||
# Configuring MQTT Device Trackers under the device_tracker platform key was deprecated
|
# Configuring MQTT Device Trackers under the device_tracker platform key was deprecated
|
||||||
# in HA Core 2022.6
|
# in HA Core 2022.6
|
||||||
@ -138,12 +155,15 @@ class MqttDeviceTracker(MqttEntity, TrackerEntity):
|
|||||||
|
|
||||||
get_mqtt_data(self.hass).state_write_requests.write_state_request(self)
|
get_mqtt_data(self.hass).state_write_requests.write_state_request(self)
|
||||||
|
|
||||||
|
state_topic: str | None = self._config.get(CONF_STATE_TOPIC)
|
||||||
|
if state_topic is None:
|
||||||
|
return
|
||||||
self._sub_state = subscription.async_prepare_subscribe_topics(
|
self._sub_state = subscription.async_prepare_subscribe_topics(
|
||||||
self.hass,
|
self.hass,
|
||||||
self._sub_state,
|
self._sub_state,
|
||||||
{
|
{
|
||||||
"state_topic": {
|
"state_topic": {
|
||||||
"topic": self._config[CONF_STATE_TOPIC],
|
"topic": state_topic,
|
||||||
"msg_callback": message_received,
|
"msg_callback": message_received,
|
||||||
"qos": self._config[CONF_QOS],
|
"qos": self._config[CONF_QOS],
|
||||||
}
|
}
|
||||||
|
@ -403,16 +403,12 @@ async def test_setting_device_tracker_location_via_lat_lon_message(
|
|||||||
mqtt_mock_entry: MqttMockHAClientGenerator,
|
mqtt_mock_entry: MqttMockHAClientGenerator,
|
||||||
caplog: pytest.LogCaptureFixture,
|
caplog: pytest.LogCaptureFixture,
|
||||||
) -> None:
|
) -> None:
|
||||||
"""Test the setting of the latitude and longitude via MQTT."""
|
"""Test the setting of the latitude and longitude via MQTT without state topic."""
|
||||||
await mqtt_mock_entry()
|
await mqtt_mock_entry()
|
||||||
async_fire_mqtt_message(
|
async_fire_mqtt_message(
|
||||||
hass,
|
hass,
|
||||||
"homeassistant/device_tracker/bla/config",
|
"homeassistant/device_tracker/bla/config",
|
||||||
"{ "
|
'{ "name": "test", "json_attributes_topic": "attributes-topic"}',
|
||||||
'"name": "test", '
|
|
||||||
'"state_topic": "test-topic", '
|
|
||||||
'"json_attributes_topic": "attributes-topic" '
|
|
||||||
"}",
|
|
||||||
)
|
)
|
||||||
await hass.async_block_till_done()
|
await hass.async_block_till_done()
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user