[5.x] Improves console output and fixes Carbon v3 support

.github/workflows/tests.yml

@@ -23,21 +23,9 @@ jobs:
     strategy:
       fail-fast: true
       matrix:
-        php: [7.3, 7.4, '8.0', 8.1, 8.2, 8.3]
-        laravel: [8, 9, 10, 11]
+        php: ['8.0', 8.1, 8.2, 8.3]
+        laravel: [9, 10, 11]
         exclude:
-          - php: 7.3
-            laravel: 9
-          - php: 7.3
-            laravel: 10
-          - php: 7.3
-            laravel: 11
-          - php: 7.4
-            laravel: 9
-          - php: 7.4
-            laravel: 10
-          - php: 7.4
-            laravel: 11
           - php: '8.0'
             laravel: 10
           - php: '8.0'

composer.json

@@ -10,21 +10,21 @@
         }
     ],
     "require": {
-        "php": "^7.3|^8.0",
+        "php": "^8.0",
         "ext-json": "*",
         "ext-pcntl": "*",
         "ext-posix": "*",
-        "illuminate/contracts": "^8.17|^9.0|^10.0|^11.0",
-        "illuminate/queue": "^8.17|^9.0|^10.0|^11.0",
-        "illuminate/support": "^8.17|^9.0|^10.0|^11.0",
+        "illuminate/contracts": "^9.21|^10.0|^11.0",
+        "illuminate/queue": "^9.21|^10.0|^11.0",
+        "illuminate/support": "^9.21|^10.0|^11.0",
         "nesbot/carbon": "^2.17|^3.0",
         "ramsey/uuid": "^4.0",
-        "symfony/process": "^5.0|^6.0|^7.0",
-        "symfony/error-handler": "^5.0|^6.0|^7.0"
+        "symfony/process": "^6.0|^7.0",
+        "symfony/error-handler": "^6.0|^7.0"
     },
     "require-dev": {
         "mockery/mockery": "^1.0",
-        "orchestra/testbench": "^6.0|^7.0|^8.0|^9.0",
+        "orchestra/testbench": "^7.0|^8.0|^9.0",
         "phpstan/phpstan": "^1.10",
         "phpunit/phpunit": "^9.0|^10.4",
         "predis/predis": "^1.1|^2.0"

src/Console/ClearCommand.php

@@ -41,7 +41,7 @@ public function handle(JobRepository $jobRepository, QueueManager $manager)
         }
 
         if (! method_exists(RedisQueue::class, 'clear')) {
-            $this->line('<error>Clearing queues is not supported on this version of Laravel</error>');
+            $this->components->error('Clearing queues is not supported on this version of Laravel.');
 
             return 1;
         }
@@ -54,7 +54,7 @@ public function handle(JobRepository $jobRepository, QueueManager $manager)
 
         $count = $manager->connection($connection)->clear($queue);
 
-        $this->line('<info>Cleared '.$count.' jobs from the ['.$queue.'] queue</info> ');
+        $this->components->info('Cleared '.$count.' jobs from the ['.$queue.'] queue.');
 
         return 0;
     }

src/Console/ClearMetricsCommand.php

@@ -31,6 +31,6 @@ public function handle(MetricsRepository $metrics)
     {
         $metrics->clear();
 
-        $this->info('Metrics cleared successfully.');
+        $this->components->info('Metrics cleared successfully.');
     }
 }

src/Console/ContinueCommand.php

@@ -36,12 +36,19 @@ public function handle(MasterSupervisorRepository $masters)
             return Str::startsWith($master->name, MasterSupervisor::basename());
         })->all();
 
-        foreach (Arr::pluck($masters, 'pid') as $processId) {
-            $this->info("Sending CONT Signal To Process: {$processId}");
+        collect(Arr::pluck($masters, 'pid'))
+            ->whenNotEmpty(fn () => $this->components->info('Sending CONT signal to processes.'))
+            ->whenEmpty(fn () => $this->components->info('No processes to continue.'))
+            ->each(function ($processId) {
+                $result = true;
 
-            if (! posix_kill($processId, SIGCONT)) {
-                $this->error("Failed to kill process: {$processId} (".posix_strerror(posix_get_last_error()).')');
-            }
-        }
+                $this->components->task("Process: $processId", function () use ($processId, &$result) {
+                    return $result = posix_kill($processId, SIGCONT);
+                });
+
+                if (! $result) {
+                    $this->components->error("Failed to kill process: {$processId} (".posix_strerror(posix_get_last_error()).')');
+                }
+            })->whenNotEmpty(fn () => $this->output->writeln(''));
     }
 }

