Fixed the new run command

bin/satellite

@@ -25,6 +25,7 @@ $app->addCommands([
     new \Kiboko\Component\Satellite\Console\Command\ValidateCommand(),
     new \Kiboko\Component\Satellite\Console\Command\PipelineRunCommand(),
     new \Kiboko\Component\Satellite\Console\Command\WorkflowRunCommand(),
+    new \Kiboko\Component\Satellite\Console\Command\RunCommand(),
 ]);
 
 $app->run(new Input\ArgvInput(), new Output\ConsoleOutput());

src/Action/ConfigurationApplier.php

@@ -10,8 +10,8 @@
 
 final class ConfigurationApplier
 {
-    private ?Action $action = null;
+    private ?Satellite\Action\Action $action = null;
     private array $packages = [];
 
     public function __construct(
         private readonly string $plugin,
@@ -22,7 +22,7 @@
 
     public function withAction(): self
     {
-        $this->action = new Action($this->plugin, clone $this->interpreter);
+        $this->action = new Satellite\Action\Action($this->plugin, clone $this->interpreter);
 
         return $this;
     }
@@ -34,11 +34,11 @@
         return $this;
     }
 
     public function appendTo(array $config, Satellite\Builder\Repository\Action $action): void
     {
         $repository = $this->service->compile($config[$this->plugin]);
 
         ($this->action)($config, $action->getBuilder(), $repository);
 
         $action->addPackages(...$this->packages);
 

src/Action/Custom/Factory/Action.php

@@ -24,7 +24,7 @@
     private readonly Processor $processor;
     private readonly ConfigurationInterface $configuration;
 
     public function __construct(
         private readonly ExpressionLanguage $interpreter = new Satellite\ExpressionLanguage(),
         private readonly array $providers = [],
     ) {
@@ -63,7 +63,7 @@
     /**
      * @throws Configurator\ConfigurationExceptionInterface
      */
-    public function compile(array $config): Repository\Action
+    public function compile(array $config): Custom\Factory\Repository\Action
     {
         $containerName = sprintf('ProjectServiceContainer%s', ByteString::fromRandom(8)->toString());
 
@@ -74,14 +74,14 @@
 
         $container = (new SatelliteDependencyInjection(...$this->providers))($config);
 
-        $repository = new Repository\Action($builder);
+        $repository = new Custom\Factory\Repository\Action($builder);
 
         $dumper = new PhpDumper($container);
         $repository->addFiles(
             new Packaging\File(
                 sprintf('%s.php', $containerName),
                 new Packaging\Asset\InMemory(
                     $dumper->dump(['class' => $containerName, 'namespace' => 'GyroscopsGenerated'])
                 )
             ),
         );

src/Action/Custom/Service.php

@@ -13,6 +13,9 @@
 
 #[Configurator\Action(
     name: 'custom',
+    dependencies: [
+        'symfony/dependency-injection:^6.0'
+    ],
 )]
 final readonly class Service implements Configurator\ActionInterface
 {
@@ -71,7 +74,7 @@
             && \count($config['expression_language'])
         ) {
             foreach ($config['expression_language'] as $provider) {
                 $interpreter->registerProvider(new $provider());
             }
         }
 

src/Adapter/AdapterChoice.php

@@ -8,12 +8,12 @@
 
 final readonly class AdapterChoice
 {
     public function __construct(
         private array $adapters,
     ) {
     }
 
     public function __invoke(array $configuration): Configurator\SatelliteBuilderInterface
     {
         $factory = null;
         foreach ($this->adapters as $alias => $adapter) {
@@ -23,7 +23,7 @@
             }
         }
 
-        \assert($factory instanceof \Kiboko\Contract\Configurator\Adapter\FactoryInterface, new AdapterNotFoundException('No compatible adapter was found for your satellite configuration.'));
+        \assert($factory instanceof Configurator\Adapter\FactoryInterface, new AdapterNotFoundException('No compatible adapter was found for your satellite configuration.'));
 
         return $factory($configuration);
     }

src/Cloud/Pipeline.php

@@ -83,7 +83,7 @@ function (string $namespace) {
         );
     }
 
-    public static function fromApiWithId(Api\Client $client, PipelineId $id, array $configuration): DTO\ReferencedPipeline
+    public static function fromApiWithId(Api\Client $client, PipelineId $id, array $configuration): ReferencedPipeline
     {
         $item = $client->getPipelineItem($id->asString());
 
@@ -99,7 +99,7 @@ public static function fromApiWithId(Api\Client $client, PipelineId $id, array $
         );
     }
 
-    public static function fromApiWithCode(Api\Client $client, string $code, array $configuration): DTO\ReferencedPipeline
+    public static function fromApiWithCode(Api\Client $client, string $code, array $configuration): ReferencedPipeline
     {
         $collection = $client->getPipelineCollection(['code' => $code]);
 
@@ -199,7 +199,7 @@ public function create(DTO\PipelineInterface $pipeline): DTO\CommandBatch
         );
     }
 
