fix broadcast

This commit is contained in:
arne 2023-01-31 20:13:02 +01:00
parent 6ebf34c4a9
commit 4e1f1b6f20

8
app.py
View File

@ -26,11 +26,11 @@ async def set_variable(project_id,var):
if not vars.get(project_id,''): if not vars.get(project_id,''):
vars[project_id] = {} vars[project_id] = {}
vars[project_id][var.get('name','')] = var.get('value','') vars[project_id][var.get('name','')] = var.get('value','')
await websockets.broadcast(clients.get(project_id,[]),json.dumps(var)) websockets.broadcast(clients.get(project_id,[]),json.dumps(var))
async def disconnect(project_id,user): async def disconnect(project_id,ws):
print("disconnecting",user) print(f"disconnecting {ws.host}:{ws.port}")
clients.get(project_id,[]).pop(user) clients.get(project_id,[]).remove(ws)
async def process(ws, path): async def process(ws, path):