Compare commits
No commits in common. "dbd507bccb46a8396acab48999be51fd074018f2" and "1bb2032b9fd042f77e56c3708a14f279d2e3be70" have entirely different histories.
dbd507bccb
...
1bb2032b9f
11 changed files with 33 additions and 108 deletions
|
@ -24,12 +24,6 @@
|
||||||
"title": "Host",
|
"title": "Host",
|
||||||
"type": "string"
|
"type": "string"
|
||||||
},
|
},
|
||||||
"music_directory": {
|
|
||||||
"description": "Your music directory, just as it's set up in your mpd.conf. mpd-now-playable uses this setting to figure out an absolute file:// URL for the current song, which MPNowPlayingInfoCenter will use to display cool stuff like audio waveforms. It'll still work fine without setting this, though.",
|
|
||||||
"format": "directory-path",
|
|
||||||
"title": "Music Directory",
|
|
||||||
"type": "string"
|
|
||||||
},
|
|
||||||
"password": {
|
"password": {
|
||||||
"description": "The password required to connect to your MPD instance, if you need one.",
|
"description": "The password required to connect to your MPD instance, if you need one.",
|
||||||
"format": "password",
|
"format": "password",
|
||||||
|
|
|
@ -194,12 +194,6 @@
|
||||||
"description": "The track number the song has on its album. This is usually one-based, but it's just an arbitrary audio tag so a particular album might start at zero or do something weird with it.",
|
"description": "The track number the song has on its album. This is usually one-based, but it's just an arbitrary audio tag so a particular album might start at zero or do something weird with it.",
|
||||||
"title": "Track",
|
"title": "Track",
|
||||||
"type": "integer"
|
"type": "integer"
|
||||||
},
|
|
||||||
"url": {
|
|
||||||
"description": "An absolute URL referring to the current song, if available. If the song's a local file and its absolute path can be determined (mpd-now-playable has been configured with your music directory), then this field will contain a file:// URL. If the song's remote, then MPD itself returns an absolute URL in the first place.",
|
|
||||||
"format": "uri",
|
|
||||||
"title": "Url",
|
|
||||||
"type": "string"
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"required": [
|
"required": [
|
||||||
|
|
|
@ -1,9 +1,7 @@
|
||||||
from os.path import expanduser
|
|
||||||
from typing import Annotated, NewType
|
from typing import Annotated, NewType
|
||||||
|
|
||||||
from annotated_types import Ge, Le
|
from annotated_types import Ge, Le
|
||||||
from pydantic import (
|
from pydantic import (
|
||||||
BeforeValidator,
|
|
||||||
Field,
|
Field,
|
||||||
PlainSerializer,
|
PlainSerializer,
|
||||||
PlainValidator,
|
PlainValidator,
|
||||||
|
@ -11,12 +9,9 @@ from pydantic import (
|
||||||
Strict,
|
Strict,
|
||||||
WithJsonSchema,
|
WithJsonSchema,
|
||||||
)
|
)
|
||||||
from pydantic import (
|
|
||||||
DirectoryPath as DirectoryType,
|
|
||||||
)
|
|
||||||
from yarl import URL as Yarl
|
from yarl import URL as Yarl
|
||||||
|
|
||||||
__all__ = ("DirectoryPath", "Host", "Password", "Port", "Url")
|
__all__ = ("Host", "Password", "Port", "Url")
|
||||||
|
|
||||||
|
|
||||||
def from_yarl(url: Yarl) -> str:
|
def from_yarl(url: Yarl) -> str:
|
||||||
|
@ -29,7 +24,6 @@ def to_yarl(value: object) -> Yarl:
|
||||||
raise NotImplementedError(f"Cannot convert {type(object)} to URL")
|
raise NotImplementedError(f"Cannot convert {type(object)} to URL")
|
||||||
|
|
||||||
|
|
||||||
DirectoryPath = Annotated[DirectoryType, BeforeValidator(expanduser)]
|
|
||||||
Host = NewType(
|
Host = NewType(
|
||||||
"Host", Annotated[str, Strict(), Field(json_schema_extra={"format": "hostname"})]
|
"Host", Annotated[str, Strict(), Field(json_schema_extra={"format": "hostname"})]
|
||||||
)
|
)
|
|
@ -4,7 +4,7 @@ from typing import Annotated, Literal, Optional, Protocol
|
||||||
from pydantic import Field
|
from pydantic import Field
|
||||||
|
|
||||||
from ..tools.schema.define import schema
|
from ..tools.schema.define import schema
|
||||||
from ..tools.schema.fields import DirectoryPath, Host, Password, Port, Url
|
from .fields import Host, Password, Port, Url
|
||||||
|
|
||||||
__all__ = (
|
__all__ = (
|
||||||
"Config",
|
"Config",
|
||||||
|
@ -55,12 +55,6 @@ class MpdConfig:
|
||||||
#: servers on one machine for some reason, you probably haven't changed this
|
#: servers on one machine for some reason, you probably haven't changed this
|
||||||
#: from the default port, 6600.
|
#: from the default port, 6600.
|
||||||
port: Port = Port(6600)
|
port: Port = Port(6600)
|
||||||
#: Your music directory, just as it's set up in your mpd.conf.
|
|
||||||
#: mpd-now-playable uses this setting to figure out an absolute file:// URL
|
|
||||||
#: for the current song, which MPNowPlayingInfoCenter will use to display
|
|
||||||
#: cool stuff like audio waveforms. It'll still work fine without setting
|
|
||||||
#: this, though.
|
|
||||||
music_directory: Optional[DirectoryPath] = None
|
|
||||||
|
|
||||||
|
|
||||||
@schema("https://cdn.00dani.me/m/schemata/mpd-now-playable/config-v1.json")
|
@schema("https://cdn.00dani.me/m/schemata/mpd-now-playable/config-v1.json")
|
||||||
|
|
|
@ -9,55 +9,37 @@ from yarl import URL
|
||||||
|
|
||||||
from ..config.model import MpdConfig
|
from ..config.model import MpdConfig
|
||||||
from ..player import Player
|
from ..player import Player
|
||||||
from ..song import PlaybackState, Song, to_artwork, to_brainz
|
from ..song import Artwork, PlaybackState, Song, to_artwork, to_brainz
|
||||||
from ..song_receiver import Receiver
|
from ..song_receiver import Receiver
|
||||||
from ..tools.types import option_fmap, un_maybe_plural
|
from ..tools.types import option_fmap, un_maybe_plural
|
||||||
from .artwork_cache import MpdArtworkCache
|
from .artwork_cache import MpdArtworkCache
|
||||||
from .types import MpdState
|
from .types import CurrentSongResponse, StatusResponse
|
||||||
|
|
||||||
|
|
||||||
def mpd_file_to_uri(config: MpdConfig, file: str) -> URL | None:
|
def mpd_current_to_song(
|
||||||
url = URL(file)
|
status: StatusResponse, current: CurrentSongResponse, art: Artwork
|
||||||
if url.scheme != "":
|
) -> Song:
|
||||||
# We already got an absolute URL - probably a stream? - so we can just return it.
|
|
||||||
return url
|
|
||||||
|
|
||||||
if not config.music_directory:
|
|
||||||
# We have a relative song URI, but we can't make it absolute since no music directory is configured.
|
|
||||||
return None
|
|
||||||
|
|
||||||
# Prepend the configured music directory, then turn the whole path into a file:// URL.
|
|
||||||
abs_file = config.music_directory / file
|
|
||||||
return URL(abs_file.as_uri())
|
|
||||||
|
|
||||||
|
|
||||||
def mpd_state_to_song(config: MpdConfig, mpd: MpdState) -> Song:
|
|
||||||
file = mpd.current["file"]
|
|
||||||
url = mpd_file_to_uri(config, file)
|
|
||||||
|
|
||||||
return Song(
|
return Song(
|
||||||
state=PlaybackState(mpd.status["state"]),
|
state=PlaybackState(status["state"]),
|
||||||
queue_index=int(mpd.current["pos"]),
|
queue_index=int(current["pos"]),
|
||||||
queue_length=int(mpd.status["playlistlength"]),
|
queue_length=int(status["playlistlength"]),
|
||||||
file=Path(file),
|
file=Path(current["file"]),
|
||||||
url=url,
|
title=current.get("title"),
|
||||||
title=mpd.current.get("title"),
|
artist=un_maybe_plural(current.get("artist")),
|
||||||
artist=un_maybe_plural(mpd.current.get("artist")),
|
album=un_maybe_plural(current.get("album")),
|
||||||
album=un_maybe_plural(mpd.current.get("album")),
|
album_artist=un_maybe_plural(current.get("albumartist")),
|
||||||
album_artist=un_maybe_plural(mpd.current.get("albumartist")),
|
composer=un_maybe_plural(current.get("composer")),
|
||||||
composer=un_maybe_plural(mpd.current.get("composer")),
|
genre=un_maybe_plural(current.get("genre")),
|
||||||
genre=un_maybe_plural(mpd.current.get("genre")),
|
track=option_fmap(int, current.get("track")),
|
||||||
track=option_fmap(int, mpd.current.get("track")),
|
disc=option_fmap(int, current.get("disc")),
|
||||||
disc=option_fmap(int, mpd.current.get("disc")),
|
duration=float(status["duration"]),
|
||||||
duration=option_fmap(float, mpd.status.get("duration")),
|
elapsed=float(status["elapsed"]),
|
||||||
elapsed=float(mpd.status["elapsed"]),
|
musicbrainz=to_brainz(current),
|
||||||
musicbrainz=to_brainz(mpd.current),
|
art=art,
|
||||||
art=to_artwork(mpd.art),
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
class MpdStateListener(Player):
|
class MpdStateListener(Player):
|
||||||
config: MpdConfig
|
|
||||||
client: MPDClient
|
client: MPDClient
|
||||||
receivers: Iterable[Receiver]
|
receivers: Iterable[Receiver]
|
||||||
art_cache: MpdArtworkCache
|
art_cache: MpdArtworkCache
|
||||||
|
@ -70,7 +52,6 @@ class MpdStateListener(Player):
|
||||||
)
|
)
|
||||||
|
|
||||||
async def start(self, conf: MpdConfig) -> None:
|
async def start(self, conf: MpdConfig) -> None:
|
||||||
self.config = conf
|
|
||||||
print(f"Connecting to MPD server {conf.host}:{conf.port}...")
|
print(f"Connecting to MPD server {conf.host}:{conf.port}...")
|
||||||
await self.client.connect(conf.host, conf.port)
|
await self.client.connect(conf.host, conf.port)
|
||||||
if conf.password is not None:
|
if conf.password is not None:
|
||||||
|
@ -96,7 +77,6 @@ class MpdStateListener(Player):
|
||||||
status, current = await asyncio.gather(
|
status, current = await asyncio.gather(
|
||||||
self.client.status(), self.client.currentsong()
|
self.client.status(), self.client.currentsong()
|
||||||
)
|
)
|
||||||
state = MpdState(status, current)
|
|
||||||
|
|
||||||
if starting_idle_count != self.idle_count:
|
if starting_idle_count != self.idle_count:
|
||||||
return
|
return
|
||||||
|
@ -110,8 +90,7 @@ class MpdStateListener(Player):
|
||||||
if starting_idle_count != self.idle_count:
|
if starting_idle_count != self.idle_count:
|
||||||
return
|
return
|
||||||
|
|
||||||
state = MpdState(status, current, art)
|
song = mpd_current_to_song(status, current, to_artwork(art))
|
||||||
song = mpd_state_to_song(self.config, state)
|
|
||||||
rprint(song)
|
rprint(song)
|
||||||
await self.update(song)
|
await self.update(song)
|
||||||
|
|
||||||
|
|
|
@ -1,4 +1,3 @@
|
||||||
from dataclasses import dataclass
|
|
||||||
from typing import Literal, NotRequired, Protocol, TypedDict
|
from typing import Literal, NotRequired, Protocol, TypedDict
|
||||||
|
|
||||||
from ..song.musicbrainz import MusicBrainzTags
|
from ..song.musicbrainz import MusicBrainzTags
|
||||||
|
@ -20,11 +19,8 @@ OneshotFlag = Literal[BooleanFlag, "oneshot"]
|
||||||
class StatusResponse(TypedDict):
|
class StatusResponse(TypedDict):
|
||||||
state: Literal["play", "stop", "pause"]
|
state: Literal["play", "stop", "pause"]
|
||||||
|
|
||||||
# The total duration and elapsed playback of the current song, measured in
|
# The total duration and elapsed playback of the current song, measured in seconds. Fractional seconds are allowed.
|
||||||
# seconds. Fractional seconds are allowed. The duration field may be
|
duration: str
|
||||||
# omitted because MPD cannot determine the duration of certain sources,
|
|
||||||
# such as Internet radio streams.
|
|
||||||
duration: NotRequired[str]
|
|
||||||
elapsed: str
|
elapsed: str
|
||||||
|
|
||||||
# The volume value ranges from 0-100. It may be omitted from
|
# The volume value ranges from 0-100. It may be omitted from
|
||||||
|
@ -80,10 +76,3 @@ class CurrentSongResponse(CurrentSongTags):
|
||||||
|
|
||||||
|
|
||||||
ReadPictureResponse = TypedDict("ReadPictureResponse", {"binary": bytes})
|
ReadPictureResponse = TypedDict("ReadPictureResponse", {"binary": bytes})
|
||||||
|
|
||||||
|
|
||||||
@dataclass
|
|
||||||
class MpdState:
|
|
||||||
status: StatusResponse
|
|
||||||
current: CurrentSongResponse
|
|
||||||
art: bytes | None = None
|
|
||||||
|
|
|
@ -25,7 +25,6 @@ from MediaPlayer import (
|
||||||
MPNowPlayingInfoCenter,
|
MPNowPlayingInfoCenter,
|
||||||
MPNowPlayingInfoMediaTypeAudio,
|
MPNowPlayingInfoMediaTypeAudio,
|
||||||
MPNowPlayingInfoMediaTypeNone,
|
MPNowPlayingInfoMediaTypeNone,
|
||||||
MPNowPlayingInfoPropertyAssetURL,
|
|
||||||
MPNowPlayingInfoPropertyElapsedPlaybackTime,
|
MPNowPlayingInfoPropertyElapsedPlaybackTime,
|
||||||
MPNowPlayingInfoPropertyExternalContentIdentifier,
|
MPNowPlayingInfoPropertyExternalContentIdentifier,
|
||||||
MPNowPlayingInfoPropertyMediaType,
|
MPNowPlayingInfoPropertyMediaType,
|
||||||
|
@ -107,9 +106,6 @@ def song_to_media_item(song: Song) -> NSMutableDictionary:
|
||||||
nowplaying_info[MPMediaItemPropertyComposer] = join_plural_field(song.composer)
|
nowplaying_info[MPMediaItemPropertyComposer] = join_plural_field(song.composer)
|
||||||
nowplaying_info[MPMediaItemPropertyPlaybackDuration] = song.duration
|
nowplaying_info[MPMediaItemPropertyPlaybackDuration] = song.duration
|
||||||
|
|
||||||
if song.url is not None:
|
|
||||||
nowplaying_info[MPNowPlayingInfoPropertyAssetURL] = song.url.human_repr()
|
|
||||||
|
|
||||||
# MPD can't play back music at different rates, so we just want to set it
|
# MPD can't play back music at different rates, so we just want to set it
|
||||||
# to 1.0 if the song is playing. (Leave it at 0.0 if the song is paused.)
|
# to 1.0 if the song is playing. (Leave it at 0.0 if the song is paused.)
|
||||||
if song.state == PlaybackState.play:
|
if song.state == PlaybackState.play:
|
||||||
|
|
|
@ -3,7 +3,6 @@ from pathlib import Path
|
||||||
import ormsgpack
|
import ormsgpack
|
||||||
from websockets import broadcast
|
from websockets import broadcast
|
||||||
from websockets.server import WebSocketServerProtocol, serve
|
from websockets.server import WebSocketServerProtocol, serve
|
||||||
from yarl import URL
|
|
||||||
|
|
||||||
from ...config.model import WebsocketsReceiverConfig
|
from ...config.model import WebsocketsReceiverConfig
|
||||||
from ...player import Player
|
from ...player import Player
|
||||||
|
@ -16,8 +15,6 @@ MSGPACK_NULL = ormsgpack.packb(None)
|
||||||
def default(value: object) -> object:
|
def default(value: object) -> object:
|
||||||
if isinstance(value, Path):
|
if isinstance(value, Path):
|
||||||
return str(value)
|
return str(value)
|
||||||
if isinstance(value, URL):
|
|
||||||
return value.human_repr()
|
|
||||||
raise TypeError
|
raise TypeError
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -3,7 +3,6 @@ from enum import StrEnum
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
|
|
||||||
from ..tools.schema.define import schema
|
from ..tools.schema.define import schema
|
||||||
from ..tools.schema.fields import Url
|
|
||||||
from .artwork import Artwork
|
from .artwork import Artwork
|
||||||
from .musicbrainz import MusicBrainzIds
|
from .musicbrainz import MusicBrainzIds
|
||||||
|
|
||||||
|
@ -15,7 +14,7 @@ class PlaybackState(StrEnum):
|
||||||
|
|
||||||
|
|
||||||
@schema("https://cdn.00dani.me/m/schemata/mpd-now-playable/song-v1.json")
|
@schema("https://cdn.00dani.me/m/schemata/mpd-now-playable/song-v1.json")
|
||||||
@dataclass(slots=True, kw_only=True)
|
@dataclass(slots=True)
|
||||||
class Song:
|
class Song:
|
||||||
#: Whether MPD is currently playing, paused, or stopped. Pretty simple.
|
#: Whether MPD is currently playing, paused, or stopped. Pretty simple.
|
||||||
state: PlaybackState
|
state: PlaybackState
|
||||||
|
@ -31,13 +30,6 @@ class Song:
|
||||||
#: places, so you can safely do the same.
|
#: places, so you can safely do the same.
|
||||||
file: Path
|
file: Path
|
||||||
|
|
||||||
#: An absolute URL referring to the current song, if available. If the
|
|
||||||
#: song's a local file and its absolute path can be determined
|
|
||||||
#: (mpd-now-playable has been configured with your music directory), then
|
|
||||||
#: this field will contain a file:// URL. If the song's remote, then MPD
|
|
||||||
#: itself returns an absolute URL in the first place.
|
|
||||||
url: Url | None = None
|
|
||||||
|
|
||||||
#: The song's title, if it's been tagged with one. Currently only one title
|
#: The song's title, if it's been tagged with one. Currently only one title
|
||||||
#: is supported, since it doesn't make a lot of sense to tag a single audio
|
#: is supported, since it doesn't make a lot of sense to tag a single audio
|
||||||
#: file with multiple titles.
|
#: file with multiple titles.
|
||||||
|
@ -69,9 +61,8 @@ class Song:
|
||||||
genre: list[str]
|
genre: list[str]
|
||||||
|
|
||||||
#: The song's duration as read from its tags, measured in seconds.
|
#: The song's duration as read from its tags, measured in seconds.
|
||||||
#: Fractional seconds are allowed. The duration may be unavailable for some
|
#: Fractional seconds are allowed.
|
||||||
#: sources, such as internet radio streams.
|
duration: float
|
||||||
duration: float | None
|
|
||||||
|
|
||||||
#: How far into the song MPD is, measured in seconds. Fractional seconds
|
#: How far into the song MPD is, measured in seconds. Fractional seconds
|
||||||
#: are allowed. This is usually going to be less than or equal to the
|
#: are allowed. This is usually going to be less than or equal to the
|
||||||
|
|
|
@ -11,8 +11,8 @@ from .define import ModelWithSchema
|
||||||
__all__ = ("write",)
|
__all__ = ("write",)
|
||||||
|
|
||||||
|
|
||||||
def write(model: ModelWithSchema, mode: JsonSchemaMode = "validation") -> None:
|
def write(model: ModelWithSchema) -> None:
|
||||||
schema = model.schema.json_schema(schema_generator=MyGenerateJsonSchema, mode=mode)
|
schema = model.schema.json_schema(schema_generator=MyGenerateJsonSchema)
|
||||||
schema["$id"] = model.id.human_repr()
|
schema["$id"] = model.id.human_repr()
|
||||||
schema_file = Path(__file__).parents[4] / "schemata" / model.id.name
|
schema_file = Path(__file__).parents[4] / "schemata" / model.id.name
|
||||||
print(f"Writing this schema to {schema_file}")
|
print(f"Writing this schema to {schema_file}")
|
||||||
|
@ -46,10 +46,8 @@ class MyGenerateJsonSchema(GenerateJsonSchema):
|
||||||
def nullable_schema(self, schema: s.NullableSchema) -> JsonSchemaValue:
|
def nullable_schema(self, schema: s.NullableSchema) -> JsonSchemaValue:
|
||||||
return self.generate_inner(schema["schema"])
|
return self.generate_inner(schema["schema"])
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
if __name__ == "__main__":
|
|
||||||
from ...config.model import Config
|
from ...config.model import Config
|
||||||
from ...song import Song
|
from ...song import Song
|
||||||
|
|
||||||
write(Config)
|
write(Config)
|
||||||
write(Song, mode="serialization")
|
write(Song)
|
||||||
|
|
|
@ -34,7 +34,6 @@ MPNowPlayingInfoPropertyPlaybackQueueIndex: Final = (
|
||||||
MPNowPlayingInfoPropertyElapsedPlaybackTime: Final = (
|
MPNowPlayingInfoPropertyElapsedPlaybackTime: Final = (
|
||||||
"MPNowPlayingInfoPropertyElapsedPlaybackTime"
|
"MPNowPlayingInfoPropertyElapsedPlaybackTime"
|
||||||
)
|
)
|
||||||
MPNowPlayingInfoPropertyAssetURL: Final = "MPNowPlayingInfoPropertyAssetURL"
|
|
||||||
MPNowPlayingInfoPropertyExternalContentIdentifier: Final = (
|
MPNowPlayingInfoPropertyExternalContentIdentifier: Final = (
|
||||||
"MPNowPlayingInfoPropertyExternalContentIdentifier"
|
"MPNowPlayingInfoPropertyExternalContentIdentifier"
|
||||||
)
|
)
|
||||||
|
|
Loading…
Reference in a new issue