Yiisoft\Yii\Cycle\Command\Migration\BaseMigrationCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Test Coverage

Coverage

87.88%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	findMigrations()	0	11	1
A	createEmptyMigration()	0	31	3

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Cycle\Command\Migration;

use Cycle\Migrations\Exception\RepositoryException;
use Cycle\Migrations\MigrationInterface;
use Cycle\Migrations\State;
use Cycle\Schema\Generator\Migrations\MigrationImage;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Output\OutputInterface;
use Yiisoft\Yii\Cycle\Command\CycleDependencyProxy;

abstract class BaseMigrationCommand extends Command
{
    protected CycleDependencyProxy $promise;

    protected const MIGRATION_STATUS = [
        State::STATUS_UNDEFINED => 'undefined',
        State::STATUS_PENDING => 'pending',
        State::STATUS_EXECUTED => 'executed',
    ];

    public function __construct(CycleDependencyProxy $promise)
    {
        $this->promise = $promise;
        parent::__construct();
    }

    protected function createEmptyMigration(
        OutputInterface $output,
        string $name,
        ?string $database = null
    ): ?MigrationImage {
        if ($database === null) {
            // get default database
            $database = $this->promise->getDatabaseProvider()->database()->getName();
        }
        $migrator = $this->promise->getMigrator();

        $migrationSkeleton = new MigrationImage($this->promise->getMigrationConfig(), $database);
        $migrationSkeleton->setName($name);

        $className = $migrationSkeleton->getClass()->getName();
        \assert($className !== null);

        try {
            $migrationFile = $migrator->getRepository()->registerMigration(
                $migrationSkeleton->buildFileName(),
                $className,
                $migrationSkeleton->getFile()->render()
            );
        } catch (RepositoryException $e) {
            $output->writeln('<fg=yellow>Can not create migration</>');
            $output->writeln('<fg=red>' . $e->getMessage() . '</>');
            return null;
        }
        $output->writeln('<info>New migration file has been created</info>');
        $output->writeln("<fg=cyan>{$migrationFile}</>");
        return $migrationSkeleton;
    }

    /**
     * @param OutputInterface $output
     *
     * @return MigrationInterface[]
     */
    protected function findMigrations(OutputInterface $output): array
    {
        $list = $this->promise->getMigrator()->getMigrations();
        $output->writeln(
            sprintf(
                '<info>Total %d migration(s) found in %s</info>',
                count($list),
                $this->promise->getMigrationConfig()->getDirectory()
            )
        );
        return $list;
    }
}