participantlist works!

backend/app/views/auth/api.py

@@ -78,7 +78,7 @@ async def read_users_me(
 
 
 @router.get("/anon")
-async def get_qnon_user(
+async def get_anon_user(
     anon_user: Annotated[schemas.AnonUser, Depends(services.get_anon_user)]
 ) -> schemas.AnonUser:
     return anon_user

backend/app/views/queue/services.py

@@ -5,7 +5,7 @@ from uuid import UUID
 import redis
 import asyncio
 
-from ...dependencies import get_db, get_pubsub
+from ...dependencies import get_db, get_pubsub, get_redis
 from ...db import models
 
 from ..auth import services as auth_services
@@ -43,7 +43,6 @@ def get_detailed_queue(
     db: Annotated[Session, Depends(get_db)],
 ) -> schemas.QueueDetail:
     q = db.query(models.Queue).filter(models.Queue.id == queue_id).first()
-    print("\n\n", queue_id, "\n\n", flush=True)
     if q:
         return schemas.QueueDetail(
             id=q.id,
@@ -63,10 +62,11 @@ def get_detailed_queue(
     )
 
 
-def join_queue(
+async def join_queue(
     queue_id: UUID,
     client: Annotated[auth_schemas.AnonUser, Depends(auth_services.get_anon_user)],
     db: Annotated[Session, Depends(get_db)],
+    r: Annotated[redis.client.Redis, Depends(get_redis)],
 ) -> schemas.QueueUser:
     q = get_queue_by_id(queue_id, db)
     if q:
@@ -78,6 +78,7 @@ def join_queue(
             )
             db.add(new_qu)
             db.commit()
+            await r.publish(str(queue_id), "updated")
             return new_qu
         raise HTTPException(
             status_code=status.HTTP_409_CONFLICT,
@@ -96,9 +97,8 @@ async def set_queue_listener(
 ) -> schemas.QueueDetail:
     await ps.subscribe(str(queue_id))
     async for m in ps.listen():
-        print(m, flush=True)
         if m.get("data", None) == b"updated":
-            print("UPDATED", flush=True)
             break
+    await ps.unsubscribe()
     new_queue = get_detailed_queue(queue_id=queue_id, db=db)
     return new_queue