Update leads_fetcher.py

leads_fetcher.py

@@ -3,6 +3,7 @@ import os
 import time
 from datetime import datetime, timedelta
 from supabase import create_client
+from token_manager import refresh_snapchat_token  # make sure it's at the top
 
 SUPABASE_URL = os.getenv("SUPABASE_URL")
 SUPABASE_API_KEY = os.getenv("SUPABASE_API_KEY")
@@ -49,21 +50,21 @@ def fetch_leads_and_poll_status():
     if res.status_code == 200:
         report_run_id = res.json()['async_stats_reports'][0]['async_stats_report']['report_run_id']
         print("📤 Report requested. Report ID:", report_run_id)
-
+    
         # Step 2: Poll until report is ready
         status_url = f"{url}?report_run_id={report_run_id}"
         max_attempts = 10
-
+    
         for attempt in range(max_attempts):
             status_res = requests.get(status_url, headers=headers)
-
+    
             if status_res.status_code == 200:
                 try:
                     report = status_res.json()['async_stats_reports'][0]['async_stats_report']
                     status = report.get("async_status")
-
+    
                     print(f"🔄 Attempt {attempt + 1}: Status = {status}")
-
+    
                     if status == "COMPLETED":
                         csv_url = report["result"]
                         print("✅ Report Completed. Download:", csv_url)
@@ -79,5 +80,11 @@ def fetch_leads_and_poll_status():
             else:
                 print("❌ Failed to check report status:", status_res.text)
                 break
+    
     else:
         print("❌ Failed to request report:", res.text)
+    
+        # 🔁 Auto-refresh token if the error is due to expiration
+        if "unauthorized" in res.text.lower() or "access token" in res.text.lower():
+            print("🔁 Access token may be expired. Refreshing token now...")
+            refresh_snapchat_token()