php-yaoi / php-yaoi

src/Migration/Manager.php

<?php

namespace Yaoi\Migration;

use Yaoi\Log;
use Yaoi\Storage;
use Yaoi\Service;

class Manager extends Service
{
    /**
     * @var Settings
     */
    protected $settings;


    public function isApplied($migrationId)
    {
        return (bool)$this->getStorage()->get($migrationId);
    }

    /**
     * @var Storage
     */
    private $storage;

    /**
     * @return Storage
     */
    protected function getStorage()
    {
        if (null === $this->storage) {
            $this->storage = Storage::getInstance($this->settings->storage);
        }
        return $this->storage;
    }

    public function perform(Migration $migration, $action = Migration::APPLY)
    {
        if ($action === Migration::SKIP) {
            return $this;
        }

        $id = $migration->getId();

        if (Migration::ROLLBACK === $action) {
            if ($migration->hasInternalState()) {

This code seems to be duplicated across your project.

                $migration->rollback();
            }
            elseif ($this->isApplied($id)) {
                if ($migration->rollback()) {
                    $this->getStorage()->delete($id);
                }
            }


        } elseif (Migration::APPLY === $action) {
            if ($migration->hasInternalState()) {

This code seems to be duplicated across your project.

                $migration->apply();
            }
            elseif (!$this->isApplied($id)) {
                if ($migration->apply()) {
                    $this->getStorage()->set($id, 1);
                }
            }
        }

        return $this;
    }


    private $jobs = array();

    /**
     * @param Migration[]|Migration $migrations
     * @param string $action
     * @return $this
     */
    public function add($migrations, $action = Migration::APPLY) {
        if ($migrations instanceof Migration) {
            $migrations = array($migrations);
        }

        foreach ($migrations as $migration) {
            $this->jobs []= array($migration, $action);
        }
        return $this;
    }

    /** @var  Log */
    private $log;
    public function setLog(Log $log = null) {
        $this->log = $log;
        return $this;
    }

    public function run($dryRun = false)
    {
        foreach ($this->jobs as $job) {
            /** @var Migration $migration */
            $migration = $job[0];
            $action = $job[1];
            if ($this->log) {
                $migration->setLog($this->log);
            }
            $migration->setDryRun($dryRun);
            $this->perform($migration, $action);
        }
        return $this;
    }

    protected static function getSettingsClassName()
    {
        return Settings::className();
    }

}