Dami\Migration\MigrationFiles

Complexity

Total Complexity

16

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	3
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
C	get()	0	33	12
A	statusIntention()	0	6	1
A	getFiles()	0	14	2

<?php

namespace Dami\Migration;

use Symfony\Component\Finder\Finder;

class MigrationFiles
{
    private $path;
    private $schemaTable;
    private $statusIntention = false;

    /**
     * @param string      $path        Migrations path.
     * @param SchemaTable $schemaTable SchemaTable instance.
     */
    public function __construct($path, SchemaTable $schemaTable)
    {
        $this->path = $path;
        $this->schemaTable = $schemaTable;
    }

    /**
     * Gets migration files.
     *
     * @param string $version Version of migration.
     *
     * @return MigrationFile[]
     */
    public function get($version = null)
    {
        $currentVersion = $this->schemaTable->getCurrentVersion();
        if (null !== $version && (int) $version === (int) $currentVersion) {
            return null;
        }
        $migrateUp = null === $version || $version >= $currentVersion;
        $migrationFiles = array();
        foreach ($this->getFiles($migrateUp) as $file) {
            $filenameParser = new FileNameParser($file->getFileName());

            $isMigrated = in_array($filenameParser->getVersion(), $this->schemaTable->getVersions());

            $migrationFile = new MigrationFile($filenameParser->getMigrationName(), $file->getRealpath(),
                $filenameParser->getVersion(), $filenameParser->getMigrationClassName(), $isMigrated);

            if (false === $this->statusIntention) {
                if ($migrateUp && $isMigrated
                    || !$migrateUp && !$isMigrated) {
                    continue;
                }
                if ($version == $migrationFile->getVersion()) {
                    if ($migrateUp) {
                        $migrationFiles[] = $migrationFile;
                    }
                    break;
                }
            }
            $migrationFiles[] = $migrationFile;
        }

        return $migrationFiles;
    }

    /**
     * This method is called when status of migrations is checking.
     *
     * @return MigrationFiles
     */
    public function statusIntention()
    {
        $this->statusIntention = true;

        return $this;
    }

    /**
     * Gets files from directory.
     *
     * @param bool $migrateUp Is migration up.
     *
     * @return bool
     */
    private function getFiles($migrateUp)
    {
        $finder = new Finder();

        return $finder
            ->files()
            ->in($this->path)
            ->sort(function (\SplFileInfo $a, \SplFileInfo $b) use ($migrateUp) {
                return $migrateUp
                    ? $a->getRealpath() > $b->getRealpath()
                    : $a->getRealpath() < $b->getRealpath();
            }
        );
    }
}