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

Delay Plex websocket connection to avoid race (#28934)

Browse Source
This commit is contained in:
jjlawren 2019-11-21 14:39:24 -06:00 committed by Paulus Schoutsen
parent c015f94fa2
commit a62bd97fa5
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
homeassistant/components/plex/__init__.py
View File

@ -16,6 +16,7 @@ from homeassistant.const import (
CONF_TOKEN, CONF_TOKEN,
CONF_URL, CONF_URL,
CONF_VERIFY_SSL, CONF_VERIFY_SSL,
EVENT_HOMEASSISTANT_START,
EVENT_HOMEASSISTANT_STOP, EVENT_HOMEASSISTANT_STOP,
) )
from homeassistant.helpers import config_validation as cv from homeassistant.helpers import config_validation as cv
@ -164,12 +165,16 @@ async def async_setup_entry(hass, entry):
websocket = PlexWebsocket( websocket = PlexWebsocket(
plex_server.plex_server, update_plex, session=session, verify_ssl=verify_ssl plex_server.plex_server, update_plex, session=session, verify_ssl=verify_ssl
) )
hass.loop.create_task(websocket.listen())
hass.data[PLEX_DOMAIN][WEBSOCKETS][server_id] = websocket hass.data[PLEX_DOMAIN][WEBSOCKETS][server_id] = websocket
async def async_start_websocket_session(_):
await websocket.listen()
def close_websocket_session(_): def close_websocket_session(_):
websocket.close() websocket.close()
hass.bus.async_listen_once(EVENT_HOMEASSISTANT_START, async_start_websocket_session)
unsub = hass.bus.async_listen_once( unsub = hass.bus.async_listen_once(
EVENT_HOMEASSISTANT_STOP, close_websocket_session EVENT_HOMEASSISTANT_STOP, close_websocket_session
) )

1
homeassistant/components/plex/media_player.py
View File

@ -68,6 +68,7 @@ async def async_setup_entry(hass, config_entry, async_add_entities):
hass, PLEX_NEW_MP_SIGNAL.format(server_id), async_new_media_players hass, PLEX_NEW_MP_SIGNAL.format(server_id), async_new_media_players
) )
hass.data[PLEX_DOMAIN][DISPATCHERS][server_id].append(unsub) hass.data[PLEX_DOMAIN][DISPATCHERS][server_id].append(unsub)
_LOGGER.debug("New entity listener created")
@callback @callback