jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-27 07:07:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use selectors for basic broker and options for MQTT config flow (#79791)

Browse Source 
Use selectors for basic broker en options
This commit is contained in:
Jan Bouwhuis 2022-10-11 10:51:35 +02:00 committed by GitHub
parent 8aa30cce26
commit 65187ab227
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 41 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
homeassistant/components/mqtt/config_flow.py
View File

@ -21,6 +21,15 @@ from homeassistant.const import (
) )
from homeassistant.core import HomeAssistant, callback from homeassistant.core import HomeAssistant, callback
from homeassistant.data_entry_flow import FlowResult from homeassistant.data_entry_flow import FlowResult
from homeassistant.helpers.selector import (
BooleanSelector,
NumberSelector,
NumberSelectorConfig,
NumberSelectorMode,
TextSelector,
TextSelectorConfig,
TextSelectorType,
)
from homeassistant.helpers.typing import ConfigType from homeassistant.helpers.typing import ConfigType
from .client import MqttClientSetup from .client import MqttClientSetup
@ -42,6 +51,19 @@ from .util import MQTT_WILL_BIRTH_SCHEMA, get_mqtt_data
MQTT_TIMEOUT = 5 MQTT_TIMEOUT = 5
BOOLEAN_SELECTOR = BooleanSelector()
TEXT_SELECTOR = TextSelector(TextSelectorConfig(type=TextSelectorType.TEXT))
PUBLISH_TOPIC_SELECTOR = TextSelector(TextSelectorConfig(type=TextSelectorType.TEXT))
PORT_SELECTOR = vol.All(
NumberSelector(NumberSelectorConfig(mode=NumberSelectorMode.BOX, min=1, max=65535)),
vol.Coerce(int),
)
PASSWORD_SELECTOR = TextSelector(TextSelectorConfig(type=TextSelectorType.PASSWORD))
QOS_SELECTOR = vol.All(
NumberSelector(NumberSelectorConfig(mode=NumberSelectorMode.BOX, min=0, max=2)),
vol.Coerce(int),
)
class FlowHandler(config_entries.ConfigFlow, domain=DOMAIN): class FlowHandler(config_entries.ConfigFlow, domain=DOMAIN):
"""Handle a config flow.""" """Handle a config flow."""
@ -282,7 +304,7 @@ class MQTTOptionsFlowHandler(config_entries.OptionsFlow):
# build form # build form
fields: OrderedDict[vol.Marker, Any] = OrderedDict() fields: OrderedDict[vol.Marker, Any] = OrderedDict()
fields[vol.Optional(CONF_DISCOVERY, default=discovery)] = bool fields[vol.Optional(CONF_DISCOVERY, default=discovery)] = BOOLEAN_SELECTOR
# Birth message is disabled if CONF_BIRTH_MESSAGE = {} # Birth message is disabled if CONF_BIRTH_MESSAGE = {}
fields[ fields[
@ -291,19 +313,21 @@ class MQTTOptionsFlowHandler(config_entries.OptionsFlow):
default=CONF_BIRTH_MESSAGE not in current_config default=CONF_BIRTH_MESSAGE not in current_config
or current_config[CONF_BIRTH_MESSAGE] != {}, or current_config[CONF_BIRTH_MESSAGE] != {},
) )
] = bool ] = BOOLEAN_SELECTOR
fields[ fields[
vol.Optional( vol.Optional(
"birth_topic", description={"suggested_value": birth[ATTR_TOPIC]} "birth_topic", description={"suggested_value": birth[ATTR_TOPIC]}
) )
] = str ] = PUBLISH_TOPIC_SELECTOR
fields[ fields[
vol.Optional( vol.Optional(
"birth_payload", description={"suggested_value": birth[CONF_PAYLOAD]} "birth_payload", description={"suggested_value": birth[CONF_PAYLOAD]}
) )
] = str ] = TEXT_SELECTOR
fields[vol.Optional("birth_qos", default=birth[ATTR_QOS])] = vol.In([0, 1, 2]) fields[vol.Optional("birth_qos", default=birth[ATTR_QOS])] = QOS_SELECTOR
fields[vol.Optional("birth_retain", default=birth[ATTR_RETAIN])] = bool fields[
vol.Optional("birth_retain", default=birth[ATTR_RETAIN])
] = BOOLEAN_SELECTOR
# Will message is disabled if CONF_WILL_MESSAGE = {} # Will message is disabled if CONF_WILL_MESSAGE = {}
fields[ fields[
@ -312,19 +336,21 @@ class MQTTOptionsFlowHandler(config_entries.OptionsFlow):
default=CONF_WILL_MESSAGE not in current_config default=CONF_WILL_MESSAGE not in current_config
or current_config[CONF_WILL_MESSAGE] != {}, or current_config[CONF_WILL_MESSAGE] != {},
) )
] = bool ] = BOOLEAN_SELECTOR
fields[ fields[
vol.Optional( vol.Optional(
"will_topic", description={"suggested_value": will[ATTR_TOPIC]} "will_topic", description={"suggested_value": will[ATTR_TOPIC]}
) )
] = str ] = PUBLISH_TOPIC_SELECTOR
fields[ fields[
vol.Optional( vol.Optional(
"will_payload", description={"suggested_value": will[CONF_PAYLOAD]} "will_payload", description={"suggested_value": will[CONF_PAYLOAD]}
) )
] = str ] = TEXT_SELECTOR
fields[vol.Optional("will_qos", default=will[ATTR_QOS])] = vol.In([0, 1, 2]) fields[vol.Optional("will_qos", default=will[ATTR_QOS])] = QOS_SELECTOR
fields[vol.Optional("will_retain", default=will[ATTR_RETAIN])] = bool fields[
vol.Optional("will_retain", default=will[ATTR_RETAIN])
] = BOOLEAN_SELECTOR
return self.async_show_form( return self.async_show_form(
step_id="options", step_id="options",
@ -366,20 +392,20 @@ async def async_get_broker_settings(
current_pass = current_config.get(CONF_PASSWORD, yaml_config.get(CONF_PASSWORD)) current_pass = current_config.get(CONF_PASSWORD, yaml_config.get(CONF_PASSWORD))
# Build form # Build form
fields[vol.Required(CONF_BROKER, default=current_broker)] = str fields[vol.Required(CONF_BROKER, default=current_broker)] = TEXT_SELECTOR
fields[vol.Required(CONF_PORT, default=current_port)] = vol.Coerce(int) fields[vol.Required(CONF_PORT, default=current_port)] = PORT_SELECTOR
fields[ fields[
vol.Optional( vol.Optional(
CONF_USERNAME, CONF_USERNAME,
description={"suggested_value": current_user}, description={"suggested_value": current_user},
) )
] = str ] = TEXT_SELECTOR
fields[ fields[
vol.Optional( vol.Optional(
CONF_PASSWORD, CONF_PASSWORD,
description={"suggested_value": current_pass}, description={"suggested_value": current_pass},
) )
] = str ] = PASSWORD_SELECTOR
# Show form # Show form
return False return False