-    public function update(DTO\ReferencedPipeline $actual, DTO\PipelineInterface $desired): DTO\CommandBatch
+    public function update(ReferencedPipeline $actual, DTO\PipelineInterface $desired): DTO\CommandBatch
     {
         if ($actual->code() !== $desired->code()) {
             throw new \RuntimeException('Code does not match between actual and desired pipeline definition.');
@@ -220,7 +220,7 @@ public function update(DTO\ReferencedPipeline $actual, DTO\PipelineInterface $de
         return new DTO\CommandBatch(...$commands);
     }
 
-    public function remove(DTO\PipelineId $id): DTO\CommandBatch
+    public function remove(PipelineId $id): DTO\CommandBatch
     {
         return new DTO\CommandBatch(
             new Command\Pipeline\RemovePipelineCommand($id),

src/Cloud/PipelineInterface.php

@@ -19,5 +19,5 @@ public function create(DTO\PipelineInterface $pipeline): DTO\CommandBatch;
 
     public function update(DTO\ReferencedPipeline $actual, DTO\PipelineInterface $desired): DTO\CommandBatch;
 
-    public function remove(DTO\PipelineId $id): DTO\CommandBatch;
+    public function remove(PipelineId $id): DTO\CommandBatch;
 }

src/ComposerScripts.php

@@ -15,7 +15,7 @@ final class ComposerScripts
     public static function postInstall(Event $event): void
     {
         self::updatePlugins(
-            $packages = new Composer\Accumulator(),
+            $packages = new Accumulator(),
             $repository = $event->getComposer()
                 ->getRepositoryManager()
                 ->getLocalRepository(),
@@ -26,7 +26,7 @@ public static function postInstall(Event $event): void
     public static function postUpdate(Event $event): void
     {
         self::updatePlugins(
-            $packages = new Composer\Accumulator(),
+            $packages = new Accumulator(),
             $repository = $event->getComposer()
                 ->getRepositoryManager()
                 ->getLocalRepository(),

src/ConfigLoader.php

@@ -8,7 +8,7 @@
 use Kiboko\Contract\Configurator\InvalidConfigurationException;
 use Symfony\Component\Config;
 
-class ConfigLoader implements ConfigLoaderInterface
+class ConfigLoader implements Satellite\ConfigLoaderInterface
 {
     public function __construct(private readonly string $basePath)
     {

src/Console/Command/BuildCommand.php

@@ -126,6 +126,6 @@ public function log($level, $message, array $context = []): void
             }
         }
 
-        return \Symfony\Component\Console\Command\Command::SUCCESS;
+        return Console\Command\Command::SUCCESS;
     }
 }

src/Console/Command/ValidateCommand.php

@@ -76,6 +76,6 @@ protected function execute(Console\Input\InputInterface $input, Console\Output\O
 
         $style->writeln(json_encode($configuration, \JSON_PRETTY_PRINT));
 
-        return \Symfony\Component\Console\Command\Command::SUCCESS;
+        return Console\Command\Command::SUCCESS;
     }
 }

src/Console/Command/WorkflowRunCommand.php

@@ -9,7 +9,7 @@
 use Symfony\Component\Console\Output\OutputInterface;
 
 #[Console\Attribute\AsCommand('run:workflow', 'Run a data flow satellite (pipeline or workflow).', hidden: true)]
-final class WorkflowRunCommand extends Console\Command\Command
+final class WorkflowRunCommand extends RunCommand
 {
     protected function configure(): void
     {

src/Feature/Logger/Factory/ElasticSearchFactory.php

@@ -53,7 +53,7 @@ public function validate(array $config): bool
         return false;
     }
 
-    public function compile(array $config): Repository\ElasticSearchRepository
+    public function compile(array $config): Logger\Factory\Repository\ElasticSearchRepository
     {
         $builder = new Logger\Builder\Monolog\ElasticSearchBuilder($this->interpreter);
 
@@ -69,6 +69,6 @@ public function compile(array $config): Repository\ElasticSearchRepository
             $builder->withIndex($config['index']);
         }
 
-        return new Repository\ElasticSearchRepository($builder);
+        return new Logger\Factory\Repository\ElasticSearchRepository($builder);
     }
 }

src/Feature/Logger/Factory/GelfFactory.php

@@ -50,7 +50,7 @@ public function validate(array $config): bool
         return false;
     }
 
-    public function compile(array $config): Repository\GelfRepository
+    public function compile(array $config): Logger\Factory\Repository\GelfRepository
     {
         $builder = new Logger\Builder\Monolog\GelfBuilder();
 
@@ -74,6 +74,6 @@ public function compile(array $config): Repository\GelfRepository
             );
         }
 
-        return new Repository\GelfRepository($builder);
+        return new Logger\Factory\Repository\GelfRepository($builder);
     }
 }

