Bernard\QueueFactory\PersistentFactory

Complexity

Total Complexity

9

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

62.86%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	create()	0	10	2
A	all()	0	7	1
A	exists()	0	4	2
A	count()	0	4	1
A	remove()	0	10	2

<?php

namespace Bernard\QueueFactory;

use Bernard\Driver;
use Bernard\Queue\PersistentQueue;
use Bernard\Serializer;

/**
 * Knows how to create queues and retrieve them from the used driver.
 * Every queue it creates is saved locally.
 */
class PersistentFactory implements \Bernard\QueueFactory
{
    protected $queues;
    protected $driver;
    protected $serializer;

    /**
     * @param Driver     $driver
     * @param Serializer $serializer
     */
    public function __construct(Driver $driver, Serializer $serializer)
    {
        $this->queues = [];
        $this->driver = $driver;
        $this->serializer = $serializer;
    }

    /**
     * {@inheritdoc}
     */
    public function create($queueName)
    {
        if (isset($this->queues[$queueName])) {
            return $this->queues[$queueName];
        }

        $queue = new PersistentQueue($queueName, $this->driver, $this->serializer);

        return $this->queues[$queueName] = $queue;
    }

    /**
     * {@inheritdoc}
     */
    public function all()
    {
        // Calls $this->create on every name returned from the driver
        array_map([$this, 'create'], $this->driver->listQueues());

        return $this->queues;
    }

    /**
     * {@inheritdoc}
     */
    public function exists($queueName)
    {
        return isset($this->queues[$queueName]) ?: in_array($queueName, $this->driver->listQueues());
    }

    /**
     * @return int
     */
    public function count()
    {
        return count($this->driver->listQueues());
    }

    /**
     * {@inheritdoc}
     */
    public function remove($queueName)
    {
        if (!$this->exists($queueName)) {
            return;
        }

        $this->create($queueName)->close();

        unset($this->queues[$queueName]);
    }
}