refactor interface

src/JobsGraph.php → src/Graph.php

@@ -16,16 +16,16 @@
 use Chevere\DataStructure\Traits\MapTrait;
 use function Chevere\Message\message;
 use Chevere\Throwable\Exceptions\InvalidArgumentException;
-use Chevere\Workflow\Interfaces\JobsGraphInterface;
+use Chevere\Workflow\Interfaces\GraphInterface;
 use Chevere\Workflow\Traits\JobDependenciesTrait;
 use Ds\Vector;
 
-final class JobsGraph implements JobsGraphInterface
+final class Graph implements GraphInterface
 {
     use JobDependenciesTrait;
     use MapTrait;
 
-    public function withPut(string $job, string ...$dependencies): JobsGraphInterface
+    public function withPut(string $job, string ...$dependencies): GraphInterface
     {
         $this->assertDependencies(...$dependencies);
         $vector = new Vector($dependencies);
@@ -106,11 +106,11 @@ public function toArray(): array
                     break;
                 }
             }
-            
+
             $return[$toIndex][] = $job;
             $previous[] = $job;
         }
-        
+
         return $return;
     }
 

src/Interfaces/JobsGraphInterface.php → src/Interfaces/GraphInterface.php

@@ -20,7 +20,7 @@
 /**
  * Describes the component in charge of defining jobs dependencies.
  */
-interface JobsGraphInterface extends MappedInterface, ToArrayInterface
+interface GraphInterface extends MappedInterface, ToArrayInterface
 {
     public function has(string $job): bool;
 
@@ -31,7 +31,7 @@ public function get(string $job): Vector;
 
     public function hasDependencies(string $job, string ...$dependencies): bool;
 
-    public function withPut(string $job, string ...$dependencies): JobsGraphInterface;
+    public function withPut(string $job, string ...$dependencies): GraphInterface;
 
     /**
      * @return Array<int, string[]>

src/Interfaces/WorkflowRunInterface.php → src/Interfaces/RunInterface.php

@@ -20,7 +20,7 @@
 /**
  * Describes the component in charge of defining a workflow run, with arguments returned for each job.
  */
-interface WorkflowRunInterface
+interface RunInterface
 {
     /**
      * @param mixed ...$vars Workflow variables.

src/Interfaces/WorkflowRunnerInterface.php → src/Interfaces/RunnerInterface.php

@@ -18,16 +18,16 @@
 /**
  * Describes the component in charge of running the workflow.
  */
-interface WorkflowRunnerInterface
+interface RunnerInterface
 {
     public function __construct(
-        WorkflowRunInterface $workflowRun,
+        RunInterface $workflowRun,
         ContainerInterface $container
     );
 
-    public function workflowRun(): WorkflowRunInterface;
+    public function run(): RunInterface;
 
-    public function withRun(): WorkflowRunnerInterface;
+    public function withRun(): RunnerInterface;
 
-    public function withRunJob(string $name): WorkflowRunnerInterface;
+    public function withRunJob(string $name): RunnerInterface;
 }

src/Jobs.php

@@ -21,8 +21,8 @@
 use Chevere\Throwable\Exceptions\InvalidArgumentException;
 use Chevere\Throwable\Exceptions\OutOfBoundsException;
 use Chevere\Throwable\Exceptions\OverflowException;
+use Chevere\Workflow\Interfaces\GraphInterface;
 use Chevere\Workflow\Interfaces\JobInterface;
-use Chevere\Workflow\Interfaces\JobsGraphInterface;
 use Chevere\Workflow\Interfaces\JobsInterface;
 use Ds\Vector;
 use Iterator;
@@ -36,13 +36,13 @@ final class Jobs implements JobsInterface
      */
     private Vector $jobs;
 
-    private JobsGraphInterface $graph;
+    private GraphInterface $graph;
 
     public function __construct(JobInterface ...$jobs)
     {
         $this->map = new Map();
         $this->jobs = new Vector();
-        $this->graph = new JobsGraph();
+        $this->graph = new Graph();
         $this->putAdded(...$jobs);
     }
 

src/WorkflowRun.php → src/Run.php

@@ -20,12 +20,12 @@
 use Chevere\Throwable\Errors\TypeError;
 use Chevere\Throwable\Exceptions\OutOfBoundsException;
 use function Chevere\VarSupport\deepCopy;
+use Chevere\Workflow\Interfaces\RunInterface;
 use Chevere\Workflow\Interfaces\WorkflowInterface;
-use Chevere\Workflow\Interfaces\WorkflowRunInterface;
 use Ds\Map;
 use Ramsey\Uuid\Uuid;
 
-final class WorkflowRun implements WorkflowRunInterface
+final class Run implements RunInterface
 {
     /**
      * @var Map<string, ResponseInterface>
@@ -64,7 +64,7 @@ public function arguments(): ArgumentsInterface
         return $this->arguments;
     }
 
-    public function withJobResponse(string $job, ResponseInterface $response): WorkflowRunInterface
+    public function withJobResponse(string $job, ResponseInterface $response): RunInterface
     {
         $new = clone $this;
         $new->workflow->jobs()->get($job);

src/WorkflowRunner.php → src/Runner.php

@@ -24,28 +24,28 @@
 use Chevere\Throwable\Exceptions\RuntimeException;
 use function Chevere\VarSupport\deepCopy;
 use Chevere\Workflow\Interfaces\JobInterface;
-use Chevere\Workflow\Interfaces\WorkflowRunInterface;
-use Chevere\Workflow\Interfaces\WorkflowRunnerInterface;
+use Chevere\Workflow\Interfaces\RunInterface;
+use Chevere\Workflow\Interfaces\RunnerInterface;
 use Psr\Container\ContainerInterface;
 use Throwable;
 
-final class WorkflowRunner implements WorkflowRunnerInterface
+final class Runner implements RunnerInterface
 {
-    /** @var WorkflowRunnerInterface[] */
+    /** @var RunnerInterface[] */
     private array $responses;
 
     public function __construct(
-        private WorkflowRunInterface $workflowRun,
+        private RunInterface $workflowRun,
         private ContainerInterface $container
     ) {
     }
 
-    public function workflowRun(): WorkflowRunInterface
+    public function run(): RunInterface
     {
         return $this->workflowRun;
     }
 
-    public function withRun(): WorkflowRunnerInterface
+    public function withRun(): RunnerInterface
     {
         $new = clone $this;
         $jobs = $new->workflowRun->workflow()->jobs();
@@ -60,7 +60,7 @@ public function withRun(): WorkflowRunnerInterface
             }
 
             try {
-                /** @var WorkflowRunnerInterface[] $responses */
+                /** @var RunnerInterface[] $responses */
                 $responses = wait(all($promises));
                 // @phpstan-ignore-next-line
                 $new->responses = $responses;
@@ -75,16 +75,16 @@ public function withRun(): WorkflowRunnerInterface
                 );
             }
             // @codeCoverageIgnoreEnd
-            /** @var WorkflowRunnerInterface $new */
+            /** @var RunnerInterface $new */
             $new = end($new->responses);
         }
 
         return $new;
     }
 
-    public function withRunJob(string $name): WorkflowRunnerInterface
+    public function withRunJob(string $name): RunnerInterface
     {
-        $job = $this->workflowRun()->workflow()->jobs()->get($name);
+        $job = $this->run()->workflow()->jobs()->get($name);
         $actionName = $job->action();
         /** @var ActionInterface $action */
         $action = new $actionName();