Mkk\GearmanBundle\Service\Abstracts\AbstractGearmanService

Complexity

Total Complexity

11

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

57.14%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
B	getJob()	0	22	5
A	getWorker()	0	11	3
A	getWorkers()	0	4	1

<?php

/**
 * Gearman Bundle for Symfony2 / Symfony3
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * Feel free to edit as you please, and have fun.
 *
 * @author Marc Morera <yuhu@mmoreram.com>
 */

namespace Mkk\GearmanBundle\Service\Abstracts;

use Mkk\GearmanBundle\Exceptions\JobDoesNotExistException;
use Mkk\GearmanBundle\Exceptions\WorkerDoesNotExistException;
use Mkk\GearmanBundle\Service\GearmanCacheWrapper;

/**
 * Gearman execute methods. All Worker methods
 *
 * @author Marc Morera <yuhu@mmoreram.com>
 */
abstract class AbstractGearmanService
{
    /**
     * All workers
     *
     * @var array
     */
    protected $workers;

    /**
     * The prefix for all job names
     *
     * @var string $jobPrefix
     */
    protected $jobPrefix = null;

    /**
     * Construct method
     *
     * @param GearmanCacheWrapper $gearmanCacheWrapper GearmanCacheWrapper
     * @param array               $defaultSettings     The default settings for the bundle
     */
    public function __construct(GearmanCacheWrapper $gearmanCacheWrapper, array $defaultSettings)
    {
        $this->workers = $gearmanCacheWrapper->getWorkers();

        if (isset($defaultSettings['job_prefix'])) {

            $this->jobPrefix = $defaultSettings['job_prefix'];
        }
    }

    /**
     * Return worker containing a job with $jobName as name
     * If is not found, throws JobDoesNotExistException Exception
     *
     * @param string $jobName Name of job
     *
     * @return array
     *
     * @throws JobDoesNotExistException
     */
    public function getJob($jobName)
    {
        $jobName = $this->jobPrefix . $jobName;

Consider using a different name than the parameter $jobName. This often makes code more readable.

        foreach ($this->workers as $worker) {

            if (is_array($worker['jobs'])) {

                foreach ($worker['jobs'] as $job) {

                    if ($jobName === $job['realCallableName']) {

                        $worker['job'] = $job;

                        return $worker;
                    }
                }
            }
        }

        throw new JobDoesNotExistException();
    }

    /**
     * Return worker with $workerName as name and all its jobs
     * If is not found, throws WorkerDoesNotExistException Exception
     *
     * @param string $workerName Name of worker
     *
     * @return array
     *
     * @throws WorkerDoesNotExistException
     */
    public function getWorker($workerName)
    {
        foreach ($this->workers as $worker) {

            if ($workerName === $worker['callableName']) {
                return $worker;
            }
        }

        throw new WorkerDoesNotExistException();
    }

    /**
     * Return array of workers
     *
     * @return array all available workers
     */
    public function getWorkers()
    {
        return $this->workers;
    }
}

As per coding style, files should not end with a newline character.