v0.1

app.py

@@ -1,34 +1,58 @@
-from flask import Flask, jsonify, render_template, request, Response, abort, send_from_directory
+from flask import Flask, jsonify, request, send_from_directory
 import os
-import urllib.parse
-from hf_scrapper import download_and_cache_file, get_system_proxies
+import json
+import threading
+from hf_scrapper import download_file, get_system_proxies, get_download_progress
 from indexer import indexer
 from tvdb import fetch_and_cache_json
-from dotenv import load_dotenv
-import json
 import re
-from threading import Thread
-from flask_socketio import SocketIO, emit
 
-load_dotenv()
+app = Flask(__name__)
+
+# Constants and Configuration
+CACHE_DIR = os.getenv("CACHE_DIR")
 INDEX_FILE = os.getenv("INDEX_FILE")
 TOKEN = os.getenv("TOKEN")
-REPO = os.getenv("REPO")
-CACHE_DIR = os.getenv("CACHE_DIR")
+download_threads = {}
 
 # Ensure CACHE_DIR exists
 if not os.path.exists(CACHE_DIR):
     os.makedirs(CACHE_DIR)
 
+# Index the file structure
 indexer()
 
+# Load the file structure JSON
 if not os.path.exists(INDEX_FILE):
     raise FileNotFoundError(f"{INDEX_FILE} not found. Please make sure the file exists.")
 
 with open(INDEX_FILE, 'r') as f:
     file_structure = json.load(f)
 
+# Function Definitions
+
+def load_json(file_path):
+    """Load JSON data from a file."""
+    with open(file_path, 'r') as file:
+        return json.load(file)
+
+def find_movie_path(json_data, title):
+    """Find the path of the movie in the JSON data based on the title."""
+    for directory in json_data:
+        if directory['type'] == 'directory' and directory['path'] == 'films':
+            for sub_directory in directory['contents']:
+                if sub_directory['type'] == 'directory':
+                    for item in sub_directory['contents']:
+                        if item['type'] == 'file' and title.lower() in item['path'].lower():
+                            return item['path']
+    return None
+
+def get_film_id(title):
+    """Generate a film ID based on the title."""
+    return title.replace(" ", "_").lower()
+
 def prefetch_metadata():
+    """Prefetch metadata for all items in the file structure."""
     for item in file_structure:
         if 'contents' in item:
             for sub_item in item['contents']:
@@ -37,6 +61,7 @@ def prefetch_metadata():
                 title = original_title
                 year = None
                 
+                # Extract year from the title if available
                 match = re.search(r'\((\d{4})\)', original_title)
                 if match:
                     year_str = match.group(1)
@@ -52,204 +77,60 @@ def prefetch_metadata():
                 fetch_and_cache_json(original_title, title, media_type, year)
 
 def start_prefetching():
+    """Start the metadata prefetching in a separate thread."""
     prefetch_metadata()
 
-thread = Thread(target=start_prefetching)
+# Start prefetching metadata
+thread = threading.Thread(target=start_prefetching)
 thread.daemon = True
 thread.start()
 
-app = Flask(__name__)
-socketio = SocketIO(app)
-
-def get_film_file_path(title):
-    decoded_title = urllib.parse.unquote(title)
-    normalized_title = decoded_title.split(' (')[0].strip()
-
-    for item in file_structure:
-        if item['path'].startswith('films'):
-            for sub_item in item['contents']:
-                sub_item_title = sub_item['path'].split('/')[-1]
-                normalized_sub_item_title = sub_item_title.split(' (')[0].strip()
-
-                if normalized_title == normalized_sub_item_title:
-                    for file in sub_item['contents']:
-                        if file['type'] == 'file':
-                            return file['path']
-    return None
+# API Endpoints
 
