ryan/chore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

attempting proxying

Browse Source
This commit is contained in:
Ryan Kegel
2025-12-09 16:11:01 -05:00
parent 42d63a78de
commit 69dd52fa55
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
events/sse.py
View File

@@ -28,6 +28,7 @@ def get_queue(user_id: str, connection_id: str) -> queue.Queue:
def send_to_user(user_id: str, data: Dict[str, Any]): def send_to_user(user_id: str, data: Dict[str, Any]):
"""Send data to all connections for a specific user.""" """Send data to all connections for a specific user."""
logger.info(f"Sending data to {user_id}")
if user_id in user_queues: if user_id in user_queues:
# Format as SSE message once # Format as SSE message once
message = f"data: {json.dumps(data)}\n\n".encode('utf-8') message = f"data: {json.dumps(data)}\n\n".encode('utf-8')