Ray\AuraSqlModule\NamedPdoModule

Complexity

Total Complexity

8

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	1
A	configure()	0	5	2
A	configureSingleDsn()	0	12	1
A	configureMasterSlaveDsn()	0	13	2
A	changeHost()	0	10	2

<?php
/**
 * This file is part of the Ray.AuraSqlModule package.
 *
 * @license http://opensource.org/licenses/MIT MIT
 */
namespace Ray\AuraSqlModule;

use Aura\Sql\ConnectionLocator;
use Aura\Sql\ExtendedPdo;
use Aura\Sql\ExtendedPdoInterface;
use Ray\Di\AbstractModule;

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

    /**
     * @var string
     */
    private $qualifer;

    /**
     * @var string
     */
    private $dsn;

    /**
     * @var string
     */
    private $user;

    /**
     * @var string
     */
    private $password;

    /**
     * @var string
     */
    private $slave;

    public function __construct(
        string $qualifer,
        string $dsn,
        string $user = '',
        string $pass = '',
        string $slave = ''
    ) {
        $this->qualifer = $qualifer;
        $this->dsn = $dsn;
        $this->user = $user;
        $this->password = $pass;
        $this->slave = $slave;
        parent::__construct();
    }

    /**
     * {@inheritdoc}
     */
    protected function configure()
    {
        $this->slave ? $this->configureMasterSlaveDsn($this->qualifer, $this->dsn, $this->user, $this->password, $this->slave)
            : $this->configureSingleDsn($this->qualifer, $this->dsn, $this->user, $this->password);
    }

    private function configureSingleDsn($qualifer, $dsn, $user, $password)
    {
        $this->bind(ExtendedPdoInterface::class)
            ->annotatedWith($qualifer)
            ->toConstructor(
                ExtendedPdo::class,
                "dsn={$qualifer}_dsn,username={$qualifer}_username,password={$qualifer}_password"
            );
        $this->bind()->annotatedWith("{$qualifer}_dsn")->toInstance($dsn);
        $this->bind()->annotatedWith("{$qualifer}_username")->toInstance($user);
        $this->bind()->annotatedWith("{$qualifer}_password")->toInstance($password);
    }

    private function configureMasterSlaveDsn($qualifer, $dsn, $user, $password, $slaveList)
    {
        $locator = new ConnectionLocator();
        $locator->setWrite('master', new Connection($dsn, $user, $password));
        $i = 1;
        $slaves = \explode(',', $slaveList);
        foreach ($slaves as $slave) {
            $slaveDsn = $this->changeHost($dsn, $slave);
            $name = 'slave' . (string) $i++;
            $locator->setRead($name, new Connection($slaveDsn, $user, $password));
        }
        $this->install(new AuraSqlReplicationModule($locator, $qualifer));

new \Ray\AuraSqlModule\AuraSqlReplicationModule($locator, $qualifer) is of type object<Ray\AuraSqlModule\AuraSqlReplicationModule>, but the function expects a object<self>.

    }

    /**
     * @param string $dsn
     * @param string $host
     *
     * @return string
     */
    private function changeHost($dsn, $host)
    {
        \preg_match(self::PARSE_PDO_DSN_REGEX, $dsn, $parts);
        if (! $parts) {

The expression $parts of type string[] is implicitly converted to a boolean; are you sure this is intended? If so, consider using empty($expr) instead to make it clear that you intend to check for an array without elements.

            return $dsn;
        }
        $dsn = \sprintf('%s:%s=%s;%s', $parts[1], $parts[2], $host, $parts[3]);

        return $dsn;
    }
}