Fix 500 errors on status endpoints — catch Supabase column errors gracefully

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: Sai Sridhar

backend/routes/calendar.py

@@ -75,12 +75,15 @@ async def calendar_callback(
 
 @router.get("/status")
 async def calendar_status(current_user: Annotated[dict, Depends(get_current_user)]):
-    supabase = get_supabase()
-    row = supabase.table("user_profiles").select(
-        "gcal_connected"
-    ).eq("id", _uid(current_user)).single().execute()
-    data = row.data or {}
-    return {"connected": bool(data.get("gcal_connected"))}
+    try:
+        supabase = get_supabase()
+        row = supabase.table("user_profiles").select(
+            "gcal_connected"
+        ).eq("id", _uid(current_user)).single().execute()
+        data = row.data or {}
+        return {"connected": bool(data.get("gcal_connected"))}
+    except Exception:
+        return {"connected": False}
 
 
 @router.get("/events")

backend/routes/crm_integrations.py

@@ -34,13 +34,16 @@ class SalesforceSaveBody(BaseModel):
 @router.get("/hubspot/status")
 async def hubspot_status(current_user: Annotated[dict, Depends(get_current_user)]):
     uid = current_user["id"]
-    supabase = get_supabase()
-    row = supabase.table("user_profiles").select("hubspot_connected, hubspot_api_key").eq("id", uid).single().execute()
-    data = row.data or {}
-    return {
-        "connected": bool(data.get("hubspot_connected")),
-        "has_key": bool(data.get("hubspot_api_key")),
-    }
+    try:
+        supabase = get_supabase()
+        row = supabase.table("user_profiles").select("hubspot_connected, hubspot_api_key").eq("id", uid).single().execute()
+        data = row.data or {}
+        return {
+            "connected": bool(data.get("hubspot_connected")),
+            "has_key": bool(data.get("hubspot_api_key")),
+        }
+    except Exception:
+        return {"connected": False, "has_key": False}
 
 
 @router.post("/hubspot/connect")
@@ -94,9 +97,12 @@ async def hubspot_disconnect(current_user: Annotated[dict, Depends(get_current_u
 @router.get("/salesforce/status")
 async def salesforce_status(current_user: Annotated[dict, Depends(get_current_user)]):
     uid = current_user["id"]
-    supabase = get_supabase()
-    row = supabase.table("user_profiles").select("sf_connected, sf_username").eq("id", uid).single().execute()
-    data = row.data or {}
+    try:
+        supabase = get_supabase()
+        row = supabase.table("user_profiles").select("sf_connected, sf_username").eq("id", uid).single().execute()
+        data = row.data or {}
+    except Exception:
+        return {"connected": False, "username": None}
     return {
         "connected": bool(data.get("sf_connected")),
         "username": data.get("sf_username"),

backend/routes/outlook.py

@@ -74,12 +74,15 @@ async def outlook_callback(
 @router.get("/status")
 async def outlook_status(current_user: Annotated[dict, Depends(get_current_user)]):
     """Return Outlook connection status."""
-    supabase = get_supabase()
-    row = supabase.table("user_profiles").select(
-        "ms_connected, ms_email"
-    ).eq("id", _uid(current_user)).single().execute()
-    data = row.data or {}
-    return {"connected": bool(data.get("ms_connected")), "email": data.get("ms_email")}
+    try:
+        supabase = get_supabase()
+        row = supabase.table("user_profiles").select(
+            "ms_connected, ms_email"
+        ).eq("id", _uid(current_user)).single().execute()
+        data = row.data or {}
+        return {"connected": bool(data.get("ms_connected")), "email": data.get("ms_email")}
+    except Exception:
+        return {"connected": False, "email": None}
 
 
 @router.post("/sync")