Facile\MongoDbBundle\Services\ConnectionFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	createConnection()	0	6	1
A	createClient()	0	4	1
A	getClientForConfiguration()	0	11	2

<?php

declare(strict_types=1);

namespace Facile\MongoDbBundle\Services;

use Facile\MongoDbBundle\Models\ConnectionConfiguration;
use MongoDB\Client;
use MongoDB\Database;

/**
 * Class ConnectionFactory.
 */
final class ConnectionFactory
{
    /** @var ConnectionRegistry */
    private $registry;

    /**
     * ConnectionFactory constructor.
     *
     * @param ConnectionRegistry $registry
     */
    public function __construct(ConnectionRegistry $registry)
    {
        $this->registry = $registry;
    }

    /**
     * @param ConnectionConfiguration $configuration
     * @param string                  $connectionKey
     *
     * @return Database
     */
    public function createConnection(ConnectionConfiguration $configuration, string $connectionKey): Database
    {
        $client = $this->getClientForConfiguration($configuration, $connectionKey);

        return $client->selectDatabase($configuration->getDatabase());
    }

    /**
     * @param ConnectionConfiguration $configuration
     *
     * @return Client
     */
    private function createClient(ConnectionConfiguration $configuration): Client
    {
        return new Client($configuration->getConnectionUri());
    }

    /**
     * @param ConnectionConfiguration $configuration
     * @param string                  $clientKey
     *
     * @return Client
     */
    private function getClientForConfiguration(ConnectionConfiguration $configuration, string $clientKey): Client
    {
        if (!$this->registry->hasClient($clientKey)) {
            $client = $this->createClient($configuration);
            $this->registry->addClient($clientKey, $client);

            return $client;
        }

        return $this->registry->getClient($clientKey);
    }
}