Conia\Quma\Connection

Complexity

Total Complexity

29

Size/Duplication

Total Lines	208
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	readDirs()	0	34	6
A	prepareDirs()	0	18	3
A	addMigrationDir()	0	4	1
A	sql()	0	3	1
A	preparePath()	0	9	2
A	migrationsColumnApplied()	0	3	1
A	migrationsColumnMigration()	0	3	1
A	setMigrationsTable()	0	3	1
A	__construct()	0	14	1
A	addSqlDirs()	0	4	1
A	getColumnName()	0	7	2
A	migrations()	0	3	1
A	setMigrationsColumnMigration()	0	3	1
A	setMigrationsColumnApplied()	0	3	1
A	migrationsTable()	0	14	4
A	readDriver()	0	11	2

<?php

declare(strict_types=1);

namespace Conia\Quma;

use Conia\Quma\Util;
use PDO;
use RuntimeException;
use ValueError;

/**
 * @psalm-type MigrationDirs = list<non-empty-string>
 * @psalm-type SqlDirs = list<non-empty-string>
 * @psalm-type SqlAssoc = array<non-empty-string, non-empty-string>
 * @psalm-type SqlMixed = list<non-empty-string|SqlAssoc>
 * @psalm-type SqlConfig = non-empty-string|SqlAssoc|SqlMixed
 */
class Connection
{
    use GetsSetsPrint;

    /** @var non-empty-string */

The doc comment non-empty-string at position 0 could not be parsed: Unknown type name 'non-empty-string' at position 0 in non-empty-string.

    public readonly string $driver;

    /** @var SqlDirs */

The type Conia\Quma\SqlDirs was not found. Maybe you did not declare it correctly or list all dependencies?

    protected array $sql;

    /** @var MigrationDirs */

The type Conia\Quma\MigrationDirs was not found. Maybe you did not declare it correctly or list all dependencies?

    protected array $migrations;

    protected string $migrationsTable = 'migrations';
    protected string $migrationsColumnMigration = 'migration';
    protected string $migrationsColumnApplied = 'applied';

    /**
     * @psalm-param SqlConfig $sql
     * @psalm-param MigrationDirs $migrations
     * */
    public function __construct(
        public readonly string $dsn,
        string|array $sql,
        string|array $migrations = null,
        public readonly ?string $username = null,
        public readonly ?string $password = null,
        public readonly array $options = [],
        public readonly int $fetchMode = PDO::FETCH_BOTH,
        bool $print = false
    ) {
        $this->driver = $this->readDriver($this->dsn);

The property driver is declared read-only in Conia\Quma\Connection.

        $this->sql = $this->readDirs($sql);

It seems like $this->readDirs($sql) of type array or string[] is incompatible with the declared type Conia\Quma\SqlDirs of property $sql.

        $this->migrations = $this->readDirs($migrations ?? []);

It seems like $this->readDirs($migrations ?? array()) of type array or string[] is incompatible with the declared type Conia\Quma\MigrationDirs of property $migrations.

        $this->print = $print;
    }

    public function setMigrationsTable(string $table): void
    {
        $this->migrationsTable = $table;
    }

    public function setMigrationsColumnMigration(string $column): void
    {
        $this->migrationsColumnMigration = $column;
    }

    public function setMigrationsColumnApplied(string $column): void
    {
        $this->migrationsColumnApplied = $column;
    }

    public function migrationsTable(): string
    {
        if ($this->driver === 'pgsql') {
            // PostgreSQL table names can contain a schema
            if (preg_match('/^([a-zA-Z0-9_]+\.)?[a-zA-Z0-9_]+$/', $this->migrationsTable)) {
                return $this->migrationsTable;
            }
        } else {
            if (preg_match('/^[a-zA-Z0-9_]+$/', $this->migrationsTable)) {
                return $this->migrationsTable;
            }
        }

        throw new ValueError('Invalid migrations table name: ' . $this->migrationsTable);
    }

    public function migrationsColumnMigration(): string
    {
        return $this->getColumnName($this->migrationsColumnMigration);
    }

