Igni\Storage\Driver\ConnectionManager

Complexity

Total Complexity

11

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Test Coverage

Coverage

76%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	hasDefaultConnection()	0	3	1
A	release()	0	8	2
A	addConnection()	0	11	3
A	getDefaultConnection()	0	6	2
A	getConnection()	0	7	2
A	hasConnection()	0	3	1

<?php declare(strict_types=1);

namespace Igni\Storage\Driver;

use Igni\Storage\Exception\StorageException;

final class ConnectionManager
{
    private static $defaultConnection;
    /** @var Connection[] */
    private static $connections = [];

    public static function release(): void
    {
        foreach (self::$connections as $connection) {
            $connection->close();
        }

        self::$defaultConnection = null;
        self::$connections = [];
    }

    public static function addConnection(Connection $connection, string $name = 'default'): void
    {
        if (!self::hasDefaultConnection()) {
            self::$defaultConnection = $connection;
        }

        if (self::hasConnection($name)) {
            throw StorageException::forAlreadyExistingConnection($name);
        }

        self::$connections[$name] = $connection;
    }

    public static function hasConnection(string $name): bool
    {
        return isset(self::$connections[$name]);
    }

    public static function hasDefaultConnection(): bool
    {
        return self::$defaultConnection !== null;
    }

    public static function getDefaultConnection(): Connection
    {
        if (!self::hasDefaultConnection()) {
            throw StorageException::forNotRegisteredConnection('default');
        }
        return self::$defaultConnection;
    }

    public static function getConnection(string $name): Connection
    {
        if (!self::hasConnection($name)) {
            throw StorageException::forNotRegisteredConnection($name);
        }

        return self::$connections[$name];
    }
}