Add --theme and --refresh-interval options

Author: steevanb

changelog.md

@@ -2,6 +2,8 @@
 
 - Fix `StartCondition::isCanceled()` when a previous process has been canceled
 - Add `SummaryTheme`
+- Add `--theme` option
+- Add `--refresh-interval` option
 
 ### [0.7.2](../../compare/0.7.1...0.7.2) - 2022-03-08
 

src/Console/Application/ParallelProcessesApplication.php

@@ -6,14 +6,17 @@
 
 use Steevanb\ParallelProcess\{
     Console\Application\Theme\DefaultTheme,
+    Console\Application\Theme\SummaryTheme,
     Console\Application\Theme\ThemeInterface,
     Console\Output\ConsoleBufferedOutput,
+    Exception\ParallelProcessException,
     Process\Process,
     Process\ProcessArray
 };
 use Symfony\Component\Console\{
     Command\SignalableCommandInterface,
     Input\InputInterface,
+    Input\InputOption,
     Output\OutputInterface,
     SingleCommandApplication
 };
@@ -146,13 +149,36 @@ public function handleSignal(int $signal): void
         }
     }
 
+    protected function configure(): void
+    {
+        parent::configure();
+
+        $this
+            ->addOption(
+                'theme',
+                't',
+                InputOption::VALUE_REQUIRED,
+                'Name or FQCN of the theme to use (examples: default, summary, ' . DefaultTheme::class . ')'
+            )
+            ->addOption(
+                'refresh-interval',
+                'r',
+                InputOption::VALUE_REQUIRED,
+                'Refresh interval in microseconds (example: 100000 for 100ms)'
+            );
+    }
+
     protected function isCanceled(): bool
     {
         return $this->canceled;
     }
 
     protected function runProcessesInParallel(InputInterface $input, OutputInterface $output): int
     {
+        $this
+            ->defineThemeFromInput($input)
+            ->defineRefreshIntervalFromInput($input);
+
         $this->getTheme()->outputStart($output, $this->getProcesses());
 
         $this
@@ -164,6 +190,53 @@ protected function runProcessesInParallel(InputInterface $input, OutputInterface
         return $this->getExitCode();
     }
 
+    protected function defineThemeFromInput(InputInterface $input): self
+    {
+        $theme = $input->getOption('theme');
+        if (is_string($theme)) {
+            switch ($theme) {
+                case 'default':
+                    $this->setTheme(new DefaultTheme());
+                    break;
+                case 'summary':
+                    $this->setTheme(new SummaryTheme());
+                    break;
+                default:
+                    if (class_exists($theme) === false) {
+                        throw new ParallelProcessException('Theme "' . $theme . '" not found.');
+                    }
+
+                    $themeObject = new $theme();
+                    if ($themeObject instanceof ThemeInterface === false) {
+                        throw new ParallelProcessException(
+                            'Theme "' . $theme . '" should implements ' . ThemeInterface::class . '.'
+                        );
+                    }
+
+                    $this->setTheme($themeObject);
+                    break;
+            }
+        }
+
+        return $this;
+    }
+
+    protected function defineRefreshIntervalFromInput(InputInterface $input): self
+    {
+        $interval = $input->getOption('refresh-interval');
+        if (is_string($interval)) {
+            if (is_numeric($interval) === false || (string) abs(intval($interval)) !== $interval) {
+                throw new ParallelProcessException(
+                    'Refresh interval "' . $interval . '" should be an integer value in microseconds.'
+                );
+            }
+
+            $this->setRefreshInterval((int) $interval);
+        }
+
+        return $this;
+    }
+
     protected function startProcesses(): self
     {
         return $this->startReadyProcesses();

tests/Processes.php

@@ -16,10 +16,11 @@
 use Symfony\Component\Console\Input\ArgvInput;
 
 require $_ENV['COMPOSER_GLOBAL_AUTOLOAD_FILE_NAME'];
+require __DIR__ . '/../vendor/autoload.php';
 
 $rootDir = dirname(__DIR__, 2);
 
-$process1 = new Process(['sleep', '1'], $rootDir);
+$process1 = new Process(['pwd'], $rootDir);
 
 $process2 = new Process(['pwd'], $rootDir);
 $process2->getStartCondition()->addProcessSuccessful($process1);
@@ -32,5 +33,4 @@
     ->addProcess($process2)
     ->addProcess($process3)
     ->setRefreshInterval(1)
-    ->setTheme(new \Steevanb\ParallelProcess\Console\Application\Theme\SummaryTheme())
-    ->run(new ArgvInput($argv));
+    ->run();