| | |
| | | token = DfTokenDao(db).get_token_by_id(token_dict[chat_type]) |
| | | # print(token) |
| | | node_list = [] |
| | | workflow_list = [] |
| | | workflow_dict = {} |
| | | if not token: |
| | | await websocket.send_json({"message": "Invalid token", "type": "error"}) |
| | | |
| | |
| | | node_data["data"]["inputs"] = {} |
| | | # print(node_data) |
| | | node_list.append(node_data) |
| | | if data.get("event") == "node_started" or data.get( |
| | | "event") == "node_finished": # "event": "message_end" |
| | | if data.get("event") == "node_started": |
| | | if "data" not in data or not data["data"]: # 信息过滤 |
| | | logger.error("非法数据--------------------") |
| | | logger.error(data) |
| | |
| | | else: |
| | | message = answer.get("title", "") |
| | | |
| | | result = {"message": message, "type": "system"} |
| | | # continue |
| | | result = {"message": message, "type": "system", "workflow": {"node_data": workflow_list}} |
| | | elif data.get("event") == "node_finished": |
| | | workflow_list.append({ |
| | | "title": data.get("data", {}).get("title", ""), |
| | | "status": data.get("data", {}).get("status", ""), |
| | | "created_at": data.get("data", {}).get("created_at", 0), |
| | | "finished_at": data.get("data", {}).get("finished_at", 0), |
| | | "node_type": data.get("data", {}).get("node_type", 0), |
| | | "elapsed_time": data.get("data", {}).get("elapsed_time", 0), |
| | | "error": data.get("data", {}).get("error", ""), |
| | | }) |
| | | if "data" not in data or not data["data"]: # 信息过滤 |
| | | logger.error("非法数据--------------------") |
| | | logger.error(data) |
| | | continue |
| | | else: # 正常输出 |
| | | answer = data.get("data", "") |
| | | if isinstance(answer, str): |
| | | logger.error("----------------未知数据--------------------") |
| | | logger.error(data) |
| | | continue |
| | | elif isinstance(answer, dict): |
| | | if answer.get("status") == "failed": |
| | | message = answer.get("error", "") |
| | | else: |
| | | message = answer.get("title", "") |
| | | |
| | | result = {"message": message, "type": "system", |
| | | "workflow": {"node_data": workflow_list}} |
| | | elif data.get("event") == "message": # "event": "message_end" |
| | | # 正常输出 |
| | | answer = data.get("answer", "") |
| | | result = {"message": answer, "type": "stream"} |
| | | result = {"message": answer, "type": "stream", "workflow": {"node_data": workflow_list}} |
| | | elif data.get("event") == "error": # "event": "message_end" |
| | | # 正常输出 |
| | | answer = data.get("message", "") |
| | | result = {"message": answer, "type": "system"} |
| | | result = {"message": answer, "type": "system", "workflow": {"node_data": workflow_list}} |
| | | elif data.get("event") == "workflow_finished": |
| | | answer = data.get("data", "") |
| | | if isinstance(answer, str): |
| | |
| | | logger.error("保存dify的会话异常!") |
| | | logger.error(e) |
| | | # await websocket.send_json(result) |
| | | workflow_dict = { |
| | | "node_data": workflow_list, |
| | | "total_tokens": data.get("data", {}).get("total_tokens", 0), |
| | | "created_at": data.get("data", {}).get("created_at", 0), |
| | | "finished_at": data.get("data", {}).get("finished_at", 0), |
| | | "status": data.get("data", {}).get("status", ""), |
| | | "error": data.get("data", {}).get("error", ""), |
| | | "elapsed_time": data.get("data", {}).get("elapsed_time", 0) |
| | | } |
| | | continue |
| | | elif data.get("event") == "message_end": |
| | | result = {"message": "", "type": "close"} |
| | | result = {"message": "", "type": "close","workflow": workflow_dict} |
| | | |
| | | else: |
| | | continue |