Команда для архивации (#7)

* поддержка поддиректорий

* fix

* команда для архивации

* try fix

README.md

@@ -61,9 +61,10 @@
 </tr>
 <tr>
     <td>`php migrator make название_миграции`</td>
-    <td>Создает файл миграции
-    Опции:<br>
-    `-d foo/bar` - указать поддиректорию, в которой будет создана миграция<br>
+    <td>
+        Создает файл миграции
+        Опции:<br>
+        `-d foo/bar` - указать поддиректорию, в которой будет создана миграция<br>
     </td>
 </tr>
 <tr>
@@ -87,6 +88,14 @@
     <td>`php migrator status`</td>
     <td>Показывает доступные для выполнения миграции, а также последние выполненные.</td>
 </tr>
+<tr>
+    <td>`php migrator archive`</td>
+    <td>
+        Переносит все миграции в архив. По умолчанию это директория archive, но можно переопределить в конфиге, указав "dir_archive"<br>
+        Опции:<br>
+        `-w 10` - не переносить в архив последние N миграций<br>
+    </td>
+</tr>
 </table>
 
 ### Шаблоны миграций

migrator

@@ -1,6 +1,7 @@
 #!/usr/bin/env php
 <?php
 
+use Arrilot\BitrixMigrations\Commands\ArchiveCommand;
 use Arrilot\BitrixMigrations\Commands\MakeCommand;
 use Arrilot\BitrixMigrations\Commands\InstallCommand;
 use Arrilot\BitrixMigrations\Commands\MigrateCommand;
@@ -22,6 +23,7 @@ CModule::IncludeModule("iblock");
 $config = [
     'table' => 'migrations',
     'dir' => './migrations',
+    // 'dir_archive' => 'archive', // not required. default = "archive"
 ];
 
 $database = new BitrixDatabaseStorage($config['table']);
@@ -37,4 +39,5 @@ $app->add(new MigrateCommand($migrator));
 $app->add(new RollbackCommand($migrator));
 $app->add(new TemplatesCommand($templates));
 $app->add(new StatusCommand($migrator));
+$app->add(new ArchiveCommand($migrator));
 $app->run();

src/Commands/ArchiveCommand.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace Arrilot\BitrixMigrations\Commands;
+
+use Arrilot\BitrixMigrations\Migrator;
+use Symfony\Component\Console\Input\InputOption;
+
+class ArchiveCommand extends AbstractCommand
+{
+    /**
+     * Migrator instance.
+     *
+     * @var Migrator
+     */
+    protected $migrator;
+
+    /**
+     * Constructor.
+     *
+     * @param Migrator $migrator
+     */
+    public function __construct(Migrator $migrator)
+    {
+        $this->migrator = $migrator;
+
+        parent::__construct();
+    }
+
+    /**
+     * Configures the current command.
+     */
+    protected function configure()
+    {
+        $this->setName('archive')
+            ->setDescription('Move migration into archive')
+            ->addOption('without', 'w', InputOption::VALUE_REQUIRED, 'Archive without last N migration');
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return null|int
+     */
+    protected function fire()
+    {
+        $files = $this->migrator->getAllMigrations();
+        $without = $this->input->getOption('without') ?: 0;
+        if ($without > 0) {
+            $files = array_slice($files, 0, $without * -1);
+        }
+
+        $count = $this->migrator->moveMigrationFiles($files);
+
+        if ($count) {
+            $this->message("<info>Moved to archive:</info> {$count}");
+        } else {
+            $this->info('Nothing to move');
+        }
+    }
+}

src/Migrator.php

@@ -27,6 +27,13 @@ class Migrator
      */
     protected $dir;
 
+    /**
+     * Directory to store archive m.
+     *
+     * @var string
+     */
+    protected $dir_archive;
+
     /**
      * Files interactions.
      *
@@ -60,6 +67,7 @@ public function __construct($config, TemplatesCollection $templates, DatabaseSto
     {
         $this->config = $config;
         $this->dir = $config['dir'];
+        $this->dir_archive = isset($config['dir_archive']) ? $config['dir_archive'] : 'archive';
 
         $this->templates = $templates;
         $this->database = $database ?: new BitrixDatabaseStorage($config['table']);
@@ -162,6 +170,16 @@ public function getRanMigrations()
         return $this->database->getRanMigrations();
     }
 
+    /**
+     * Get all migrations.
+     *
+     * @return array
+     */
+    public function getAllMigrations()
+    {
+        return $this->files->getMigrationFiles($this->dir);
+    }
+
     /**
      * Determine whether migration file for migration exists.
      *
@@ -225,13 +243,46 @@ public function deleteMigrationFile($migration)
      */
     public function getMigrationsToRun()
     {
-        $allMigrations = $this->files->getMigrationFiles($this->dir);
+        $allMigrations = $this->getAllMigrations();
 
         $ranMigrations = $this->getRanMigrations();
 
         return array_diff($allMigrations, $ranMigrations);
     }
 
+    /**
+     * Move migration files.
+     *
+     * @param array $files
+     * @param string $toDir
+     *
+     * @return int
+     */
+    public function moveMigrationFiles($files = [], $toDir = '')
+    {
+        $toDir = trim($toDir ?: $this->dir_archive, '/');
+        $files = $files ?: $this->getAllMigrations();
+        $this->files->createDirIfItDoesNotExist("$this->dir/$toDir");
+
+        $count = 0;
+        foreach ($files as $migration) {
+            $from = $this->getMigrationFilePath($migration);
+            $to = "$this->dir/$toDir/$migration.php";
+
+            if ($from == $to) {
+                continue;
+            }
+
+            $flag = $this->files->move($from, $to);
+
+            if ($flag) {
+                $count++;
+            }
+        }
+
+        return $count;
+    }
+
     /**
      * Construct migration file name from migration name and current time.
      *

src/Storages/FileStorage.php

@@ -114,4 +114,17 @@ public function delete($path)
     {
         return $this->exists($path) ? unlink($path) : false;
     }
+
+    /**
+     * Move file.
+     *
+     * @param string $path_from
+     * @param string $path_to
+     *
+     * @return bool
+     */
+    public function move($path_from, $path_to)
+    {
+        return $this->exists($path_from) ? rename($path_from, $path_to) : false;
+    }
 }