Dtc\QueueBundle\Redis\Predis

Complexity

Total Complexity

33

Size/Duplication

Total Lines	193
Duplicated Lines	17.1 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

95.65%

Importance

Changes

0

21 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	zCount()	0	4	1
A	zAdd()	0	4	1
A	hGetAll()	0	4	1
A	lRem()	0	4	1
A	lPush()	0	4	1
A	lRange()	0	4	1
A	del()	0	4	1
A	zRem()	0	4	1
A	hIncrBy()	0	4	1
A	set()	10	10	2
A	get()	0	12	2
A	setEx()	9	9	2
A	getOptions()	0	12	3
A	zScan()	7	7	1
A	mGet()	0	4	1
A	getResults()	0	11	3
A	setCursor()	0	6	2
A	hScan()	7	7	1
B	zPop()	0	24	3
B	zPopByMaxScore()	0	24	3

<?php

namespace Dtc\QueueBundle\Redis;

use Predis\Client;
use Predis\Response\Status;
use Predis\Transaction\MultiExec;

class Predis implements RedisInterface
{
    protected $predis;
    protected $maxRetries;

    public function __construct(Client $predis, $maxRetries = 5)
    {
        $this->predis = $predis;
        $this->maxRetries = $maxRetries;
    }

    public function zCount($key, $min, $max)
    {
        return $this->predis->zcount($key, $min, $max);
    }

    public function zAdd($zkey, $score, $value)
    {
        return $this->predis->zadd($zkey, [$value => $score]);
    }

    public function hGetAll($key)
    {
        return $this->predis->hGetAll($key);
    }

    public function hIncrBy($key, $hashKey, $value)
    {
        return $this->predis->hIncrBy($key, $hashKey, $value);
    }

    public function set($key, $value)

This method seems to be duplicated in your project.

    {
        /** @var Status $result */
        $result = $this->predis->set($key, $value);
        if ('OK' == $result->getPayload()) {
            return true;
        }

        return false;
    }

    public function get($key)
    {
        $this->predis->multi();
        $this->predis->exists($key);
        $this->predis->get($key);
        list($exists, $result) = $this->predis->exec();
        if (!$exists) {
            return false;
        }

        return $result;
    }

    public function setEx($key, $seconds, $value)

This method seems to be duplicated in your project.

    {
        $result = $this->predis->setex($key, $seconds, $value);
        if ('OK' == $result->getPayload()) {
            return true;
        }

        return false;
    }

    public function lRem($lKey, $count, $value)
    {
        return $this->predis->lrem($lKey, $count, $value);
    }

    public function lPush($lKey, array $values)
    {
        return $this->predis->lpush($lKey, $values);
    }

    public function lRange($lKey, $start, $stop)
    {
        return $this->predis->lrange($lKey, $start, $stop);
    }

    public function del(array $keys)
    {
        return $this->predis->del($keys);
    }

    public function zRem($zkey, $value)
    {
        return $this->predis->zrem($zkey, $value);
    }

    protected function getOptions($pattern = '', $count = 0)
    {
        $options = [];
        if ('' !== $pattern) {
            $options['MATCH'] = $pattern;
        }
        if (0 !== $count) {
            $options['COUNT'] = $count;
        }

        return $options;
    }

    public function zScan($key, &$cursor, $pattern = '', $count = 0)

This method seems to be duplicated in your project.

    {
        $this->setCursor($cursor);
        $results = $this->predis->zscan($key, $cursor, $this->getOptions($pattern, $count));

        return $this->getResults($results, $cursor);
    }

    public function mGet(array $keys)
    {
        return $this->predis->mget($keys);
    }

    protected function getResults(&$results, &$cursor)
    {
        if (isset($results[0])) {
            $cursor = intval($results[0]);
        }
        if (isset($results[1])) {
            return $results[1];
        }

        return [];
    }

    protected function setCursor(&$cursor)
    {
        if (null === $cursor) {
            $cursor = 0;
        }
    }

    public function hScan($key, &$cursor, $pattern = '', $count = 0)

This method seems to be duplicated in your project.

    {
        $this->setCursor($cursor);
        $results = $this->predis->hscan($key, $cursor, $this->getOptions($pattern, $count));

        return $this->getResults($results, $cursor);
    }

    public function zPop($key)
    {
        $element = null;
        $options = [
            'cas' => true,
            'watch' => $key,
            'retry' => $this->maxRetries,
        ];

        try {
            $this->predis->transaction($options, function (MultiExec $tx) use ($key, &$element) {
                list($element) = $tx->zrange($key, 0, 0);

                if (isset($element)) {
                    $tx->multi();
                    $tx->zrem($key, $element);
                }
            });
        } catch (\Exception $exception) {
            return null;
        }

        return $element;
    }

    public function zPopByMaxScore($key, $max)
    {
        $element = null;
        $options = [
            'cas' => true,
            'watch' => $key,
            'retry' => $this->maxRetries,
        ];

        try {
            $this->predis->transaction($options, function (MultiExec $tx) use ($key, $max, &$element) {
                list($element) = $tx->zrangebyscore($key, 0, $max, ['LIMIT' => [0, 1]]);

                if (isset($element)) {
                    $tx->multi();
                    $tx->zrem($key, $element);
                }
            });
        } catch (\Exception $exception) {
            return null;
        }

        return $element;
    }
}