Beanie\Manager

Complexity

Total Complexity

6

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	stats()	0	7	1
A	peek()	0	7	1
A	tubes()	0	14	2
A	__toString()	0	4	1

<?php


namespace Beanie;


use Beanie\Command\CommandFactory;
use Beanie\Command\CommandInterface;
use Beanie\Job\JobFactory;
use Beanie\Server\Server;
use Beanie\Tube\Tube;

class Manager
{
    /** @var Server */
    protected $server;

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

    /** @var JobFactory */
    protected $jobFactory;

    /**
     * @param Server $server
     */
    public function __construct(Server $server)
    {
        $this->server = $server;
        $this->commandFactory = CommandFactory::instance();
        $this->jobFactory = JobFactory::instance();
    }

    /**
     * @return array
     * @throws Exception\InvalidArgumentException
     */
    public function stats()
    {
        return $this->server
            ->dispatchCommand($this->commandFactory->create(CommandInterface::COMMAND_STATS))
            ->invoke()
            ->getData();
    }

    /**
     * @param int $jobId
     * @return Job\Job|null
     * @throws Exception\InvalidArgumentException
     */
    public function peek($jobId)
    {
        return $this->jobFactory->createFromCommand(
            $this->commandFactory->create(CommandInterface::COMMAND_PEEK, [$jobId]),
            $this->server
        )->invoke();
    }

    /**
     * @return Tube[]
     * @throws Exception\InvalidArgumentException
     */
    public function tubes()
    {
        $tubes = [];

        foreach (
            $this->server->dispatchCommand(
                $this->commandFactory->create(CommandInterface::COMMAND_LIST_TUBES)
            )->invoke()->getData() as $tubeName
        ) {
            $tubes[] = new Tube($tubeName, $this->server);
        }

        return $tubes;
    }

    /**
     * @return string
     */
    public function __toString()
    {
        return (string)$this->server;
    }
}