metadata routes

app.py

@@ -1,6 +1,9 @@
-from fastapi import FastAPI
+from fastapi import FastAPI,HTTPException
+from fastapi.responses import JSONResponse
 from LoadBalancer import LoadBalancer
 import os
+import urllib.parse
+from utils import read_json_file
 
 CACHE_DIR = os.getenv("CACHE_DIR")
 TOKEN = os.getenv("TOKEN")
@@ -37,4 +40,38 @@ async def get_all_films_api():
 
 @app.get("/api/get/tv/all")
 async def get_all_tvshows_api():
-    return load_balancer.get_all_tv_shows()
+    return load_balancer.get_all_tv_shows()
+
+@app.get("/api/get/film/metadata/{title}")
+async def get_film_metadata_api(title: str):
+    """Endpoint to get the film metadata by title."""
+    if not title:
+        raise HTTPException(status_code=400, detail="No title provided")
+    
+    json_cache_path = os.path.join(CACHE_DIR, f"{urllib.parse.quote(title)}.json")
+    
+    if os.path.exists(json_cache_path):
+        data = await read_json_file(json_cache_path)
+        return JSONResponse(content=data)
+    
+    raise HTTPException(status_code=404, detail="Metadata not found")
+
+@app.get("/api/get/tv/metadata/{title}")
+async def get_tv_metadata_api(title: str):
+    """Endpoint to get the TV show metadata by title."""
+    if not title:
+        raise HTTPException(status_code=400, detail="No title provided")
+    
+    json_cache_path = os.path.join(CACHE_DIR, f"{urllib.parse.quote(title)}.json")
+    
+    if os.path.exists(json_cache_path):
+        data = await read_json_file(json_cache_path)
+        
+        # Add the file structure to the metadata
+        tv_structure_data = await load_balancer.get_tv_structure(title)
+        if tv_structure_data:
+            data['file_structure'] = tv_structure_data
+        
+        return JSONResponse(content=data)
+    
+    raise HTTPException(status_code=404, detail="Metadata not found")

utils.py

@@ -1,4 +1,6 @@
 import re
+import aiofiles
+import json
 
 def is_valid_url(url):
     """
@@ -62,3 +64,12 @@ def encode_episodeid(title, season, episode):
         str: The encoded episode ID.
     """
     return f"{title}_{season}_{episode}"
+
+async def read_json_file(file_path: str):
+    """Helper function to read JSON data from a file asynchronously."""
+    try:
+        async with aiofiles.open(file_path, 'r') as f:
+            data = await f.read()
+        return json.loads(data)
+    except Exception as e:
+        raise e