Puzzle\AMQP\Workers\Providers\Pimple

Complexity

Total Complexity

13

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getWorker()	0	12	2
A	computeWorkerServiceKey()	0	7	1
A	listAll()	0	6	1
A	listWithRegexFilter()	0	8	1
A	listWorkers()	0	20	3
A	extractWorkers()	0	7	1
A	formatWorkerName()	0	4	1
A	getMessageProcessors()	0	9	2

<?php

namespace Puzzle\AMQP\Workers\Providers;

use Puzzle\AMQP\Workers\WorkerProvider;
use Puzzle\AMQP\Workers\WorkerContext;

class Pimple implements WorkerProvider
{
    private
        $container;

    public function __construct(\Pimple\Container $container)
    {
        $this->container = $container;
    }

    public function getWorker($workerName)
    {
        $workerContext = null;
        $key = $this->computeWorkerServiceKey($workerName);

        if(isset($this->container[$key]))
        {
            $workerContext = $this->container[$key];
        }

        return $workerContext;
    }

    private function computeWorkerServiceKey($workerName)
    {
        return sprintf(
            'worker.%s',
            $workerName
        );
    }

    public function listAll()
    {
        $workers = $this->extractWorkers();

        return $this->listWorkers($workers);
    }

    public function listWithRegexFilter($workerNamePattern)
    {
        $workers = $this->extractWorkers();
        $workers = new \RegexIterator(new \ArrayIterator($workers), sprintf('~^worker\.%s~', $workerNamePattern));
        $workers = iterator_to_array($workers);

        return $this->listWorkers($workers);
    }

    private function listWorkers(array $extractedWorkers)
    {
        $workers = array();

        foreach($extractedWorkers as $worker)
        {
            $key = $this->formatWorkerName($worker);
            $worker = $this->container[$worker];

            if($worker instanceof WorkerContext)
            {
                $workers[$key] = [
                    'queue' => $worker->getQueueName(),
                    'description' => $worker->getDescription(),
                ];
            }
        }

        return $workers;
    }

    private function extractWorkers()
    {
        $services = new \ArrayIterator($this->container->keys());
        $services = new \RegexIterator($services, '~^worker\..+~');

        return iterator_to_array($services);
    }

    private function formatWorkerName($workerServiceName)
    {
        return str_replace('worker.', '', $workerServiceName);
    }
    
    public function getMessageProcessors()
    {
        if(isset($this->container[self::MESSAGE_PROCESSORS_SERVICE_KEY]))
        {
            return $this->container[self::MESSAGE_PROCESSORS_SERVICE_KEY];
        }
        
        return [];
    }
}