media_player.py

Go to the documentation of this file.

"""MediaPlayer platform for Roon integration."""
 
from __future__ import annotations
 
import logging
from typing import Any, cast
 
from roonapi import split_media_path
import voluptuous as vol
 
from homeassistant.components.media_player import (
    BrowseMedia,
    MediaPlayerEntity,
    MediaPlayerEntityFeature,
    MediaPlayerState,
    MediaType,
    RepeatMode,
)
from homeassistant.config_entries import ConfigEntry
from homeassistant.const import DEVICE_DEFAULT_NAME
from homeassistant.core import HomeAssistant, callback
from homeassistant.helpers import config_validation as cv, entity_platform
from homeassistant.helpers.device_registry import DeviceInfo
from homeassistant.helpers.dispatcher import (
    async_dispatcher_connect,
    async_dispatcher_send,
)
from homeassistant.helpers.entity_platform import AddEntitiesCallback
from homeassistant.util import convert
from homeassistant.util.dt import utcnow
 
from .const import DOMAIN
from .media_browser import browse_media
 
_LOGGER = logging.getLogger(__name__)
 
SERVICE_TRANSFER = "transfer"
 
ATTR_TRANSFER = "transfer_id"
 
REPEAT_MODE_MAPPING_TO_HA = {
    "loop": RepeatMode.ALL,
    "disabled": RepeatMode.OFF,
    "loop_one": RepeatMode.ONE,
}
 
REPEAT_MODE_MAPPING_TO_ROON = {
    value: key for key, value in REPEAT_MODE_MAPPING_TO_HA.items()
}
 
 
async def async_setup_entry(
    hass: HomeAssistant,
    config_entry: ConfigEntry,
    async_add_entities: AddEntitiesCallback,
) -> None:
    """Set up Roon MediaPlayer from Config Entry."""
    roon_server = hass.data[DOMAIN][config_entry.entry_id]
    media_players = set()
 
    # Register entity services
    platform = entity_platform.async_get_current_platform()
    platform.async_register_entity_service(
        SERVICE_TRANSFER,
        {vol.Required(ATTR_TRANSFER): cv.entity_id},
        "async_transfer",
    )
 
    @callback
    def async_update_media_player(player_data):
        """Add or update Roon MediaPlayer."""
        dev_id = player_data["dev_id"]
        if dev_id not in media_players:
            # new player!
            media_player = RoonDevice(roon_server, player_data)
            media_players.add(dev_id)
            async_add_entities([media_player])
        else:
            # update existing player
            async_dispatcher_send(
                hass, f"room_media_player_update_{dev_id}", player_data
            )
 
    # start listening for players to be added or changed by the server component
    async_dispatcher_connect(hass, "roon_media_player", async_update_media_player)
 
 
