|
|
@@ -56,6 +56,11 @@ async def handle_client(websocket: WebSocket,
|
|
|
await websocket.send_json(result)
|
|
|
await websocket.close()
|
|
|
return
|
|
|
+ else:
|
|
|
+ chat_history.append({
|
|
|
+ "content": message["message"],
|
|
|
+ "role": "user"
|
|
|
+ })
|
|
|
async for rag_response in ragflow_service.chat(token, chat_id, chat_history):
|
|
|
try:
|
|
|
print(f"Received from ragflow: {rag_response}")
|