add mark all completed command

Author: daverdalas

src/CommandRunner.php

@@ -74,8 +74,8 @@ public function __construct(
         Container $laravel,
         DatabaseMigrationRepository $repository,
         Resolver $resolver,
-        Filesystem $files)
-    {
+        Filesystem $files
+    ) {
         $this->laravel = $laravel;
         $this->files = $files;
         $this->resolver = $resolver;
@@ -116,9 +116,7 @@ public function run($paths = [], array $options = [])
         // run each of the outstanding migrations against a database connection.
         $files = $this->getCommandFiles($paths);
 
-        $this->requireFiles($migrations = $this->pendingMigrations(
-            $files, $this->repository->getRan()
-        ));
+        $migrations = $this->requirePendingMigrations($files);
 
         // Once we have all these migrations that are outstanding we are ready to run
         // we will go ahead and run them "up". This will execute each migration as
@@ -128,11 +126,53 @@ public function run($paths = [], array $options = [])
         return $migrations;
     }
 
+    /**
+     * @param array $paths
+     * @param array $options
+     * @return array
+     */
+    public function markAllCompleted($paths = [], array $options = [])
+    {
+        $files = $this->getCommandFiles($paths);
+
+        $migrations = $this->requirePendingMigrations($files);
+
+        foreach ($migrations as $file) {
+            $this->markFileCompleted($file);
+        }
+
+        $this->note("<info>Marked all pending commands as completed</info>");
+
+        return $migrations;
+    }
+
+    /**
+     * @param string $file
+     * @return void
+     */
+    protected function markFileCompleted($file)
+    {
+        $name = $this->getCommandName($file);
+        $this->repository->log($name);
+    }
+
+    /**
+     * @param array $files
+     * @return array
+     */
+    protected function requirePendingMigrations(array $files = [])
+    {
+        $this->requireFiles($migrations = $this->pendingMigrations(
+            $files, $this->repository->getRan()
+        ));
+        return $migrations;
+    }
+
     /**
      * Get the migration files that have not yet run.
      *
-     * @param  array  $files
-     * @param  array  $ran
+     * @param  array $files
+     * @param  array $ran
      * @return array
      */
     protected function pendingMigrations($files, $ran)
@@ -211,8 +251,8 @@ protected function runCommand($file, $pretend)
     /**
      * Pretend to run the migrations.
      *
-     * @param  object|Command  $command
-     * @param  string  $method
+     * @param  object|Command $command
+     * @param  string $method
      * @return void
      */
     protected function pretendToRun($command, $method)
@@ -227,8 +267,8 @@ protected function pretendToRun($command, $method)
     /**
      * Get all of the queries that would be run for a migration.
      *
-     * @param  object|Command  $command
-     * @param  string  $method
+     * @param  object|Command $command
+     * @param  string $method
      * @return array
      */
     protected function getQueries($command, $method)
@@ -248,7 +288,7 @@ protected function getQueries($command, $method)
     /**
      * Resolve a migration instance from a file.
      *
-     * @param  string  $file
+     * @param  string $file
      * @return object|Command
      */
     public function resolve($file)
