serve video

app.py

@@ -4,6 +4,7 @@ from threading import Thread
 from Instance import Instance
 from api import LoadBalancerAPI
 import os
+import re
 # Constants and Configuration
 CACHE_DIR = os.getenv("CACHE_DIR")
 TOKEN = os.getenv("TOKEN")
@@ -17,6 +18,39 @@ instance = Instance(id=ID, url=URL, cache_dir=CACHE_DIR, token=TOKEN, repo=REPO,
 
 app = FastAPI()
 
+async def serve_video(file_path: str, request: Request):
+    """Serve video file with support for range requests."""
+    if not os.path.isfile(file_path):
+        raise HTTPException(status_code=404, detail="Video file not found")
+    
+    file_size = os.path.getsize(file_path)
+    range_header = request.headers.get('range', None)
+
+    if range_header:
+        match = re.match(r'bytes=(\d+)-(\d*)', range_header)
+        if match:
+            start, end = match.groups()
+            start = int(start)
+            end = int(end) if end else file_size - 1
+            
+            if start >= file_size or end >= file_size or start > end:
+                raise HTTPException(status_code=416, detail="Requested range not satisfiable")
+            
+            headers = {
+                'Content-Range': f'bytes {start}-{end}/{file_size}',
+                'Accept-Ranges': 'bytes',
+                'Content-Length': str(end - start + 1),
+                'Content-Type': 'video/mp4'  # Change as per your video format
+            }
+            with open(file_path, 'rb') as f:
+                f.seek(start)
+                data = f.read(end - start + 1)
+            return Response(content=data, status_code=206, headers=headers)
+    
+    # Fallback for serving the whole file if no range requested
+    return FileResponse(file_path)
+
+
 @app.get("/")
 async def index():
     return instance.version
@@ -36,9 +70,16 @@ async def get_film_store_api():
     """Endpoint to get the TV store JSON."""
     return JSONResponse(instance.FILM_STORE)
 
+from fastapi import FastAPI, HTTPException, Request, Response
+from fastapi.responses import FileResponse
+import os
+from threading import Thread
+
+app = FastAPI()
+
 @app.get("/api/get/film/{title}")
-async def get_movie_api(title: str):
-    """Endpoint to get the movie by title."""
+async def get_movie_api(request: Request, title: str):
+    """Endpoint to get the movie by title with support for range requests."""
     if not title:
         raise HTTPException(status_code=400, detail="Title parameter is required")
     
@@ -46,7 +87,7 @@ async def get_movie_api(title: str):
     if title in instance.FILM_STORE:
         cache_path = instance.FILM_STORE[title]
         if os.path.exists(cache_path):
-            return FileResponse(cache_path)
+            return await serve_video(cache_path, request)
     
     movie_path = instance.find_movie_path(title)