Merge pull request #4 from unparalleled-js/feat/custom-playe

feat: support for AFPlay

Author: antazoey

README.md

@@ -123,6 +123,13 @@ And if you really enjoy the track, you can download it by doing:
 audius tracks download G0wyE song.mp3
 ```
 
+By default, `audius-py` tries to find the best player.
+However, specify your player of choice using the `--player` flag:
+
+```shell
+audius tracks play G0wyE --player vlc
+```
+
 ### Python SDK
 
 Use the Python SDK directly:

audius/cli/options.py

@@ -0,0 +1,12 @@
+import click
+
+from audius.types import PlayerType
+
+
+def player_option():
+    return click.option(
+        "--player",
+        help="The player to use.",
+        type=click.Choice([x.value for x in PlayerType.__members__.values()], case_sensitive=False),
+        callback=lambda _, _2, val: PlayerType(val),
+    )

audius/cli/tracks.py

@@ -3,8 +3,11 @@
 
 import click
 
+from audius.cli.options import player_option
 from audius.cli.utils import sdk
 
+DEFAULT_BUFFER_SIZE = 1024 * 1024
+
 
 def tracks(sdk_cls: Type):
     sdk.py = sdk_cls
@@ -55,23 +58,27 @@ def search(sdk, query):
     @cli.command()
     @sdk.audius()
     @click.argument("track_id")
-    def play(sdk, track_id):
+    @player_option()
+    def play(sdk, track_id, player):
         """
         Play a track.
         """
 
-        sdk.tracks.play(track_id)
+        sdk.tracks.play(track_id, player=player)
 
     @cli.command()
     @sdk.audius()
     @click.argument("track_id")
     @click.argument("out_path", type=Path)
-    def download(sdk, track_id, out_path):
+    @click.option(
+        "--buffer-size", help="The buffer size when downloading.", default=DEFAULT_BUFFER_SIZE
+    )
+    def download(sdk, track_id, out_path, buffer_size):
         """
         Download a track.
         """
 
-        sdk.tracks.download(track_id, out_path)
+        sdk.tracks.download(track_id, out_path, chunk_size=buffer_size)
 
     return cli
 

audius/client.py

@@ -1,14 +1,44 @@
 from functools import cached_property
+from typing import TYPE_CHECKING
 
 from requests import Response, Session
 
-from audius.config import Config
+if TYPE_CHECKING:
+    from audius.config import Config
+    from audius.playlists import Playlists
+    from audius.sdk import Audius
+    from audius.tips import Tips
+    from audius.tracks import Tracks
+    from audius.users import Users
 
 
 class API:
-    def __init__(self, client: "Client", config: Config):
-        self.client = client
-        self.config = config
+    def __init__(self, sdk: "Audius"):
+        self.sdk = sdk
+
+    @property
+    def client(self) -> "Client":
+        return self.sdk.client
+
+    @property
+    def config(self) -> "Config":
+        return self.sdk.config
+
+    @property
+    def playlists(self) -> "Playlists":
+        return self.sdk.playlists
+
+    @property
+    def tips(self) -> "Tips":
+        return self.sdk.tips
+
+    @property
+    def tracks(self) -> "Tracks":
+        return self.sdk.tracks
+
+    @property
+    def users(self) -> "Users":
+        return self.sdk.users
 
     def _handle_id(self, _id: str) -> str:
         return self.config.aliases[_id] if _id in self.config.aliases else _id
@@ -30,8 +60,16 @@ def get(self, url: str, **kwargs) -> dict:
 
         return self.request("GET", url, **kwargs).json()
 
+    def get_redirect_url(self, uri: str):
+        result = self.request("HEAD", uri, allow_redirects=True)
+        return result.url
+
     def request(self, method: str, url: str, **kwargs) -> Response:
-        url = f"{self.host_address}/v1/{url}"
+        prefix = f"{self.host_address}/v1/"
+        uri = url.replace(prefix, "")
+        if "https://" not in uri:
+            url = f"{prefix}{uri}"
+
         response = self.session.request(method, url, **kwargs)
         response.raise_for_status()
         return response

audius/config.py

@@ -1,9 +1,12 @@
 import os
-from typing import Dict, Optional
+from typing import Dict, Optional, Union
+
+from audius.player import PlayerType
 
 DEFAULT_APP_NAME = "audius-py"
 AUDIUS_APP_NAME_ENV_VAR = "AUDIUS_APP_NAME"
 AUDIUS_HOST_NAME_ENV_VAR = "AUDIUS_HOST_NAME"
+AUDIUS_PLAYER_ENV_VAR = "AUDIUS_PLAYER"
 
 
 class Config:
@@ -16,13 +19,16 @@ def __init__(
         app_name: str = DEFAULT_APP_NAME,
         host: Optional[str] = None,
         aliases: Optional[Dict[str, str]] = None,
+        player: Optional[Union[PlayerType, str]] = None,
     ):
         self.app_name = app_name
         self.host = host  # Uses random if not provided.
         self.aliases = aliases or {}
+        self.player = PlayerType(player) if player is not None else None
 
     @classmethod
     def from_env(cls) -> "Config":
         app_name = os.environ.get(AUDIUS_APP_NAME_ENV_VAR, DEFAULT_APP_NAME)
         host = os.environ.get(AUDIUS_HOST_NAME_ENV_VAR)
-        return cls(app_name=app_name, host=host)
+        player = os.environ.get(AUDIUS_PLAYER_ENV_VAR)
+        return cls(app_name=app_name, host=host, player=player)

audius/data.py

@@ -50,7 +50,7 @@ class MissingPlayerError(AudiusException):
     """
 
     def __init__(self):
-        super().__init__("Missing audio player. Ensure VLC music player is installed.")
+        super().__init__("Missing audio player. Try installing VLC music player.")
 
 
 class OutputPathError(AudiusException):

audius/exceptions.py

@@ -0,0 +1,52 @@
+from typing import TYPE_CHECKING, Dict, Optional, Type
+
+from audius.client import API
+from audius.exceptions import MissingPlayerError
+from audius.player.af import AFPlayer
+from audius.player.base import BasePlayer
+from audius.player.vlc import VLCPlayer
+from audius.types import PlayerType
+
+if TYPE_CHECKING:
+    from audius.sdk import Audius
+
+
+class Player(API):
+    def __init__(self, sdk: "Audius") -> None:
+        super().__init__(sdk)
+        self._player_classes: Dict[PlayerType, Type] = {
+            PlayerType.AFPLAY: AFPlayer,
+            PlayerType.VLC: VLCPlayer,
+        }
+        self._player_map: Dict[PlayerType, BasePlayer] = {}
+
+    def play(self, url: str, player_type: Optional[PlayerType] = None):
+        player = self.get_player(player_type=player_type)
+        player.play(url)
+
+    def display_now_playing(self, track: Dict, player_type: Optional[PlayerType] = None):
+        player = self.get_player(player_type=player_type)
+        player.display_now_playing(track)
+
+    def get_player(self, player_type: Optional[PlayerType] = None) -> BasePlayer:
+        player_type = player_type or self.config.player
+        if player_type is not None:
+            if player_type not in self._player_classes:
+                raise ValueError(f"Unknown player type '{player_type}'")
+
+            self._player_map[player_type] = self._player_classes[player_type](self.sdk)
+            return self._player_map[player_type]
+
+        if self._player_map:
+            # Use previously connected player.
+            player_type = next(iter(self._player_map))
+            return self._player_map[player_type]
+
+        # Find an available player.
+        for player_cls in self._player_classes.values():
+            player = player_cls(self.sdk)
+            if player.is_available():
+                self._player_map[player._type] = player
+                return player
+
+        raise MissingPlayerError()

audius/player.py

@@ -0,0 +1,41 @@
+import os
+import subprocess
+import tempfile
+import threading
+import time
+from typing import TYPE_CHECKING
+
+from audius.player.base import BasePlayer
+from audius.types import PlayerType
+
+if TYPE_CHECKING:
+    from audius.sdk import Audius
+
+
+class AFPlayer(BasePlayer):
+    def __init__(self, sdk: "Audius"):
+        super().__init__(PlayerType.AFPLAY, sdk)
+
+    def is_available(self):
+        try:
+            subprocess.run("afplay", stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+            return True
+        except FileNotFoundError:
+            return False
+
+    def play(self, url: str):
+        download_url = self.client.get_redirect_url(url)
+        with tempfile.NamedTemporaryFile(mode="w+b", delete=False) as _file:
+            fd3 = os.dup(_file.fileno())
+
+            def download():
+                self.sdk.tracks.download(download_url, fd3, hide_output=True)
+
+            # Stream the song while playing it to prevent waiting
+            # for entire track to finish download.
+            thread = threading.Thread(target=download)
+            thread.start()
+            time.sleep(5)  # Buffer
+            subprocess.Popen(["afplay", _file.name])
+            thread.join()
+            time.sleep(1)