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

Mobile app fixes (#36559)

Browse Source
This commit is contained in:
Paulus Schoutsen 2020-06-08 10:20:25 -07:00 committed by GitHub
parent b3cbce3566
commit 3adfb86a19
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
homeassistant/components/mobile_app/webhook.py
View File

@ -1,4 +1,5 @@
"""Webhook handlers for mobile_app.""" """Webhook handlers for mobile_app."""
import asyncio
from functools import wraps from functools import wraps
import logging import logging
import secrets import secrets
@ -28,7 +29,7 @@ from homeassistant.const import (
HTTP_CREATED, HTTP_CREATED,
) )
from homeassistant.core import EventOrigin from homeassistant.core import EventOrigin
from homeassistant.exceptions import HomeAssistantError, ServiceNotFound, TemplateError from homeassistant.exceptions import ServiceNotFound, TemplateError
from homeassistant.helpers import config_validation as cv, device_registry as dr from homeassistant.helpers import config_validation as cv, device_registry as dr
from homeassistant.helpers.dispatcher import async_dispatcher_send from homeassistant.helpers.dispatcher import async_dispatcher_send
from homeassistant.helpers.template import attach from homeassistant.helpers.template import attach
@ -95,6 +96,7 @@ from .helpers import (
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
DELAY_SAVE = 10
WEBHOOK_COMMANDS = Registry() WEBHOOK_COMMANDS = Registry()
@ -184,7 +186,10 @@ async def handle_webhook(
"Received webhook payload for type %s: %s", webhook_type, webhook_payload "Received webhook payload for type %s: %s", webhook_type, webhook_payload
) )
return await WEBHOOK_COMMANDS[webhook_type](hass, config_entry, webhook_payload) # Shield so we make sure we finish the webhook, even if sender hangs up.
return await asyncio.shield(
WEBHOOK_COMMANDS[webhook_type](hass, config_entry, webhook_payload)
)
@WEBHOOK_COMMANDS.register("call_service") @WEBHOOK_COMMANDS.register("call_service")
@ -376,11 +381,9 @@ async def webhook_register_sensor(hass, config_entry, data):
hass.data[DOMAIN][entity_type][unique_store_key] = data hass.data[DOMAIN][entity_type][unique_store_key] = data
try: hass.data[DOMAIN][DATA_STORE].async_delay_save(
await hass.data[DOMAIN][DATA_STORE].async_save(savable_state(hass)) lambda: savable_state(hass), DELAY_SAVE
except HomeAssistantError as ex: )
_LOGGER.error("Error registering sensor: %s", ex)
return empty_okay_response()
register_signal = f"{DOMAIN}_{data[ATTR_SENSOR_TYPE]}_register" register_signal = f"{DOMAIN}_{data[ATTR_SENSOR_TYPE]}_register"
async_dispatcher_send(hass, register_signal, data) async_dispatcher_send(hass, register_signal, data)
@ -458,18 +461,14 @@ async def webhook_update_sensor_states(hass, config_entry, data):
hass.data[DOMAIN][entity_type][unique_store_key] = new_state hass.data[DOMAIN][entity_type][unique_store_key] = new_state
safe = savable_state(hass)
try:
await hass.data[DOMAIN][DATA_STORE].async_save(safe)
except HomeAssistantError as ex:
_LOGGER.error("Error updating mobile_app registration: %s", ex)
return empty_okay_response()
async_dispatcher_send(hass, SIGNAL_SENSOR_UPDATE, new_state) async_dispatcher_send(hass, SIGNAL_SENSOR_UPDATE, new_state)
resp[unique_id] = {"success": True} resp[unique_id] = {"success": True}
hass.data[DOMAIN][DATA_STORE].async_delay_save(
lambda: savable_state(hass), DELAY_SAVE
)
return webhook_response(resp, registration=config_entry.data) return webhook_response(resp, registration=config_entry.data)