src/Console/ContinueSupervisorCommand.php

@@ -38,15 +38,15 @@ public function handle(SupervisorRepository $supervisors)
         }))->pid;
 
         if (is_null($processId)) {
-            $this->error('Failed to find a supervisor with this name');
+            $this->components->error('Failed to find a supervisor with this name');
 
             return 1;
         }
 
-        $this->info("Sending CONT Signal To Process: {$processId}");
+        $this->components->info("Sending CONT signal to process: {$processId}");
 
         if (! posix_kill($processId, SIGCONT)) {
-            $this->error("Failed to send CONT signal to process: {$processId} (".posix_strerror(posix_get_last_error()).')');
+            $this->components->error("Failed to send CONT signal to process: {$processId} (".posix_strerror(posix_get_last_error()).')');
         }
     }
 }

src/Console/ForgetFailedCommand.php

@@ -31,9 +31,9 @@ public function handle(JobRepository $repository)
         $repository->deleteFailed($this->argument('id'));
 
         if ($this->laravel['queue.failer']->forget($this->argument('id'))) {
-            $this->info('Failed job deleted successfully!');
+            $this->components->info('Failed job deleted successfully!');
         } else {
-            $this->error('No failed job matches the given ID.');
+            $this->components->error('No failed job matches the given ID.');
 
             return 1;
         }

src/Console/HorizonCommand.php

