diff --git a/bot/models/redis/__init__.py b/bot/models/redis/__init__.py index 1cec5e2..5782628 100644 --- a/bot/models/redis/__init__.py +++ b/bot/models/redis/__init__.py @@ -1,19 +1,19 @@ from bot import r + # ------------------------------------------------------------------------ -def add_to_queue(usuario_id, url, fecha): - usuario_info = {'url': url, 'fecha': fecha} - r.hset(cola, usuario_id, usuario_info) +def add_to_queue(group_id, from_user, date): + values = {"from_user": from_user, "date": date} + hset = r.hset("queues", group_id, values) + return hset + def next_in_queue(): - proximo_usuario = r.hgetall(cola).popitem() - - usuario_id = proximo_usuario[0] - usuario_info = proximo_usuario[1] - - print(f"Usuario ID: {usuario_id}") - print(f"URL: {usuario_info[b'url'].decode()}") - print(f"Fecha: {usuario_info[b'fecha'].decode()}") - - r.hdel(cola, usuario_id) -# ------------------------------------------------------------------------ \ No newline at end of file + queue = r.hgetall("queues").popitem() + group_id = queue[0] + value = queue[1] + hdel = r.hdel("queues", group_id) + return hdel + + +# ------------------------------------------------------------------------