Update app.py

app.py

@@ -25,13 +25,12 @@ class StartPayload(BaseModel):
 
 def download_video(anime_id: str, episode: int, quality: str) -> str | None:
     url = f"{HF_AYANO_BASE}/anime/download?id={anime_id}&episode={episode}&quality={quality}"
-    log(f"Fetching link for ep {episode} {quality}")
+    log(f"Fetching link ep {episode} {quality}")
+    headers = {
+        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0 Safari/537.36",
+        "Referer": "https://animepahe.si/"
+    }
     try:
-        headers = {
-    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36",
-    "Referer": "https://animepahe.si/"
-     }
-
         resp = requests.get(url, headers=headers, timeout=20)
         resp.raise_for_status()
         data = resp.json()
@@ -39,10 +38,9 @@ def download_video(anime_id: str, episode: int, quality: str) -> str | None:
             return None
         video_url = data["direct_link"]
     except:
-        log(f"Failed to get link ep {episode} {quality}")
+        log(f"Link failed ep {episode} {quality}")
         return None
 
-    headers = {"User-Agent": "Mozilla/5.0", "Referer": "https://animepahe.si/"}
     tmp_path = tempfile.mktemp(suffix=".mp4")
     log(f"Downloading ep {episode} {quality}")
     try:
@@ -69,7 +67,7 @@ def upload_to_0x0(file_path: str, file_name: str) -> str:
             r = requests.post(UPLOAD_URL, files={"file": (file_name, f)}, timeout=180)
         r.raise_for_status()
         url = r.text.strip()
-        log(f"Uploaded {file_name}: {url}")
+        log(f"Uploaded: {url}")
         return url
     except Exception as e:
         log(f"Upload failed: {e}")
@@ -103,44 +101,35 @@ def blur_video(input_path: str) -> str:
         "-c:v", "libx264", "-preset", "veryfast", "-crf", "23",
         "-c:a", "copy", output
     ]
-    try:
-        subprocess.run(cmd, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
-        return output
-    except Exception as e:
-        log(f"Blur failed: {e}")
-        raise
+    subprocess.run(cmd, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+    return output
 
 def process_anime(anime_id: str, anime_name: str):
-    log(f"Started processing {anime_id} - {anime_name}")
+    log(f"Started {anime_id} - {anime_name}")
     episode = 1
     while True:
-        episode_processed = False
+        processed = False
         for quality in QUALITIES:
             try:
-                local_file = download_video(anime_id, episode, quality)
-                if not local_file:
+                file = download_video(anime_id, episode, quality)
+                if not file:
                     continue
-
                 log(f"Blurring ep {episode} {quality}")
-                blurred_file = blur_video(local_file)
-                os.remove(local_file)
-
-                file_name = get_filename(anime_name, episode, quality)
-                file_url = upload_to_0x0(blurred_file, file_name)
-                os.remove(blurred_file)
-
-                notify_render(anime_id, episode, quality, file_url, file_name, 2)
-                episode_processed = True
-
-            except Exception:
+                blurred = blur_video(file)
+                os.remove(file)
+                name = get_filename(anime_name, episode, quality)
+                url = upload_to_0x0(blurred, name)
+                os.remove(blurred)
+                notify_render(anime_id, episode, quality, url, name, 2)
+                processed = True
+            except:
                 notify_render(anime_id, episode, quality, "", "", 3)
-
-        if not episode_processed:
+        if not processed:
             log("No more episodes")
             notify_render(anime_id, 0, "", "", "", 5)
             break
         episode += 1
-    log("Processing complete")
+    log("Complete")
 
 @app.post("/start")
 def start(payload: StartPayload, bg: BackgroundTasks):