Unverified Commit 0f5e168c authored by Dan Jones's avatar Dan Jones
Browse files

fix: return list of queues with properties

Plus properly implement auth handler
parent f0a6a868
......@@ -6,16 +6,27 @@ from rmq import get_queue_status
class QueueList(AuthResource):
def __init__(self):
super().__init__()
self.clients_file = ClientModel()
def get(self):
allow = self.auth(request)
if allow:
return {
queue_status = {
client_id: {
"inbox": get_queue_status(f"{client_id}-inbox")["size"],
"outbox": get_queue_status(f"{client_id}-outbox")["size"],
"broadcast": get_queue_status(f"{client_id}-broadcast")["size"],
"inbox": get_queue_status(f"{client_id}-inbox"),
"outbox": get_queue_status(f"{client_id}-outbox"),
"broadcast": get_queue_status(f"{client_id}-broadcast"),
}
for client_id in self.clients_file.get().keys()
}
return [
{
"client_id": client_id,
"queue": f"{client_id}-{queue_type}",
"type": queue_type,
"properties": queue_size,
}
for client_id, client_queues in queue_status.items()
for queue_type, queue_size in client_queues.items()
]
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment