fix

app.py

@@ -129,6 +129,7 @@ def list_tv():
 def film_page(title):
     title = urllib.parse.unquote(title)
     film_file_path = get_film_file_path(title)
+    
     if not film_file_path:
         return jsonify({'error': 'Film not found'}), 404
     
@@ -199,6 +200,20 @@ def cache_film(title):
 def film_details(title):
     return render_template('film_details_page.html', title=title)
 
+@app.route('/film_player/<path:title>')
+def film_player(title):
+    title = urllib.parse.unquote(title)
+    film_file_path = get_film_file_path(title)
+    
+    if not film_file_path:
+        return jsonify({'error': 'Film not found'}), 404
+    
+    cached_file_path = os.path.join(CACHE_DIR, film_file_path)
+    if not os.path.exists(cached_file_path):
+        return jsonify({'error': 'Film not cached'}), 404
+    
+    return render_template('film_player.html', title=title)
+
 @app.route('/cached_films/<path:title>')
 def serve_cached_film(title):
     cached_file_path = os.path.join(CACHE_DIR, urllib.parse.unquote(title))

hf_scrapper.py

@@ -1,10 +1,9 @@
 import os
-import subprocess
 import requests
 import json
 import urllib.request
 from requests.exceptions import RequestException
-from ffmpy import FFmpeg
+from concurrent.futures import ThreadPoolExecutor
 
 def get_system_proxies():
     try:
@@ -18,15 +17,21 @@ def get_system_proxies():
         print(f"Error getting system proxies: {e}")
         return {}
 
-
 def download_and_cache_file(file_url, token, cache_path, proxies=None):
     print(f"Downloading file from URL: {file_url} to {cache_path} with proxies: {proxies}")
+
+    # Create a requests session for better performance
+    session = requests.Session()
+    session.headers.update({'Authorization': f'Bearer {token}'})
+    session.proxies.update(proxies)
+
     try:
-        response = requests.get(file_url, headers={'Authorization': f'Bearer {token}'}, proxies=proxies, stream=True)
+        response = session.get(file_url, stream=True)
         response.raise_for_status()
         os.makedirs(os.path.dirname(cache_path), exist_ok=True)
+
         with open(cache_path, 'wb') as f:
-            for chunk in response.iter_content(chunk_size=8192):
+            for chunk in response.iter_content(chunk_size=16384):  # Larger chunk size
                 if chunk:
                     f.write(chunk)
         print(f'File cached to {cache_path} successfully.')
@@ -41,6 +46,7 @@ def get_file_structure(repo, token, path="", proxies=None):
     api_url = f"https://huggingface.co/api/models/{repo}/tree/main/{path}"
     headers = {'Authorization': f'Bearer {token}'}
     print(f"Fetching file structure from URL: {api_url} with proxies: {proxies}")
+
     try:
         response = requests.get(api_url, headers=headers, proxies=proxies)
         response.raise_for_status()
@@ -57,10 +63,24 @@ def write_file_structure_to_json(file_structure, file_path):
     except IOError as e:
         print(f"Error writing file structure to JSON: {e}")
 
+# Function to download files in parallel
+def parallel_downloads(file_urls, token, cache_dir, proxies=None):
+    with ThreadPoolExecutor() as executor:
+        futures = []
+        for file_url in file_urls:
+            filename = file_url.split("/")[-1]
+            cache_path = os.path.join(cache_dir, filename)
+            futures.append(executor.submit(download_and_cache_file, file_url, token, cache_path, proxies))
+        # Wait for all futures to complete
+        for future in futures:
+            future.result()
 
 if __name__ == "__main__":
-    file_url="https://huggingface.co/Unicone-Studio/jellyfin_media/resolve/main/films/Funky%20Monkey%202004/Funky%20Monkey%20(2004)%20Web-dl%201080p.mp4"
-    token=os.getenv("TOKEN")
-    cache_path="tmp/cache/films/Funky%20Monkey%202004/Funky%20Monkey%20(2004)%20Web-dl%201080p.mp4"
-    proxy=get_system_proxies()
-    download_and_cache_file(file_url, token, cache_path, proxies=proxy)
+    file_urls = [
+        "https://huggingface.co/Unicone-Studio/jellyfin_media/resolve/main/films/Funky%20Monkey%202004/Funky%20Monkey%20(2004)%20Web-dl%201080p.mp4"
+    ]
+    token = os.getenv("TOKEN")
+    cache_dir = "tmp/cache/films"
+    proxies = get_system_proxies()
+
+    parallel_downloads(file_urls, token, cache_dir, proxies)