7e4b9adc3d
* Rewrite of Spotify integration * Update homeassistant/components/spotify/config_flow.py Co-Authored-By: Paulus Schoutsen <balloob@gmail.com> * Remove configurator dependency * Strip whitespace from device model in case Spotify product is missing * Ensure domain dict exists in hass data on setup entry * Simply config validation for client id and secret * Abort flow on any exception from spotipy * Add tests for config flow * Gen requirements all * Add test package __init__ * Remove Spotify from coveragerc * Made alias handling more robuust * Fix supported_features for Spotify free and open accounts * Improve error message in the logs * Re-implement Spotify media_player * Change media content type when play a playlist * Process review suggestions * Move Spotify init, static current user and supported_features * Remove unneeded me call * Remove playlist content type due to frontend issues * Improve playlist handling, when context is missing * Handle entity disabled correctly * Handle being offline/unavailable correctly * Bump Spotipy to 2.7.1 * Update coverage RC, mark integration silver * Remove URI limitation, lib supports all Spotify URI's now * Final cleanup * Addresses Pylint error Co-authored-by: Paulus Schoutsen <paulus@home-assistant.io>
57 lines
1.8 KiB
Python
57 lines
1.8 KiB
Python
"""Config flow for Spotify."""
|
|
import logging
|
|
|
|
from spotipy import Spotify
|
|
|
|
from homeassistant import config_entries
|
|
from homeassistant.helpers import config_entry_oauth2_flow
|
|
|
|
from .const import DOMAIN
|
|
|
|
_LOGGER = logging.getLogger(__name__)
|
|
|
|
|
|
class SpotifyFlowHandler(
|
|
config_entry_oauth2_flow.AbstractOAuth2FlowHandler, domain=DOMAIN
|
|
):
|
|
"""Config flow to handle Spotify OAuth2 authentication."""
|
|
|
|
DOMAIN = DOMAIN
|
|
CONNECTION_CLASS = config_entries.CONN_CLASS_CLOUD_POLL
|
|
|
|
@property
|
|
def logger(self) -> logging.Logger:
|
|
"""Return logger."""
|
|
return logging.getLogger(__name__)
|
|
|
|
@property
|
|
def extra_authorize_data(self) -> dict:
|
|
"""Extra data that needs to be appended to the authorize url."""
|
|
scopes = [
|
|
# Needed to be able to control playback
|
|
"user-modify-playback-state",
|
|
# Needed in order to read available devices
|
|
"user-read-playback-state",
|
|
# Needed to determine if the user has Spotify Premium
|
|
"user-read-private",
|
|
]
|
|
return {"scope": ",".join(scopes)}
|
|
|
|
async def async_oauth_create_entry(self, data: dict) -> dict:
|
|
"""Create an entry for Spotify."""
|
|
spotify = Spotify(auth=data["token"]["access_token"])
|
|
|
|
try:
|
|
current_user = await self.hass.async_add_executor_job(spotify.current_user)
|
|
except Exception: # pylint: disable=broad-except
|
|
return self.async_abort(reason="connection_error")
|
|
|
|
name = data["id"] = current_user["id"]
|
|
|
|
if current_user.get("display_name"):
|
|
name = current_user["display_name"]
|
|
data["name"] = name
|
|
|
|
await self.async_set_unique_id(current_user["id"])
|
|
|
|
return self.async_create_entry(title=name, data=data)
|