@@ -32,7 +32,7 @@ class HorizonCommand extends Command
     public function handle(MasterSupervisorRepository $masters)
     {
         if ($masters->find(MasterSupervisor::name())) {
-            return $this->comment('A master supervisor is already running on this machine.');
+            return $this->components->warn('A master supervisor is already running on this machine.');
         }
 
         $environment = $this->option('environment') ?? config('horizon.env') ?? config('app.env');
@@ -43,12 +43,14 @@ public function handle(MasterSupervisorRepository $masters)
 
         ProvisioningPlan::get(MasterSupervisor::name())->deploy($environment);
 
-        $this->info('Horizon started successfully.');
+        $this->components->info('Horizon started successfully.');
 
         pcntl_async_signals(true);
 
         pcntl_signal(SIGINT, function () use ($master) {
-            $this->line('Shutting down...');
+            $this->output->writeln('');
+
+            $this->components->info('Shutting down.');
 
             return $master->terminate();
         });

src/Console/InstallCommand.php

@@ -29,18 +29,17 @@ class InstallCommand extends Command
      */
     public function handle()
     {
-        $this->comment('Publishing Horizon Service Provider...');
-        $this->callSilent('vendor:publish', ['--tag' => 'horizon-provider']);
+        $this->components->info('Installing Horizon resources.');
 
-        $this->comment('Publishing Horizon Assets...');
-        $this->callSilent('vendor:publish', ['--tag' => 'horizon-assets']);
-
-        $this->comment('Publishing Horizon Configuration...');
-        $this->callSilent('vendor:publish', ['--tag' => 'horizon-config']);
+        collect([
+            'Assets' => fn () => $this->callSilent('vendor:publish', ['--tag' => 'horizon-assets']) == 0,
+            'Service Provider' => fn () => $this->callSilent('vendor:publish', ['--tag' => 'horizon-provider']) == 0,
+            'Configuration' => fn () => $this->callSilent('vendor:publish', ['--tag' => 'horizon-config']) == 0,
+        ])->each(fn ($task, $description) => $this->components->task($description, $task));
 
         $this->registerHorizonServiceProvider();
 
-        $this->info('Horizon scaffolding installed successfully.');
+        $this->components->info('Horizon scaffolding installed successfully.');
     }
 
     /**

src/Console/ListCommand.php

@@ -32,9 +32,11 @@ public function handle(MasterSupervisorRepository $masters)
         $masters = $masters->all();
 
         if (empty($masters)) {
-            return $this->info('No machines are running.');
+            return $this->components->info('No machines are running.');
         }
 
+        $this->output->writeln('');
+
         $this->table([
             'Name', 'PID', 'Supervisors', 'Status',
         ], collect($masters)->map(function ($master) {
@@ -47,5 +49,7 @@ public function handle(MasterSupervisorRepository $masters)
                 $master->status,
             ];
         })->all());
+
+        $this->output->writeln('');
     }
 }

src/Console/PauseCommand.php

@@ -36,12 +36,19 @@ public function handle(MasterSupervisorRepository $masters)
             return Str::startsWith($master->name, MasterSupervisor::basename());
         })->all();
 
-        foreach (Arr::pluck($masters, 'pid') as $processId) {
-            $this->info("Sending USR2 Signal To Process: {$processId}");
+        collect(Arr::pluck($masters, 'pid'))
+            ->whenNotEmpty(fn () => $this->components->info('Sending USR2 signal to processes.'))
+            ->whenEmpty(fn () => $this->components->info('No processes to pause.'))
+            ->each(function ($processId) {
+                $result = true;
 
-            if (! posix_kill($processId, SIGUSR2)) {
-                $this->error("Failed to kill process: {$processId} (".posix_strerror(posix_get_last_error()).')');
-            }
-        }
+                $this->components->task("Process: $processId", function () use ($processId, &$result) {
+                    return $result = posix_kill($processId, SIGUSR2);
+                });
+
+                if (! $result) {
+                    $this->components->error("Failed to kill process: {$processId} (".posix_strerror(posix_get_last_error()).')');
+                }
+            })->whenNotEmpty(fn () => $this->output->writeln(''));
     }
 }

src/Console/PauseSupervisorCommand.php

@@ -38,15 +38,15 @@ public function handle(SupervisorRepository $supervisors)
         }))->pid;
 
         if (is_null($processId)) {
-            $this->error('Failed to find a supervisor with this name');
+            $this->components->error('Failed to find a supervisor with this name');
 
             return 1;
         }
 
-        $this->info("Sending USR2 Signal To Process: {$processId}");
+        $this->components->info("Sending USR2 signal to process: {$processId}");
 
         if (! posix_kill($processId, SIGUSR2)) {
-            $this->error("Failed to send USR2 signal to process: {$processId} (".posix_strerror(posix_get_last_error()).')');
+            $this->components->error("Failed to send USR2 signal to process: {$processId} (".posix_strerror(posix_get_last_error()).')');
         }
     }
 }

src/Console/PurgeCommand.php

@@ -96,13 +96,15 @@ public function purge($master, $signal = SIGTERM)
             $master, $this->supervisors->longestActiveTimeout()
         );
 
-        collect($expired)->each(function ($processId) use ($master, $signal) {
-            $this->comment("Killing Process: {$processId}");
-
-            exec("kill -s {$signal} {$processId}");
-
-            $this->processes->forgetOrphans($master, [$processId]);
-        });
+        collect($expired)
+            ->whenNotEmpty(fn () => $this->components->info('Sending TERM signal to expired processes of ['.$master.']'))
+            ->each(function ($processId) use ($master, $signal) {
+                $this->components->task("Process: $processId", function () use ($processId, $signal) {
+                    exec("kill -s {$signal} {$processId}");
+                });
+
+                $this->processes->forgetOrphans($master, [$processId]);
+            })->whenNotEmpty(fn () => $this->output->writeln(''));
     }
 
     /**
@@ -118,12 +120,18 @@ protected function recordOrphans($master, $signal)
             $master, $orphans = $this->inspector->orphaned()
         );
 
-        foreach ($orphans as $processId) {
-            $this->info("Observed Orphan: {$processId}");
+        collect($orphans)
+            ->whenNotEmpty(fn () => $this->components->info('Sending TERM signal to orphaned processes of ['.$master.']'))
+            ->each(function ($processId) use ($signal) {
+                $result = true;
 
-            if (! posix_kill($processId, $signal)) {
-                $this->error("Failed to kill process for Orphan: {$processId} (".posix_strerror(posix_get_last_error()).')');
-            }
-        }
+                $this->components->task("Process: $processId", function () use ($processId, $signal, &$result) {
+                    return $result = posix_kill($processId, $signal);
+                });
+
+                if (! $result) {
+                    $this->components->error("Failed to kill orphan process: {$processId} (".posix_strerror(posix_get_last_error()).')');
+                }
+            })->whenNotEmpty(fn () => $this->output->writeln(''));
     }
 }

src/Console/SnapshotCommand.php

@@ -34,7 +34,7 @@ public function handle(Lock $lock, MetricsRepository $metrics)
         if ($lock->get('metrics:snapshot', config('horizon.metrics.snapshot_lock', 300) - 30)) {
             $metrics->snapshot();
 
-            $this->info('Metrics snapshot stored successfully.');
+            $this->components->info('Metrics snapshot stored successfully.');
         }
     }
 }

src/Console/StatusCommand.php

@@ -30,20 +30,20 @@ class StatusCommand extends Command
     public function handle(MasterSupervisorRepository $masterSupervisorRepository)
     {
         if (! $masters = $masterSupervisorRepository->all()) {
-            $this->error('Horizon is inactive.');
+            $this->components->error('Horizon is inactive.');
 
             return 1;
         }
 
         if (collect($masters)->contains(function ($master) {
             return $master->status === 'paused';
         })) {
-            $this->warn('Horizon is paused.');
+            $this->components->warn('Horizon is paused.');
 
             return 1;
         }
 
-        $this->info('Horizon is running.');
+        $this->components->info('Horizon is running.');
 
         return 0;
     }

src/Console/SupervisorCommand.php

@@ -68,7 +68,7 @@ public function handle(SupervisorFactory $factory)
         try {
             $supervisor->ensureNoDuplicateSupervisors();
         } catch (Exception $e) {
-            $this->error('A supervisor with this name is already running.');
+            $this->components->error('A supervisor with this name is already running.');
 
             return 13;
         }

src/Console/SupervisorsCommand.php

@@ -32,9 +32,11 @@ public function handle(SupervisorRepository $supervisors)
         $supervisors = $supervisors->all();
 
         if (empty($supervisors)) {
-            return $this->info('No supervisors are running.');
+            return $this->components->info('No supervisors are running.');
         }
 
+        $this->output->writeln('');
+
         $this->table([
             'Name', 'PID', 'Status', 'Workers', 'Balancing',
         ], collect($supervisors)->map(function ($supervisor) {
@@ -48,5 +50,7 @@ public function handle(SupervisorRepository $supervisors)
                 $supervisor->options['balance'],
             ];
         })->all());
+
+        $this->output->writeln('');
     }
 }

src/Console/TerminateCommand.php

@@ -48,13 +48,20 @@ public function handle(CacheFactory $cache, MasterSupervisorRepository $masters)
             return Str::startsWith($master->name, MasterSupervisor::basename());
         })->all();
 
-        foreach (Arr::pluck($masters, 'pid') as $processId) {
-            $this->info("Sending TERM Signal To Process: {$processId}");
+        collect(Arr::pluck($masters, 'pid'))
+            ->whenNotEmpty(fn () => $this->components->info('Sending TERM signal to processes.'))
+            ->whenEmpty(fn () => $this->components->info('No processes to terminate.'))
+            ->each(function ($processId) {
+                $result = true;
 
-            if (! posix_kill($processId, SIGTERM)) {
-                $this->error("Failed to kill process: {$processId} (".posix_strerror(posix_get_last_error()).')');
-            }
-        }
+                $this->components->task("Process: $processId", function () use ($processId, &$result) {
+                    return $result = posix_kill($processId, SIGTERM);
+                });
+
+                if (! $result) {
+                    $this->components->error("Failed to kill process: {$processId} (".posix_strerror(posix_get_last_error()).')');
+                }
+            })->whenNotEmpty(fn () => $this->output->writeln(''));
 
         $this->laravel['cache']->forever('illuminate:queue:restart', $this->currentTime());
     }