Algatux\InfluxDbBundle\Services\ConnectionFactory

Complexity

Total Complexity

7

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	createClient()	0	10	2
B	createConnection()	0	22	5

<?php

namespace Algatux\InfluxDbBundle\Services;

use InfluxDB\Client;
use InfluxDB\Driver\UDP;

/**
 * Create connections as `InfluxDB\Database` instances.
 *
 * This keeps clients on a property to avoid useless instance duplication.
 *
 * @internal
 */
final class ConnectionFactory
{
    /**
     * @var Client[]
     */
    private $clients = [];

    /**
     * @param string $database
     * @param string $host
     * @param int    $httpPort
     * @param int    $udpPort
     * @param string $user
     * @param string $password
     * @param bool   $udp
     *
     * @return \InfluxDB\Database
     */
    public function createConnection(string $database, string $host, int $httpPort, int $udpPort, string $user, string $password, bool $udp = false)
    {
        $protocol = $udp ? 'udp' : 'http';
        // Define the client key to retrieve or create the client instance.
        $clientKey = sprintf('%s.%s.%s', $host, $udpPort, $httpPort);
        if (!empty($user)) {
            $clientKey .= '.'.$user;
        }
        if (!empty($password)) {
            $clientKey .= '.'.$password;
        }
        $clientKey .= '.'.$protocol;

        if (!array_key_exists($clientKey, $this->clients)) {
            $client = $this->createClient($host, $httpPort, $udpPort, $user, $password, $udp);
            $this->clients[$clientKey] = $client;
        } else {
            $client = $this->clients[$clientKey];
        }

        return $client->selectDB($database);
    }

    private function createClient(string $host, int $httpPort, int $udpPort, string $user, string $password, bool $udp = false)
    {
        $client = new Client($host, $httpPort, $user, $password);

        if ($udp) {
            $client->setDriver(new UDP($client->getHost(), $udpPort));
        }

        return $client;
    }
}