Ray\AuraSqlModule\NamedPdoEnvModule

Complexity

Total Complexity

6

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	17	1
A	configure()	0	4	2
A	getLocator()	0	9	1
A	configureMasterSlaveDsn()	0	4	1
A	configureSingleDsn()	0	14	1

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

use Aura\Sql\ConnectionLocator;
use Aura\Sql\ExtendedPdoInterface;
use Ray\Di\AbstractModule;

class NamedPdoEnvModule extends AbstractModule
{
    public const PARSE_PDO_DSN_REGEX = '/(.*?)\:(host|server)=.*?;(.*)/i';

    private string $qualifer;
    private string $dsn;
    private string $username;
    private string $password;
    private string $slave;

    /** @var array<string> */
    private array $options;

    /** @var array<string> */
    private array $queries;

    /**
     * @param string        $qualifer Qualifer for ExtendedPdoInterface
     * @param string        $dsn      Data Source Name (DSN)
     * @param string        $username User name for the DSN string
     * @param string        $password Password for the DSN string
     * @param string        $slave    Comma separated slave host list
     * @param array<string> $options  A key=>value array of driver-specific connection options
     * @param array<string> $queries  Queries to execute after the connection.
     */
    public function __construct(
        string $qualifer,
        string $dsn,
        string $username = '',
        string $password = '',
        string $slave = '',
        array $options = [],
        array $queries = []
    ) {
        $this->qualifer = $qualifer;
        $this->dsn = $dsn;
        $this->username = $username;
        $this->password = $password;
        $this->slave = $slave;
        $this->options = $options;
        $this->queries = $queries;
        parent::__construct();
    }

    /**
     * {@inheritdoc}
     */
    protected function configure(): void
    {
        $this->slave ? $this->configureMasterSlaveDsn()
            : $this->configureSingleDsn();
    }

    private function configureSingleDsn(): void
    {
        $connection = new EnvConnection(
            $this->dsn,
            null,
            $this->username,
            $this->password,
            $this->options,
            $this->queries
        );
        $this->bind(EnvConnection::class)->annotatedWith($this->qualifer)->toInstance($connection);
        $this->bind(ExtendedPdoInterface::class)->annotatedWith($this->qualifer)->toProvider(
            NamedExtendedPdoProvider::class,
            $this->qualifer
        );
    }

    private function configureMasterSlaveDsn(): void
    {
        $locator = $this->getLocator();
        $this->install(new AuraSqlReplicationModule($locator, $this->qualifer));
    }

    private function getLocator(): ConnectionLocator
    {
            return ConnectionLocatorFactory::fromEnv(
                $this->dsn,
                $this->username,
                $this->password,
                $this->slave,
                $this->options,
                $this->queries
            );
    }
}