Facile\MongoDbBundle\Services\ClientRegistry

Complexity

Total Complexity

6

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	addClientConfiguration()	0	4	1
A	getClient()	0	12	3
A	getClientForDatabase()	0	4	1

<?php

declare(strict_types=1);

namespace Facile\MongoDbBundle\Services;

use Facile\MongoDbBundle\Capsule\Client;
use Facile\MongoDbBundle\Models\ClientConfiguration;

/**
 * Class ClientRegistry.
 */
class ClientRegistry
{
    /** @var Client[] */
    private $clients;
    /** @var ClientConfiguration[] */
    private $configurations;
    /** @var ClientUriBuilder */
    private $uriBuilder;

    /**
     * ClientRegistry constructor.
     *
     * @param ClientUriBuilder $uriBuilder
     */
    public function __construct(ClientUriBuilder $uriBuilder)
    {
        $this->clients = [];
        $this->configurations = [];
        $this->uriBuilder = $uriBuilder;
    }

    /**
     * @param string $name
     * @param array  $conf
     */
    public function addClientConfiguration(string $name, array $conf)
    {
        $this->configurations[$name] = new ClientConfiguration($conf['host'], $conf['port'], $conf['username'], $conf['password']);
    }

    /**
     * @param string $name
     * @param string $databaseName
     *
     * @return Client
     */
    public function getClient(string $name, string $databaseName = null): Client
    {
        $clientKey = !is_null($databaseName) ? $name.'.'.$databaseName : $name;

        if (!isset($this->clients[$clientKey])) {
            $conf = $this->configurations[$name];
            $uri = $this->uriBuilder->buildUriForConfiguration($conf, $databaseName);
            $this->clients[$clientKey] = new Client($uri, $conf->getCredentialsArray());
        }

        return $this->clients[$clientKey];
    }

    /**
     * @param string $name
     * @param string $databaseName
     *
     * @return Client
     */
    public function getClientForDatabase(string $name, string $databaseName): Client
    {
        return $this->getClient($name, $databaseName);
    }
}