Cycle orm migrations

composer.json

@@ -43,7 +43,8 @@
         "yiisoft/html": "^3.0@dev",
         "yiisoft/security": "^3.0@dev",
         "cycle/orm": "^1.1",
-        "cycle/annotated": "^2.0"
+        "cycle/annotated": "^2.0",
+        "cycle/migrations": "^1.0"
     },
     "require-dev": {
         "hiqdev/composer-config-plugin": "^1.0@dev"

config/common.php

@@ -1,10 +1,13 @@
 <?php
 
+use App\Factory\CycleDbalFactory;
 use App\Factory\CycleOrmFactory;
 use App\Factory\LoggerFactory;
 use App\Factory\MailerFactory;
+use App\Helper\CycleOrmHelper;
 use Cycle\ORM\ORMInterface;
 use Psr\Log\LoggerInterface;
+use Spiral\Database\DatabaseManager;
 use Yiisoft\Aliases\Aliases;
 use Yiisoft\Cache\ArrayCache;
 use Yiisoft\Cache\Cache;
@@ -23,22 +26,18 @@
         '@src' => '@root/src',
         '@runtime' => '@root/runtime',
     ],
-    CacheInterface::class => [
-        '__class' => Cache::class,
-        'handler' => [
-            '__class' => ArrayCache::class,
-        ],
-    ],
+    Psr\SimpleCache\CacheInterface::class => ArrayCache::class,
+    CacheInterface::class => Cache::class,
     LoggerInterface::class => new LoggerFactory(),
     FileRotatorInterface::class => [
         '__class' => FileRotator::class,
         '__construct()' => [
             10
         ]
     ],
