Update api.py

api.py

@@ -14,18 +14,13 @@ logger = logging.getLogger(__name__)
 
 app = FastAPI()
 
-# --- ADD THIS NEW TEST ENDPOINT ---
 @app.get("/")
 def health_check():
     return {"status": "ok", "message": "API is running!"}
-# --- END OF NEW TEST ENDPOINT ---
 
-# This block allows your React frontend to make requests to your Python backend.
-# IMPORTANT: When you deploy your React app to a live URL, you must add that URL to this list.
 origins = [
     "http://localhost:3000",
     "http://localhost:3001",
-    # e.g., "https://your-react-app.vercel.app" 
 ]
 
 app.add_middleware(
@@ -38,4 +33,21 @@ app.add_middleware(
 
 counselor = UltraAdvancedHybridCounselor()
 
-class CounselRequest(BaseModel):
+# --- THIS BLOCK WAS CAUSING THE ERROR ---
+# The two lines below must be indented to be inside the class.
+class CounselRequest(BaseModel):
+    query: str
+    session_id: str
+# --- END OF FIX ---
+
+@app.post("/counsel")
+async def counsel(request: CounselRequest):
+    async def stream_gen():
+        try:
+            async for chunk in counselor.get_comprehensive_answer(request.query, request.session_id):
+                yield chunk.encode('utf-8')
+        except Exception as e:
+            logger.error(f"Streaming error: {e}")
+            yield "An error occurred during streaming.".encode('utf-8')
+    
+    return StreamingResponse(stream_gen(), media_type="text/plain")