Beanie\Server\Pool

Complexity

Total Complexity

9

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	3
A	addServer()	0	5	1
A	getServers()	0	4	1
A	getServer()	0	8	2
A	dispatchCommand()	0	7	1
A	getRandomServer()	0	4	1

<?php


namespace Beanie\Server;


use Beanie\Command\CommandInterface;
use Beanie\Exception\InvalidArgumentException;
use Beanie\Tube\TubeAwareInterface;
use Beanie\Tube\TubeStatus;

class Pool implements TubeAwareInterface
{
    use TubeAwareTrait;

    /** @var Server[] */
    protected $servers = [];

    /**
     * @param Server[] $servers
     * @throws InvalidArgumentException
     */
    public function __construct(array $servers)
    {
        if (!count($servers)) {
            throw new InvalidArgumentException('Pool needs servers');
        }

        foreach ($servers as $server) {
            $this->addServer($server);
        }

        $this->tubeStatus = new TubeStatus();
    }

    /**
     * @param Server $server
     * @return $this
     */
    protected function addServer(Server $server)
    {
        $this->servers[(string) $server] = $server;
        return $this;
    }

    /**
     * @return Server[]
     */
    public function getServers()
    {
        return $this->servers;
    }

    /**
     * @param string $name
     * @return Server
     * @throws InvalidArgumentException
     */
    public function getServer($name)
    {
        if (!isset($this->servers[$name])) {
            throw new InvalidArgumentException('Server not found by name: ' . $name);
        }

        return $this->servers[$name];
    }

    /**
     * @param CommandInterface $command
     * @return \Beanie\Server\ResponseOath
     */
    public function dispatchCommand(CommandInterface $command)
    {
        return $this
            ->getRandomServer()
            ->transformTubeStatusTo($this->tubeStatus, TubeStatus::TRANSFORM_USE)
            ->dispatchCommand($command);
    }

    /**
     * @return Server
     */
    public function getRandomServer()
    {
        return $this->servers[array_rand($this->servers, 1)];
    }
}