Changed namespace and added php-etl/console-state into dependencies

Author: sebprt

composer.json

@@ -18,16 +18,17 @@
     "require": {
         "php": "^8.0",
         "symfony/console": "^5.2",
-        "php-etl/pipeline-contracts": "^0.3.0"
+        "php-etl/pipeline-contracts": "^0.3.0",
+        "php-etl/console-state": "^0.1.0"
     },
     "autoload": {
         "psr-4": {
-            "Kiboko\\Component\\Runtime\\PipelineConsoleRuntime\\": "src/"
+            "Kiboko\\Component\\Runtime\\Pipeline\\": "src/"
         }
     },
     "autoload-dev": {
         "psr-4": {
-            "functional\\Kiboko\\Component\\Runtime\\PipelineConsoleRuntime\\": "tests/unit/"
+            "functional\\Kiboko\\Component\\Runtime\\Pipeline\\": "tests/unit/"
         }
     },
     "config": {

composer.lock

@@ -1,7 +1,8 @@
 <?php declare(strict_types=1);
 
-namespace Kiboko\Component\Runtime\PipelineConsoleRuntime;
+namespace Kiboko\Component\Runtime\Pipeline;
 
+use Kiboko\Component\State;
 use Kiboko\Contract\Pipeline\ExtractorInterface;
 use Kiboko\Contract\Pipeline\TransformerInterface;
 use Kiboko\Contract\Pipeline\LoaderInterface;
@@ -12,22 +13,22 @@
 
 final class PipelineConsoleRuntime implements PipelineRuntimeInterface
 {
-    private StateOutput\Pipeline $state;
+    private State\StateOutput\Pipeline $state;
 
     public function __construct(
         ConsoleOutput $output,
         private PipelineInterface $pipeline,
-        ?StateOutput\Pipeline $state = null
+        ?State\StateOutput\Pipeline $state = null
     ) {
-        $this->state = $state  ?? new StateOutput\Pipeline($output, 'A', 'Pipeline');
+        $this->state = $state ?? new State\StateOutput\Pipeline($output, 'A', 'Pipeline');
     }
 
     public function extract(
         ExtractorInterface $extractor,
         RejectionInterface $rejection,
         StateInterface $state,
     ): self {
-        $this->pipeline->extract($extractor, $rejection, $state = new MemoryState($state));
+        $this->pipeline->extract($extractor, $rejection, $state = new State\MemoryState($state));
 
         $this->state->withStep('extractor')
             ->addMetric('read', $state->observeAccept())
@@ -42,7 +43,7 @@ public function transform(
         RejectionInterface $rejection,
         StateInterface $state,
     ): self {
-        $this->pipeline->transform($transformer, $rejection, $state = new MemoryState($state));
+        $this->pipeline->transform($transformer, $rejection, $state = new State\MemoryState($state));
 
         $this->state->withStep('transformer')
             ->addMetric('read', $state->observeAccept())
@@ -57,7 +58,7 @@ public function load(
         RejectionInterface $rejection,
         StateInterface $state,
     ): self {
-        $this->pipeline->load($loader, $rejection, $state = new MemoryState($state));
+        $this->pipeline->load($loader, $rejection, $state = new State\MemoryState($state));
 
         $this->state->withStep('loader')
             ->addMetric('read', $state->observeAccept())

src/PipelineConsoleRuntime.php

@@ -1,6 +1,6 @@
 <?php declare(strict_types=1);
 
-namespace Kiboko\Component\Runtime\PipelineConsoleRuntime;
+namespace Kiboko\Component\Runtime\Pipeline;
 
 use Kiboko\Contract\Pipeline\ExtractingInterface;
 use Kiboko\Contract\Pipeline\LoadingInterface;