Beanie\Producer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes	5
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	put()	0	15	1
A	createJob()	0	9	1
A	useTube()	0	5	1
A	getPool()	0	4	1

<?php


namespace Beanie;


use Beanie\Command\CommandFactory;
use Beanie\Command\CommandInterface;
use Beanie\Command\Response;
use Beanie\Job\Job;
use Beanie\Server\Pool;
use Beanie\Server\TubeAwareTrait;
use Beanie\Tube\TubeAwareInterface;
use Beanie\Tube\TubeStatus;

class Producer implements TubeAwareInterface
{
    use TubeAwareTrait;

    /** @var Pool */
    protected $pool;

    /** @var CommandFactory */
    protected $commandFactory;

    /** @var array */
    protected static $jobStateMap = [
        Response::RESPONSE_INSERTED => Job::STATE_RELEASED,
        Response::RESPONSE_BURIED => Job::STATE_BURIED
    ];

    /**
     * @param Pool $pool
     */
    public function __construct(Pool $pool)
    {
        $this->pool = $pool;
        $this->tubeStatus = new TubeStatus();
        $this->commandFactory = CommandFactory::instance();
    }

    /**
     * @param string $jobData
     * @param int $priority
     * @param int $delay
     * @param int $timeToRun
     * @return Job
     * @throws Exception\InvalidArgumentException
     */
    public function put(
        $jobData,
        $priority = Beanie::DEFAULT_PRIORITY,
        $delay = Beanie::DEFAULT_DELAY,
        $timeToRun = Beanie::DEFAULT_TIME_TO_RUN
    ) {
        return $this->createJob(
            $jobData,
            $this->pool->transformTubeStatusTo($this->tubeStatus)->dispatchCommand(
                $this->commandFactory->create(CommandInterface::COMMAND_PUT, [
                    $jobData, $priority, $delay, $timeToRun
                ])
            )->invoke()
        );
    }

    /**
     * @param string $jobData
     * @param Response $response
     * @return Job
     */
    protected function createJob($jobData, Response $response)
    {
        return new Job(
            $response->getData(),
            $jobData,
            $response->getServer(),
            self::$jobStateMap[$response->getName()]
        );
    }

    /**
     * @param string $tubeName
     * @return $this
     */
    public function useTube($tubeName)
    {
        $this->tubeStatus->setCurrentTube($tubeName);
        return $this;
    }

    /**
     * @return Pool
     */
    public function getPool()
    {
        return $this->pool;
    }
}