-def get_tv_show_seasons(title):
-    seasons = []
-    for item in file_structure:
-        if item['path'].startswith('tv'):
-            for sub_item in item['contents']:
-                if sub_item['type'] == 'directory' and title in sub_item['path']:
-                    for season in sub_item['contents']:
-                        if season['type'] == 'directory':
-                            episodes = [
-                                {"title": episode['path'].split('/')[-1], "path": episode['path']}
-                                for episode in season['contents'] if episode['type'] == 'file'
-                            ]
-                            seasons.append({
-                                "season": season['path'].split('/')[-1],
-                                "episodes": episodes
-                            })
-                    return seasons
-    return []
-
-def download_film_if_needed(file_path):
-    cached_file_path = os.path.join(CACHE_DIR, file_path)
-    if not os.path.exists(cached_file_path):
-        file_url = f"https://huggingface.co/{REPO}/resolve/main/{file_path}"
-        success = download_and_cache_file(file_url, TOKEN, cached_file_path, proxies=get_system_proxies())
-        if not success:
-            abort(404, description="File not found or failed to download.")
-    return cached_file_path
-
-@app.route('/')
-def home():
-    return render_template('index.html')
-
-@app.route('/films')
-def films():
-    return render_template('films.html')
-
-@app.route('/api/films')
-def list_films():
-    films = [item for item in file_structure if item['path'].startswith('films')]
-    return jsonify([sub_item for film in films for sub_item in film['contents']])
-
-@app.route('/tv')
-def tv_shows():
-    return render_template('tvshows.html')
-
-@app.route('/api/tv')
-def list_tv():
-    tv_shows = [item for item in file_structure if item['path'].startswith('tv')]
-    return jsonify([sub_item for show in tv_shows for sub_item in show['contents']])
-
-@app.route('/api/film/<path:title>')
-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
-    
-    json_cache_path = os.path.join(CACHE_DIR, f"{urllib.parse.quote(title)}.json")
-    if os.path.exists(json_cache_path):
-        with open(json_cache_path, 'r') as f:
-            metadata = json.load(f)
-    else:
-        return jsonify({'error': 'Metadata not found'}), 404
-    
-    cached_url = f"/cached_films/{urllib.parse.quote(title)}"
-    return jsonify({
-        'metadata': metadata,
-        'cached_url': cached_url
-    })
-
-@app.route('/api/tv/<path:show_title>')
-def tv_page(show_title):
-    show_title = urllib.parse.unquote(show_title)
-    seasons = get_tv_show_seasons(show_title)
-    if not seasons:
-        return jsonify({'error': 'TV show not found'}), 404
-    
-    json_cache_path = os.path.join(CACHE_DIR, f"{urllib.parse.quote(show_title)}.json")
-    if os.path.exists(json_cache_path):
-        with open(json_cache_path, 'r') as f:
-            metadata = json.load(f)
-    else:
-        return jsonify({'error': 'Metadata not found'}), 404
-    
-    return jsonify({
-        'metadata': metadata,
-        'seasons': seasons
-    })
-
-@app.route('/get_metadata')
-def get_metadata():
+@app.route('/api/movie', methods=['GET'])
+def get_movie():
+    """Endpoint to get the movie by title."""
     title = request.args.get('title')
     if not title:
-        return jsonify({'error': 'No title provided'}), 400
-    
-    json_cache_path = os.path.join(CACHE_DIR, f"{urllib.parse.quote(title)}.json")
-    
-    if os.path.exists(json_cache_path):
-        with open(json_cache_path, 'r') as f:
-            data = json.load(f)
-        return jsonify(data)
-    
-    return jsonify({'error': 'Metadata not found'}), 404
-
-@app.route('/api/cache_film/<path:title>')
-def cache_film(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):
-        file_url = f"https://huggingface.co/{REPO}/resolve/main/{film_file_path}"
-        success = download_and_cache_file(file_url, TOKEN, cached_file_path, proxies=get_system_proxies())
-        if not success:
-            return jsonify({'error': 'Failed to cache film'}), 500
-    
-    return jsonify({'success': True})
-
-@app.route('/film/<path: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
-    
-    # Provide the URL to the cached file
-    cached_url = f"/cached_films/{urllib.parse.quote(title)}"
-    
-    return render_template('film_player.html', title=title, cached_url=cached_url)
-
-@app.route('/cached_films/<path:title>')
-def serve_cached_film(title):
-    title = urllib.parse.unquote(title)
-    cached_file_path = get_film_file_path(title)
-    if not cached_file_path:
-        return jsonify({'error': 'Film not found'}), 404
-
-    return send_from_directory(os.path.dirname(cached_file_path), os.path.basename(cached_file_path))
-
-@socketio.on('download')
-def handle_download(data):
-    title = data.get('title')
-    film_file_path = get_film_file_path(title)
-    if not film_file_path:
-        emit('download_progress', {'error': 'Film not found'})
-        return
-    
-    cached_file_path = os.path.join(CACHE_DIR, film_file_path)
-    if os.path.exists(cached_file_path):
-        emit('download_progress', {'progress': 100, 'status': 'already cached'})
-        return
-
-    file_url = f"https://huggingface.co/{REPO}/resolve/main/{film_file_path}"
-    def download_callback(progress):
-        socketio.emit('download_progress', {'progress': progress})
-    
-    success = download_and_cache_file(file_url, TOKEN, cached_file_path, proxies=get_system_proxies(), callback=download_callback)
-    if not success:
-        emit('download_progress', {'error': 'Failed to download film'})
-    else:
-        emit('download_progress', {'progress': 100, 'status': 'completed'})
+        return jsonify({"error": "Title parameter is required"}), 400
+    
+    json_data = load_json(INDEX_FILE)
+    movie_path = find_movie_path(json_data, title)
+    
+    if not movie_path:
+        return jsonify({"error": "Movie not found"}), 404
+    
+    cache_path = os.path.join(CACHE_DIR, movie_path)
+    if not os.path.exists(cache_path):
+        file_url = f"https://huggingface.co/Unicone-Studio/jellyfin_media/resolve/main/{movie_path}"
+        proxies = get_system_proxies()
+        film_id = get_film_id(title)
+        
+        # Start the download in a separate thread if not already downloading
+        if film_id not in download_threads or not download_threads[film_id].is_alive():
+            thread = threading.Thread(target=download_file, args=(file_url, TOKEN, cache_path, proxies, film_id))
+            download_threads[film_id] = thread
+            thread.start()
+        
+        return jsonify({"status": "Download started", "film_id": film_id})
+    
+    return send_from_directory(os.path.dirname(cache_path), os.path.basename(cache_path))
+
+@app.route('/api/progress/<film_id>', methods=['GET'])
+def get_progress(film_id):
+    """Endpoint to get the download progress of a movie."""
+    progress = get_download_progress(film_id)
+    return jsonify({"film_id": film_id, "progress": progress})
+
+@app.route('/api/filmid', methods=['GET'])
+def get_film_id_by_title():
+    """Endpoint to get the film ID by providing the movie title."""
+    title = request.args.get('title')
+    if not title:
+        return jsonify({"error": "Title parameter is required"}), 400
+    film_id = get_film_id(title)
+    return jsonify({"film_id": film_id})
 
+# Main entry point
 if __name__ == "__main__":
-    socketio.run(app, host='0.0.0.0', port=7860, allow_unsafe_werkzeug=True)
+    app.run(debug=True, host="0.0.0.0", port=7860)

hf_scrapper.py

@@ -4,13 +4,19 @@ import json
 import urllib.request
 from requests.exceptions import RequestException
 from tqdm import tqdm
-from concurrent.futures import ThreadPoolExecutor, as_completed
 
 CACHE_DIR = os.getenv("CACHE_DIR")
 CACHE_JSON_PATH = os.path.join(CACHE_DIR, "cached_films.json")
-MAX_WORKERS = 4  # Adjust the number of threads for concurrent downloads
+
+download_progress = {}
 
 def get_system_proxies():
+    """
+    Retrieves the system's HTTP and HTTPS proxies.
+
+    Returns:
+        dict: A dictionary containing the proxies.
+    """
     try:
         proxies = urllib.request.getproxies()
         print("System proxies:", proxies)
@@ -22,43 +28,70 @@ def get_system_proxies():
         print(f"Error getting system proxies: {e}")
         return {}
 
-def download_file_chunk(url, headers, proxies, start, end):
-    headers['Range'] = f"bytes={start}-{end}"
-    response = requests.get(url, headers=headers, proxies=proxies, stream=True)
-    response.raise_for_status()
-    return response.content
+def download_file(file_url, token, cache_path, proxies, film_id, chunk_size=50 * 1024 * 1024):  # 50MB chunk size
+    """
+    Downloads a file from the specified URL and saves it to the cache path.
+    Tracks the download progress.
 
-def download_and_cache_file(file_url, token, cache_path, proxies=None):
+    Args:
+        file_url (str): The URL of the file to download.
+        token (str): The authorization token for the request.
+        cache_path (str): The path to save the downloaded file.
+        proxies (dict): Proxies for the request.
+        film_id (str): Unique identifier for the film download.
+        chunk_size (int): Size of each chunk to download.
+    """
     print(f"Downloading file from URL: {file_url} to {cache_path} with proxies: {proxies}")
     headers = {'Authorization': f'Bearer {token}'}
     try:
-        response = requests.head(file_url, headers=headers, proxies=proxies)
+        response = requests.get(file_url, headers=headers, proxies=proxies, stream=True)
         response.raise_for_status()
-
+        
         total_size = int(response.headers.get('content-length', 0))
-        os.makedirs(os.path.dirname(cache_path), exist_ok=True)
-
-        chunk_size = total_size // MAX_WORKERS
-        ranges = [(i, min(i + chunk_size, total_size) - 1) for i in range(0, total_size, chunk_size)]
-
-        with ThreadPoolExecutor(max_workers=MAX_WORKERS) as executor:
-            futures = [executor.submit(download_file_chunk, file_url, headers, proxies, start, end) for start, end in ranges]
-            with open(cache_path, 'wb') as f, tqdm(total=total_size, unit='B', unit_scale=True, desc=cache_path) as pbar:
-                for future in as_completed(futures):
-                    chunk = future.result()
-                    f.write(chunk)
-                    pbar.update(len(chunk))
+        download_progress[film_id] = {"total": total_size, "downloaded": 0}
 
+        os.makedirs(os.path.dirname(cache_path), exist_ok=True)
+        with open(cache_path, 'wb') as file, tqdm(total=total_size, unit='B', unit_scale=True, desc=cache_path) as pbar:
+            for data in response.iter_content(chunk_size=chunk_size):
+                file.write(data)
+                pbar.update(len(data))
+                download_progress[film_id]["downloaded"] += len(data)
+        
         print(f'File cached to {cache_path} successfully.')
         update_cache_json(file_url, cache_path)
-        return True
     except RequestException as e:
         print(f"Error downloading file: {e}")
     except IOError as e:
         print(f"Error writing file {cache_path}: {e}")
-    return False
+    finally:
+        del download_progress[film_id]
+
+
+def get_download_progress(film_id):
+    """
+    Gets the download progress for a specific film.
+
+    Args:
+        film_id (str): The unique identifier for the film download.
+
+    Returns:
+        dict: A dictionary containing the total size, downloaded size, and progress percentage.
+    """
+    if film_id in download_progress:
+        total = download_progress[film_id]["total"]
+        downloaded = download_progress[film_id]["downloaded"]
+        progress = (downloaded / total) * 100
+        return {"total": total, "downloaded": downloaded, "progress": progress}
+    return {"total": 0, "downloaded": 0, "progress": 0}
 
 def update_cache_json(file_url, cache_path):
+    """
+    Updates the cached films JSON with the new file.
+
+    Args:
+        file_url (str): The URL of the downloaded file.
+        cache_path (str): The local path where the file is saved.
+    """
     cache_data = {}
     if os.path.exists(CACHE_JSON_PATH):
         with open(CACHE_JSON_PATH, 'r') as json_file:
@@ -69,10 +102,21 @@ def update_cache_json(file_url, cache_path):
 
     with open(CACHE_JSON_PATH, 'w') as json_file:
         json.dump(cache_data, json_file, indent=2)
-
-    print(f'Updated cache JSON: {CACHE_JSON_PATH} with {film_title}: {cache_path}')
+    print(f'Cache updated with {film_title}.')
 
 def get_file_structure(repo, token, path="", proxies=None):
+    """
+    Fetches the file structure of a specified Hugging Face repository.
+
+    Args:
+        repo (str): The name of the repository.
+        token (str): The authorization token for the request.
+        path (str, optional): The specific path in the repository. Defaults to "".
+        proxies (dict, optional): The proxies to use for the request. Defaults to None.
+
+    Returns:
+        list: A list of file structure information.
+    """
     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}")
