Kenjis\CodeIgniter_Cli\Command\Migrate

Complexity

Total Complexity

20

Size/Duplication

Total Lines	122
Duplicated Lines	11.48 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
B	__invoke()	8	42	7
A	migrateToVersion()	6	11	2
A	getDbVersion()	0	5	2
A	showVersions()	0	17	1
A	getLatestVersion()	0	11	2
B	listMigrationFiles()	0	28	6

<?php
/**
 * Part of Cli for CodeIgniter
 *
 * @author     Kenji Suzuki <https://github.com/kenjis>
 * @license    MIT License
 * @copyright  2015 Kenji Suzuki
 * @link       https://github.com/kenjis/codeigniter-cli
 */

namespace Kenjis\CodeIgniter_Cli\Command;

use Aura\Cli\Status;

/**
 * @property \CI_Migration $migration
 * @property \CI_Loader    $load
 * @property \CI_Config    $config
 */
class Migrate extends Command
{
    public function __invoke($command = null)
    {
        $this->load->library('migration');
        $this->load->config('migration');

        if ($command === 'status') {
            $this->listMigrationFiles();
            return;
        }

        if ($command === 'version') {
            $this->showVersions();
            return;
        }

        // if argument is digits, migrate to the version
        if (ctype_digit($command)) {
            if ($this->migrateToVersion($command) === false) {
                return Status::FAILURE;
            } else {
                $this->showVersions();
                return;
            }
        }

        if ($command !== null) {
            $this->stdio->errln(
                '<<red>>No such command: ' . $command . '<<reset>>'
            );
            return Status::USAGE;
        }

        // if no argument, migrate to current
        if ($this->migration->current() === false) {

This code seems to be duplicated across your project.

            $this->stdio->errln(
                '<<red>>' . $this->migration->error_string() . '<<reset>>'
            );
            return Status::FAILURE;
        } else {
            $this->showVersions();
        }
    }

    private function migrateToVersion($version)
    {
        if ($this->migration->version($version) === false) {

This code seems to be duplicated across your project.

            $this->stdio->errln(
                '<<red>>' . $this->migration->error_string() . '<<reset>>'
            );
            return false;
        }
        
        return true;
    }

    private function getDbVersion()
    {
        $row = $this->db->select('version')->get($this->config->item('migration_table'))->row();
        return $row ? $row->version : '0';
    }

    private function showVersions()
    {
        $this->stdio->outln(
            ' current: <<green>>' . $this->config->item('migration_version') . '<<reset>>'
            . ' (in config/migration.php)'
        );
        $version = $this->getDbVersion();
        $this->stdio->outln(
            'database: <<bold>>' . $version . '<<reset>>'
            . ' (in database table)'
        );
        $version = $this->getLatestVersion();
        $this->stdio->outln(
            '  latest: ' . $version . ''
            . ' (in migration files)'
        );
    }

    private function getLatestVersion()
    {
        $files = $this->migration->find_migrations();
        
        if ($files === []) {
            return 'null';
        }
        
        end($files);
        return key($files);
    }

    private function listMigrationFiles()
    {
        $this->stdio->outln(
            $this->config->item('migration_path')
        );

        $current = $this->config->item('migration_version');
        $db = $this->getDbVersion();

        $files = $this->migration->find_migrations();
        foreach ($files as $v => $file) {
            if ($v == $current && $v == $db) {
                $this->stdio->outln(
                    '  <<green>>' . basename($file) .' (current/database)<<reset>>'
                );
            } elseif ($v == $current) {
                $this->stdio->outln(
                    '  <<green>>' . basename($file) .' (current)<<reset>>'
                );
            } elseif ($v == $db) {
                $this->stdio->outln(
                    '  <<bold>>' . basename($file) .' (database)<<reset>>'
                );
            } else {
                $this->stdio->outln('  ' . basename($file));
            }
        }
    }
}