support non-streaming api

Author: leehuwuj

templates/types/streaming/fastapi/app/api/routers/chat.py

@@ -4,8 +4,8 @@
 
 from app.api.callbacks.llamacloud import LlamaCloudFileDownload
 from app.api.callbacks.next_question import SuggestNextQuestions
-from app.api.callbacks.stream_handler import StreamHandler
 from app.api.callbacks.source_nodes import AddNodeUrl
+from app.api.callbacks.stream_handler import StreamHandler
 from app.api.routers.models import (
     ChatData,
 )
@@ -50,8 +50,41 @@ async def chat(
             ],
         ).vercel_stream()
     except Exception as e:
-        logger.exception("Error in chat engine", exc_info=True)
+        logger.exception("Error in chat", exc_info=True)
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail=f"Error in chat: {e}",
+        ) from e
+
+
+# non-streaming endpoint - delete if not needed
+@r.post("/request")
+async def chat_request(
+    request: Request,
+    data: ChatData,
+):
+    try:
+        last_message_content = data.get_last_message_content()
+        messages = data.get_history_messages(include_agent_messages=True)
+
+        doc_ids = data.get_chat_document_ids()
+        filters = generate_filters(doc_ids)
+        params = data.data or {}
+
+        workflow = create_workflow(
+            params=params,
+            filters=filters,
+        )
+
+        handler = workflow.run(
+            user_msg=last_message_content,
+            chat_history=messages,
+            stream=False,
+        )
+        return await handler
+    except Exception as e:
+        logger.exception("Error in chat request", exc_info=True)
         raise HTTPException(
             status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
-            detail=f"Error in chat engine: {e}",
+            detail=f"Error in chat request: {e}",
         ) from e