Sending items to the kyoo api

scanner/providers/types/movie.py

@@ -1,6 +1,8 @@
-from dataclasses import dataclass, field
+import os
+from dataclasses import asdict, dataclass, field
 from datetime import datetime
 from typing import Optional
+
 from .genre import Genre
 from .status import Status
 
@@ -28,3 +30,9 @@ class Movie:
 
 	translations: dict[str, MovieTranslation] = field(default_factory=dict)
 
+
+	def to_kyoo(self):
+		# For now, the API of kyoo only support one language so we remove the others.
+		default_language = os.environ["LIBRARY_LANGUAGES"].split(',')[0]
+		return { **asdict(self), **asdict(self.translations[default_language]) }
+

scanner/scanner/scanner.py

@@ -2,17 +2,18 @@ import asyncio
 import logging
 from pathlib import Path
 from guessit import guessit
-from themoviedb.routes.base import ClientSession
+from themoviedb.routes.base import ClientSession, os
 from providers.provider import Provider
 
 class Scanner:
 	def __init__(self, client: ClientSession, languages: list[str]) -> None:
+		self._client = client
 		self.provider = Provider.get_all(client)[0]
 		self.languages = languages
 
 	async def scan(self, path: str):
 		videos = filter(lambda p: p.is_file(), Path(path).rglob("*"))
-		await asyncio.gather(*map(self.identify, videos))
+		await asyncio.gather(*map(self.identify, videos), return_exceptions=True)
 
 	async def identify(self, path: Path):
 		raw = guessit(path)
@@ -24,7 +25,12 @@ class Scanner:
 		if raw["type"] == "movie":
 			movie = await self.provider.identify_movie(raw["title"], raw.get("year"), language=self.languages)
 			logging.debug("Got movie: %s", movie)
+			await self.post("movies", data=movie.to_kyoo())
 		elif raw["type"] == "episode":
 			pass
 		else:
 			logging.warn("Unknown video file type: %s", raw["type"])
+
+	async def post(self, path: str, *, data: object):
+		async with self._client.post(f"{os.environ['KYOO_URL']}/{path}", json=data) as r:
+			r.raise_for_status()