Convert unnecessary coroutines into functions (#118311)

This commit is contained in:
Markus Jacobsen 2024-05-29 16:44:43 +02:00 committed by GitHub
parent 916c6a2f46
commit 7fda7ccafc
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 23 additions and 15 deletions

View File

@ -17,6 +17,7 @@ from mozart_api.mozart_client import MozartClient
from homeassistant.config_entries import ConfigEntry
from homeassistant.const import CONF_HOST
from homeassistant.core import callback
from homeassistant.helpers.device_registry import DeviceInfo
from homeassistant.helpers.entity import Entity
@ -62,7 +63,8 @@ class BangOlufsenEntity(Entity, BangOlufsenBase):
self._attr_device_info = DeviceInfo(identifiers={(DOMAIN, self._unique_id)})
async def _update_connection_state(self, connection_state: bool) -> None:
@callback
def _async_update_connection_state(self, connection_state: bool) -> None:
"""Update entity connection state."""
self._attr_available = connection_state

View File

@ -43,7 +43,7 @@ from homeassistant.components.media_player import (
)
from homeassistant.config_entries import ConfigEntry
from homeassistant.const import CONF_MODEL
from homeassistant.core import HomeAssistant
from homeassistant.core import HomeAssistant, callback
from homeassistant.helpers.device_registry import DeviceInfo
from homeassistant.helpers.dispatcher import async_dispatcher_connect
from homeassistant.helpers.entity_platform import AddEntitiesCallback
@ -138,7 +138,7 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
async_dispatcher_connect(
self.hass,
f"{self._unique_id}_{CONNECTION_STATUS}",
self._update_connection_state,
self._async_update_connection_state,
)
)
@ -146,7 +146,7 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
async_dispatcher_connect(
self.hass,
f"{self._unique_id}_{WebsocketNotification.PLAYBACK_ERROR}",
self._update_playback_error,
self._async_update_playback_error,
)
)
@ -154,7 +154,7 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
async_dispatcher_connect(
self.hass,
f"{self._unique_id}_{WebsocketNotification.PLAYBACK_METADATA}",
self._update_playback_metadata,
self._async_update_playback_metadata,
)
)
@ -162,14 +162,14 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
async_dispatcher_connect(
self.hass,
f"{self._unique_id}_{WebsocketNotification.PLAYBACK_PROGRESS}",
self._update_playback_progress,
self._async_update_playback_progress,
)
)
self.async_on_remove(
async_dispatcher_connect(
self.hass,
f"{self._unique_id}_{WebsocketNotification.PLAYBACK_STATE}",
self._update_playback_state,
self._async_update_playback_state,
)
)
self.async_on_remove(
@ -183,14 +183,14 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
async_dispatcher_connect(
self.hass,
f"{self._unique_id}_{WebsocketNotification.SOURCE_CHANGE}",
self._update_source_change,
self._async_update_source_change,
)
)
self.async_on_remove(
async_dispatcher_connect(
self.hass,
f"{self._unique_id}_{WebsocketNotification.VOLUME}",
self._update_volume,
self._async_update_volume,
)
)
@ -300,7 +300,8 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
if self.hass.is_running:
self.async_write_ha_state()
async def _update_playback_metadata(self, data: PlaybackContentMetadata) -> None:
@callback
def _async_update_playback_metadata(self, data: PlaybackContentMetadata) -> None:
"""Update _playback_metadata and related."""
self._playback_metadata = data
@ -309,18 +310,21 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
self.async_write_ha_state()
async def _update_playback_error(self, data: PlaybackError) -> None:
@callback
def _async_update_playback_error(self, data: PlaybackError) -> None:
"""Show playback error."""
_LOGGER.error(data.error)
async def _update_playback_progress(self, data: PlaybackProgress) -> None:
@callback
def _async_update_playback_progress(self, data: PlaybackProgress) -> None:
"""Update _playback_progress and last update."""
self._playback_progress = data
self._attr_media_position_updated_at = utcnow()
self.async_write_ha_state()
async def _update_playback_state(self, data: RenderingState) -> None:
@callback
def _async_update_playback_state(self, data: RenderingState) -> None:
"""Update _playback_state and related."""
self._playback_state = data
@ -330,7 +334,8 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
self.async_write_ha_state()
async def _update_source_change(self, data: Source) -> None:
@callback
def _async_update_source_change(self, data: Source) -> None:
"""Update _source_change and related."""
self._source_change = data
@ -343,7 +348,8 @@ class BangOlufsenMediaPlayer(BangOlufsenEntity, MediaPlayerEntity):
self.async_write_ha_state()
async def _update_volume(self, data: VolumeState) -> None:
@callback
def _async_update_volume(self, data: VolumeState) -> None:
"""Update _volume."""
self._volume = data