|
@@ -82,8 +82,8 @@ async def handle_client(websocket: WebSocket,
|
|
|
result = {"message": "内部错误:" + answer, "type": "message"}
|
|
result = {"message": "内部错误:" + answer, "type": "message"}
|
|
|
else: # 正常输出
|
|
else: # 正常输出
|
|
|
answer = data.get("answer", "")
|
|
answer = data.get("answer", "")
|
|
|
- reference = data.get("reference", "")
|
|
|
|
|
- result = {"message": answer, "type": "message", "reference": reference }
|
|
|
|
|
|
|
+ reference = data.get("reference", {})
|
|
|
|
|
+ result = {"message": answer, "type": "message", "reference": reference}
|
|
|
await websocket.send_json(result)
|
|
await websocket.send_json(result)
|
|
|
except json.JSONDecodeError:
|
|
except json.JSONDecodeError:
|
|
|
print(f"Error decode ragflow response: {text}")
|
|
print(f"Error decode ragflow response: {text}")
|