Ray\AuraSqlModule\AuraSqlModule

Complexity

Total Complexity

5

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes	8
Bugs	1	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	5	2
A	configureSingleDsn()	0	18	1
A	__construct()	0	12	1
A	configureMasterSlaveDsn()	0	11	1

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

use Aura\Sql\ExtendedPdo;
use Aura\Sql\ExtendedPdoInterface;
use Override;

The type Override was not found. Maybe you did not declare it correctly or list all dependencies?

use Ray\Di\AbstractModule;
use Ray\Di\Scope;
use SensitiveParameter;

The type SensitiveParameter was not found. Maybe you did not declare it correctly or list all dependencies?

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

    /**
     * @param string              $dsn      Data Source Name (DSN)
     * @param string              $user     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,mixed> $options  A key=>value array of driver-specific connection options
     * @param array<string>       $queries
     */
    public function __construct(
        private readonly string $dsn,
        private readonly string $user = '',
        #[SensitiveParameter]
        private readonly string $password = '',
        private readonly string $slave = '',
        /** @var array<string, mixed> */
        private readonly array $options = [],
        /** @var array<string> */
        private readonly array $queries = []
    ) {
        parent::__construct();
    }

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

    private function configureSingleDsn(): void
    {
        $this->bind()->annotatedWith('pdo_dsn')->toInstance($this->dsn);
        $this->bind()->annotatedWith('pdo_user')->toInstance($this->user);
        $this->bind()->annotatedWith('pdo_pass')->toInstance($this->password);
        $this->bind()->annotatedWith('pdo_slave')->toInstance($this->slave);
        $this->bind()->annotatedWith('pdo_options')->toInstance($this->options);
        $this->bind()->annotatedWith('pdo_queries')->toInstance($this->queries);
        $this->bind(ExtendedPdoInterface::class)->toConstructor(
            ExtendedPdo::class,
            [
                'dsn' => 'pdo_dsn',
                'username' => 'pdo_user',
                'password' => 'pdo_pass',
                'options' => 'pdo_options',
                'queries' => 'pdo_queries',
            ],
        )->in(Scope::SINGLETON);
    }

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