mirrors/lnbits-legend
1
0
Fork 0
mirror of https://github.com/lnbits/lnbits-legend.git synced 2025-02-24 06:48:02 +01:00
Code Issues Projects Releases Packages Wiki Activity

Removed returns and reverted socket check so multiple clients can join

Browse source
This commit is contained in:
ben 2022-11-29 11:09:54 +00:00
parent 187d709098
commit 31d9f2e2ee
1 changed files with 2 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lnbits/core/services.py
View file

@ -387,24 +387,19 @@ def fee_reserve(amount_msat: int) -> int:
class WebsocketConnectionManager: class WebsocketConnectionManager:
def __init__(self): def __init__(self):
self.active_connections: List[WebSocket] = [] self.active_connections: List[WebSocket] = []
return
async def connect(self, websocket: WebSocket, item_id: str): async def connect(self, websocket: WebSocket, item_id: str):
await websocket.accept() await websocket.accept()
if item_id not in self.active_connections:
websocket.id = item_id websocket.id = item_id
self.active_connections.append(websocket) self.active_connections.append(websocket)
return
def disconnect(self, websocket: WebSocket): def disconnect(self, websocket: WebSocket):
self.active_connections.remove(websocket) self.active_connections.remove(websocket)
return
async def send_data(self, message: str, item_id: str): async def send_data(self, message: str, item_id: str):
for connection in self.active_connections: for connection in self.active_connections:
if connection.id == item_id: if connection.id == item_id:
await connection.send_text(message) await connection.send_text(message)
return
websocketManager = WebsocketConnectionManager() websocketManager = WebsocketConnectionManager()