insolita\cqueue\SimpleCircularQueue

Complexity

Total Complexity

11

Size/Duplication

Total Lines	79
Duplicated Lines	11.39 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getName()	0	3	1
A	purgeQueued()	0	3	1
A	listQueued()	7	7	3
A	countQueued()	0	3	1
A	fill()	0	4	1
A	__construct()	0	10	1
A	queueKey()	0	3	1
A	next()	0	8	2

<?php
/**
 * Created by solly [30.10.17 22:05]
 */

namespace insolita\cqueue;

use function array_map;
use insolita\cqueue\Contracts\EmptyQueueBehaviorInterface;
use insolita\cqueue\Contracts\PayloadConverterInterface;
use insolita\cqueue\Contracts\QueueInterface;
use insolita\cqueue\Contracts\StorageInterface;

class SimpleCircularQueue implements QueueInterface
{
    /**
     * @var string
     */
    protected $name;
    
    /**
     * @var \insolita\cqueue\Contracts\PayloadConverterInterface
     */
    protected $converter;
    
    /**
     * @var \insolita\cqueue\Contracts\EmptyQueueBehaviorInterface
     */
    protected $emptyQueueBehavior;
    
    /**
     * @var \insolita\cqueue\Contracts\StorageInterface
     */
    protected $storage;
    
    public function __construct(
        string $name,
        PayloadConverterInterface $converter,
        EmptyQueueBehaviorInterface $emptyQueueBehavior,
        StorageInterface $redis
    ) {
        $this->name = $name;
        $this->converter = $converter;
        $this->emptyQueueBehavior = $emptyQueueBehavior;
        $this->storage = $redis;
    }
    
    public function getName(): string
    {
        return $this->name;
    }
    
    public function fill(array $data)
    {
        $identities = array_map([$this->converter, 'toIdentity'], $data);
        $this->storage->listPush($this->queueKey(), $identities);
    }
    
    public function purgeQueued()
    {
        $this->storage->delete($this->queueKey());
    }
    
    public function countQueued(): int
    {
        return $this->storage->listCount($this->queueKey());
    }
    
    public function listQueued($converted = false): array

This method seems to be duplicated in your project.

    {
        $list = $this->storage->listItems($this->queueKey());
        if ($converted === false || empty($list)) {
            return $list;
        } else {
            return array_map([$this->converter, 'toPayload'], $list);
        }
    }
    
    public function next()
    {
        $item = $this->storage->listPop($this->queueKey());
        if (!$item) {
            return $this->emptyQueueBehavior->resolve($this);
        } else {
            $this->storage->listPush($this->queueKey(), [$item]);
            return $this->converter->toPayload($item);
        }
    }
    
    protected function queueKey(): string
    {
        return $this->getName() . ':Queue';
    }
}