diff --git a/Dockerfile b/Dockerfile
index 12d2b13..93bc449 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -1,5 +1,6 @@
FROM python:3.11-slim
WORKDIR /app
COPY ta_symlink.py .
-RUN pip install --no-cache-dir requests
+RUN pip install --no-cache-dir requests flask
+EXPOSE 5000
CMD ["python", "ta_symlink.py"]
diff --git a/ta_symlink.py b/ta_symlink.py
index 9cfc88e..0497085 100644
--- a/ta_symlink.py
+++ b/ta_symlink.py
@@ -1,8 +1,10 @@
+
from pathlib import Path
import os
import requests
import re
import sys
+from flask import Flask, jsonify, render_template_string, request
# Load config from environment variables
API_URL = os.getenv("API_URL", "http://localhost:8457/api")
@@ -12,6 +14,10 @@ SOURCE_DIR = Path("/app/source")
TARGET_DIR = Path("/app/target")
HEADERS = {"Authorization": f"Token {API_TOKEN}"}
+app = Flask(__name__)
+
+processed_videos = []
+
# Utility functions
def sanitize(text):
text = text.encode("ascii", "ignore").decode()
@@ -42,38 +48,31 @@ def fetch_video_metadata(video_id):
return None
# Main logic
-def process_videos():
- print("📁 Starting video processing...", flush=True)
+def process_videos():
+ global processed_videos
+ processed_videos = []
try:
for channel_path in SOURCE_DIR.iterdir():
if not channel_path.is_dir():
continue
-
for video_file in channel_path.glob("*.*"):
video_id = video_file.stem
meta = fetch_video_metadata(video_id)
if not meta:
- print(f"⚠️ Skipped {video_id}: could not fetch metadata", flush=True)
continue
-
sanitized_channel_name = sanitize(meta["channel_name"])
channel_dir = TARGET_DIR / sanitized_channel_name
channel_dir.mkdir(parents=True, exist_ok=True)
-
sanitized_title = sanitize(meta["title"])
folder_name = f"{meta['published']} - {sanitized_title}"
video_dir = channel_dir / folder_name
video_dir.mkdir(parents=True, exist_ok=True)
-
actual_file = next(channel_path.glob(f"{video_id}.*"), None)
if not actual_file:
- print(f"⚠️ Video file not found for {video_id} in {channel_path}", flush=True)
continue
-
host_path_root = Path("/mnt/user/tubearchives/bp")
host_source_path = host_path_root / actual_file.relative_to(SOURCE_DIR)
-
dest_file = video_dir / f"video{actual_file.suffix}"
try:
if dest_file.exists():
@@ -84,11 +83,67 @@ def process_videos():
os.symlink(host_source_path, dest_file)
else:
os.symlink(host_source_path, dest_file)
- print(f"✅ Linked: {dest_file}", flush=True)
except Exception:
pass
+ processed_videos.append({
+ "video_id": video_id,
+ "title": meta["title"],
+ "channel": meta["channel_name"],
+ "published": meta["published"],
+ "symlink": str(dest_file)
+ })
except Exception as e:
- print(f"💥 Unhandled error: {e}", file=sys.stderr, flush=True)
+ return str(e)
+ return None
+
+
+# Flask routes
+@app.route("/")
+def index():
+ return render_template_string('''
+
+ TA Organizerr
+
+ TA Organizerr
+
+ Processed Videos
+
+ {% for v in videos %}
+ - {{v.published}} - {{v.title}} ({{v.channel}})
Symlink: {{v.symlink}}
+ {% endfor %}
+
+
+
+ ''', videos=processed_videos)
+
+@app.route("/process", methods=["POST"])
+def process():
+ error = process_videos()
+ if error:
+ return f"Error: {error}", 500
+ return render_template_string('''
+
+ TA Organizerr
+
+ TA Organizerr
+
+ Processed Videos
+
+ {% for v in videos %}
+ - {{v.published}} - {{v.title}} ({{v.channel}})
Symlink: {{v.symlink}}
+ {% endfor %}
+
+
+
+ ''', videos=processed_videos)
+
+@app.route("/api/videos")
+def api_videos():
+ return jsonify(processed_videos)
if __name__ == "__main__":
- process_videos()
+ app.run(host="0.0.0.0", port=5000)