Metfan\RabbitSetup\Http\ClientPool

Complexity

Total Complexity

10

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	2
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	setConnections()	0	6	1
A	overrideUser()	0	6	1
A	overridePassword()	0	6	1
A	getClientByName()	0	8	2
A	createClient()	0	16	4

<?php
namespace Metfan\RabbitSetup\Http;

use Metfan\RabbitSetup\Factory\CurlClientFactory;

/**
 * Pool of HttpClient by connection.
 * Lazy createclient on demand
 *
 * @author Ulrich
 * @package Metfan\RabbitSetup\Http
 */
class ClientPool
{
    /**
     * @var CurlClientFactory
     */
    private $factory;

    /**
     * @var array
     */
    private $pool = array();

    /**
     * @var array
     */
    private $connections;

    private $user;

    private $password;

    public function __construct(CurlClientFactory $factory)
    {
        $this->factory = $factory;
        $this->connections = [];
    }

    /**
     * @param array $connections
     * @return $this
     *
     */
    public function setConnections(array $connections)
    {
        $this->connections = $connections;

        return $this;
    }

    /**
     * @param mixed $user
     * @return $this
     */
    public function overrideUser($user)
    {
        $this->user = $user;

        return $this;
    }

    /**
     * @param mixed $password
     * @return $this
     */
    public function overridePassword($password)
    {
        $this->password = $password;

        return $this;
    }

    /**
     * Return a Client by his name
     *
     * @param $name
     * @return ClientInterface
     */
    public function getClientByName($name)
    {
        if (!array_key_exists($name, $this->pool)) {
            $this->createClient($name);
        }

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

    /**
     * create a client
     *
     * @param $name
     */
    private function createClient($name)
    {
        if (!array_key_exists($name, $this->connections)) {
            throw new \OutOfRangeException(sprintf('Expected connection %s doesn\'t exists', $name));
        }

        if (null !== $this->user) {
            $this->connections[$name]['user'] = $this->user;
        }

        if (null !== $this->password) {
            $this->connections[$name]['password'] = $this->password;
        }

        $this->pool[$name] = $this->factory->createClient($this->connections[$name]);
    }
}