Update main.py

main.py

@@ -1,4 +1,4 @@
-# main.py (Correcting SyntaxError at line 216)
+# main.py (Correcting SyntaxError at line 201)
 import os
 import re
 import logging
@@ -132,7 +132,7 @@ async def get_transcript_via_supadata(video_id: str, api_key: str) -> Optional[s
     if not video_id: logger.error("[Supadata] No video_id provided"); return None
     if not api_key: logger.error("[Supadata] API key missing."); return None
     logger.info(f"[Supadata] Attempting fetch for video ID: {video_id}")
-    api_endpoint = "https://api.supadata.ai/v1/youtube/transcript" # Corrected URL
+    api_endpoint = "https://api.supadata.ai/v1/youtube/transcript"
     params = {"videoId": video_id, "format": "text"}; headers = {"X-API-Key": api_key}
     try:
         async with httpx.AsyncClient(timeout=30.0) as client:
@@ -153,22 +153,22 @@ async def get_transcript_via_supadata(video_id: str, api_key: str) -> Optional[s
             else: logger.error(f"[Supadata] Unexpected status {response.status_code} for {video_id}. Resp: {response.text[:200]}"); return None
     except httpx.TimeoutException: logger.error(f"[Supadata] Timeout connecting for {video_id}"); return None
     except httpx.RequestError as e:
-        if "CERTIFICATE_VERIFY_FAILED" in str(e): logger.error(f"[Supadata] SSL Cert Verify Failed for {video_id}: {e}") # Should be fixed now
+        if "CERTIFICATE_VERIFY_FAILED" in str(e): logger.error(f"[Supadata] SSL Cert Verify Failed for {video_id}: {e}")
         else: logger.error(f"[Supadata] Request error for {video_id}: {e}")
         return None
     except Exception as e: logger.error(f"[Supadata] Unexpected error for {video_id}: {e}", exc_info=True); return None
 
 async def get_transcript_via_apify(video_url: str, api_token: str) -> Optional[str]:
     """Fetches YouTube transcript using Apify REST API (run-sync-get-dataset-items endpoint)."""
-    global APIFY_ACTOR_ID # Should be karamelo~youtube-transcripts
+    global APIFY_ACTOR_ID
     if not video_url: logger.error("[Apify SyncItems] No video_url provided"); return None
     if not api_token: logger.error("[Apify SyncItems] API token missing."); return None
     logger.info(f"[Apify SyncItems] Attempting fetch for URL: {video_url} (Actor: {APIFY_ACTOR_ID})")
 
     sync_items_endpoint = f"https://api.apify.com/v2/acts/{APIFY_ACTOR_ID}/run-sync-get-dataset-items"
-    params = {"token": api_token} # Token in param as per OpenAPI spec for this endpoint
+    params = {"token": api_token}
     payload = { "urls": [video_url], "outputFormat": "singleStringText", "maxRetries": 5, "channelHandleBoolean": False, "channelNameBoolean": False, "datePublishedBoolean": False, "relativeDateTextBoolean": False, }
-    headers = {"Content-Type": "application/json"} # No Auth header needed if token in params
+    headers = {"Content-Type": "application/json"}
 
     try:
         async with httpx.AsyncClient(timeout=120.0) as client:
@@ -198,8 +198,14 @@ async def get_transcript_via_apify(video_url: str, api_token: str) -> Optional[s
             elif response.status_code == 400: logger.error(f"[Apify SyncItems] Bad Request (400) for {video_url}. Check payload. Resp:{response.text[:200]}"); return None
             elif response.status_code == 401: logger.error("[Apify SyncItems] Auth error (401). Check token."); return None
             elif response.status_code == 404:
-                 error_info = ""; try: error_info = response.json().get("error", {}).get("message", "") except Exception: pass
-                 logger.error(f"[Apify SyncItems] Endpoint/Actor Not Found (404). Error: '{error_info}' Resp:{response.text[:200]}"); return None
+                 # *** FIX: Correct indentation for error info extraction ***
+                 error_info = ""
+                 try:
+                     error_info = response.json().get("error", {}).get("message", "")
+                 except Exception:
+                     pass
+                 logger.error(f"[Apify SyncItems] Endpoint/Actor Not Found (404). Error: '{error_info}' Resp:{response.text[:200]}");
+                 return None
             else: logger.error(f"[Apify SyncItems] Unexpected status {response.status_code} for {video_url}. Resp:{response.text[:200]}"); return None
 
     except httpx.TimeoutException as e: logger.error(f"[Apify SyncItems] Timeout during API interaction for {video_url}: {e}"); return None
@@ -326,7 +332,7 @@ async def generate_summary(text: str, summary_type: str) -> str:
             elif response.status_code == 429: logger.warning("OpenRouter Rate Limit Exceeded (429)."); return "Sorry, AI model is busy. Try again."
             elif response.status_code == 500: logger.error(f"OpenRouter Internal Server Error (500). Resp:{response.text[:500]}"); return "Sorry, AI service internal error."
             else:
-                # *** FIX: Corrected Indentation for error info extraction ***
+                # Corrected Indentation for error info extraction
                 error_info = ""
                 try:
                     error_info = response.json().get("error", {}).get("message", "")