Skip to content

Commit 0219d8f

Browse files
committed
feat: add WebSocket connection manager for real-time match events
1 parent 2d027c8 commit 0219d8f

File tree

1 file changed

+23
-0
lines changed

1 file changed

+23
-0
lines changed
Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
from typing import Dict
2+
from fastapi import WebSocket
3+
4+
class ConnectionManager:
5+
def __init__(self):
6+
self.active_connections: Dict[str, WebSocket] = {}
7+
8+
async def connect(self, user_id: str, websocket: WebSocket):
9+
await websocket.accept()
10+
self.active_connections[user_id] = websocket
11+
12+
def disconnect(self, user_id: str):
13+
self.active_connections.pop(user_id, None)
14+
15+
async def send_event(self, user_id: str, event: str, data: dict):
16+
websocket = self.active_connections.get(user_id)
17+
if websocket:
18+
await websocket.send_json({
19+
"event": event,
20+
"data": data
21+
})
22+
23+
manager = ConnectionManager()

0 commit comments

Comments
 (0)