Update token_manager.py

token_manager.py

@@ -1,28 +1,39 @@
 import requests
-import json, os
+import os
 from datetime import datetime
+from supabase import create_client
+
+SUPABASE_URL = os.getenv("SUPABASE_URL")
+SUPABASE_API_KEY = os.getenv("SUPABASE_API_KEY")
+supabase = create_client(SUPABASE_URL, SUPABASE_API_KEY)
 
 def refresh_snapchat_token():
-    with open("tokens.json", "r") as f:
-        tokens = json.load(f)
+    # Get latest token from Supabase
+    result = supabase.table("snapchat_tokens").select("*").order("refreshed_at", desc=True).limit(1).execute()
+    if not result.data:
+        print("❌ No tokens found in Supabase")
+        return
+
+    latest = result.data[0]
 
     data = {
         "grant_type": "refresh_token",
-        "refresh_token": tokens["refresh_token"],
+        "refresh_token": latest["refresh_token"],
         "client_id": os.getenv("CLIENT_ID"),
         "client_secret": os.getenv("CLIENT_SECRET")
     }
 
     headers = {"Content-Type": "application/x-www-form-urlencoded"}
     url = "https://accounts.snapchat.com/login/oauth2/access_token"
-
     response = requests.post(url, headers=headers, data=data)
     res_data = response.json()
 
     if "access_token" in res_data:
-        res_data["refreshed_at"] = datetime.now().isoformat()
-        with open("tokens.json", "w") as f:
-            json.dump(res_data, f, indent=2)
-        print(f"✅ Token refreshed at {res_data['refreshed_at']}")
+        supabase.table("snapchat_tokens").insert({
+            "access_token": res_data["access_token"],
+            "refresh_token": res_data["refresh_token"],
+            "refreshed_at": datetime.utcnow().isoformat()
+        }).execute()
+        print(f"✅ Token refreshed and saved at {datetime.utcnow().isoformat()}")
     else:
         print("❌ Failed to refresh token:", res_data)