attempting proxying
This commit is contained in:
@@ -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]):
|
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} 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:
|
if user_id in user_queues:
|
||||||
logger.info(f"Queued {user_id}")
|
logger.info(f"Queued {user_id}")
|
||||||
# Format as SSE message once
|
# Format as SSE message once
|
||||||
@@ -61,9 +61,8 @@ def sse_response_for_user(user_id: str):
|
|||||||
try:
|
try:
|
||||||
while True:
|
while True:
|
||||||
# Get message from queue (blocks until available)
|
# Get message from queue (blocks until available)
|
||||||
|
logger.info(f"blocking on get for {user_id} user")
|
||||||
message = user_queue.get()
|
message = user_queue.get()
|
||||||
logging.info(
|
|
||||||
f"Sending SSE message to user {user_id} (connection {connection_id}): {message.decode('utf-8').strip()}")
|
|
||||||
yield message
|
yield message
|
||||||
except GeneratorExit:
|
except GeneratorExit:
|
||||||
# Clean up when client disconnects
|
# Clean up when client disconnects
|
||||||
|
|||||||
Reference in New Issue
Block a user