class RoonDevice(MediaPlayerEntity):
    """Representation of an Roon device."""
 
    _attr_should_poll = False
    _attr_supported_features = (
        MediaPlayerEntityFeature.BROWSE_MEDIA
        | MediaPlayerEntityFeature.GROUPING
        | MediaPlayerEntityFeature.PAUSE
        | MediaPlayerEntityFeature.STOP
        | MediaPlayerEntityFeature.PREVIOUS_TRACK
        | MediaPlayerEntityFeature.NEXT_TRACK
        | MediaPlayerEntityFeature.REPEAT_SET
        | MediaPlayerEntityFeature.SHUFFLE_SET
        | MediaPlayerEntityFeature.SEEK
        | MediaPlayerEntityFeature.TURN_ON
        | MediaPlayerEntityFeature.TURN_OFF
        | MediaPlayerEntityFeature.VOLUME_MUTE
        | MediaPlayerEntityFeature.PLAY
        | MediaPlayerEntityFeature.PLAY_MEDIA
    )
 
    def __init__(self, server, player_data):
        """Initialize Roon device object."""
        self._remove_signal_status_remove_signal_status = None
        self._server_server = server
        self._attr_available_attr_available = True
        self._supports_standby_supports_standby = False
        self._attr_state_attr_state = MediaPlayerState.IDLE
        self._zone_id_zone_id = None
        self._output_id_output_id = None
        self._attr_name_attr_name = DEVICE_DEFAULT_NAME
        self._attr_media_position_attr_media_position = 0
        self._attr_media_duration_attr_media_duration = 0
        self._attr_is_volume_muted_attr_is_volume_muted = False
        self._attr_volume_step_attr_volume_step = 0
        self._attr_shuffle_attr_shuffle = False
        self._attr_media_image_url_attr_media_image_url = None
        self._attr_volume_level_attr_volume_level = 0
        self._volume_fixed_volume_fixed = True
        self._volume_incremental_volume_incremental = False
        self.update_dataupdate_data(player_data)
 
    async def async_added_to_hass(self) -> None:
        """Register callback."""
        self.async_on_removeasync_on_remove(
            async_dispatcher_connect(
                self.hasshass,
                f"room_media_player_update_{self.unique_id}",
                self.async_update_callbackasync_update_callback,
            )
        )
        self._server_server.add_player_id(self.entity_identity_id, self.namename)
 
    @callback
    def async_update_callback(self, player_data):
        """Handle device updates."""
        self.update_dataupdate_data(player_data)
        self.async_write_ha_stateasync_write_ha_state()
 
    @property
    def group_members(self):
        """Return the grouped players."""
 
        roon_names = self._server_server.roonapi.grouped_zone_names(self._output_id_output_id)
        return [self._server_server.entity_id(roon_name) for roon_name in roon_names]
 
    @property
    def device_info(self) -> DeviceInfo | None:
        """Return the device info."""
        if self.unique_idunique_id is None:
            return None
        if self.player_dataplayer_data.get("source_controls"):
            dev_model = self.player_dataplayer_data["source_controls"][0].get("display_name")
        return DeviceInfo(
            identifiers={(DOMAIN, self.unique_idunique_id)},
            # Instead of setting the device name to the entity name, roon
            # should be updated to set has_entity_name = True, and set the entity
            # name to None
            name=cast(str | None, self.namename),
            manufacturer="RoonLabs",
            model=dev_model,
            via_device=(DOMAIN, self._server_server.roon_id),
        )
 
    def update_data(self, player_data=None):
        """Update session object."""
        if player_data:
            self.player_dataplayer_data = player_data
        if not self.player_dataplayer_data["is_available"]:
            # this player was removed
            self._attr_available_attr_available = False
            self._attr_state_attr_state = MediaPlayerState.OFF
        else:
            self._attr_available_attr_available = True
            # determine player state
            self.update_stateupdate_state()
            if self.statestatestatestatestate == MediaPlayerState.PLAYING:
                self._attr_media_position_updated_at_attr_media_position_updated_at = utcnow()
 
    @classmethod
    def _parse_volume(cls, player_data):
        """Parse volume data to determine volume levels and mute state."""
        volume = {
            "level": 0,
            "step": 0,
            "muted": False,
            "fixed": True,
            "incremental": False,
        }
 
        try:
            volume_data = player_data["volume"]
        except KeyError:
            return volume
 
        volume["fixed"] = False
        volume["incremental"] = volume_data["type"] == "incremental"
        volume["muted"] = volume_data.get("is_muted", False)
        volume["step"] = convert(volume_data.get("step"), int, 0)
 
        try:
            volume_max = volume_data["max"]
            volume_min = volume_data["min"]
 
            raw_level = convert(volume_data["value"], float, 0)
 
            volume_range = volume_max - volume_min
            volume_percentage_factor = volume_range / 100
 
            level = (raw_level - volume_min) / volume_percentage_factor
            volume["level"] = round(level) / 100
        except KeyError:
            pass
 
        return volume
 
    def _parse_now_playing(self, player_data):
        """Parse now playing data to determine title, artist, position, duration and artwork."""
        now_playing = {
            "title": None,
            "artist": None,
            "album": None,
            "position": 0,
            "duration": 0,
            "image": None,
        }
        now_playing_data = None
 
        media_position = convert(player_data.get("seek_position"), int, 0)
 
        try:
            now_playing_data = player_data["now_playing"]
            media_title = now_playing_data["three_line"]["line1"]
            media_artist = now_playing_data["three_line"]["line2"]
            media_album_name = now_playing_data["three_line"]["line3"]
            media_duration = convert(now_playing_data.get("length"), int, 0)
            image_id = now_playing_data.get("image_key")
        except KeyError:
            # catch KeyError
            pass
        else:
            now_playing["title"] = media_title
            now_playing["artist"] = media_artist
            now_playing["album"] = media_album_name
            now_playing["position"] = media_position
            now_playing["duration"] = media_duration
            if image_id:
                now_playing["image"] = self._server_server.roonapi.get_image(image_id)
 
        return now_playing
 
    def update_state(self):
        """Update the power state and player state."""
 
        new_state = ""
        # power state from source control (if supported)
        if "source_controls" in self.player_dataplayer_data:
            for source in self.player_dataplayer_data["source_controls"]:
                if source["supports_standby"] and source["status"] != "indeterminate":
                    self._supports_standby_supports_standby = True
                    if source["status"] in ["standby", "deselected"]:
                        new_state = MediaPlayerState.OFF
                    break
        # determine player state
        if not new_state:
            if (
                self.player_dataplayer_data["state"] == "playing"
                or self.player_dataplayer_data["state"] == "loading"
            ):
                new_state = MediaPlayerState.PLAYING
            elif self.player_dataplayer_data["state"] == "stopped":
                new_state = MediaPlayerState.IDLE
            elif self.player_dataplayer_data["state"] == "paused":
                new_state = MediaPlayerState.PAUSED
            else:
                new_state = MediaPlayerState.IDLE
        self._attr_state_attr_state = new_state
        self._attr_unique_id_attr_unique_id = self.player_dataplayer_data["dev_id"]
        self._zone_id_zone_id = self.player_dataplayer_data["zone_id"]
        self._output_id_output_id = self.player_dataplayer_data["output_id"]
        self._attr_repeat_attr_repeat = REPEAT_MODE_MAPPING_TO_HA.get(
            self.player_dataplayer_data["settings"]["loop"]
        )
        self._attr_shuffle_attr_shuffle = self.player_dataplayer_data["settings"]["shuffle"]
        self._attr_name_attr_name = self.player_dataplayer_data["display_name"]
 
        volume = RoonDevice._parse_volume(self.player_dataplayer_data)
        self._attr_is_volume_muted_attr_is_volume_muted = volume["muted"]
        self._attr_volume_step_attr_volume_step = volume["step"]
        self._attr_volume_level_attr_volume_level = volume["level"]
        self._volume_fixed_volume_fixed = volume["fixed"]
        self._volume_incremental_volume_incremental = volume["incremental"]
        if not self._volume_fixed_volume_fixed:
            self._attr_supported_features_attr_supported_features_attr_supported_features = (
                self._attr_supported_features_attr_supported_features_attr_supported_features | MediaPlayerEntityFeature.VOLUME_STEP
            )
            if not self._volume_incremental_volume_incremental:
                self._attr_supported_features_attr_supported_features_attr_supported_features = (
                    self._attr_supported_features_attr_supported_features_attr_supported_features | MediaPlayerEntityFeature.VOLUME_SET
                )
 
        now_playing = self._parse_now_playing_parse_now_playing(self.player_dataplayer_data)
        self._attr_media_title_attr_media_title = now_playing["title"]
        self._attr_media_artist_attr_media_artist = now_playing["artist"]
        self._attr_media_album_name_attr_media_album_name = now_playing["album"]
        self._attr_media_position_attr_media_position = now_playing["position"]
        self._attr_media_duration_attr_media_duration = now_playing["duration"]
        self._attr_media_image_url_attr_media_image_url = now_playing["image"]
 
    @property
    def zone_id(self):
        """Return current session Id."""
        return self._zone_id_zone_id
 
    @property
    def output_id(self):
        """Return current session Id."""
        return self._output_id_output_id
 
    @property
    def media_album_artist(self) -> str | None:
        """Album artist of current playing media (Music track only)."""
        return self.media_artistmedia_artist
 
    @property
    def supports_standby(self):
        """Return power state of source controls."""
        return self._supports_standby_supports_standby
 
    def media_play(self) -> None:
        """Send play command to device."""
        self._server_server.roonapi.playback_control(self.output_idoutput_id, "play")
 
    def media_pause(self) -> None:
        """Send pause command to device."""
        self._server_server.roonapi.playback_control(self.output_idoutput_id, "pause")
 
    def media_play_pause(self) -> None:
        """Toggle play command to device."""
        self._server_server.roonapi.playback_control(self.output_idoutput_id, "playpause")
 
    def media_stop(self) -> None:
        """Send stop command to device."""
        self._server_server.roonapi.playback_control(self.output_idoutput_id, "stop")
 
    def media_next_track(self) -> None:
        """Send next track command to device."""
        self._server_server.roonapi.playback_control(self.output_idoutput_id, "next")
 
    def media_previous_track(self) -> None:
        """Send previous track command to device."""
        self._server_server.roonapi.playback_control(self.output_idoutput_id, "previous")
 
    def media_seek(self, position: float) -> None:
        """Send seek command to device."""
        self._server_server.roonapi.seek(self.output_idoutput_id, position)
        # Seek doesn't cause an async update - so force one
        self._attr_media_position_attr_media_position = round(position)
        self.schedule_update_ha_stateschedule_update_ha_state()
 
    def set_volume_level(self, volume: float) -> None:
        """Send new volume_level to device."""
        volume = volume * 100
        self._server_server.roonapi.set_volume_percent(self.output_idoutput_id, volume)
 
    def mute_volume(self, mute=True):
        """Send mute/unmute to device."""
        self._server_server.roonapi.mute(self.output_idoutput_id, mute)
 
    def volume_up(self) -> None:
        """Send new volume_level to device."""
        if self._volume_incremental_volume_incremental:
            self._server_server.roonapi.change_volume_raw(self.output_idoutput_id, 1, "relative")
        else:
            self._server_server.roonapi.change_volume_percent(self.output_idoutput_id, 3)
 
    def volume_down(self) -> None:
        """Send new volume_level to device."""
        if self._volume_incremental_volume_incremental:
            self._server_server.roonapi.change_volume_raw(self.output_idoutput_id, -1, "relative")
        else:
            self._server_server.roonapi.change_volume_percent(self.output_idoutput_id, -3)
 
    def turn_on(self) -> None:
        """Turn on device (if supported)."""
        if not (self.supports_standbysupports_standby and "source_controls" in self.player_dataplayer_data):
            self.media_playmedia_playmedia_play()
            return
        for source in self.player_dataplayer_data["source_controls"]:
            if source["supports_standby"] and source["status"] != "indeterminate":
                self._server_server.roonapi.convenience_switch(
                    self.output_idoutput_id, source["control_key"]
                )
                return
 
    def turn_off(self) -> None:
        """Turn off device (if supported)."""
        if not (self.supports_standbysupports_standby and "source_controls" in self.player_dataplayer_data):
            self.media_stopmedia_stopmedia_stop()
            return
 
        for source in self.player_dataplayer_data["source_controls"]:
            if source["supports_standby"] and source["status"] != "indeterminate":
                self._server_server.roonapi.standby(self.output_idoutput_id, source["control_key"])
                return
 
    def set_shuffle(self, shuffle: bool) -> None:
        """Set shuffle state."""
        self._server_server.roonapi.shuffle(self.output_idoutput_id, shuffle)
 
    def set_repeat(self, repeat: RepeatMode) -> None:
        """Set repeat mode."""
        if repeat not in REPEAT_MODE_MAPPING_TO_ROON:
            raise ValueError(f"Unsupported repeat mode: {repeat}")
        self._server_server.roonapi.repeat(self.output_idoutput_id, REPEAT_MODE_MAPPING_TO_ROON[repeat])
 
    def play_media(
        self, media_type: MediaType | str, media_id: str, **kwargs: Any
    ) -> None:
        """Send the play_media command to the media player."""
 
        _LOGGER.debug("Playback request for %s / %s", media_type, media_id)
        if media_type in ("library", "track"):
            # media_id is a roon browser id
            self._server_server.roonapi.play_id(self.zone_idzone_id, media_id)
        else:
            # media_id is a path matching the Roon menu structure
            path_list = split_media_path(media_id)
            if not self._server_server.roonapi.play_media(self.zone_idzone_id, path_list):
                _LOGGER.error(
                    "Playback request for %s / %s / %s was unsuccessful",
                    media_type,
                    media_id,
                    path_list,
                )
 
    def join_players(self, group_members: list[str]) -> None:
        """Join `group_members` as a player group with the current player."""
 
        zone_data = self._server_server.roonapi.zone_by_output_id(self._output_id_output_id)
        if zone_data is None:
            _LOGGER.error("No zone data for %s", self.namename)
            return
 
        sync_available = {}
        for zone in self._server_server.zones.values():
            for output in zone["outputs"]:
                if (
                    zone["display_name"] != self.namename
                    and output["output_id"]
                    in self.player_dataplayer_data["can_group_with_output_ids"]
                    and zone["display_name"] not in sync_available
                ):
                    sync_available[zone["display_name"]] = output["output_id"]
 
        names = []
        for entity_id in group_members:
            name = self._server_server.roon_name(entity_id)
            if name is None:
                _LOGGER.error("No roon player found for %s", entity_id)
                return
            if name not in sync_available:
                _LOGGER.error(
                    (
                        "Can't join player %s with %s because it's not in the join"
                        " available list %s"
                    ),
                    name,
                    self.namename,
                    list(sync_available),
                )
                return
            names.append(name)
 
        _LOGGER.debug("Joining %s to %s", names, self.namename)
        self._server_server.roonapi.group_outputs(
            [self._output_id_output_id] + [sync_available[name] for name in names]
        )
 
    def unjoin_player(self) -> None:
        """Remove this player from any group."""
 
        if not self._server_server.roonapi.is_grouped(self._output_id_output_id):
            _LOGGER.error(
                "Can't unjoin player %s because it's not in a group",
                self.namename,
            )
            return
 
        self._server_server.roonapi.ungroup_outputs([self._output_id_output_id])
 
    async def async_transfer(self, transfer_id):
        """Transfer playback from this roon player to another."""
 
        name = self._server_server.roon_name(transfer_id)
        if name is None:
            _LOGGER.error("No roon player found for %s", transfer_id)
            return
 
        zone_ids = {
            output["display_name"]: output["zone_id"]
            for output in self._server_server.zones.values()
            if output["display_name"] != self.namename
        }
 
        if (transfer_id := zone_ids.get(name)) is None:
            _LOGGER.error(
                "Can't transfer from %s to %s because destination is not known %s",
                self.namename,
                transfer_id,
                list(zone_ids),
            )
 
        _LOGGER.debug("Transferring from %s to %s", self.namename, name)
        await self.hasshass.async_add_executor_job(
            self._server_server.roonapi.transfer_zone, self._zone_id_zone_id, transfer_id
        )
 
    async def async_browse_media(
        self,
        media_content_type: MediaType | str | None = None,
        media_content_id: str | None = None,
    ) -> BrowseMedia:
        """Implement the websocket media browsing helper."""
        return await self.hasshass.async_add_executor_job(
            browse_media,
            self.zone_idzone_id,
            self._server_server,
            media_content_type,
            media_content_id,
        )