mirror of
https://github.com/Benexl/FastAnime.git
synced 2025-12-12 15:50:01 -08:00
style: ruff check + format
This commit is contained in:
@@ -204,14 +204,13 @@ def download_anime(
|
||||
anime_title: str,
|
||||
episode: str,
|
||||
):
|
||||
from rich import print
|
||||
|
||||
from ...core.downloader import DownloadParams, create_downloader
|
||||
from ...libs.provider.anime.params import EpisodeStreamsParams
|
||||
|
||||
downloader = create_downloader(config.downloads)
|
||||
|
||||
with feedback.progress(f"Fetching episode streams"):
|
||||
with feedback.progress("Fetching episode streams"):
|
||||
streams = provider.episode_streams(
|
||||
EpisodeStreamsParams(
|
||||
anime_id=anime.id,
|
||||
@@ -226,14 +225,14 @@ def download_anime(
|
||||
)
|
||||
|
||||
if config.stream.server.value == "TOP":
|
||||
with feedback.progress(f"Fetching top server"):
|
||||
with feedback.progress("Fetching top server"):
|
||||
server = next(streams, None)
|
||||
if not server:
|
||||
raise FastAnimeError(
|
||||
f"Failed to get server for anime: {anime.title}, episode: {episode}"
|
||||
)
|
||||
else:
|
||||
with feedback.progress(f"Fetching servers"):
|
||||
with feedback.progress("Fetching servers"):
|
||||
servers = {server.name: server for server in streams}
|
||||
servers_names = list(servers.keys())
|
||||
if config.stream.server in servers_names:
|
||||
|
||||
@@ -5,7 +5,6 @@ Registry sync command - synchronize local registry with remote media API
|
||||
import click
|
||||
from fastanime.cli.service.feedback.service import FeedbackService
|
||||
from fastanime.cli.service.registry.service import MediaRegistryService
|
||||
from rich.progress import Progress
|
||||
|
||||
from .....core.config import AppConfig
|
||||
|
||||
|
||||
@@ -141,7 +141,7 @@ def stream_anime(
|
||||
|
||||
player_service = PlayerService(config, provider)
|
||||
|
||||
with feedback.progress(f"Fetching episode streams"):
|
||||
with feedback.progress("Fetching episode streams"):
|
||||
streams = provider.episode_streams(
|
||||
EpisodeStreamsParams(
|
||||
anime_id=anime.id,
|
||||
@@ -156,14 +156,14 @@ def stream_anime(
|
||||
)
|
||||
|
||||
if config.stream.server.value == "TOP":
|
||||
with feedback.progress(f"Fetching top server"):
|
||||
with feedback.progress("Fetching top server"):
|
||||
server = next(streams, None)
|
||||
if not server:
|
||||
raise FastAnimeError(
|
||||
f"Failed to get server for anime: {anime.title}, episode: {episode}"
|
||||
)
|
||||
else:
|
||||
with feedback.progress(f"Fetching servers"):
|
||||
with feedback.progress("Fetching servers"):
|
||||
servers = {server.name: server for server in streams}
|
||||
servers_names = list(servers.keys())
|
||||
if config.stream.server.value in servers_names:
|
||||
|
||||
@@ -1,7 +1,4 @@
|
||||
from .....core.utils.fuzzy import fuzz
|
||||
from .....core.utils.normalizer import normalize_title
|
||||
from .....libs.provider.anime.params import AnimeParams, SearchParams
|
||||
from ....service.download.service import DownloadService
|
||||
from ...session import Context, session
|
||||
from ...state import InternalDirective, State
|
||||
|
||||
@@ -9,6 +6,10 @@ from ...state import InternalDirective, State
|
||||
@session.menu
|
||||
def download_episodes(ctx: Context, state: State) -> State | InternalDirective:
|
||||
"""Menu to select and download episodes synchronously."""
|
||||
from .....core.utils.fuzzy import fuzz
|
||||
from .....core.utils.normalizer import normalize_title
|
||||
from ....service.download.service import DownloadService
|
||||
|
||||
feedback = ctx.feedback
|
||||
selector = ctx.selector
|
||||
media_item = state.media_api.media_item
|
||||
|
||||
@@ -11,7 +11,6 @@ from .....libs.media_api.types import (
|
||||
UserMediaListStatus,
|
||||
)
|
||||
from .....libs.player.params import PlayerParams
|
||||
from ....service.registry.service import DownloadStatus
|
||||
from ...session import Context, session
|
||||
from ...state import InternalDirective, MediaApiState, MenuName, State
|
||||
|
||||
@@ -20,6 +19,8 @@ MenuAction = Callable[[], State | InternalDirective]
|
||||
|
||||
@session.menu
|
||||
def media_actions(ctx: Context, state: State) -> State | InternalDirective:
|
||||
from ....service.registry.service import DownloadStatus
|
||||
|
||||
feedback = ctx.feedback
|
||||
|
||||
icons = ctx.config.general.icons
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
from typing import Callable, Dict, Literal, Union
|
||||
|
||||
from .....libs.player.params import PlayerParams
|
||||
from ....service.registry.models import DownloadStatus
|
||||
from ...session import Context, session
|
||||
from ...state import InternalDirective, MenuName, State
|
||||
|
||||
@@ -11,6 +10,8 @@ MenuAction = Callable[[], Union[State, InternalDirective]]
|
||||
@session.menu
|
||||
def play_downloads(ctx: Context, state: State) -> State | InternalDirective:
|
||||
"""Menu to select and play locally downloaded episodes."""
|
||||
from ....service.registry.models import DownloadStatus
|
||||
|
||||
feedback = ctx.feedback
|
||||
media_item = state.media_api.media_item
|
||||
current_episode_num = state.provider.episode
|
||||
|
||||
Reference in New Issue
Block a user