Updated code to be compatible with php-etl/pipeline-contracts:0.5

Author: gplanchat

src/Console.php

@@ -37,7 +37,7 @@ public function extract(
 
         $this->state->withStep((string) $step)
             ->addMetric('read', $state->observeAccept())
-            ->addMetric('error', fn () => 0)
+            ->addMetric('error', $state->observeError())
             ->addMetric('rejected', $state->observeReject())
         ;
 

src/MemoryState.php

@@ -5,6 +5,7 @@
 namespace Kiboko\Component\Runtime\Pipeline;
 
 use Kiboko\Contract\Pipeline\StateInterface;
+use Kiboko\Contract\Pipeline\StepCodeInterface;
 
 final class MemoryState implements StateInterface
 {
@@ -26,21 +27,21 @@ public function initialize(int $start = 0): void
         $this->decorated?->initialize($start);
     }
 
-    public function accept(int $step = 1): void
+    public function accept(StepCodeInterface $step, int $count = 1): void
     {
-        $this->metrics['accept'] += $step;
+        $this->metrics['accept'] += $count;
         $this->decorated?->accept($step);
     }
 
-    public function reject(int $step = 1): void
+    public function reject(StepCodeInterface $step, int $count = 1): void
     {
-        $this->metrics['reject'] += $step;
+        $this->metrics['reject'] += $count;
         $this->decorated?->reject($step);
     }
 
-    public function error(int $step = 1): void
+    public function error(StepCodeInterface $step, int $count = 1): void
     {
-        $this->metrics['error'] += $step;
+        $this->metrics['error'] += $count;
         $this->decorated?->error($step);
     }
 
@@ -49,6 +50,11 @@ public function observeAccept(): callable
         return fn () => $this->metrics['accept'];
     }
 
+    public function observeError(): callable
+    {
+        return fn () => $this->metrics['error'];
+    }
+
     public function observeReject(): callable
     {
         return fn () => $this->metrics['reject'];

src/Pipeline.php

@@ -10,7 +10,7 @@
 
 final class Pipeline
 {
-    /** @var Step */
+    /** @var list<Step> */
     private array $steps = [];
     private readonly ConsoleSectionOutput $section;
 

src/Step/MemoryState.php

@@ -42,13 +42,13 @@ public function observeAccept(): callable
         return fn () => $this->metrics['accept'];
     }
 
-    public function observeReject(): callable
+    public function observeError(): callable
     {
-        return fn () => $this->metrics['reject'];
+        return fn () => $this->metrics['accept'];
     }
 
-    public function teardown(): void
+    public function observeReject(): callable
     {
-        $this->decorated?->teardown();
+        return fn () => $this->metrics['reject'];
     }
 }