Update server.py

server.py

@@ -1,4 +1,4 @@
-
+ #!/usr/bin/env python3
 import os
 import json
 import asyncio
@@ -231,9 +231,16 @@ async def run_processing_loop():
                 unprocessed_movies.append((movie_name, hooks, []))
                 add_log(f"  ⊘ {movie_name} (no ready videos, process all {len(hooks)} segments)")
             else:
-                # Check which segments are already processed
+                # Check which segments are already processed by matching filenames
                 processed_segments = processed_videos[movie_name]
-                unprocessed_hooks = [h for h in hooks if not any(f"segment-{json.loads(open(h).read()).get('segment_number', 1):02d}.mp4" in s for s in processed_segments)]
+                unprocessed_hooks = []
+                for h in hooks:
+                    # Extract segment filename and convert to .mp4 version
+                    segment_filename = h.split('/')[-1]  # e.g., "segment-01.json"
+                    segment_mp4 = segment_filename.replace('.json', '.mp4')  # e.g., "segment-01.mp4"
+                    if segment_mp4 not in processed_segments:
+                        unprocessed_hooks.append(h)
+                
                 if unprocessed_hooks:
                     unprocessed_movies.append((movie_name, unprocessed_hooks, list(processed_segments)))
                     add_log(f"  ⊘ {movie_name} (already has {len(processed_segments)} videos, {len(unprocessed_hooks)} segments remaining)")