Update subscriptions.py

subscriptions.py

@@ -3,6 +3,16 @@ import psycopg
 from psycopg.rows import dict_row
 from supabase import create_client, Client
 import asyncio
+import json
+from pathlib import Path
+
+ADMINS_PATH = Path("assets/admins.json")
+
+try:
+    ADMIN_EMAIL_MAP = json.loads(ADMINS_PATH.read_text())
+except Exception as e:
+    print(f"Failed to load admins.json: {e}")
+    ADMIN_EMAIL_MAP = {}
 
 conn = None
 conn_lock = asyncio.Lock()
@@ -47,6 +57,34 @@ async def fetch_subscription(jwt: str):
     user = auth_res.user
     email = user.email
 
+    auth_res = supabase.auth.get_user(jwt)
+    if auth_res.user is None:
+        return {"error": "Invalid or expired session"}
+    
+    user = auth_res.user
+    email = user.email.lower()
+    
+    if email in ADMIN_EMAIL_MAP:
+        admin = ADMIN_EMAIL_MAP[email]
+        print(f"[ADMIN OVERRIDE] {email} → forcing plan '{admin['plan_key']}'")
+    
+        subscription_obj = {
+            "subscription_id": admin.get("subscription_id", "admin-override"),
+            "status": admin.get("status", "active"),
+            "current_period_end": None,
+            "price_id": None,
+            "product_name": admin.get("product_name"),
+            "nickname": admin.get("nickname"),
+            "plan_key": admin.get("plan_key"),
+        }
+    
+        return {
+            "email": email,
+            "signed_up": user.created_at.isoformat(),
+            "subscription": [subscription_obj],
+            "plan_key": admin["plan_key"],
+        }
+
     async with conn_lock:
         connection = await get_conn()