Awssat\SyncMigration\SyncMigrateCommand

Complexity

Total Complexity

13

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	14	4
A	getAllSchemas()	0	3	1
A	schemasTables()	0	4	1
A	tables()	0	5	1
A	syncedOrNot()	0	3	2
A	abondedTables()	0	3	1
A	processMigration()	0	8	2
A	__construct()	0	6	1

<?php

namespace Awssat\SyncMigration;

use Illuminate\Support\Facades\DB;
use Spatie\Regex\Regex;
use Illuminate\Database\Console\Migrations\BaseCommand;

The type Illuminate\Database\Console\Migrations\BaseCommand was not found. Maybe you did not declare it correctly or list all dependencies?

use Illuminate\Database\Migrations\Migrator;

The type Illuminate\Database\Migrations\Migrator was not found. Maybe you did not declare it correctly or list all dependencies?

use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Schema as LaravelSchema;

class SyncMigrateCommand extends BaseCommand
{
    /**
     * The migrator instance.
     *
     * @var \Illuminate\Database\Migrations\Migrator
     */
    protected $migrator;

    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'migrate:sync';
    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Developer migrations syncing tool';


    protected $schemas;

    /**
     * Create a new migration command instance.
     *
     * @param  \Illuminate\Database\Migrations\Migrator  $migrator
     * @return void
     */
    public function __construct(Migrator $migrator)
    {
        parent::__construct();

        $this->schemas = Collection::make();
        $this->migrator = $migrator;
    }

    /**
     *
     */
    public function handle()
    {
        $files = $this->migrator->getMigrationFiles($this->getMigrationPaths());

        foreach ($files as $file) {
            $this->processMigration(file_get_contents($file));
        }

        $this->abondedTables()->each(function ($table) {
            $this->error("Schemas doesn't have table <fg=black;bg=white> {$table} </> seems you have delete it");

            $this->confirm("Do you want to drop <fg=black;bg=white> {$table} </> ?",
                true) && LaravelSchema::dropIfExists($table);
        })->isEmpty() && $this->syncedOrNot();

    }

    protected function syncedOrNot()
    {
        return !$this->schemas->pluck('synced')->contains(true) && $this->info('Nothing to sync.');
    }

    protected function tables()
    {
        return Collection::make(DB::select('SHOW TABLES'))->map(function ($table) {
            return array_values((array)$table);
        })->flatten();
    }

    protected function processMigration($content)
    {
        $schemas = $this->getAllSchemas($content);

        foreach ($schemas as $schema) {
            $schema = new Schema($schema, $this);
            $schema->process();
            $this->schemas->push($schema);
        }
    }

    protected function getAllSchemas($content)
    {
        return Regex::matchAll('/Schema::create\s*\((.*)\,.*{(.*)}\);/sU', $content)->results();
    }

    /**
     * @return mixed
     */
    protected function abondedTables()
    {
        return $this->tables()->diff($this->schemasTables());
    }

    protected function schemasTables()
    {
        return $this->schemas->pluck('name')->push('migrations')->map(function ($name) {
            return DB::getTablePrefix() . $name;
        });
    }
}