updated api routes

backend/api.py

@@ -52,7 +52,7 @@ def _client_config():
         }
     }
 
-@api.get("/oauth/google/start")
+@api.get("api/oauth/google/start")
 def oauth_start():
     # optional CSRF protection
     state = secrets.token_urlsafe(16)
@@ -65,7 +65,7 @@ def oauth_start():
     # You can store `state` server-side if you validate it later
     return RedirectResponse(url=auth_url)
 
-@api.get("/oauth/google/callback")
+@api.get("/api/oauth/google/callback")
 def oauth_callback(request: Request):
     # Exchange code for tokens
     full_url = str(request.url)  # includes ?code=...
@@ -76,57 +76,13 @@ def oauth_callback(request: Request):
     TOKEN_FILE.write_text(creds.to_json())
     return PlainTextResponse("Google Calendar connected. You can close this tab.")
 
-@api.get("/health")
+@api.get("/api/health")
 def health():
     return {"ok": True}
 
-async def _event_stream(thread_id: str, message: str, request: Request):
-    """
-    Common generator for SSE. Emits:
-      - thread: thread_id to persist in the client
-      - token : streamed model text tokens
-      - done  : end-of-stream sentinel
-    """
-    config = {"configurable": {"thread_id": thread_id}}
-
-    # send thread id early so the client can store it immediately
-    yield {"event": "thread", "data": thread_id}
-
-    try:
-        # stream events directly from LangGraph
-        async for ev in lg_app.astream_events(
-            {"messages": [("user", message)]},
-            config=config,
-            version="v2",
-        ):
-            # model token stream
-            if ev["event"] == "on_chat_model_stream":
-                chunk = ev["data"]["chunk"].content
-                # chunk can be a string, None, or (rarely) list of content parts
-                if isinstance(chunk, list):
-                    text = "".join(getattr(p, "text", "") or str(p) for p in chunk)
-                else:
-                    text = chunk or ""
-                if text:
-                    yield {"event": "token", "data": text}
-
-            # (optional) forward tool results:
-            # if ev["event"] == "on_tool_end":
-            #     tool_name = ev["name"]
-            #     tool_out  = ev["data"].get("output")
-            #     yield {"event": "tool", "data": json.dumps({"name": tool_name, "output": tool_out})}
-
-            # stop if client disconnects
-            if await request.is_disconnected():
-                break
-
-    finally:
-        # explicit completion so the client can stop spinners immediately
-        yield {"event": "done", "data": "1"}
-
 # --- GET route for EventSource (matches the React UI I gave you) ---
 # GET
-@api.get("/chat")
+@api.get("/api/chat")
 async def chat_get(
     request: Request,
     message: str = Query(...),
@@ -155,7 +111,7 @@ async def chat_get(
     return EventSourceResponse(stream())
 
 # POST
-@api.post("/chat")
+@api.post("api/chat")
 async def chat_post(request: Request):
     body = await request.json()
     message = body.get("message", "")

backend/app.py

@@ -0,0 +1 @@
+from backend.api import api as app

ui/src/useChat.tsx

@@ -181,7 +181,7 @@ export function useChat() {
       if (typeof window === "undefined") return; // SSR guard
 
       // Start SSE
-      const url = new URL("/chat", window.location.origin);
+      const url = new URL("api/chat", window.location.origin);
       url.searchParams.set("message", text);
       url.searchParams.set("thread_id", thread_id);