| | |
|---|
| | | return websocket.send_json(ret) |
|---|
| | | |
|---|
| | | token = get_bisheng_token(db, current_user.id) |
|---|
| | | service_uri = f"{settings.bisheng_websocket_url}/api/v1/chat/{agent_id}?type=L1&t=&chat_id={chat_id}" |
|---|
| | | service_uri = f"{settings.sgb_websocket_url}/api/v1/chat/{agent_id}?type=L1&t=&chat_id={chat_id}" |
|---|
| | | headers = {'cookie': f"access_token_cookie={token};"} |
|---|
| | | |
|---|
| | | await websocket.accept() |
|---|
| | |
|---|
| | | agent = db.query(AgentModel).filter(AgentModel.id == agent_id).first() |
|---|
| | | if not agent: |
|---|
| | | return ResponseList(code=404, msg="Agent not found") |
|---|
| | | bisheng_service = BishengService(base_url=settings.bisheng_base_url) |
|---|
| | | bisheng_service = BishengService(base_url=settings.sgb_base_url) |
|---|
| | | try: |
|---|
| | | token = get_bisheng_token(db, current_user.id) |
|---|
| | | result = await bisheng_service.variable_list(token, agent_id) |
|---|
