Ray\AuraSqlModule\AuraSqlReplicationModule

Complexity

Total Complexity

6

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Importance

Changes	5
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	configureWithQualifier()	0	13	1
A	installReadWriteConnection()	0	13	1
A	configure()	0	11	2
A	configureWithoutQualifier()	0	9	1

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

use Aura\Sql\ConnectionLocatorInterface;
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\AuraSqlModule\Annotation\ReadOnlyConnection;
use Ray\AuraSqlModule\Annotation\WriteConnection;
use Ray\Di\AbstractModule;
use Ray\Di\Scope;

final class AuraSqlReplicationModule extends AbstractModule
{
    public function __construct(
        private readonly ConnectionLocatorInterface $connectionLocator,
        private readonly string $qualifer = '',
        ?AbstractModule $module = null
    ) {
        parent::__construct($module);
    }

    /**
     * {@inheritDoc}
     */
    #[Override]
    protected function configure(): void
    {
        if ($this->qualifer === '') {
            $this->configureWithoutQualifier();
        } else {
            $this->configureWithQualifier();
        }

        // @ReadOnlyConnection @WriteConnection
        $this->installReadWriteConnection();
    }

    private function configureWithoutQualifier(): void
    {
        $this->bind(ConnectionLocatorInterface::class)
            ->toInstance($this->connectionLocator);

        // ReadOnlyConnection when GET, otherwise WriteConnection
        $this->bind(ExtendedPdoInterface::class)
            ->toProvider(AuraSqlReplicationDbProvider::class, '')
            ->in(Scope::SINGLETON);
    }

    private function configureWithQualifier(): void
    {
        $this->bind(ConnectionLocatorInterface::class)
            /** @phpstan-ignore argument.type */
            ->annotatedWith($this->qualifer)
            ->toInstance($this->connectionLocator);

        // ReadOnlyConnection when GET, otherwise WriteConnection
        $this->bind(ExtendedPdoInterface::class)
            /** @phpstan-ignore argument.type */
            ->annotatedWith($this->qualifer)
            ->toProvider(AuraSqlReplicationDbProvider::class, $this->qualifer)
            ->in(Scope::SINGLETON);
    }

    protected function installReadWriteConnection(): void
    {
        // @ReadOnlyConnection
        $this->bindInterceptor(
            $this->matcher->any(),
            $this->matcher->annotatedWith(ReadOnlyConnection::class),
            [AuraSqlSlaveDbInterceptor::class],

The type Ray\AuraSqlModule\AuraSqlSlaveDbInterceptor was not found. Maybe you did not declare it correctly or list all dependencies?

        );
        // @WriteConnection
        $this->bindInterceptor(
            $this->matcher->any(),
            $this->matcher->annotatedWith(WriteConnection::class),
            [AuraSqlMasterDbInterceptor::class],

The type Ray\AuraSqlModule\AuraSqlMasterDbInterceptor was not found. Maybe you did not declare it correctly or list all dependencies?

        );
    }
}