-    \Swift_Transport::class => \Swift_SmtpTransport::class,
-    \Swift_SmtpTransport::class => [
-        '__class' => \Swift_SmtpTransport::class,
+    Swift_Transport::class => Swift_SmtpTransport::class,
+    Swift_SmtpTransport::class => [
+        '__class' => Swift_SmtpTransport::class,
         '__construct()' => [
             'host' => $params['mailer.host'],
             'port' => $params['mailer.port'],
@@ -49,6 +48,17 @@
     ],
     MailerInterface::class => new MailerFactory(),
 
+
+    // Cycle DBAL
+    DatabaseManager::class => new CycleDbalFactory(),
     // Cycle ORM
     ORMInterface::class => new CycleOrmFactory(),
+    // Cycle Entity Finder
+    CycleOrmHelper::class => [
+        '__class' => CycleOrmHelper::class,
+        'addEntityPaths()' => [
+            'paths' => $params['entityPaths'],
+        ],
+    ],
+
 ];

config/console.php

@@ -1,8 +1,29 @@
 <?php
 
 
-use App\ConsoleCommand\CreateUser;
+use App\Console\Command\CreateUser;
+use App\Factory\CycleMigratorFactory;
+use Psr\Container\ContainerInterface;
+use Spiral\Migrations\Config\MigrationConfig;
+use Spiral\Migrations\Migrator;
+use Yiisoft\Aliases\Aliases;
+
+$params = $params ?? [];
 
 return [
+
     CreateUser::class => CreateUser::class,
+
+    // Cycle Migrations
+    Migrator::class => new CycleMigratorFactory(),
+    // Migration Config
+    MigrationConfig::class => function (ContainerInterface $container) {
+        $aliases = $container->get(Aliases::class);
+        return new MigrationConfig([
+            'directory' => $aliases->get('@src/Console/Migration'),
+            'namespace' => 'App\Console\Migration',
+            'table' => 'migration',
+            'safe' => false,
+        ]);
+    }
 ];

config/params.php

@@ -1,6 +1,10 @@
 <?php
 
-use App\ConsoleCommand\CreateUser;
+use App\Console\Command\CreateUser;
+use App\Console\Command\MigrateDown;
+use App\Console\Command\MigrateGenerate;
+use App\Console\Command\MigrateList;
+use App\Console\Command\MigrateUp;
 
 return [
     'mailer.host' => 'smtp.example.com',
@@ -13,5 +17,13 @@
 
     'commands' => [
         'user/create' => CreateUser::class,
+        'migrate/generate' => MigrateGenerate::class,
+        'migrate/up' => MigrateUp::class,
+        'migrate/down' => MigrateDown::class,
+        'migrate/list' => MigrateList::class,
     ],
+
+    'entityPaths' => [
+        '@src/Entity'
+    ]
 ];

src/ConsoleCommand/CreateUser.php → src/Console/Command/CreateUser.php

@@ -1,8 +1,7 @@
 <?php
 
 
-namespace App\ConsoleCommand;
-
+namespace App\Console\Command;
 
 use App\Entity\User;
 use Cycle\ORM\ORMInterface;

src/Console/Command/MigrateDown.php

@@ -0,0 +1,77 @@
+<?php
+namespace App\Console\Command;
+
+use App\Helper\CycleOrmHelper;
+use Spiral\Migrations\Config\MigrationConfig;
+use Spiral\Migrations\MigrationInterface;
+use Spiral\Migrations\Migrator;
+use Spiral\Migrations\State;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class MigrateDown extends Command
+{
+    protected static $defaultName = 'migrate/down';
+
+    /** @var MigrationConfig */
+    private $config;
+
+    /** @var Migrator */
+    private $migrator;
+
+    /** @var CycleOrmHelper */
+    private $cycleOrmHelper;
+
+    /**
+     * MigrateGenerateCommand constructor.
+     * @param Migrator        $migrator
+     * @param MigrationConfig $conf
+     * @param CycleOrmHelper  $cycleOrmHelper
+     */
+    public function __construct(Migrator $migrator, MigrationConfig $conf, CycleOrmHelper $cycleOrmHelper)
+    {
+        parent::__construct();
+        $this->config = $conf;
+        $this->migrator = $migrator;
+        $this->cycleOrmHelper = $cycleOrmHelper;
+    }
+
+    public function configure(): void
+    {
+        $this
+            ->setDescription('Rollback last migration');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        // drop cached schema
+        $this->cycleOrmHelper->dropCurrentSchemaCache();
+
+        $list = $this->migrator->getMigrations();
+        $output->writeln('<fg=green>' . count($list) . ' migrations found in ' . $this->config->getDirectory() . '</fg=green>');
+
+        $statuses = [
+            State::STATUS_UNDEFINED => 'undefined',
+            State::STATUS_PENDING => 'pending',
+            State::STATUS_EXECUTED => 'executed',
+        ];
+        try {
+            $migration = $this->migrator->rollback();
+            if (!$migration instanceof MigrationInterface) {
+                throw new \Exception('Migration not found');
+            }
+
+            $state = $migration->getState();
+            $status = $state->getStatus();
+            $output->writeln($state->getName() . ': ' . ($statuses[$status] ?? $status));
+        } catch (\Throwable $e) {
+            $output->writeln([
+                '===================',
+                'Error!',
+                $e->getMessage(),
+            ]);
+            return;
+        }
+    }
+}

src/Console/Command/MigrateGenerate.php

@@ -0,0 +1,54 @@
+<?php
+namespace App\Console\Command;
+
+use App\Helper\CycleOrmHelper;
+use Spiral\Migrations\Migrator;
+use Spiral\Migrations\Config\MigrationConfig;
+use Spiral\Migrations\State;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class MigrateGenerate extends Command
+{
+    protected static $defaultName = 'migrate/generate';
+
+    /** @var Migrator */
+    private $migrator;
+
+    /** @var CycleOrmHelper */
+    private $cycleHelper;
+
+    /** @var MigrationConfig */
+    private $config;
+
+    public function __construct(
+        Migrator $migrator,
+        MigrationConfig $conf,
+        CycleOrmHelper $cycleHelper
+    ) {
+        parent::__construct();
+        $this->migrator = $migrator;
+        $this->config = $conf;
+        $this->cycleHelper = $cycleHelper;
+    }
+
+    public function configure(): void
+    {
+        $this->setDescription('Generates a migration');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): void
+    {
+        // check existing unapplied migrations
+        $list = $this->migrator->getMigrations();
+        foreach ($list as $migration) {
+            if ($migration->getState()->getStatus() !== State::STATUS_EXECUTED) {
+                $output->writeln('<fg=red>Outstanding migrations found, run `migrate/up` first.</fg=red>');
+                return;
+            }
+        }
+
+        $this->cycleHelper->generateMigration($this->migrator, $this->config);
+    }
+}

src/Console/Command/MigrateList.php

@@ -0,0 +1,54 @@
+<?php
+namespace App\Console\Command;
+
+use Spiral\Migrations\Config\MigrationConfig;
+use Spiral\Migrations\Migrator;
+use Spiral\Migrations\State;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class MigrateList extends Command
+{
+    protected static $defaultName = 'migrate/list';
+
+    /** @var MigrationConfig */
+    private $config;
+    /** @var Migrator */
+    private $migrator;
+    /**
+     * MigrateGenerateCommand constructor.
+     * @param Migrator                 $migrator
+     * @param MigrationConfig   $conf
+     */
+    public function __construct(Migrator $migrator, MigrationConfig $conf)
+    {
+        $this->config = $conf;
+        $this->migrator = $migrator;
+        parent::__construct();
+    }
+
+    public function configure(): void
+    {
+        $this
+            ->setDescription('Print list of all migrations');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $list = $this->migrator->getMigrations();
+        $output->writeln('<fg=green>' . count($list) . ' migrations found in ' . $this->config->getDirectory() . ':</fg=green>');
+
+        $statuses = [
+            State::STATUS_UNDEFINED => 'undefined',
+            State::STATUS_PENDING => 'pending',
+            State::STATUS_EXECUTED => 'executed',
+        ];
+        $list = $this->migrator->getMigrations();
+
+        foreach ($list as $migration) {
+            $state = $migration->getState();
+            $output->writeln($state->getName() . ' <fg=yellow>[' . ($statuses[$state->getStatus()] ?? '?') . ']</fg=yellow>');
+        }
+    }
+}