radu/py-dj
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: make a copy of websockets before broadcasting

Browse source
This commit is contained in:
Radu C. Martin 2025-04-15 14:11:12 +02:00
parent a1fa762ea8
commit e984e70390
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
main.py
View file

@ -40,7 +40,9 @@ class ConnectionManager:
async def broadcast(self, ws_type: WSConnectionType, message: BaseModel): async def broadcast(self, ws_type: WSConnectionType, message: BaseModel):
broken = set() broken = set()
for ws in self.active_connections[ws_type.value]: conn_list = list(self.active_connections[ws_type.value])
for idx in range(len(conn_list)):
ws = conn_list[idx]
try: try:
await ws.send_json(message.model_dump()) await ws.send_json(message.model_dump())
except Exception: except Exception: