Add queue debug

Author: jq1836

matching-service/app/logic/matching.py

@@ -16,19 +16,28 @@ async def find_match_else_enqueue(
     if not islocked:
         raise Exception("Could not acquire lock")
 
+    queue = await redis_client.lrange(queue_key, 0, -1)
+    _print_queue_state(topic, difficulty, queue, True)
+
     # Check if the user is already in the queue
-    if user_id in await redis_client.lrange(queue_key, 0, -1):
+    if user_id in queue:
         await release_lock(redis_client, queue_key)
         return Response(status_code=304)
 
     # Check if there are no other users in the queue
     if await redis_client.llen(queue_key) == 0:
         await redis_client.lpush(queue_key, user_id)
+        print(f"QUEUE:    Added {user_id} to queue")
+        queue = await redis_client.lrange(queue_key, 0, -1)
+        _print_queue_state(topic, difficulty, queue, False)
         await release_lock(redis_client, queue_key)
         return Response(status_code=202)
 
     # There is a user in the queue
     matched_user = await redis_client.rpop(queue_key)
+    print(f"QUEUE:    Match found for {user_id} and {matched_user}")
+    queue = await redis_client.lrange(queue_key, 0, -1)
+    _print_queue_state(topic, difficulty, queue, False)
     await release_lock(redis_client, queue_key)
     response = MatchModel(
         user1=matched_user,
@@ -51,8 +60,14 @@ async def remove_user_from_queue(
     if not islocked:
         raise Exception("Could not acquire lock")
 
-    if user_id in await redis_client.lrange(queue_key, 0, -1):
+    queue = await redis_client.lrange(queue_key, 0, -1)
+    _print_queue_state(topic, difficulty, queue, True)
+
+    if user_id in queue:
         await redis_client.lrem(queue_key, 0, user_id)
+        print(f"QUEUE:    Removed {user_id} from queue")
+        queue = await redis_client.lrange(queue_key, 0, -1)
+        _print_queue_state(topic, difficulty, queue, False)
 
     await release_lock(redis_client, queue_key)
     await manager.disconnect_all(user_id, topic, difficulty)
@@ -64,3 +79,9 @@ async def remove_user_from_queue(
 # Builds a queue key based on topic and difficulty
 def _build_queue_key(topic: str, difficulty: str):
     return f"{topic}:{difficulty}"
+
+def _print_queue_state(topic, difficulty, queue, before: bool):
+    if before:
+        print(f"QUEUE:    Before Queue for {(topic, difficulty)}: ", queue)
+    else:
+        print(f"QUEUE:    After Queue for {(topic, difficulty)}: ", queue)