123
This commit is contained in:
@@ -222,8 +222,13 @@ async def chat(websocket: WebSocket):
|
||||
continue
|
||||
print(f"----------------{message.source}----------------\n {message.content}")
|
||||
if message.type == 'TextMessage' or message.type == 'HandoffMessage' \
|
||||
or message.type == 'ToolCallRequestEvent' or message.type == 'UserInputRequestedEvent':
|
||||
await websocket.send_json(message.model_dump())
|
||||
or message.type == 'UserInputRequestedEvent':
|
||||
if isinstance(message.content, str):
|
||||
await websocket.send_json(message.model_dump())
|
||||
else:
|
||||
_message = message
|
||||
_message.content = str(_message.content)
|
||||
await websocket.send_json(_message.model_dump())
|
||||
if not isinstance(message, UserInputRequestedEvent):
|
||||
history.append(message.model_dump())
|
||||
|
||||
|
||||
Reference in New Issue
Block a user