Insolita / circular-queue

src/Storage/PhpRedisStorage.php

<?php
/**
 * Created by solly [01.11.17 14:06]
 */

namespace insolita\cqueue\Storage;

use insolita\cqueue\Contracts\StorageInterface;
use Redis;

class PhpRedisStorage implements StorageInterface
{
    /**
     * @var \Redis
     */
    private $redis;
    
    public function __construct(Redis $client)
    {
        $this->redis = $client;
    }
    
    public function delete($key)
    {
        return $this->redis->del($key);
    }
    
    public function listCount($key): int
    {
        return $this->redis->llen($key) ?? 0;
    }
    
    public function listItems($key): array
    {
        return $this->redis->lrange($key, 0, -1);
    }
    
    public function listPop($key)
    {
        return $this->redis->rpop($key);
    }
    
    public function listPush($key, array $values)
    {
        if (!empty($values)) {
            foreach ($values as $value) {
                $this->redis->lPush($key, $value);
            }
        }
    }
    
    public function zSetCount($key): int
    {
        return $this->redis->zcard($key) ?? 0;
    }
    
    public function zSetItems($key): array
    {
        return $this->redis->zrange($key, 0, -1);
    }
    
    public function zSetExpiredItems($key, $score): array
    {
        return $this->redis->zrevrangebyscore($key, $score, '-inf');

'-inf' of type string is incompatible with the type integer expected by parameter $end of Redis::zRevRangeByScore().

    }
    
    public function zSetPush($key, $score, $identity)
    {
        return $this->redis->zadd($key, $score, $identity);

The call to Redis::zAdd() has too few arguments starting with value1.

    }
    
    public function zSetRem($key, $identity)
    {
        return $this->redis->zrem($key, $identity);
    }
    
    public function zSetExists($key, $identity): bool
    {
        $score = $this->redis->zScore($key, $identity);
        return ($score !== null && $score !== false);
    }
    
    public function moveFromZSetToList($listKey, $zSetKey, $item)
    {
        if ($this->redis->zrem($zSetKey, $item) == 1) {
            $this->redis->lpush($listKey, $item);
        }
        //If key not in set ?
    }
}