Ray\AuraSqlModule\AuraSqlLocatorModule

Complexity

Total Complexity

6

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	installReadWriteConnection()	0	13	1
A	configure()	0	15	3
A	installLocatorDb()	0	15	1
A	__construct()	0	11	1

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

use Aura\Sql\ConnectionLocatorInterface;
use Ray\AuraSqlModule\Annotation\AuraSql;
use Ray\AuraSqlModule\Annotation\Read;
use Ray\AuraSqlModule\Annotation\ReadOnlyConnection;
use Ray\AuraSqlModule\Annotation\Write;
use Ray\AuraSqlModule\Annotation\WriteConnection;
use Ray\Di\AbstractModule;

use function array_merge;

class AuraSqlLocatorModule extends AbstractModule
{
    private ConnectionLocatorInterface $connectionLocator;

    /** @var string[] */
    private array $readMethods;

    /** @var string[] */
    private array $writeMethods;

    /**
     * @phpstan-param array<string> $readMethods
     * @phpstan-param array<string> $writeMethods
     */
    public function __construct(
        ConnectionLocatorInterface $connectionLocator,
        array $readMethods = [],
        array $writeMethods = [],
        ?AbstractModule $module = null
    ) {
        $this->connectionLocator = $connectionLocator;
        $this->readMethods = $readMethods;
        $this->writeMethods = $writeMethods;

        parent::__construct($module);
    }

    /**
     * {@inheritDoc}
     */
    protected function configure(): void
    {
        if ((bool) $this->readMethods && (bool) $this->writeMethods) {
            $this->bind()->annotatedWith(Read::class)->toInstance($this->readMethods);
            $this->bind()->annotatedWith(Write::class)->toInstance($this->writeMethods);
        }

        $this->bind(ConnectionLocatorInterface::class)->toInstance($this->connectionLocator);
        $methods = array_merge($this->readMethods, $this->writeMethods);
        // @AuraSql
        $this->installLocatorDb($methods);
        // @ReadOnlyConnection @WriteConnection
        $this->installReadWriteConnection();
        // @Transactional
        $this->install(new TransactionalModule());
    }

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

    /** @param string[] $methods */
    private function installLocatorDb(array $methods): void
    {
        // locator db
        $this->bindInterceptor(
            $this->matcher->annotatedWith(AuraSql::class), // @AuraSql in class
            $this->matcher->logicalAnd(
                new IsInMethodMatcher($methods),
                $this->matcher->logicalNot(
                    $this->matcher->annotatedWith(ReadOnlyConnection::class),
                ),
                $this->matcher->logicalNot(
                    $this->matcher->annotatedWith(Connection::class),
                ),
            ),
            [AuraSqlConnectionInterceptor::class],
        );
    }
}