Merge pull request #2 from php-etl/feature/actions

Added loadAction method

Author: gplanchat

composer.json

@@ -19,9 +19,12 @@
         "php": "^8.2",
         "symfony/console": "^6.0",
         "php-etl/pipeline-contracts": "0.4.*",
+        "php-etl/satellite-contracts": "0.1.*",
         "php-etl/pipeline": "*",
         "php-etl/console-state": "*",
-        "php-etl/pipeline-console-runtime": "*"
+        "php-etl/pipeline-console-runtime": "*",
+        "php-etl/action-console-runtime": "*",
+        "php-etl/action": "*"
     },
     "require-dev": {
         "rector/rector": "^0.15",
@@ -41,7 +44,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-main": "0.2.x-dev"
+            "dev-main": "0.3.x-dev"
         }
     }
 }

composer.lock

@@ -4,18 +4,20 @@
 
 namespace Kiboko\Component\Runtime\Workflow;
 
+use Kiboko\Component\Action\Action;
 use Kiboko\Component\Pipeline\Pipeline;
+use Kiboko\Component\Runtime\Action\Console as ActionConsoleRuntime;
 use Kiboko\Component\Runtime\Pipeline\Console as PipelineConsoleRuntime;
 use Kiboko\Component\State;
 use Kiboko\Contract\Pipeline\PipelineRunnerInterface;
-use Kiboko\Contract\Pipeline\RunnableInterface;
+use Kiboko\Contract\Satellite\RunnableInterface as JobRunnableInterface;
 use Symfony\Component\Console\Output\ConsoleOutput;
 
 final class Console implements WorkflowRuntimeInterface
 {
     private readonly State\StateOutput\Workflow $state;
 
-    /** @var list<RunnableInterface> */
+    /** @var list<JobRunnableInterface> */
     private array $jobs = [];
 
     public function __construct(
@@ -34,7 +36,16 @@ public function loadPipeline(string $filename): PipelineConsoleRuntime
         return $factory(new PipelineConsoleRuntime($this->output, $pipeline, $this->state->withPipeline(basename($filename))));
     }
 
-    public function job(RunnableInterface $job): self
+    public function loadAction(string $filename): ActionConsoleRuntime
+    {
+        $factory = require $filename;
+
+        $action = new Action();
+
+        return $factory(new ActionConsoleRuntime($this->output, $action, $this->state->withAction(basename($filename))));
+    }
+
+    public function job(JobRunnableInterface $job): self
     {
         $this->jobs[] = $job;