From f84d2237b0a6b2cf9315dde5349d41de73dd7adc Mon Sep 17 00:00:00 2001 From: Ryan Kegel Date: Tue, 9 Dec 2025 16:18:48 -0500 Subject: [PATCH] attempting proxying --- events/sse.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/events/sse.py b/events/sse.py index ea85f60..4eed109 100644 --- a/events/sse.py +++ b/events/sse.py @@ -28,7 +28,7 @@ def get_queue(user_id: str, connection_id: str) -> queue.Queue: def send_to_user(user_id: str, data: Dict[str, Any]): """Send data to all connections for a specific user.""" - logger.info(f"Sending data to {user_id} user quesues are {user_queues}") + logger.info(f"Sending data to {user_id} user quesues are {user_queues.keys()}") if user_id in user_queues: logger.info(f"Queued {user_id}") # Format as SSE message once @@ -61,9 +61,8 @@ def sse_response_for_user(user_id: str): try: while True: # Get message from queue (blocks until available) + logger.info(f"blocking on get for {user_id} user") message = user_queue.get() - logging.info( - f"Sending SSE message to user {user_id} (connection {connection_id}): {message.decode('utf-8').strip()}") yield message except GeneratorExit: # Clean up when client disconnects