format files

This commit is contained in:
maxDorninger
2025-06-28 22:46:38 +02:00
parent ab377ecfdc
commit a1c7b9b941
10 changed files with 16 additions and 27 deletions

View File

@@ -56,10 +56,10 @@ from media_manager.tv.service import ( # noqa: E402
import_all_show_torrents,
update_all_non_ended_shows_metadata,
)
from media_manager.movies.service import (
from media_manager.movies.service import ( # noqa: E402
import_all_movie_torrents,
update_all_movies_metadata,
) # noqa: E402
)
import uvicorn # noqa: E402
from fastapi.staticfiles import StaticFiles # noqa: E402
from media_manager.auth.users import openid_client # noqa: E402

View File

@@ -54,6 +54,3 @@ class AbstractMetadataProvider(ABC):
:return: True if the image was downloaded successfully, False otherwise.
"""
raise NotImplementedError()

View File

@@ -2,7 +2,6 @@ from typing import Annotated, Literal
from fastapi import Depends
from media_manager.exceptions import InvalidConfigError
from fastapi.exceptions import HTTPException
from media_manager.metadataProvider.tmdb import TmdbMetadataProvider
from media_manager.metadataProvider.abstractMetaDataProvider import (
@@ -24,6 +23,7 @@ def get_metadata_provider(
detail=f"Invalid metadata provider: {metadata_provider}. Supported providers are 'tmdb' and 'tvdb'.",
)
metadata_provider_dep = Annotated[
AbstractMetadataProvider, Depends(get_metadata_provider)
]

View File

@@ -1,11 +1,9 @@
import requests
import tvdb_v4_official
import logging
from pydantic_settings import BaseSettings
import media_manager.metadataProvider.utils
from media_manager.exceptions import InvalidConfigError
from media_manager.metadataProvider.abstractMetaDataProvider import (
AbstractMetadataProvider,
)

View File

@@ -171,9 +171,7 @@ def update_movie_request(
return movie_service.update_movie_request(movie_request=movie_request)
@router.patch(
"/requests/{movie_request_id}", status_code=status.HTTP_204_NO_CONTENT
)
@router.patch("/requests/{movie_request_id}", status_code=status.HTTP_204_NO_CONTENT)
def authorize_request(
movie_service: movie_service_dep,
movie_request_id: MovieRequestId,
@@ -225,9 +223,13 @@ def get_movie_by_id(movie_service: movie_service_dep, movie_id: MovieId):
response_model=list[PublicIndexerQueryResult],
)
def get_all_available_torrents_for_a_movie(
movie_service: movie_service_dep, movie_id: MovieId, search_query_override: str | None = None
movie_service: movie_service_dep,
movie_id: MovieId,
search_query_override: str | None = None,
):
return movie_service.get_all_available_torrents_for_a_movie(movie_id=movie_id, search_query_override=search_query_override)
return movie_service.get_all_available_torrents_for_a_movie(
movie_id=movie_id, search_query_override=search_query_override
)
@router.post(

View File

@@ -6,7 +6,7 @@ from pydantic import BaseModel, Field, ConfigDict, model_validator
from media_manager.auth.schemas import UserRead
from media_manager.torrent.models import Quality
from media_manager.torrent.schemas import TorrentId, Torrent, TorrentStatus
from media_manager.torrent.schemas import TorrentId, TorrentStatus
MovieId = typing.NewType("MovieId", UUID)
MovieRequestId = typing.NewType("MovieRequestId", UUID)
@@ -84,6 +84,7 @@ class MovieTorrent(BaseModel):
imported: bool
file_path_suffix: str
class RichMovieTorrent(BaseModel):
movie_id: MovieId
name: str

View File

@@ -5,8 +5,6 @@ from typing import Any, Optional
import valkey.asyncio as valkey
import os
from functools import wraps
import asyncio
import inspect
log = logging.getLogger(__name__)
@@ -61,5 +59,7 @@ def cache_response(prefix: str, ttl: int = 3600):
await set_cached_response(cache_key, response, ttl)
return response
return wrapper
return decorator

View File

@@ -50,6 +50,3 @@ else:
@cache_response("tmdb_movie", ttl=28800)
async def get_tmdb_movie(movie_id: int):
return Movies(movie_id).info()

View File

@@ -21,38 +21,32 @@ else:
async def get_tvdb_trending_tv():
return tvdb_client.get_all_series()
@router.get("/tv/search")
@cache_response("tvdb_tv_search", ttl=14400)
async def search_tvdb_tv(query: str):
return tvdb_client.search(query)
@router.get("/tv/shows/{show_id}")
@cache_response("tvdb_tv_show", ttl=28800)
async def get_tvdb_show(show_id: int):
return tvdb_client.get_series_extended(show_id)
@router.get("/tv/seasons/{season_id}")
@cache_response("tvdb_tv_season", ttl=28800)
async def get_tvdb_season(season_id: int):
return tvdb_client.get_season_extended(season_id)
@router.get("/movies/trending")
@cache_response("tvdb_movies_trending", ttl=7200)
async def get_tvdb_trending_movies():
return tvdb_client.get_all_movies()
@router.get("/movies/search")
@cache_response("tvdb_movies_search", ttl=14400)
async def search_tvdb_movies(query: str):
return tvdb_client.search(query)
@router.get("/movies/{movie_id}")
@cache_response("tvdb_movie", ttl=28800)
async def get_tvdb_movie(movie_id: int):
return tvdb_client.get_movie_extended(movie_id)
return tvdb_client.get_movie_extended(movie_id)

View File

@@ -17,4 +17,4 @@ app.include_router(tvdb_router)
@app.get("/")
async def root():
return {"message": "Hello World"}
return {"message": "Hello World"}