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

Implement retry for Netatmo webhook registration (#62597)

Browse Source
This commit is contained in:
Tobias Sauerwein 2022-01-04 16:52:27 +01:00 committed by GitHub
parent ee375ff42d
commit c423b01eb0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
homeassistant/components/netatmo/__init__.py
View File

@ -73,6 +73,8 @@ CONFIG_SCHEMA = vol.Schema(
extra=vol.ALLOW_EXTRA, extra=vol.ALLOW_EXTRA,
) )
MAX_WEBHOOK_RETRIES = 3
async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool: async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
"""Set up the Netatmo component.""" """Set up the Netatmo component."""
@ -146,6 +148,8 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
hass.config_entries.async_setup_platforms(entry, PLATFORMS) hass.config_entries.async_setup_platforms(entry, PLATFORMS)
_webhook_retries = 0
async def unregister_webhook(call: ServiceCall | None) -> None: async def unregister_webhook(call: ServiceCall | None) -> None:
if CONF_WEBHOOK_ID not in entry.data: if CONF_WEBHOOK_ID not in entry.data:
return return
@ -163,6 +167,11 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
"No webhook to be dropped for %s", entry.data[CONF_WEBHOOK_ID] "No webhook to be dropped for %s", entry.data[CONF_WEBHOOK_ID]
) )
nonlocal _webhook_retries
if _webhook_retries < MAX_WEBHOOK_RETRIES:
_webhook_retries += 1
async_call_later(hass, 30, register_webhook)
async def register_webhook(call: ServiceCall | None) -> None: async def register_webhook(call: ServiceCall | None) -> None:
if CONF_WEBHOOK_ID not in entry.data: if CONF_WEBHOOK_ID not in entry.data:
data = {**entry.data, CONF_WEBHOOK_ID: secrets.token_hex()} data = {**entry.data, CONF_WEBHOOK_ID: secrets.token_hex()}