@@ -265,13 +305,13 @@ public function resolve($file)
     /**
      * Get all of the migration files in a given path.
      *
-     * @param  string|array  $paths
+     * @param  string|array $paths
      * @return array
      */
     public function getCommandFiles($paths)
     {
         return Collection::make($paths)->flatMap(function ($path) {
-            return $this->files->glob($path.'/*_*.php');
+            return $this->files->glob($path . '/*_*.php');
         })->filter()->sortBy(function ($file) {
             return $this->getCommandName($file);
         })->values()->keyBy(function ($file) {
@@ -282,7 +322,7 @@ public function getCommandFiles($paths)
     /**
      * Require in all the migration files in a given path.
      *
-     * @param  array   $files
+     * @param  array $files
      * @return void
      */
     public function requireFiles(array $files)
@@ -295,7 +335,7 @@ public function requireFiles(array $files)
     /**
      * Get the name of the migration.
      *
-     * @param  string  $path
+     * @param  string $path
      * @return string
      */
     public function getCommandName($path)
@@ -306,7 +346,7 @@ public function getCommandName($path)
     /**
      * Register a custom migration path.
      *
-     * @param  string  $path
+     * @param  string $path
      * @return void
      */
     public function path($path)
@@ -327,12 +367,12 @@ public function paths()
     /**
      * Set the default connection name.
      *
-     * @param  string  $name
+     * @param  string $name
      * @return void
      */
     public function setConnection($name)
     {
-        if (! is_null($name)) {
+        if (!is_null($name)) {
             $this->resolver->setDefaultConnection($name);
         }
 
@@ -344,7 +384,7 @@ public function setConnection($name)
     /**
      * Resolve the database connection instance.
      *
-     * @param  string  $connection
+     * @param  string $connection
      * @return \Illuminate\Database\Connection
      */
     public function resolveConnection($connection)
@@ -355,7 +395,7 @@ public function resolveConnection($connection)
     /**
      * Get the schema grammar out of a migration connection.
      *
-     * @param  \Illuminate\Database\Connection  $connection
+     * @param  \Illuminate\Database\Connection $connection
      * @return \Illuminate\Database\Schema\Grammars\Grammar
      */
     protected function getSchemaGrammar($connection)
@@ -402,7 +442,7 @@ public function getFilesystem()
     /**
      * Raise a note event for the migrator.
      *
-     * @param  string  $message
+     * @param  string $message
      * @return void
      */
     protected function note($message)

src/Console/BaseCommand.php

@@ -36,4 +36,20 @@ protected function getCommandPath()
     {
         return $this->laravel->databasePath().DIRECTORY_SEPARATOR.'commands';
     }
+
+    /**
+     * Prepare the migration database for running.
+     *
+     * @return void
+     */
+    protected function prepareDatabase()
+    {
+        $this->commandRunner->setConnection($this->option('database'));
+
+        if (! $this->commandRunner->repositoryExists()) {
+            $this->call(
+                'deploy-commands:install', ['--database' => $this->option('database')]
+            );
+        }
+    }
 }

src/Console/MarkCommand.php

@@ -0,0 +1,62 @@
+<?php
+
+namespace DaverDalas\LaravelPostDeployCommands\Console;
+
+use DaverDalas\LaravelPostDeployCommands\CommandRunner;
+
+class MarkCommand extends BaseCommand
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'deploy-commands:mark-all-completed {--database= : The database connection to use.}
+                {--path= : The path of commands files to be executed.}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Mark all post deploy commands as completed';
+
+    /**
+     * The CommandRunner instance.
+     *
+     * @var \DaverDalas\LaravelPostDeployCommands\CommandRunner
+     */
+    protected $commandRunner;
+
+    /**
+     * Create a new migration command instance.
+     *
+     * @param  \DaverDalas\LaravelPostDeployCommands\CommandRunner  $commandRunner
+     * @return void
+     */
+    public function __construct(CommandRunner $commandRunner)
+    {
+        parent::__construct();
+
+        $this->commandRunner = $commandRunner;
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return void
+     * @throws \Exception
+     * @throws \Throwable
+     */
+    public function handle()
+    {
+        $this->prepareDatabase();
+
+        $this->commandRunner->setOutput($this->output);
+
+        // Next, we will check to see if a path option has been defined. If it has
+        // we will use the path relative to the root of this installation folder
+        // so that migrations may be run for any path within the applications.
+        $this->commandRunner->markAllCompleted($this->getCommandPaths());
+    }
+}

src/Console/RunCommand.php

@@ -62,20 +62,4 @@ public function handle()
             'pretend' => $this->option('pretend'),
         ]);
     }
-
-    /**
-     * Prepare the migration database for running.
-     *
-     * @return void
-     */
-    protected function prepareDatabase()
-    {
-        $this->commandRunner->setConnection($this->option('database'));
-
-        if (! $this->commandRunner->repositoryExists()) {
-            $this->call(
-                'deploy-commands:install', ['--database' => $this->option('database')]
-            );
-        }
-    }
 }

src/ServiceProvider.php

@@ -4,6 +4,7 @@
 
 use DaverDalas\LaravelPostDeployCommands\Console\InstallCommand;
 use DaverDalas\LaravelPostDeployCommands\Console\MakeCommand;
+use DaverDalas\LaravelPostDeployCommands\Console\MarkCommand;
 use DaverDalas\LaravelPostDeployCommands\Console\RunCommand;
 use Illuminate\Support\ServiceProvider as BaseServiceProvider;
 
@@ -24,7 +25,8 @@ public function boot()
             $this->commands([
                 'command.deploy-commands.install',
                 'command.deploy-commands.make',
-                'command.deploy-commands.run'
+                'command.deploy-commands.run',
+                'command.deploy-commands.mark'
             ]);
         }
     }
@@ -53,6 +55,8 @@ public function register()
             $this->registerMakeCommand();
 
             $this->registerRunCommand();
+
+            $this->registerMarkCommand();
         }
     }
 
@@ -142,6 +146,18 @@ protected function registerRunCommand()
         });
     }
 
+    /**
+     * Register the command.
+     *
+     * @return void
+     */
+    protected function registerMarkCommand()
+    {
+        $this->app->singleton('command.deploy-commands.mark', function ($app) {
+            return new MarkCommand($app['deploy-commands.runner']);
+        });
+    }
+
 
     /**
      * Get the services provided by the provider.