@@ -85,6 +129,13 @@ def get_file_structure(repo, token, path="", proxies=None):
         return []
 
 def write_file_structure_to_json(file_structure, file_path):
+    """
+    Writes the file structure to a JSON file.
+
+    Args:
+        file_structure (list): The file structure data.
+        file_path (str): The path where the JSON file will be saved.
+    """
     try:
         with open(file_path, 'w') as json_file:
             json.dump(file_structure, json_file, indent=2)
@@ -96,5 +147,6 @@ 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 = os.path.join(CACHE_DIR, "films/Funky Monkey 2004/Funky Monkey (2004) Web-dl 1080p.mp4")
-    proxy = get_system_proxies()
-    download_and_cache_file(file_url, token, cache_path, proxies=proxy)
+    proxies = get_system_proxies()
+    film_id = "funky_monkey_2004"  # Unique identifier for the film download
+    download_file(file_url, token, cache_path, proxies=proxies, film_id=film_id)

templates/film_details_page.html

@@ -1,203 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Film Details</title>
-    <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/4.0.0/socket.io.min.js" integrity="sha384-13fTj1YYl5Xk8bo8dqPG7ZNmTPukjZ08s5hlIBvbxkQa2ClOsuT9hALo5eUn53I1" crossorigin="anonymous"></script>
-    <style>
-        body {
-            font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
-            background: linear-gradient(to right, #141414, #333);
-            color: #fff;
-            margin: 0;
-            padding: 0;
-            display: flex;
-            justify-content: center;
-            align-items: center;
-            min-height: 100vh;
-        }
-        .container {
-            width: 90%;
-            max-width: 1200px;
-            display: flex;
-            gap: 20px;
-            padding: 20px;
-            background-color: #1e1e1e;
-            border-radius: 10px;
-            box-shadow: 0 4px 8px rgba(0, 0, 0, 0.5);
-        }
-        .poster {
-            flex: 1;
-            max-width: 300px;
-            position: relative;
-        }
-        .poster img {
-            width: 100%;
-            height: auto;
-            border-radius: 10px;
-            box-shadow: 0 4px 8px rgba(0, 0, 0, 0.8);
-        }
-        .details {
-            flex: 2;
-            display: flex;
-            flex-direction: column;
-            gap: 20px;
-            padding: 10px;
-        }
-        .details h2 {
-            margin: 0;
-            font-size: 36px;
-            font-weight: bold;
-        }
-        .details p {
-            margin: 5px 0;
-            font-size: 16px;
-            line-height: 1.6;
-            color: #d1d1d1;
-        }
-        .genres, .metadata {
-            display: flex;
-            flex-wrap: wrap;
-            gap: 10px;
-        }
-        .genres div, .metadata div {
-            background-color: #333;
-            padding: 8px 12px;
-            border-radius: 5px;
-            font-size: 14px;
-        }
-        .metadata div {
-            background-color: #444;
-        }
-        .play-button {
-            display: inline-block;
-            padding: 15px 30px;
-            background: linear-gradient(to right, #ff6f61, #ff3f34);
-            color: #fff;
-            text-decoration: none;
-            border-radius: 50px;
-            font-size: 18px;
-            font-weight: bold;
-            text-align: center;
-            transition: background 0.3s, transform 0.3s;
-        }
-        .play-button:hover {
-            background: linear-gradient(to right, #ff3f34, #ff6f61);
-            transform: scale(1.05);
-        }
-        .play-button:focus {
-            outline: none;
-            box-shadow: 0 0 0 2px rgba(255, 105, 97, 0.5);
-        }
-        .error-message {
-            color: #ff4d4d;
-            font-size: 18px;
-            text-align: center;
-            margin-top: 20px;
-        }
-        .metadata-container {
-            display: flex;
-            flex-direction: column;
-            gap: 10px;
-        }
-        .metadata-container div {
-            display: flex;
-            justify-content: space-between;
-            padding: 5px 10px;
-            background-color: #333;
-            border-radius: 5px;
-        }
-        .metadata-container div span {
-            font-weight: bold;
-        }
-    </style>
-</head>
-<body>
-    <div class="container">
-        <div class="poster" id="film-poster">
-            <img src="https://via.placeholder.com/300x450.png" alt="Poster">
-        </div>
-        <div class="details" id="film-details">
-            <h2 id="film-title">Film Title</h2>
-            <p id="film-overview">Film overview goes here...</p>
-            <div class="genres" id="film-genres"></div>
-            <div class="metadata-container" id="film-metadata"></div>
-            <a href="#" class="play-button" id="play-button" onclick="playFilm()">Play</a>
-        </div>
-    </div>
-    <script>
-        async function fetchData(endpoint) {
-            try {
-                const response = await fetch(endpoint);
-                if (!response.ok) throw new Error('Network response was not ok');
-                return await response.json();
-            } catch (error) {
-                console.error('Fetch error:', error);
-                return null;
-            }
-        }
-
-        function createMetadataElement(label, value) {
-            const div = document.createElement('div');
-            div.innerHTML = `<span>${label}</span><span>${value}</span>`;
-            return div;
-        }
-
-        function createGenreElement(genre) {
-            const div = document.createElement('div');
-            div.textContent = genre;
-            return div;
-        }
-
-        async function loadFilmDetails(title) {
-            const data = await fetchData(`/api/film/${encodeURIComponent(title)}`);
-            if (!data || data.error) {
-                document.getElementById('film-details').innerHTML = '<p class="error-message">Film not found</p>';
-                return;
-            }
-            
-            const metadata = data.metadata.data[0];
-            document.getElementById('film-poster').querySelector('img').src = metadata.image_url || 'https://via.placeholder.com/300x450.png';
-            document.getElementById('film-title').textContent = metadata.extended_title;
-            document.getElementById('film-overview').textContent = metadata.overview;
-            
-            const genresContainer = document.getElementById('film-genres');
-            genresContainer.innerHTML = '';
-            metadata.genres.forEach(genre => genresContainer.appendChild(createGenreElement(genre)));
-
-            const metadataContainer = document.getElementById('film-metadata');
-            metadataContainer.innerHTML = '';
-            metadataContainer.appendChild(createMetadataElement('Director', metadata.director));
-            metadataContainer.appendChild(createMetadataElement('Country', metadata.country));
-            metadataContainer.appendChild(createMetadataElement('Release Date', metadata.first_air_time));
-
-            const playButton = document.getElementById('play-button');
-            playButton.href = `#`; // Will be handled by JavaScript
-        }
-
-        async function playFilm() {
-            const title = "{{ title }}";
-            try {
-                const response = await fetch(`/api/cache_film/${encodeURIComponent(title)}`);
-                const data = await response.json();
-                if (data.success) {
-                    window.location.href = `/film_player/${encodeURIComponent(title)}`;
-                } else {
-                    alert('Error caching film: ' + data.error);
-                }
-            } catch (error) {
-                alert('Error: ' + error.message);
-            }
-        }
-
-        const urlParams = new URLSearchParams(window.location.search);
-        const title = "{{ title }}";
-        if (title) {
-            loadFilmDetails(title);
-        } else {
-            document.getElementById('film-details').innerHTML = '<p class="error-message">No film title provided</p>';
-        }
-    </script>
-</body>
-</html>

templates/film_player.html

@@ -1,15 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>{{ title }}</title>
-</head>
-<body>
-    <h1>{{ title }}</h1>
-    <video controls width="100%" height="auto">
-        <source src="{{ cached_url }}" type="video/mp4">
-        Your browser does not support the video tag.
-    </video>
-</body>
-</html>

templates/films.html

@@ -1,174 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Films</title>
-    <style>
-        body {
-            font-family: 'Roboto', sans-serif;
-            background: #0f0f0f;
-            color: #e0e0e0;
-            margin: 0;
-            padding: 0;
-            overflow-x: hidden;
-        }
-        .header {
-            background: linear-gradient(to right, #ff2c20, #ef8b81);
-            color: #fff;
-            padding: 40px 20px;
-            text-align: center;
-            border-bottom: 2px solid rgba(255, 255, 255, 0.2);
-            position: relative;
-            z-index: 1;
-        }
-        .header h1 {
-            margin: 0;
-            font-size: 48px;
-            font-weight: bold;
-            text-shadow: 2px 2px 4px rgba(0, 0, 0, 0.7);
-        }
-        .content {
-            padding: 20px;
-            position: relative;
-            z-index: 1;
-        }
-        .section {
-            margin-bottom: 60px;
-        }
-        .section h2 {
-            margin-bottom: 20px;
-            font-size: 36px;
-            font-weight: bold;
-            color: #fff;
-            border-bottom: 2px solid #ff1e1e;
-            padding-bottom: 10px;
-        }
-        .grid {
-            display: grid;
-            grid-template-columns: repeat(auto-fill, minmax(220px, 1fr));
-            gap: 20px;
-            margin-top: 20px;
-        }
-        .card {
-            position: relative;
-            background: #222;
-            border-radius: 15px;
-            overflow: hidden;
-            text-align: center;
-            transition: transform 0.3s, box-shadow 0.3s;
-            cursor: pointer;
-            box-shadow: 0 6px 12px rgba(0, 0, 0, 0.8);
-        }
-        .card:hover {
-            transform: scale(1.05);
-            box-shadow: 0 8px 16px rgba(0, 0, 0, 0.9);
-        }
-        .card img {
-            width: 100%;
-            height: 330px;
-            object-fit: cover;
-            transition: opacity 0.3s;
-        }
-        .card h3 {
-            margin: 0;
-            padding: 10px;
-            font-size: 22px;
-            font-weight: bold;
-            background: rgba(0, 0, 0, 0.6);
-            height: 100%;
-        }
-        .card::after {
-            content: '';
-            display: block;
-            position: absolute;
-            top: 0;
-            left: 0;
-            width: 100%;
-            height: 100%;
-            background: linear-gradient(to bottom, rgba(0, 0, 0, 0.2) 0%, rgba(0, 0, 0, 0.7) 100%);
-            opacity: 0;
-            transition: opacity 0.3s;
-            z-index: 1;
-        }
-        .card:hover::after {
-            opacity: 1;
-        }
-        .card p {
-            margin: 0;
-            padding: 10px;
-            font-size: 16px;
-            color: #ccc;
-        }
-    </style>
-</head>
-<body>
-    <div class="header">
-        <h1>All Films</h1>
-    </div>
-    <div class="content">
-        <div class="section" id="films">
-            <h2>Films</h2>
-            <div class="grid" id="films-grid"></div>
-        </div>
-    </div>
-    <script>
-        async function fetchData(endpoint) {
-            try {
-                const response = await fetch(endpoint);
-                if (!response.ok) throw new Error('Network response was not ok');
-                return await response.json();
-            } catch (error) {
-                console.error('Fetch error:', error);
-                return [];
-            }
-        }
-
-        async function fetchMetadata(title) {
-            try {
-                const response = await fetch(`/get_metadata?title=${encodeURIComponent(title)}`);
-                if (response.ok) {
-                    const data = await response.json();
-                    if (data.data && data.data.length > 0) {
-                        const thumbnailUrl = data.data[0].thumbnail;
-                        return thumbnailUrl;
-                    }
-                }
-            } catch (error) {
-                console.error('Metadata fetch error:', error);
-            }
-            return null;
-        }
-
-        function createCard(item) {
-            const card = document.createElement('div');
-            card.className = 'card';
-            const title = item.path.split('/').pop();
-            card.innerHTML = `
-                <img src="https://via.placeholder.com/220x330.png" alt="${title}">
-                <h3>${title}</h3>
-            `;
-            // Redirect to the appropriate page on card click
-            card.onclick = () => {
-                window.location.href = `/film/${encodeURIComponent(title)}`;
-            };
-            fetchMetadata(title).then(thumbnailUrl => {
-                if (thumbnailUrl !== null) {
-                    card.querySelector('img').src = thumbnailUrl;
-                }
-            });
-            return card;
-        }
-
-        async function populateGrid(endpoint, gridId) {
-            const grid = document.getElementById(gridId);
-            const data = await fetchData(endpoint);
-            data.forEach(item => {
-                grid.appendChild(createCard(item));
-            });
-        }
-
-        populateGrid('/api/films', 'films-grid');
-    </script>
-</body>
-</html>

templates/index.html

@@ -1,187 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Media Library</title>
-    <style>
-        body {
-            font-family: 'Roboto', sans-serif;
-            background: #0f0f0f;
-            color: #e0e0e0;
-            margin: 0;
-            padding: 0;
-            overflow-x: hidden;
-        }
-        .header {
-            background: linear-gradient(to right, #ff2c20, #ef8b81);
-            color: #fff;
-            padding: 40px 20px;
-            text-align: center;
-            border-bottom: 2px solid rgba(255, 255, 255, 0.2);
-            position: relative;
-            z-index: 1;
-        }
-        .header h1 {
-            margin: 0;
-            font-size: 48px;
-            font-weight: bold;
-            text-shadow: 2px 2px 4px rgba(0, 0, 0, 0.7);
-        }
-        .content {
-            padding: 20px;
-            position: relative;
-            z-index: 1;
-        }
-        .section {
-            margin-bottom: 60px;
-        }
-        .section h2 {
-            margin-bottom: 20px;
-            font-size: 36px;
-            font-weight: bold;
-            color: #fff;
-            border-bottom: 2px solid #ff1e1e;
-            padding-bottom: 10px;
-        }
-        .section h2 a {
-            color: #f2629f;
-            text-decoration: none;
-            font-size: 16px;
-        }
-        .grid {
-            display: grid;
-            grid-template-columns: repeat(auto-fill, minmax(220px, 1fr));
-            gap: 20px;
-            margin-top: 20px;
-        }
-        .card {
-            position: relative;
-            background: #222;
-            border-radius: 15px;
-            overflow: hidden;
-            text-align: center;
-            transition: transform 0.3s, box-shadow 0.3s;
-            cursor: pointer;
-            box-shadow: 0 6px 12px rgba(0, 0, 0, 0.8);
-        }
-        .card:hover {
-            transform: scale(1.05);
-            box-shadow: 0 8px 16px rgba(0, 0, 0, 0.9);
-        }
-        .card img {
-            width: 100%;
-            height: 330px;
-            object-fit: cover;
-            transition: opacity 0.3s;
-        }
-        .card h3 {
-            margin: 0;
-            padding: 10px;
-            font-size: 22px;
-            font-weight: bold;
-            background: rgba(0, 0, 0, 0.6);
-        }
-        .card::after {
-            content: '';
-            display: block;
-            position: absolute;
-            top: 0;
-            left: 0;
-            width: 100%;
-            height: 100%;
-            background: linear-gradient(to bottom, rgba(0, 0, 0, 0.2) 0%, rgba(0, 0, 0, 0.7) 100%);
-            opacity: 0;
-            transition: opacity 0.3s;
-            z-index: 1;
-        }
-        .card:hover::after {
-            opacity: 1;
-        }
-        .card p {
-            margin: 0;
-            padding: 10px;
-            font-size: 16px;
-            color: #ccc;
-        }
-    </style>
-</head>
-<body>
-    <div class="header">
-        <h1>Media Library</h1>
-    </div>
-    <div class="content">
-        <div class="section" id="films">
-            <h2>Films <a href="/films">View All</a></h2>
-            <div class="grid" id="films-grid"></div>
-        </div>
-        <div class="section" id="tv">
-            <h2>TV Shows <a href="/tv">View All</a></h2>
-            <div class="grid" id="tv-grid"></div>
-        </div>
-    </div>
-    <script>
-        async function fetchData(endpoint) {
-            try {
-                const response = await fetch(endpoint);
-                if (!response.ok) throw new Error('Network response was not ok');
-                return await response.json();
-            } catch (error) {
-                console.error('Fetch error:', error);
-                return [];
-            }
-        }
-
-        async function fetchMetadata(title) {
-            try {
-                const response = await fetch(`/get_metadata?title=${encodeURIComponent(title)}`);
-                if (response.ok) {
-                    const data = await response.json();
-                    if (data.data && data.data.length > 0) {
-                        const thumbnailUrl = data.data[0].thumbnail;
-                        return thumbnailUrl;
-                    }
-                }
-            } catch (error) {
-                console.error('Metadata fetch error:', error);
-            }
-            return null;
-        }
-
-        function createCard(item, mediaType) {
-            const card = document.createElement('div');
-            card.className = 'card';
-            const title = item.path.split('/').pop();
-            card.innerHTML = `
-                <img src="https://via.placeholder.com/220x330.png" alt="${title}">
-                <h3>${title}</h3>
-            `;
-            // Redirect to the appropriate page on card click
-            card.onclick = () => {
-                if (mediaType === 'movie') {
-                    window.location.href = `/film/${encodeURIComponent(title)}`;
-                } else if (mediaType === 'series') {
-                    window.location.href = `/tv/${encodeURIComponent(title)}`;
-                }
-            };
-            fetchMetadata(title).then(thumbnailUrl => {
-                if (thumbnailUrl !== null) {
-                    card.querySelector('img').src = thumbnailUrl;
-                }
-            });
-            return card;
-        }
-
-        async function populateGrid(endpoint, gridId, mediaType, limit = 5) {
-            const grid = document.getElementById(gridId);
-            const data = await fetchData(endpoint);
-            data.slice(0, limit).forEach(item => {
-                grid.appendChild(createCard(item, mediaType));
-            });
-        }
-
-        populateGrid('/api/films', 'films-grid', 'movie');
-        populateGrid('/api/tv', 'tv-grid', 'series');
-    </script>
-</body>
-</html>

templates/tvshow_player.html

@@ -1,50 +0,0 @@
-<!DOCTYPE html>
-<html>
-<head>
-    <title>Media Player</title>
-    <style>
-        body {
-            font-family: Arial, sans-serif;
-            background-color: #141414;
-            color: #fff;
-            margin: 0;
-            padding: 0;
-        }
-        .header {
-            background-color: #000;
-            padding: 20px;
-            text-align: center;
-        }
-        .header h1 {
-            margin: 0;
-            font-size: 24px;
-        }
-        .content {
-            padding: 20px;
-        }
-        .player-container {
-            max-width: 100%;
-            margin: auto;
-            text-align: center;
-        }
-        video {
-            width: 100%;
-            height: auto;
-            background-color: #333;
-        }
-    </style>
-</head>
-<body>
-    <div class="header">
-        <h1>TV Show Player</h1>
-    </div>
-    <div class="content">
-        <div class="player-container">
-            <video id="videoPlayer" controls>
-                <source id="videoSource" type="video/mp4">
-                Your browser does not support the video tag.
-            </video>
-        </div>
-    </div>
-</body>
-</html>

templates/tvshows.html

@@ -1,174 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>All TV Shows</title>
-    <style>
-        body {
-            font-family: 'Roboto', sans-serif;
-            background: #0f0f0f;
-            color: #e0e0e0;
-            margin: 0;
-            padding: 0;
-            overflow-x: hidden;
-        }
-        .header {
-            background: linear-gradient(to right, #ff2c20, #ef8b81);
-            color: #fff;
-            padding: 40px 20px;
-            text-align: center;
-            border-bottom: 2px solid rgba(255, 255, 255, 0.2);
-            position: relative;
-            z-index: 1;
-        }
-        .header h1 {
-            margin: 0;
-            font-size: 48px;
-            font-weight: bold;
-            text-shadow: 2px 2px 4px rgba(0, 0, 0, 0.7);
-        }
-        .content {
-            padding: 20px;
-            position: relative;
-            z-index: 1;
-        }
-        .section {
-            margin-bottom: 60px;
-        }
-        .section h2 {
-            margin-bottom: 20px;
-            font-size: 36px;
-            font-weight: bold;
-            color: #fff;
-            border-bottom: 2px solid #ff1e1e;
-            padding-bottom: 10px;
-        }
-        .grid {
-            display: grid;
-            grid-template-columns: repeat(auto-fill, minmax(220px, 1fr));
-            gap: 20px;
-            margin-top: 20px;
-        }
-        .card {
-            position: relative;
-            background: #222;
-            border-radius: 15px;
-            overflow: hidden;
-            text-align: center;
-            transition: transform 0.3s, box-shadow 0.3s;
-            cursor: pointer;
-            box-shadow: 0 6px 12px rgba(0, 0, 0, 0.8);
-        }
-        .card:hover {
-            transform: scale(1.05);
-            box-shadow: 0 8px 16px rgba(0, 0, 0, 0.9);
-        }
-        .card img {
-            width: 100%;
-            height: 330px;
-            object-fit: cover;
-            transition: opacity 0.3s;
-        }
-        .card h3 {
-            margin: 0;
-            padding: 10px;
-            font-size: 22px;
-            font-weight: bold;
-            background: rgba(0, 0, 0, 0.6);
-            height: 100%;
-        }
-        .card::after {
-            content: '';
-            display: block;
-            position: absolute;
-            top: 0;
-            left: 0;
-            width: 100%;
-            height: 100%;
-            background: linear-gradient(to bottom, rgba(0, 0, 0, 0.2) 0%, rgba(0, 0, 0, 0.7) 100%);
-            opacity: 0;
-            transition: opacity 0.3s;
-            z-index: 1;
-        }
-        .card:hover::after {
-            opacity: 1;
-        }
-        .card p {
-            margin: 0;
-            padding: 10px;
-            font-size: 16px;
-            color: #ccc;
-        }
-    </style>
-</head>
-<body>
-    <div class="header">
-        <h1>All TV Shows</h1>
-    </div>
-    <div class="content">
-        <div class="section" id="tv">
-            <h2>TV Shows</h2>
-            <div class="grid" id="tv-grid"></div>
-        </div>
-    </div>
-    <script>
-        async function fetchData(endpoint) {
-            try {
-                const response = await fetch(endpoint);
-                if (!response.ok) throw new Error('Network response was not ok');
-                return await response.json();
-            } catch (error) {
-                console.error('Fetch error:', error);
-                return [];
-            }
-        }
-
-        async function fetchMetadata(title) {
-            try {
-                const response = await fetch(`/get_metadata?title=${encodeURIComponent(title)}`);
-                if (response.ok) {
-                    const data = await response.json();
-                    if (data.data && data.data.length > 0) {
-                        const thumbnailUrl = data.data[0].thumbnail;
-                        return thumbnailUrl;
-                    }
-                }
-            } catch (error) {
-                console.error('Metadata fetch error:', error);
-            }
-            return null;
-        }
-
-        function createCard(item) {
-            const card = document.createElement('div');
-            card.className = 'card';
-            const title = item.path.split('/').pop();
-            card.innerHTML = `
-                <img src="https://via.placeholder.com/220x330.png" alt="${title}">
-                <h3>${title}</h3>
-            `;
-            // Redirect to the appropriate page on card click
-            card.onclick = () => {
-                window.location.href = `/tv/${encodeURIComponent(title)}`;
-            };
-            fetchMetadata(title).then(thumbnailUrl => {
-                if (thumbnailUrl !== null) {
-                    card.querySelector('img').src = thumbnailUrl;
-                }
-            });
-            return card;
-        }
-
-        async function populateGrid(endpoint, gridId) {
-            const grid = document.getElementById(gridId);
-            const data = await fetchData(endpoint);
-            data.forEach(item => {
-                grid.appendChild(createCard(item));
-            });
-        }
-
-        populateGrid('/api/tv', 'tv-grid');
-    </script>
-</body>
-</html>

video.py

@@ -1,52 +0,0 @@
-import os
-import logging
-import ffmpeg
-
-# Set up logging
-logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(levelname)s - %(message)s')
-
-def ffmpeg_stream(file_url, token, output_dir="tmp/cache/stream", stream_id=None):
-    # Generate a unique directory for the stream
-    stream_dir = os.path.join(output_dir, stream_id)
-    
-    if not os.path.exists(stream_dir):
-        os.makedirs(stream_dir)
-
-    # Set the output paths
-    output_path = os.path.join(stream_dir, 'output.m3u8')
-    segment_filename = os.path.join(stream_dir, 'segment_%03d.ts')
-
-    # Log the URL and output paths
-    logging.debug(f"URL: {file_url}")
-    logging.debug(f"Output Path: {output_path}")
-    logging.debug(f"Segment Filename: {segment_filename}")
-
-    try:
-        # Log the command being executed
-        logging.debug(f"Starting FFmpeg process with URL: {file_url}")
-
-        # Run the FFmpeg command using ffmpeg-python
-        process = (
-            ffmpeg
-            .input(file_url, headers=f"Authorization: Bearer {token}")
-            .output(output_path, 
-                    vcodec='libx264', crf=23, preset='medium', 
-                    acodec='aac', audio_bitrate='192k', format='hls', 
-                    hls_time=10, hls_list_size=0, 
-                    hls_segment_filename=segment_filename)
-        )
-
-        process.run(capture_stdout=True, capture_stderr=True)
-
-        # Check if the output file was created
-        if os.path.exists(output_path):
-            logging.info(f"HLS playlist created at {output_path}")
-            return output_path
-        else:
-            logging.error(f"HLS playlist not created at {output_path}")
-            return None
-
-    except ffmpeg.Error as e:
-        error_message = e.stderr.decode('utf8') if e.stderr else str(e)
-        logging.error(f"Error using FFmpeg to stream file: {error_message}")
-        return None