src/Feature/Logger/Factory/StreamFactory.php

@@ -50,7 +50,7 @@ public function validate(array $config): bool
         return false;
     }
 
-    public function compile(array $config): Repository\StreamRepository
+    public function compile(array $config): Logger\Factory\Repository\StreamRepository
     {
         $builder = new Logger\Builder\Monolog\StreamBuilder($config['path']);
 
@@ -66,6 +66,6 @@ public function compile(array $config): Repository\StreamRepository
             $builder->withLocking($config['use_locking']);
         }
 
-        return new Repository\StreamRepository($builder);
+        return new Logger\Factory\Repository\StreamRepository($builder);
     }
 }

src/Feature/Logger/Factory/SyslogFactory.php

@@ -50,7 +50,7 @@ public function validate(array $config): bool
         return false;
     }
 
-    public function compile(array $config): Repository\SyslogRepository
+    public function compile(array $config): Logger\Factory\Repository\SyslogRepository
     {
         $builder = new Logger\Builder\Monolog\SyslogBuilder($config['ident']);
 
@@ -66,6 +66,6 @@ public function compile(array $config): Repository\SyslogRepository
             $builder->withLogopts($config['logopts']);
         }
 
-        return new Repository\SyslogRepository($builder);
+        return new Logger\Factory\Repository\SyslogRepository($builder);
     }
 }

src/Feature/Rejection/Builder/RabbitMQBuilder.php

