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

Fix owntone websocket reconnection (#82680)

Browse Source
This commit is contained in:
uvjustin 2022-11-25 23:16:16 +08:00 committed by GitHub
parent 424d38ecc7
commit 5381f9f92f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
homeassistant/components/forked_daapd/media_player.py
View File

@ -926,7 +926,8 @@ class ForkedDaapdUpdater:
else: else:
_LOGGER.error("Invalid websocket port") _LOGGER.error("Invalid websocket port")
def _disconnected_callback(self): async def _disconnected_callback(self):
"""Send update signals when the websocket gets disconnected."""
async_dispatcher_send( async_dispatcher_send(
self.hass, SIGNAL_UPDATE_MASTER.format(self._entry_id), False self.hass, SIGNAL_UPDATE_MASTER.format(self._entry_id), False
) )

2
tests/components/forked_daapd/test_media_player.py
View File

@ -785,7 +785,7 @@ async def test_websocket_disconnect(hass, mock_api_object):
assert hass.states.get(TEST_MASTER_ENTITY_NAME).state != STATE_UNAVAILABLE assert hass.states.get(TEST_MASTER_ENTITY_NAME).state != STATE_UNAVAILABLE
assert hass.states.get(TEST_ZONE_ENTITY_NAMES[0]).state != STATE_UNAVAILABLE assert hass.states.get(TEST_ZONE_ENTITY_NAMES[0]).state != STATE_UNAVAILABLE
updater_disconnected = mock_api_object.start_websocket_handler.call_args[0][4] updater_disconnected = mock_api_object.start_websocket_handler.call_args[0][4]
updater_disconnected() await updater_disconnected()
await hass.async_block_till_done() await hass.async_block_till_done()
assert hass.states.get(TEST_MASTER_ENTITY_NAME).state == STATE_UNAVAILABLE assert hass.states.get(TEST_MASTER_ENTITY_NAME).state == STATE_UNAVAILABLE
assert hass.states.get(TEST_ZONE_ENTITY_NAMES[0]).state == STATE_UNAVAILABLE assert hass.states.get(TEST_ZONE_ENTITY_NAMES[0]).state == STATE_UNAVAILABLE