import redis
import time

CodaR = redis.Redis(host='localhost', port=6379, db=0, password='24068Seriate')
queue_name='IOB'

#-----------------------------------
# Gestione code REDIS
# per sostituzione 1:1 con coda in ram

# Function to add an item to the queue (enqueue)
def enqueue(item):
    CodaR.rpush(queue_name, item)
    print(f"Enqueued: {item}")

# Function to remove an item from the queue (dequeue)
def dequeue():
    item = CodaR.lpop(queue_name)
    if item:
        print(f"Dequeued: {item.decode('utf-8')}")
        return item.decode('utf-8')
    else:
        print("Queue is empty")

# Function to count queue actual lenght in Redis
def rqlen():
    clen = CodaR.llen(queue_name)
    if clen:
        print(f"Queue len: {clen}")
        return clen
    else:
        print("Queue is empty")
        return 0


lung = rqlen()
print ("queue lenght: "+str(lung))

enqueue('prova1')
enqueue('prova2')
enqueue('prova3')

time.sleep(5)

lung = rqlen()
while lung > 0:
    dequeue()
    lung = rqlen()