    public function migrationsColumnApplied(): string
    {
        return $this->getColumnName($this->migrationsColumnApplied);
    }

    /** @psalm-param non-empty-string $migrations */
    public function addMigrationDir(string $migrations): void
    {
        $migrations = $this->readDirs($migrations);
        $this->migrations = array_merge($migrations, $this->migrations);

It seems like array_merge($migrations, $this->migrations) of type array is incompatible with the declared type Conia\Quma\MigrationDirs of property $migrations.

    }

    /** @psalm-return MigrationDirs */
    public function migrations(): array
    {
        return $this->migrations;
    }

    /** @psalm-param SqlConfig $sql */
    public function addSqlDirs(array|string $sql): void
    {
        $sql = $this->readDirs($sql);
        $this->sql = array_merge($sql, $this->sql);

It seems like array_merge($sql, $this->sql) of type array is incompatible with the declared type Conia\Quma\SqlDirs of property $sql.

    }

    public function sql(): array
    {
        return $this->sql;
    }

    /** @return non-empty-string */

The doc comment non-empty-string at position 0 could not be parsed: Unknown type name 'non-empty-string' at position 0 in non-empty-string.

    protected function preparePath(string $path): string
    {
        $result = realpath($path);

        if ($result) {
            return $result;
        }

        throw new ValueError("Path does not exist: {$path}");
    }

    /** @return non-empty-string */

The doc comment non-empty-string at position 0 could not be parsed: Unknown type name 'non-empty-string' at position 0 in non-empty-string.

    protected function readDriver(string $dsn): string
    {
        $driver = explode(':', $dsn)[0];

        if (in_array($driver, PDO::getAvailableDrivers())) {
            assert(!empty($driver));

            return $driver;
        }

        throw new RuntimeException('PDO driver not supported: ' . $driver);
    }

    /**
     * @psalm-param SqlAssoc $entry
     *
     * @psalm-return MigrationDirs
     */
    protected function prepareDirs(array $entry): array
    {
        /** @var MigrationDirs */
        $dirs = [];

        // Add sql scripts for the current pdo driver.
        // Should be the first in the list as they
        // may have platform specific queries.
        if (array_key_exists($this->driver, $entry)) {
            $dirs[] = $this->preparePath($entry[$this->driver]);
        }

        // Add sql scripts for all platforms
        if (array_key_exists('all', $entry)) {
            $dirs[] = $this->preparePath($entry['all']);
        }

        return $dirs;
    }

    /**
     * Adds the sql script paths from configuration.
     *
     * Script paths are ordered last in first out (LIFO).
     * Which means the last path added is the first one searched
     * for a SQL script.
     *
     * @psalm-param SqlConfig $sql
     *
     * @return MigrationDirs
     */
    protected function readDirs(string|array $sql): array
    {
        if (is_string($sql)) {

The condition is_string($sql) is always false.

            /** @var MigrationDirs */
            return [$this->preparePath($sql)];
        }

        if (Util::isAssoc($sql)) {
            /** @var SqlAssoc $sql */
            return $this->prepareDirs($sql);

$sql of type Conia\Quma\SqlAssoc is incompatible with the type array expected by parameter $entry of Conia\Quma\Connection::prepareDirs().

The expression return $this->prepareDirs($sql) returns the type array|string[] which is incompatible with the documented return type Conia\Quma\MigrationDirs.

        }

        /** @var MigrationDirs */
        $dirs = [];

        foreach ($sql as $entry) {
            if (is_string($entry)) {
                array_unshift($dirs, $this->preparePath($entry));

                continue;
            }

            if (Util::isAssoc($entry)) {
                $dirs = array_merge($this->prepareDirs($entry), $dirs);

                continue;
            }

            throw new ValueError(
                "A single 'sql' item must be either a string or an associative array"
            );
        }

        return $dirs;
    }

    protected function getColumnName(string $column): string
    {
        if (preg_match('/^[a-zA-Z0-9_]+$/', $column)) {
            return $column;
        }

        throw new ValueError('Invalid migrations table column name: ' . $column);
    }
}