Igni\Storage\MigrationManager

Complexity

Total Complexity

14

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	findNewestVersion()	0	11	3
B	migrate()	0	24	8
A	getCurrentVersion()	0	3	1
A	register()	0	3	1

<?php declare(strict_types=1);

namespace Igni\Storage;

use Igni\Storage\Migration\Version;
use Igni\Storage\Migration\VersionSynchronizer;

class MigrationManager
{
    /**
     * @var VersionSynchronizer
     */
    private $synchronizer;

    /**
     * @var Migration[]
     */
    private $migrations = [];

    public function __construct(VersionSynchronizer $synchronizer)
    {
        $this->synchronizer = $synchronizer;
    }

    public function register(Migration $migration): void
    {
        $this->migrations[] = $migration;
    }

    public function getCurrentVersion(): Version
    {
        return $this->synchronizer->getVersion();
    }

    public function migrate(Version $targetVersion = null): Version
    {
        $lastVersion = $this->synchronizer->getVersion();
        if ($targetVersion === null) {
            $targetVersion = $this->findNewestVersion();
        }

        if ($targetVersion->greaterThan($lastVersion)) {
            foreach ($this->migrations as $migration) {
                if ($migration->getVersion()->lowerOrEquals($targetVersion)) {
                    $migration->up();
                }
            }
        } else if ($targetVersion->lowerThan($lastVersion)) {
            foreach ($this->migrations as $migration) {
                if ($migration->getVersion()->greaterThan($targetVersion)) {
                    $migration->down();
                }
            }
        }

        $this->synchronizer->setVersion($targetVersion);

        return $targetVersion;
    }

    private function findNewestVersion(): Version
    {
        $version = Version::fromString('0.0.0');

        foreach ($this->migrations as $migration) {
            if ($migration->getVersion()->greaterThan($version)) {
                $version = clone $migration->getVersion();
            }
        }

        return $version;
    }
}