updated g-cal

backend/agent.py

@@ -274,21 +274,26 @@ class Attendee(TypedDict):
 @tool("schedule_meeting")
 def schedule_meeting(
     title: str,
-    start_rfc3339: str,   # e.g., "2025-08-13T10:00:00-05:00"
-    end_rfc3339: str,     # e.g., "2025-08-13T10:30:00-05:00"
-    attendees: Optional[List[Attendee]] = None, # [{"email":"[email protected]"}, ...]
-    description: Optional[str] = None,
-    location: Optional[str] = None,
+    start_rfc3339: str,
+    end_rfc3339: str,
+    attendees: list[dict] | None = None,
+    description: str | None = None,
+    location: str | None = None,
     calendar_id: str = "primary",
     make_meet_link: bool = True,
+    send_updates: str = "all",   # "all" | "externalOnly" | "none"
 ) -> str:
     """
     Create a Google Calendar event (and optional Google Meet link).
     Returns a human-readable confirmation.
     """
     try:
-        tool_log.info(f"schedule_meeting args title={title} start={start_rfc3339} end={end_rfc3339} attendees={[a.get('email') for a in (attendees or [])]}")
         svc = get_gcal_service()
+        tool_log.info(
+            "schedule_meeting args title=%s start=%s end=%s attendees=%s",
+            title, start_rfc3339, end_rfc3339,
+            [a.get("email") for a in (attendees or [])],
+        )
 
         body = {
             "summary": title,
@@ -296,29 +301,45 @@ def schedule_meeting(
             "location": location or "",
             "start": {"dateTime": start_rfc3339},
             "end": {"dateTime": end_rfc3339},
-            "attendees": [{"email": a["email"], "optional": a.get("optional", False)} for a in (attendees or [])],
+            "attendees": [{"email": a["email"], "optional": bool(a.get("optional", False))}
+                          for a in (attendees or [])],
         }
+        params = {"calendarId": calendar_id, "sendUpdates": send_updates}
 
-        params = {}
         if make_meet_link:
-            body["conferenceData"] = {
-                "createRequest": {"requestId": str(uuid4())}
-            }
+            body["conferenceData"] = {"createRequest": {"requestId": str(uuid4())}}
             params["conferenceDataVersion"] = 1
 
-        event = svc.events().insert(calendarId=calendar_id, body=body, **params).execute()
-        tool_log.info(f"✅ created event id={event.get('id')} html={event.get('htmlLink')}")
-        meet = (
-            (event.get("conferenceData") or {})
-            .get("entryPoints", [{}])[0]
-            .get("uri")
-            if make_meet_link
-            else None
+        ev = svc.events().insert(**params, body=body).execute()
+        eid = ev.get("id")
+        hlink = ev.get("htmlLink")
+        tool_log.info("✅ event created id=%s link=%s", eid, hlink)
+
+        # Extract meet url if present
+        meet_url = None
+        conf = ev.get("conferenceData") or {}
+        for ep in conf.get("entryPoints", []):
+            if ep.get("entryPointType") == "video":
+                meet_url = ep.get("uri"); break
+
+        if not eid:
+            return "Calendar error: event creation returned no id."
+
+        attendees_str = ", ".join([a["email"] for a in (attendees or [])]) or "—"
+        when = f'{ev["start"].get("dateTime") or ev["start"].get("date")} → {ev["end"].get("dateTime") or ev["end"].get("date")}'
+        return (
+            f"✅ Scheduled: {title}\n"
+            f"📅 When: {when}\n"
+            f"👥 With: {attendees_str}\n"
+            f"🔗 Meet: {meet_url or '—'}\n"
+            f"🗂️ Calendar: {calendar_id}\n"
+            f"🔎 View: {hlink or '—'}\n"
+            f"🆔 Event ID: {eid}"
         )
-
-        attendee_str = ", ".join([a["email"] for a in (attendees or [])]) or "no attendees"
-        when = f'{event["start"]["dateTime"]} → {event["end"]["dateTime"]}'
-        return f"✅ Scheduled: {title}\n📅 When: {when}\n👥 With: {attendee_str}\n🔗 Meet: {meet or '—'}\n🗂️ Calendar: {calendar_id}\n🆔 Event ID: {event.get('id','')}"
+    except RuntimeError:
+        base = os.getenv("PUBLIC_BASE_URL", "").rstrip("/")
+        connect = f"{base}/oauth/google/start" if base else "/oauth/google/start"
+        return f"Google Calendar is not connected.\n→ Connect here: {connect}\nThen try again."
     except Exception as e:
         tool_log.exception("❌ schedule_meeting failed")
         return f"Calendar error: {e}"

backend/api.py

@@ -80,6 +80,28 @@ def debug_oauth():
         "base_url_effective": BASE_URL,
         "redirect_uri_built": REDIRECT_URI,
     }
+    # backend/api.py
+@api.get("/api/debug/google/scopes")
+def debug_google_scopes():
+    try:
+        from google.oauth2.credentials import Credentials
+        from .g_cal import TOKEN_FILE
+        creds = Credentials.from_authorized_user_file(str(TOKEN_FILE))
+        return {"ok": True, "scopes": list(creds.scopes or [])}
+    except Exception as e:
+        return JSONResponse({"ok": False, "error": str(e)}, status_code=500)
+
+# backend/api.py
+@api.post("/api/debug/google/reset")
+def google_reset():
+    from .g_cal import TOKEN_FILE
+    try:
+        if TOKEN_FILE.exists():
+            TOKEN_FILE.unlink()
+        return {"ok": True, "message": "Token cleared. Reconnect at /oauth/google/start"}
+    except Exception as e:
+        return JSONResponse({"ok": False, "error": str(e)}, status_code=500)
+
 
 @api.get("/debug/env")
 def debug_env():
@@ -158,16 +180,30 @@ def resume_download():
         filename="Krishna_Vamsi_Dhulipalla_Resume.pdf",
     )
     
-@api.get("/health/google")
+@api.get("/api/health/google")
 def google_health():
+    """
+    Minimal write+delete probe using only calendar.events:
+      - create a 1-minute event 5 minutes in the future (sendUpdates='none')
+      - delete it immediately
+    """
     try:
         svc = get_gcal_service()
-        data = svc.calendarList().list(maxResults=1).execute()
-        names = [item.get("summary") for item in data.get("items", [])]
-        log.info(f"🟢 Google token OK; calendars={names}")
-        return {"ok": True, "calendars": names}
+        now = datetime.now(timezone.utc)
+        start = (now + timedelta(minutes=5)).isoformat(timespec="seconds")
+        end   = (now + timedelta(minutes=6)).isoformat(timespec="seconds")
+        body = {"summary": "HF Health Probe",
+                "start": {"dateTime": start},
+                "end":   {"dateTime": end}}
+        ev = svc.events().insert(
+            calendarId="primary", body=body, sendUpdates="none"
+        ).execute()
+        eid = ev.get("id", "")
+        # clean up
+        if eid:
+            svc.events().delete(calendarId="primary", eventId=eid, sendUpdates="none").execute()
+        return {"ok": True, "probe": "insert+delete", "event_id": eid}
     except Exception as e:
-        log.exception("🔴 Google Calendar health failed")
         return JSONResponse({"ok": False, "error": str(e)}, status_code=500)
     
 @api.get("/oauth/google/start")