Wandu\Database\Migrator\MigrateManager

Complexity

Total Complexity

23

Size/Duplication

Total Lines	130
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getMigrations()	0	8	2
A	getMigration()	0	9	3
A	up()	0	12	3
A	down()	0	14	3
A	migrate()	0	12	3
B	getAllMigrationFiles()	0	10	5
A	getMigrationClassFromSource()	0	12	3

<?php
namespace Wandu\Database\Migrator;

use RuntimeException;
use DirectoryIterator;
use Wandu\DI\ContainerInterface;

class MigrateManager
{
    /** @var \Wandu\Database\Migrator\MigrateAdapterInterface */
    protected $adapter;
    
    /** @var \Wandu\Database\Migrator\Configuration */
    protected $config;

    /** @var \Wandu\DI\ContainerInterface */
    protected $container;
    
    /**
     * @param \Wandu\Database\Migrator\MigrateAdapterInterface $adapter
     * @param \Wandu\Database\Migrator\Configuration $config
     * @param \Wandu\DI\ContainerInterface $container
     */
    public function __construct(MigrateAdapterInterface $adapter, Configuration $config, ContainerInterface $container)
    {
        $this->adapter = $adapter;
        $this->config = $config;
        $this->container = $container;
    }

    /**
     * @return array|\Wandu\Database\Migrator\MigrationContainer[]
     */
    public function getMigrations()
    {
        $migrations = [];
        foreach ($this->getAllMigrationFiles() as $file) {
            $migrations[] = new MigrationContainer($file, $this->adapter, $this->container);
        }
        return $migrations;
    }

    /**
     * @param string $migrationId
     * @return \Wandu\Database\Migrator\MigrationContainer
     */
    public function getMigration($migrationId)
    {
        foreach ($this->getAllMigrationFiles() as $file) {
            if (strpos($file, $migrationId . '_') === 0) {
                return new MigrationContainer($file, $this->adapter, $this->container);
            }
        }
        throw new RuntimeException("there is no migration id \"{$migrationId}\".");
    }

    /**
     * @param string $migrationId
     */
    public function up($migrationId)
    {
        if (!preg_match('/^\d{6}_\d{6}$/', $migrationId)) {
            throw new RuntimeException("invalid migration id. it must be like 000000_000000.");
        }
        $version = $this->adapter->version($migrationId);
        if ($version) {

The expression $version of type array 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.

            throw new RuntimeException("this {$migrationId} is already applied.");
        }
        
        $this->getMigration($migrationId)->up();
    }

    /**
     * @param string $migrationId
     */
    public function down($migrationId)
    {
        if (!preg_match('/^\d{6}_\d{6}$/', $migrationId)) {
            throw new RuntimeException("invalid migration id. it must be like 000000_000000.");
        }
        $version = $this->adapter->version($migrationId);
        if (!$version) {

The expression $version of type array 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.

            throw new RuntimeException("this {$migrationId} is not already applied.");
        }

        $migrationName = $this->getMigrationClassFromSource($version['source']);
        $this->container->create($migrationName)->down();
        $this->adapter->down($migrationId);
    }

    /**
     * @return array|\Wandu\Database\Migrator\MigrationContainer[]
     */
    public function migrate()
    {
        $migratedMigrations = [];
        $migrations = $this->getMigrations();
        foreach ($migrations as $migration) {
            if (!$this->adapter->version($migration->getId())) {
                $migration->up();
                $migratedMigrations[] = $migration;
            }
        }
        return $migratedMigrations;
    }
    
    /**
     * @return array
     */
    protected function getAllMigrationFiles()
    {
        $files = [];
        foreach (new DirectoryIterator($this->config->getPath()) as $file) {
            if ($file->isDot() || $file->isDir() || $file->getFilename()[0] === '.') continue;
            $files[] = $file->getFileInfo();
        }
        sort($files);
        return $files;
    }

    /**
     * @param string $source
     * @return string
     */
    protected function getMigrationClassFromSource($source)
    {
        $definedClasses = get_declared_classes();
        eval('?>' . $source);

It is generally not recommended to use eval unless absolutely required.

        $lastMigrationClass = null;
        foreach (array_diff(get_declared_classes(), $definedClasses) as $declaredClass) {
            if ((new \ReflectionClass($declaredClass))->isSubclassOf(MigrationInterface::class)) {
                $lastMigrationClass = $declaredClass; // last migration class is migration class. (maybe)
            }
        }
        return $lastMigrationClass;
    }
}