Pyrowman\PheanstalkBundle\Command\AbstractPheanstalkCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getPheanstalk()	0	17	4
A	__construct()	0	5	1

<?php

namespace Pyrowman\PheanstalkBundle\Command;

use Pyrowman\PheanstalkBundle\PheanstalkLocator;
use Pheanstalk\PheanstalkInterface;
use Symfony\Component\Console\Command\Command;

abstract class AbstractPheanstalkCommand extends Command
{
    /**
     * @var PheanstalkLocator
     */
    protected $locator;

    /**
     * @param PheanstalkLocator $locator
     */
    public function __construct(PheanstalkLocator $locator)
    {
        parent::__construct();

        $this->locator = $locator;
    }

    /**
     * @param string $name
     *
     * @return PheanstalkInterface
     */
    protected function getPheanstalk(&$name = null)
    {
        $pheanstalk = $this->locator->getPheanstalk($name);

        if (null === $name) {
            $name = 'default';
        }

        if (null === $pheanstalk) {
            throw new \RuntimeException('Pheanstalk not found: '.$name);
        }

        if (!$pheanstalk->getConnection()->isServiceListening()) {
            throw new \RuntimeException('Pheanstalk not connected: '.$name);
        }

        return $pheanstalk;
    }
}