Update app.py

app.py

@@ -1,10 +1,17 @@
-from fastapi import FastAPI, WebSocket, WebSocketDisconnect, HTTPException
+from fastapi import FastAPI, WebSocket, WebSocketDisconnect
+from websockets import connect as websockets_connect
 from typing import Dict
 app = FastAPI()
 clients: Dict[str, WebSocket] = {}
 @app.get("/clients")
 def get_clients():
     return list(clients.keys())
+@app.get("/send/{name}/{id}/{message}")
+async def sendmsg(name,id,message):
+    async with websockets_connect("ws://localhost:7860"+name) as websocket:
+        await websocket.send(f"{id}:{message}")
+        return await websocket.recv()
+
 @app.websocket("/ws/{client_id}")
 async def websocket_endpoint(websocket: WebSocket, client_id: str):
     await websocket.accept()