Update app.py

app.py

@@ -29,6 +29,7 @@ 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 ep {episode} {quality}")
     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/"
@@ -40,21 +41,27 @@ def download_video(anime_id: str, episode: int, quality: str) -> str | None:
         if data.get("status") == 422:
             raise EpisodeExceedsAvailableCount()
         if data.get("status") != 200:
+            log(f"No link available ep {episode} {quality}")
             return None
         video_url = data["direct_link"]
+        log(f"Got direct link ep {episode} {quality}")
     except EpisodeExceedsAvailableCount:
         raise
-    except:
+    except Exception as e:
+        log(f"Link error ep {episode} {quality}: {e}")
         return None
 
     tmp_path = tempfile.mktemp(suffix=".mp4")
+    log(f"Downloading ep {episode} {quality}")
     try:
         with requests.get(video_url, headers=headers, stream=True, timeout=120) as r:
             r.raise_for_status()
             with open(tmp_path, "wb") as f:
                 shutil.copyfileobj(r.raw, f)
+        log(f"Downloaded ep {episode} {quality}")
         return tmp_path
-    except:
+    except Exception as e:
+        log(f"Download failed ep {episode} {quality}: {e}")
         if os.path.exists(tmp_path):
             os.remove(tmp_path)
         return None
@@ -64,13 +71,16 @@ def get_filename(anime_name: str, ep: int, quality: str) -> str:
     return f"nt-animes_{slug}_ep{ep}_{quality}.mp4"
 
 def upload_to_0x0(file_path: str, file_name: str) -> str:
+    log(f"Uploading {file_name}")
     try:
         with open(file_path, "rb") as f:
             r = requests.post(UPLOAD_URL, files={"file": (file_name, f)}, timeout=180)
         r.raise_for_status()
-        return r.text.strip()
+        url = r.text.strip()
+        log(f"Uploaded {file_name}: {url}")
+        return url
     except Exception as e:
-        log(f"[ERROR] Upload failed: {e}")
+        log(f"Upload failed: {e}")
         raise
 
 def notify_render(anime_id: str, episode: int, quality: str, file_url: str, file_name: str, status: int):
@@ -82,10 +92,11 @@ def notify_render(anime_id: str, episode: int, quality: str, file_url: str, file
         "file_name": file_name,
         "status": status
     }
+    log(f"Notifying Render status={status} ep={episode} {quality}")
     try:
         requests.post(RENDER_UPDATE_ENDPOINT, json=payload, timeout=20)
     except Exception as e:
-        log(f"[ERROR] Notify failed: {e}")
+        log(f"Notify failed: {e}")
 
 def blur_video(input_path: str) -> str:
     output = tempfile.mktemp(suffix="_blurred.mp4")
@@ -100,11 +111,17 @@ def blur_video(input_path: str) -> str:
         "-c:v", "libx264", "-preset", "fast", "-crf", "23",
         "-c:a", "copy", output
     ]
-    subprocess.run(cmd, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
-    return output
+    log("Blurring video")
+    try:
+        subprocess.run(cmd, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+        log("Blur complete")
+        return output
+    except Exception as e:
+        log(f"Blur failed: {e}")
+        raise
 
 def process_anime(anime_id: str, anime_name: str):
-    log(f"Started {anime_id} - {anime_name}")
+    log(f"Started processing {anime_id} - {anime_name}")
     episode = 1
     while True:
         processed = False
@@ -121,15 +138,18 @@ def process_anime(anime_id: str, anime_name: str):
                 notify_render(anime_id, episode, quality, file_url, file_name, 2)
                 processed = True
             except EpisodeExceedsAvailableCount:
+                log("All episodes processed")
                 notify_render(anime_id, 0, "", "", "", 5)
                 return
-            except:
+            except Exception as e:
+                log(f"Error ep {episode} {quality}: {e}")
                 notify_render(anime_id, episode, quality, "", "", 3)
         if not processed:
+            log("No more episodes")
             notify_render(anime_id, 0, "", "", "", 5)
             break
         episode += 1
-    log("Complete")
+    log("Processing finished")
 
 @app.post("/start")
 def start(payload: StartPayload, bg: BackgroundTasks):