Consigliere\Components\Migrations\Migrator

Complexity

Total Complexity

30

Size/Duplication

Total Lines	301
Duplicated Lines	26.25 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

18 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	setDatabase()	0	6	3
A	getComponent()	0	4	1
A	getPath()	8	8	3
B	getMigrations()	27	27	3
A	rollback()	22	22	3
A	reset()	22	22	3
A	down()	0	4	1
A	up()	0	4	1
A	resolve()	0	8	1
A	requireFiles()	0	7	2
A	table()	0	4	2
A	find()	0	4	1
A	log()	0	7	1
A	getNextBatchNumber()	0	4	1
A	getLastBatchNumber()	0	6	1
A	getLast()	0	12	1
A	getRan()	0	4	1

<?php

namespace Consigliere\Components\Migrations;

use Illuminate\Support\Collection;
use Consigliere\Components\Component;

class Migrator
{
    /**
     * Pingpong Component instance.
     *
     * @var \Consigliere\Components\Component
     */
    protected $component;

    /**
     * Laravel Application instance.
     *
     * @var \Illuminate\Foundation\Application.
     */
    protected $laravel;

    /**
     * The database connection to be used
     *
     * @var string
     */
    protected $database = '';

    /**
     * Create new instance.
     *
     * @param \Consigliere\Components\Component $component
     */
    public function __construct(Component $component)
    {
        $this->component = $component;
        $this->laravel   = $component->getLaravel();

It seems like $component->getLaravel() of type object<Illuminate\Foundation\Application> is incompatible with the declared type object<Illuminate\Foundation\Application.> of property $laravel.

    }

    /**
     * Set the database connection to be used
     *
     * @param $database
     *
     * @return $this
     */
    public function setDatabase($database)
    {
        if (is_string($database) && $database) {
            $this->database = $database;
        }
    }

    /**
     * @return Component
     */
    public function getComponent()
    {
        return $this->component;
    }

    /**
     * Get migration path.
     *
     * @return string
     */
    public function getPath()

This method seems to be duplicated in your project.

    {
        $config = $this->component->get('migration');

        $path = (is_array($config) && array_key_exists('path', $config)) ? $config['path'] : config('components.paths.generator.migration');

        return $this->component->getExtraPath($path);
    }

    /**
     * Get migration files.
     *
     * @param boolean $reverse
     *
     * @return array
     */
    public function getMigrations($reverse = false)

This method seems to be duplicated in your project.

    {
        $files = $this->laravel['files']->glob($this->getPath() . '/*_*.php');

        // Once we have the array of files in the directory we will just remove the
        // extension and take the basename of the file which is all we need when
        // finding the migrations that haven't been run against the databases.
        if ($files === false) {
            return [];
        }

        $files = array_map(function($file) {
            return str_replace('.php', '', basename($file));

        }, $files);

        // Once we have all of the formatted file names we will sort them and since
        // they all start with a timestamp this should give us the migrations in
        // the order they were actually created by the application developers.
        sort($files);

        if ($reverse) {
            return array_reverse($files);
        }

        return $files;
    }

    /**
     * Rollback migration.
     *
     * @return array
     */
    public function rollback()

This method seems to be duplicated in your project.

    {
        $migrations = $this->getLast($this->getMigrations(true));

        $this->requireFiles($migrations->toArray());

        $migrated = [];

        foreach ($migrations as $migration) {
            $data = $this->find($migration);

            if ($data->count()) {
                $migrated[] = $migration;

                $this->down($migration);

                $data->delete();
            }
        }

        return $migrated;
    }

    /**
     * Reset migration.
     *
     * @return array
     */
    public function reset()

This method seems to be duplicated in your project.

    {
        $migrations = $this->getMigrations(true);

        $this->requireFiles($migrations);

        $migrated = [];

        foreach ($migrations as $migration) {
            $data = $this->find($migration);

            if ($data->count()) {
                $migrated[] = $migration;

                $this->down($migration);

                $data->delete();
            }
        }

        return $migrated;
    }

    /**
     * Run down schema from the given migration name.
     *
     * @param string $migration
     */
    public function down($migration)
    {
        $this->resolve($migration)->down();
    }

    /**
     * Run up schema from the given migration name.
     *
     * @param string $migration
     */
    public function up($migration)
    {
        $this->resolve($migration)->up();
    }

    /**
     * Resolve a migration instance from a file.
     *
     * @param string $file
     *
     * @return object
     */
    public function resolve($file)
    {
        $file = implode('_', array_slice(explode('_', $file), 4));

        $class = studly_case($file);

        return new $class();
    }

    /**
     * Require in all the migration files in a given path.
     *
     * @param array $files
     */
    public function requireFiles(array $files)
    {
        $path = $this->getPath();
        foreach ($files as $file) {
            $this->laravel['files']->requireOnce($path . '/' . $file . '.php');
        }
    }

    /**
     * Get table instance.
     *
     * @return string
     */
    public function table()
    {
        return $this->database ? $this->laravel['db']->connection($this->database)->table(config('database.migrations')) : $this->laravel['db']->table(config('database.migrations'));
    }

    /**
     * Find migration data from database by given migration name.
     *
     * @param string $migration
     *
     * @return object
     */
    public function find($migration)
    {
        return $this->table()->whereMigration($migration);

The method whereMigration cannot be called on $this->table() (of type string).

    }

    /**
     * Save new migration to database.
     *
     * @param string $migration
     *
     * @return mixed
     */
    public function log($migration)
    {
        return $this->table()->insert([

The method insert cannot be called on $this->table() (of type string).

            'migration' => $migration,
            'batch'     => $this->getNextBatchNumber(),
        ]);
    }

    /**
     * Get the next migration batch number.
     *
     * @return int
     */
    public function getNextBatchNumber()
    {
        return $this->getLastBatchNumber() + 1;

The call to getLastBatchNumber() misses a required argument $migrations.

    }

    /**
     * Get the last migration batch number.
     *
     * @param array $migrations
     *
     * @return int
     */
    public function getLastBatchNumber($migrations)
    {
        return $this->table()

The method whereIn cannot be called on $this->table() (of type string).

            ->whereIn('migration', $migrations)
            ->max('batch');
    }

    /**
     * Get the last migration batch.
     *
     * @param array $migrations
     *
     * @return Collection
     */
    public function getLast($migrations)
    {
        $query = $this->table()

The method where cannot be called on $this->table() (of type string).

            ->where('batch', $this->getLastBatchNumber($migrations))
            ->whereIn('migration', $migrations);

        $result = $query->orderBy('migration', 'desc')->get();

        return collect($result)->map(function($item) {
            return (array)$item;
        })->pluck('migration');
    }

    /**
     * Get the ran migrations.
     *
     * @return Collection
     */
    public function getRan()
    {
        return $this->table()->pluck('migration');

The method pluck cannot be called on $this->table() (of type string).

    }
}