Ray\AuraSqlModule\AuraSqlEnvModule

Complexity

Total Complexity

5

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	configureMasterSlaveDsn()	0	11	1
A	__construct()	0	15	1
A	configureSingleDsn()	0	6	1
A	configure()	0	4	2

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

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

class AuraSqlEnvModule extends AbstractModule
{
    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        $dsnKey      Env key for Data Source Name (DSN)
     * @param string        $usernameKey Env key for Username for the DSN string
     * @param string        $passwordKey Env key for Password for the DSN string
     * @param string        $slaveKey    Env key for 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 $dsnKey,
        string $usernameKey = '',
        string $passwordKey = '',
        string $slaveKey = '',
        array $options = [],
        array $queries = []
    ) {
        $this->dsn = $dsnKey;
        $this->username = $usernameKey;
        $this->password = $passwordKey;
        $this->slave = $slaveKey;
        $this->options = $options;
        $this->queries = $queries;
        parent::__construct();
    }

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

    private function configureSingleDsn(): void
    {
        $this->bind(Connection::class)->toInstance(
            new Connection($this->dsn, $this->username, $this->password, $this->options, $this->queries)
        );
        $this->bind(ExtendedPdoInterface::class)->toProvider(ExtendedPdoProvider::class)->in(Scope::SINGLETON);
    }

    public function configureMasterSlaveDsn(): void
    {
        $locator = ConnectionLocatorFactory::fromEnv(
            $this->dsn,
            $this->username,
            $this->password,
            $this->slave,
            $this->options,
            $this->queries
        );
        $this->install(new AuraSqlReplicationModule($locator));
    }
}