Bernard\Driver\PhpRedis\Driver

Complexity

Total Complexity

12

Size/Duplication

Total Lines	110
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	listQueues()	0	4	1
A	createQueue()	0	4	1
A	countMessages()	0	4	1
A	pushMessage()	0	4	1
A	popMessage()	0	14	2
A	peekQueue()	0	6	1
A	acknowledgeMessage()	0	3	1
A	removeQueue()	0	5	1
A	info()	0	4	1
A	resolveKey()	0	4	1

<?php

namespace Bernard\Driver\PhpRedis;

use Redis;

/**
 * Implements a Driver for use with https://github.com/nicolasff/phpredis
 *
 * @package Bernard
 */
class Driver implements \Bernard\Driver
{
    const QUEUE_PREFIX = 'queue:';
    
    protected $redis;

    /**
     * @param Redis $redis
     */
    public function __construct(Redis $redis)
    {
        $this->redis = $redis;
    }

    /**
     * {@inheritdoc}
     */
    public function listQueues()
    {
        return $this->redis->sMembers('queues');

The method sMembers does only exist in Redis, but not in Predis\ClientInterface.

    }

    /**
     * {@inheritdoc}
     */
    public function createQueue($queueName)
    {
        $this->redis->sAdd('queues', $queueName);

The method sAdd does only exist in Redis, but not in Predis\ClientInterface.

    }

    /**
     * {@inheritdoc}
     */
    public function countMessages($queueName)
    {
        return $this->redis->lLen(self::QUEUE_PREFIX . $queueName);

The method lLen does only exist in Redis, but not in Predis\ClientInterface.

    }

    /**
     * {@inheritdoc}
     */
    public function pushMessage($queueName, $message)
    {
        $this->redis->rpush($this->resolveKey($queueName), $message);

The method rpush does only exist in Redis, but not in Predis\ClientInterface.

    }

    /**
     * {@inheritdoc}
     */
    public function popMessage($queueName, $duration = 5)
    {
        // When PhpRedis is set up with an Redis::OPT_PREFIX
        // it does set the prefix to the key and to the timeout value something like:
        // "BLPOP" "bernard:queue:my-queue" "bernard:5"
        //
        // To set the resolved key in an array seems fixing this issue. We get:
        // "BLPOP" "bernard:queue:my-queue" "5"
        //
        // see https://github.com/nicolasff/phpredis/issues/158
        list(, $message) = $this->redis->blpop([$this->resolveKey($queueName)], $duration) ?: null;

The method blpop does only exist in Redis, but not in Predis\ClientInterface.

        return [$message, null];
    }

    /**
     * {@inheritdoc}
     */
    public function peekQueue($queueName, $index = 0, $limit = 20)
    {
        $limit += $index - 1;

        return $this->redis->lRange($this->resolveKey($queueName), $index, $limit);

The method lRange does only exist in Redis, but not in Predis\ClientInterface.

    }

    /**
     * {@inheritdoc}
     */
    public function acknowledgeMessage($queueName, $receipt)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function removeQueue($queueName)
    {
        $this->redis->sRem('queues', $queueName);

The method sRem does only exist in Redis, but not in Predis\ClientInterface.

        $this->redis->del($this->resolveKey($queueName));

The method del does only exist in Redis, but not in Predis\ClientInterface.

    }

    /**
     * {@inheritdoc}
     */
    public function info()
    {
        return $this->redis->info();

The method info does only exist in Redis, but not in Predis\ClientInterface.

    }

    /**
     * Transform the queueName into a key.
     *
     * @param string $queueName
     *
     * @return string
     */
    protected function resolveKey($queueName)
    {
        return self::QUEUE_PREFIX . $queueName;
    }
}