@@ -44,25 +44,25 @@ public function withExchange(
     public function getNode(): Node\Expr
     {
         $args = [
-            new Node\Arg($this->host, name: new Node\Identifier('host')),
-            new Node\Arg($this->vhost, name: new Node\Identifier('vhost')),
-            new Node\Arg($this->topic, name: new Node\Identifier('topic')),
-            new Node\Arg($this->stepUuid, name: new Node\Identifier('stepUuid')),
+            new Node\Arg($this->host, name: new Identifier('host')),
+            new Node\Arg($this->vhost, name: new Identifier('vhost')),
+            new Node\Arg($this->topic, name: new Identifier('topic')),
+            new Node\Arg($this->stepUuid, name: new Identifier('stepUuid')),
         ];
 
         if (null !== $this->exchange) {
-            $args[] = new Node\Arg($this->exchange, name: new Node\Identifier('exchange'));
+            $args[] = new Node\Arg($this->exchange, name: new Identifier('exchange'));
         }
 
         if (null !== $this->port) {
-            $args[] = new Node\Arg($this->port, name: new Node\Identifier('port'));
+            $args[] = new Node\Arg($this->port, name: new Identifier('port'));
         }
 
         if (null !== $this->user) {
             array_push(
                 $args,
-                new Node\Arg($this->user, name: new Node\Identifier('user')),
-                new Node\Arg($this->password, name: new Node\Identifier('password')),
+                new Node\Arg($this->user, name: new Identifier('user')),
+                new Node\Arg($this->password, name: new Identifier('password')),
             );
 
             return new Node\Expr\StaticCall(

src/Feature/Rejection/Factory/RabbitMQFactory.php

@@ -55,7 +55,7 @@ public function validate(array $config): bool
         return false;
     }
 
-    public function compile(array $config): Repository\RabbitMQRepository
+    public function compile(array $config): Rejection\Factory\Repository\RabbitMQRepository
     {
         $builder = new Rejection\Builder\RabbitMQBuilder(
             stepUuid: compileValueWhenExpression($this->interpreter, uniqid()),
@@ -76,6 +76,6 @@ public function compile(array $config): Repository\RabbitMQRepository
             $builder->withExchange(compileValueWhenExpression($this->interpreter, $config['exchange']));
         }
 
-        return new Repository\RabbitMQRepository($builder);
+        return new Rejection\Factory\Repository\RabbitMQRepository($builder);
     }
 }

src/Plugin/Custom/Factory/Extractor.php

@@ -63,7 +63,7 @@ public function validate(array $config): bool
     /**
      * @throws Configurator\ConfigurationExceptionInterface
      */
-    public function compile(array $config): Repository\Extractor
+    public function compile(array $config): Custom\Factory\Repository\Extractor
     {
         $containerName = sprintf('ProjectServiceContainer%s', ByteString::fromRandom(8)->toString());
 
@@ -74,7 +74,7 @@ public function compile(array $config): Repository\Extractor
 
         $container = (new SatelliteDependencyInjection(...$this->providers))($config);
 
-        $repository = new Repository\Extractor($builder);
+        $repository = new Custom\Factory\Repository\Extractor($builder);
 
         $dumper = new PhpDumper($container);
         $repository->addFiles(

src/Plugin/Custom/Factory/Loader.php

@@ -63,7 +63,7 @@ public function validate(array $config): bool
     /**
      * @throws Configurator\ConfigurationExceptionInterface
      */
-    public function compile(array $config): Repository\Loader
+    public function compile(array $config): Custom\Factory\Repository\Loader
     {
         $containerName = sprintf('ProjectServiceContainer%s', ByteString::fromRandom(8)->toString());
 
@@ -74,7 +74,7 @@ public function compile(array $config): Repository\Loader
 
         $container = (new SatelliteDependencyInjection(...$this->providers))($config);
 
-        $repository = new Repository\Loader($builder);
+        $repository = new Custom\Factory\Repository\Loader($builder);
 
         $dumper = new PhpDumper($container);
         $repository->addFiles(

src/Plugin/Custom/Factory/Transformer.php

@@ -63,7 +63,7 @@ public function validate(array $config): bool
     /**
      * @throws Configurator\ConfigurationExceptionInterface
      */
-    public function compile(array $config): Repository\Transformer
+    public function compile(array $config): Custom\Factory\Repository\Transformer
     {
         $containerName = sprintf('ProjectServiceContainer%s', ByteString::fromRandom(8)->toString());
 
@@ -74,7 +74,7 @@ public function compile(array $config): Repository\Transformer
 
         $container = (new SatelliteDependencyInjection(...$this->providers))($config);
 
-        $repository = new Repository\Transformer($builder);
+        $repository = new Custom\Factory\Repository\Transformer($builder);
 
         $dumper = new PhpDumper($container);
         $repository->addFiles(

src/Plugin/Custom/Service.php

@@ -13,11 +13,14 @@
 
 #[Configurator\Pipeline(
     name: 'custom',
+    dependencies: [
+        'symfony/dependency-injection:^6.0'
+    ],
     steps: [
         new Configurator\Pipeline\StepExtractor(),
         new Configurator\Pipeline\StepTransformer(),
         new Configurator\Pipeline\StepLoader(),
-    ],
+    ]
 )] final readonly class Service implements Configurator\PipelinePluginInterface
 {
     private Processor $processor;
@@ -27,7 +30,7 @@ public function __construct(
         private ExpressionLanguage $interpreter = new Satellite\ExpressionLanguage()
     ) {
         $this->processor = new Processor();
-        $this->configuration = new Configuration();
+        $this->configuration = new Custom\Configuration();
     }
 
     public function interpreter(): ExpressionLanguage