PyPI 官网下载 | sublime_music-0.11.12.tar.gz

import logging import os import random import shutil import sys from datetime import timedelta from functools import partial from pathlib import Path from typing import Any, Callable, Dict, Iterable, List, Optional, Set, Tuple from urllib.parse import urlparse import bleach try: import osxmmkeys tap_imported = True except Exception: tap_imported = False from gi.repository import Gdk, GdkPixbuf, Gio, GLib, Gtk try: import gi gi.require_version("Notify", "0.7") from gi.repository import Notify glib_notify_exists = True except Exception: # I really don't care what kind of exception it is, all that matters is the # import failed for some reason. logging.warning( "Unable to import Notify from GLib. Notifications will be disabled." ) glib_notify_exists = False from .adapters import ( AdapterManager, AlbumSearchQuery, CacheMissError, DownloadProgress, Result, SongCacheStatus, ) from .adapters.api_objects import Playlist, PlayQueue, Song from .config import AppConfiguration, ProviderConfiguration from .dbus import dbus_propagate, DBusManager from .players import PlayerDeviceEvent, PlayerEvent, PlayerManager from .ui.configure_provider import ConfigureProviderDialog from .ui.main import MainWindow from .ui.state import RepeatType, UIState from .util import resolve_path class SublimeMusicApp(Gtk.Application): def __init__(self, config_file: Path): super().__init__(application_id="app.sublimemusic.SublimeMusic") if glib_notify_exists: Notify.init("Sublime Music") self.window: Optional[Gtk.Window] = None self.app_config = AppConfiguration.load_from_file(config_file) self.dbus_manager: Optional[DBusManager] = None self.connect("shutdown", self.on_app_shutdown) player_manager: Optional[PlayerManager] = None exiting: bool = False def do_startup(self): Gtk.Application.do_startup(self) def add_action(name: str, fn: Callable, parameter_type: str = None): """Registers an action with the application.""" if type(parameter_type) == str: parameter_type = GLib.VariantType(parameter_type) action = Gio.SimpleAction.new(name, parameter_type) action.connect("activate", fn) self.add_action(action) # Add action for menu items. add_action("add-new-music-provider", self.on_add_new_music_provider) add_action("edit-current-music-provider", self.on_edit_current_music_provider) add_action( "switch-music-provider", self.on_switch_music_provider, parameter_type="s" ) add_action( "remove-music-provider", self.on_remove_music_provider, parameter_type="s" ) # Add actions for player controls add_action("play-pause", self.on_play_pause) add_action("next-track", self.on_next_track) add_action("prev-track", self.on_prev_track) add_action("repeat-press", self.on_repeat_press) add_action("shuffle-press", self.on_shuffle_press) # Navigation actions. add_action("play-next", self.on_play_next, parameter_type="as") add_action("add-to-queue", self.on_add_to_queue, parameter_type="as") add_action("go-to-album", self.on_go_to_album, parameter_type="s") add_action("go-to-artist", self.on_go_to_artist, parameter_type="s") add_action("browse-to", self.browse_to, parameter_type="s") add_action("go-to-playlist", self.on_go_to_playlist, parameter_type="s") add_action("go-online", self.on_go_online) add_action("refresh-devices", self.on_refresh_devices) add_action( "refresh-window", lambda *a: self.on_refresh_window(None, {}, True), ) add_action("mute-toggle", self.on_mute_toggle) add_action( "update-play-queue-from-server", lambda a, p: self.update_play_state_from_server(), ) if tap_imported: self.tap = osxmmkeys.Tap() self.tap.on("play_pause", self.on_play_pause) self.tap.on("next_track", self.on_next_track) self.tap.on("prev_track", self.on_prev_track) self.tap.start() def do_activate(self): # We only allow a single window and raise any existing ones if self.window: self.window.present() return # Configure Icons default_icon_theme = Gtk.IconTheme.get_default() for adapter in AdapterManager.available_adapters: if icon_dir := adapter.get_ui_info().icon_dir: default_icon_theme.append_search_path(str(icon_dir)) icon_dirs = [resolve_path("ui/icons"), resolve_path("adapters/icons")] for icon_dir in icon_dirs: default_icon_theme.append_search_path(str(icon_dir)) # Windows are associated with the application when the last one is # closed the application shuts down. self.window = MainWindow(application=self, title="Sublime Music") # Configure the CSS provider so that we can style elements on the # window. css_provider = Gtk.CssProvider() css_provider.load_from_path(str(resolve_path("ui/app_styles.css"))) context = Gtk.StyleContext() screen = Gdk.Screen.get_default() context.add_provider_for_screen( screen, css_provider, Gtk.STYLE_PROVIDER_PRIORITY_USER ) self.window.show_all() self.window.present() # Load the state for the server, if it exists. self.app_config.load_state() # If there is no current provider, use the first one if there are any # configured, and if none are configured, then show the dialog to create a new # one. if self.app_config.provider is None: if len(self.app_config.providers) == 0: self.show_configure_servers_dialog() # If they didn't add one with the dialog, close the window. if len(self.app_config.providers) == 0: self.window.close() return AdapterManager.reset(self.app_config, self.on_song_download_progress) # Connect after we know there's a server configured. self.window.stack.connect("notify::visible-child", self.on_stack_change) self.window.connect("song-clicked", self.on_song_clicked) self.window.connect("songs-removed", self.on_songs_removed) self.window.connect("refresh-window", self.on_refresh_window) self.window.connect("notification-closed", self.on_notification_closed) self.window.connect("go-to", self.on_window_go_to) self.window.connect("key-press-event", self.on_window_key_press) self.window.player_controls.connect("song-scrub", self.on_song_scrub) self.window.player_controls.connect("device-update", self.on_device_update) self.window.player_controls.connect("volume-change", self.on_volume_change) # Configure the players self.last_play_queue_update = timedelta(0) self.loading_state = False self.should_scrobble_song = False def on_timepos_change(value: Optional[float]): if ( self.loading_state or not self.window or not self.app_config.state.current_song ): return if value is None: self.last_play_queue_update = timedelta(0) return self.app_config.state.song_progress = timedelta(seconds=value) GLib.idle_add( self.window.player_controls.update_scrubber, self.app_config.state.song_progress, self.app_config.state.current_song.duration, self.app_config.state.song_stream_cache_progress, ) if (self.last_play