| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 |
- import json
- import datetime
- import db
- from typing import Dict, List, Any
- from fastapi import WebSocket
- class ChatConnectionManager:
- def __init__(self):
- # order_id -> list of active websockets
- # order_id -> list of dicts: {"ws": websocket, "role": str}
- self.active_connections: Dict[int, List[Dict[str, Any]]] = {}
- async def connect(self, websocket: WebSocket, order_id: int, role: str):
- await websocket.accept()
- if order_id not in self.active_connections:
- self.active_connections[order_id] = []
- self.active_connections[order_id].append({"ws": websocket, "role": role})
- print(f"DEBUG: Chat WS connected for Order #{order_id} (Role: {role}). Total connections: {len(self.active_connections[order_id])}")
- await self.broadcast_presence(order_id)
- def disconnect(self, websocket: WebSocket, order_id: int):
- if order_id in self.active_connections:
- self.active_connections[order_id] = [c for c in self.active_connections[order_id] if c["ws"] != websocket]
- print(f"DEBUG: Chat WS disconnected for Order #{order_id}. Remaining: {len(self.active_connections[order_id])}")
- if not self.active_connections[order_id]:
- del self.active_connections[order_id]
- else:
- import asyncio
- try:
- asyncio.create_task(self.broadcast_presence(order_id))
- except Exception:
- pass
- async def broadcast_presence(self, order_id: int):
- if order_id in self.active_connections:
- roles = [c["role"] for c in self.active_connections[order_id]]
- payload = json.dumps({"type": "presence", "online_roles": list(set(roles))})
- for connection in self.active_connections[order_id]:
- try:
- await connection["ws"].send_text(payload)
- except:
- pass
- async def broadcast_to_order(self, order_id: int, message: Any):
- if order_id in self.active_connections:
- # We must serialize datetime to JSON string
- if isinstance(message, dict) and 'created_at' in message:
- if isinstance(message['created_at'], datetime.datetime):
- message['created_at'] = message['created_at'].isoformat()
-
- if "type" not in message:
- message["type"] = "message"
- payload = json.dumps(message)
- print(f"DEBUG: Broadcasting to Order #{order_id} to {len(self.active_connections[order_id])} receivers")
- for connection in self.active_connections[order_id]:
- try:
- await connection["ws"].send_text(payload)
- except Exception as e:
- print(f"DEBUG: Failed to send WS message to a connection: {e}")
- else:
- print(f"DEBUG: Attempted broadcast to Order #{order_id} but NO active connections found")
- manager = ChatConnectionManager()
|