Umbrellio\Deploy\Console\RollbackNewMigrations

Complexity

Total Complexity

6

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	downMigrationFile()	0	9	2
A	handle()	0	27	4

<?php

declare(strict_types=1);

namespace Umbrellio\Deploy\Console;

use Illuminate\Console\Command;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Str;
use SplFileInfo;

class RollbackNewMigrations extends Command
{
    private const COMMAND = 'git ls-tree --name-only origin/master database/migrations/';

    protected $signature = 'rollback_new_migrations:rollback';
    protected $description = 'Rollback new migrations (default way for k8s staging)';

    public function handle(): void
    {
        if (App::environment('production')) {
            $this->error('It`s restricted to rollback new migrations on production.');
            return;
        }

        $migrationsFromMaster = collect(explode(PHP_EOL, shell_exec(self::COMMAND)))
            ->filter()
            ->map(fn (string $path) => new SplFileInfo(base_path($path)));
        $migrationsFromCurrent = collect(File::files(base_path('database/migrations')));

        /** @var Collection|SplFileInfo[] $migrationsToRollback */
        $migrationsToRollback = $migrationsFromCurrent->keyBy->getFileName()
            ->diffKeys($migrationsFromMaster->keyBy->getFileName())
            ->sort(fn (SplFileInfo $file1, SplFileInfo $file2) => strcmp($file1->getFilename(), $file2->getFilename()))
            ->reverse();

        if ($migrationsToRollback->isEmpty()) {
            $this->info('There are no migrations to rollback.');
            return;
        }

        DB::transaction(function () use ($migrationsToRollback) {
            foreach ($migrationsToRollback as $migration) {
                $this->info('Rolling back: ' . $migration->getFilename());
                $this->downMigrationFile($migration);
            }
        });
    }

    private function downMigrationFile(SplFileInfo $f): void
    {
        require_once $f->getPathname();
        $filename = explode('.php', $f->getRelativePathname())[0];

The method getRelativePathname() does not exist on SplFileInfo. It seems like you code against a sub-type of SplFileInfo such as ECSPrefix20210920\Symfony\Component\Finder\SplFileInfo or Symfony\Component\Finder\SplFileInfo or Illuminate\Http\UploadedFile.

        $class = Str::studly(implode('_', array_slice(explode('_', $filename), 4)));
        $migration = new $class();
        if (method_exists($migration, 'down')) {
            $migration->down();
            DB::table(config('database.migrations', 'migrations'))->where('migration', $filename)->delete();
        }
    }
}