Workana\AsyncJobs\WorkerBuilder

Complexity

Total Complexity

9

Size/Duplication

Total Lines	117
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	usingQueue()	0	6	1
A	usingMultipleQueues()	0	6	1
A	usingDriverClass()	0	6	1
A	build()	0	13	1
A	getQueue()	0	19	3
A	getRetryStrategy()	0	7	1

<?php
namespace Workana\AsyncJobs;

use Bernard\Queue\RoundRobinQueue;
use Workana\AsyncJobs\Process\ProcessManager;

/**
 * Worker builder
 *
 * @author Carlos Frutos <charly@workana.com>
 */
class WorkerBuilder
{
    /**
     * @var JobManager
     */
    protected $jm;

    /**
     * Creates a new Worker builder
     *
     * @param JobManager $jm
     */
    public function __construct(JobManager $jm)
    {
        $this->jm = $jm;
    }

    /**
     * @var string[]
     */
    protected $queueNames = [];

    /**
     * Using queue
     *
     * @param string $queueName
     *
     * @return self
     */
    public function usingQueue($queueName)
    {
        $this->queueNames[] = (string) $queueName;

        return $this;
    }

    /**
     * Using multiple queues
     *
     * @param string[] $queueNames
     *
     * @return self
     */
    public function usingMultipleQueues(array $queueNames)
    {
        $this->queueNames = array_merge(array_filter($queueNames), $this->queueNames);

It seems like array_merge(array_filter($queueNames), $this->queueNames) of type array is incompatible with the declared type array<integer,string> of property $queueNames.

        return $this;
    }

    /**
     * Using Driver class
     *
     * @param string $driverClass
     *
     * @return self
     */
    public function usingDriverClass($driverClass)
    {
        $this->driverClass = (string) $driverClass;

The property driverClass does not exist. Did you maybe forget to declare it?

        return $this;
    }

    /**
     * Build worker
     *
     * @return Worker
     */
    public function build()
    {
        $queue = $this->getQueue();
        $retryStrategy = $this->getRetryStrategy();

        return new Worker(
            $queue,
            $this->jm->getRouter(),
            $this->jm->getEventDispatcher(),
            new ProcessManager(),
            $retryStrategy
        );
    }

    /**
     * @return \Bernard\Queue
     */
    protected function getQueue()
    {
        if (!empty($this->queueNames)) {
            $queueNames = $this->queueNames;
        } else {
            $queueNames = $this->jm->getDriver()->listQueues();
        }

        $qtyQueues = count($queueNames);

        if ($qtyQueues === 1) {
            $queue = $this->jm->getQueueFactory()->create(reset($queueNames));
        } else {
            $queueSet = array_map([$this->jm->getQueueFactory(), 'create'], $queueNames);
            $queue = new RoundRobinQueue($queueSet);
        }

        return $queue;
    }

    /**
     * @return Retry\RetryStrategy
     */
    protected function getRetryStrategy()
    {
        $retryStrategy = $this->jm->getContainer()->get($this->jm->getConfiguration()->getRetryStrategyClass());
        $retryStrategy->setJobManager($this->jm);

        return $retryStrategy;
    }
}