evlli/hass-core
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Remove deprecated hass.components from mysensors (#113611)

Browse source
This commit is contained in:
Jan-Philipp Benecke 2024-03-16 20:49:25 +01:00 • committed by GitHub
parent 6ee273a548
commit 4be9d3e7f6
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
homeassistant/components/mysensors/gateway.py
View file

@ -17,6 +17,8 @@ from homeassistant.components.mqtt import (
DOMAIN as MQTT_DOMAIN, DOMAIN as MQTT_DOMAIN,
ReceiveMessage as MQTTReceiveMessage, ReceiveMessage as MQTTReceiveMessage,
ReceivePayloadType, ReceivePayloadType,
async_publish,
async_subscribe,
) )
from homeassistant.config_entries import ConfigEntry from homeassistant.config_entries import ConfigEntry
from homeassistant.const import CONF_DEVICE, EVENT_HOMEASSISTANT_STOP from homeassistant.const import CONF_DEVICE, EVENT_HOMEASSISTANT_STOP
@ -171,13 +173,10 @@ async def _get_gateway(
# Naive check that doesn't consider config entry state. # Naive check that doesn't consider config entry state.
if MQTT_DOMAIN not in hass.config.components: if MQTT_DOMAIN not in hass.config.components:
return None return None
mqtt = hass.components.mqtt
def pub_callback(topic: str, payload: str, qos: int, retain: bool) -> None: def pub_callback(topic: str, payload: str, qos: int, retain: bool) -> None:
"""Call MQTT publish function.""" """Call MQTT publish function."""
hass.async_create_task( hass.async_create_task(async_publish(hass, topic, payload, qos, retain))
mqtt.async_publish(hass, topic, payload, qos, retain)
)
def sub_callback( def sub_callback(
topic: str, sub_cb: Callable[[str, ReceivePayloadType, int], None], qos: int topic: str, sub_cb: Callable[[str, ReceivePayloadType, int], None], qos: int
@ -189,7 +188,7 @@ async def _get_gateway(
"""Call callback.""" """Call callback."""
sub_cb(msg.topic, msg.payload, msg.qos) sub_cb(msg.topic, msg.payload, msg.qos)
hass.async_create_task(mqtt.async_subscribe(topic, internal_callback, qos)) hass.async_create_task(async_subscribe(hass, topic, internal_callback, qos))
gateway = mysensors.AsyncMQTTGateway( gateway = mysensors.AsyncMQTTGateway(
pub_callback, pub_callback,