Ray\AuraSqlModule\AuraSqlReplicationDbProvider

Complexity

Total Complexity

5

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	2	1
A	get()	0	7	3
A	setContext()	0	4	1

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

use Aura\Sql\ConnectionLocatorInterface;
use Aura\Sql\ExtendedPdoInterface;
use Override;
use Ray\Di\InjectorInterface;
use Ray\Di\ProviderInterface;
use Ray\Di\SetContextInterface;

/** @implements ProviderInterface<ExtendedPdoInterface> */
final class AuraSqlReplicationDbProvider implements ProviderInterface, SetContextInterface
{
    private string $context = '';

    public function __construct(private readonly InjectorInterface $injector)
    {
    }

    /**
     * {@inheritDoc}
     *
     * @param string $context
     */
    #[Override]
    public function setContext($context): void
    {
        $this->context = $context;
    }

    /**
     * {@inheritDoc}
     */
    #[Override]
    public function get(): ExtendedPdoInterface
    {
        $connectionLocator = $this->injector->getInstance(ConnectionLocatorInterface::class, $this->context);
        $isGetRequest = isset($_SERVER['REQUEST_METHOD']) && $_SERVER['REQUEST_METHOD'] === 'GET';

        return $isGetRequest ? $connectionLocator->getRead() : $connectionLocator->getWrite();
    }
}