Merge pull request #106 from php-etl/fix/clear-vendors

clear vendors when composer.json is not valid,

src/Adapter/Composer.php

@@ -32,7 +32,7 @@ private function execute(Process $process): void
         });
 
         if (0 !== $process->getExitCode()) {
-            throw new \RuntimeException(sprintf('Process exited unexpectedly. %s', $process->getCommandLine()));
+            throw new ComposerFailureException($process->getCommandLine(), sprintf('Process exited unexpectedly with output: %s', $process->getErrorOutput()), $process->getExitCode());
         }
     }
 
@@ -86,14 +86,76 @@ public function minimumStability(string $stability): void
         );
     }
 
+    private function clearVendor(): void
+    {
+        $iterator = new \AppendIterator();
+
+        try {
+            $iterator->append(new \GlobIterator($this->workdir.'/composer.*', \FilesystemIterator::CURRENT_AS_FILEINFO | \FilesystemIterator::SKIP_DOTS | \FilesystemIterator::KEY_AS_PATHNAME));
+            $iterator->append(new \RecursiveIteratorIterator(
+                new \RecursiveDirectoryIterator(
+                    $this->workdir.'/vendor',
+                    \FilesystemIterator::KEY_AS_PATHNAME | \FilesystemIterator::CURRENT_AS_FILEINFO | \FilesystemIterator::SKIP_DOTS
+                ),
+                \RecursiveIteratorIterator::CHILD_FIRST,
+            ));
+        } catch (\UnexpectedValueException $e) {
+            $this->logger->warning($e->getMessage());
+        }
+
+        foreach ($iterator as $file) {
+            'dir' === $file->getType() ? rmdir($file->getPathname()) : unlink($file->getPathname());
+        }
+    }
+
     public function init(string $name): void
     {
+        if (file_exists($this->workdir.'/composer.json')) {
+            if (filesize($this->workdir.'/composer.json') <= 2) {
+                $this->clearVendor();
+            } else {
+                try {
+                    $this->allowPlugins('php-http/discovery');
+
+                    return;
+                } catch (ComposerFailureException) {
+                    $this->clearVendor();
+                }
+            }
+        }
+
         $this->command(
             'composer',
             'init',
             '--no-interaction',
             sprintf('--name=%s', $name),
         );
+
+        $this->allowPlugins('php-http/discovery');
+    }
+
+    public function allowPlugins(string ...$plugins): void
+    {
+        foreach ($plugins as $packageName) {
+            $this->command(
+                'composer',
+                'config',
+                sprintf('allow-plugins.%s', $packageName),
+                'true',
+            );
+        }
+    }
+
+    public function denyPlugins(string ...$plugins): void
+    {
+        foreach ($plugins as $packageName) {
+            $this->command(
+                'composer',
+                'config',
+                sprintf('allow-plugins.%s', $packageName),
+                'false',
+            );
+        }
     }
 
     /**

src/Adapter/ComposerFailureException.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Kiboko\Component\Satellite\Adapter;
+
+final class ComposerFailureException extends \RuntimeException
+{
+    public function __construct(private readonly string $command = '', string $message = '', int $code = 0, null|\Throwable $previous = null)
+    {
+        parent::__construct($message, $code, $previous);
+    }
+
+    public function getCommand(): string
+    {
+        return $this->command;
+    }
+}

src/Console/Command/PipelineRunCommand.php

@@ -65,6 +65,11 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             ),
         );
 
+        if (!file_exists('pipeline.php')) {
+            $style->error('The provided path does not contain one single pipeline, did you mean to run "run:workflow"?');
+
+            return \Symfony\Component\Console\Command\Command::FAILURE;
+        }
         /** @var callable(runtime: PipelineRuntimeInterface): \Runtime $pipeline */
         $pipeline = include 'pipeline.php';
 

src/Console/Command/WorkflowRunCommand.php

@@ -61,6 +61,11 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             new \Kiboko\Component\Pipeline\PipelineRunner(new \Psr\Log\NullLogger()),
         );
 
+        if (!file_exists('workflow.php')) {
+            $style->error('The provided path does not contain a workflow, did you mean to run "run:pipeline"?');
+
+            return \Symfony\Component\Console\Command\Command::FAILURE;
+        }
         /** @var callable(runtime: WorkflowRuntimeInterface): \Runtime $workflow */
         $workflow = include 'workflow.php';