Added php-etl/action-contracts + added rector action

Author: sebprt

.github/workflows/phpstan-7.yaml

@@ -15,7 +15,6 @@ jobs:
         with:
           args: --prefer-dist
           php_version: 8.2
-
       - name: PHPStan
         uses: php-actions/phpstan@v3
         with:

.github/workflows/phpstan-8.yaml

@@ -15,7 +15,6 @@ jobs:
         with:
           args: --prefer-dist
           php_version: 8.2
-
       - name: PHPStan
         uses: php-actions/phpstan@v3
         with:

.github/workflows/rector.yaml

@@ -0,0 +1,34 @@
+# github action that checks code with Rector
+name: Rector
+
+on: pull_request
+
+jobs:
+    rector:
+        runs-on: ubuntu-latest
+        if: github.event.pull_request.head.repo.full_name == 'php-etl/action-console-runtime'
+        steps:
+            -
+                if: github.event.pull_request.head.repo.full_name == github.repository
+                uses: actions/checkout@v3
+                with:
+                    # Must be used to trigger workflow after push
+                    token: ${{ secrets.ACCESS_TOKEN }}
+
+            -
+                uses: shivammathur/setup-php@v2
+                with:
+                    php-version: 8.1
+                    coverage: none
+
+            -   uses: "ramsey/composer-install@v2"
+
+            -   run: bin/rector --ansi
+
+            -
+                # commit only to core contributors who have repository access
+                uses: stefanzweifel/git-auto-commit-action@v4
+                with:
+                    commit_message: '[rector] Rector fixes'
+                    commit_author: 'GitHub Action <[email protected]>'
+                    commit_user_email: '[email protected]'

composer.json

@@ -18,8 +18,8 @@
     "require": {
         "php": "^8.2",
         "symfony/console": "^5.2",
-        "php-etl/pipeline-contracts": "^0.3.0",
-        "php-etl/console-state": "^0.1.0"
+        "php-etl/console-state": "^0.1.0",
+        "php-etl/action-contracts": "^0.1.0"
     },
     "autoload": {
         "psr-4": {

composer.lock

@@ -11,7 +11,6 @@
 return static function (RectorConfig $rectorConfig): void {
     $rectorConfig->paths([
         __DIR__ . '/src',
-        __DIR__ . '/tests',
     ]);
 
     $rectorConfig->rule(InlineConstructorDefaultToPropertyRector::class);

rector.php

@@ -2,10 +2,10 @@
 
 namespace Kiboko\Component\Runtime\Action;
 
-use Kiboko\Contract\Pipeline\ActionInterface;
-use Kiboko\Contract\Pipeline\RejectionInterface;
-use Kiboko\Contract\Pipeline\RunnableInterface;
-use Kiboko\Contract\Pipeline\StateInterface;
+use Kiboko\Contract\Action\ActionInterface;
+use Kiboko\Contract\Action\RejectionInterface;
+use Kiboko\Contract\Action\RunnableInterface;
+use Kiboko\Contract\Action\StateInterface;
 
 interface ActionRuntimeInterface extends RunnableInterface
 {

src/ActionRuntimeInterface.php

@@ -3,10 +3,11 @@
 namespace Kiboko\Component\Runtime\Action;
 
 use Kiboko\Component\State;
-use Kiboko\Contract\Pipeline\ActionInterface;
-use Kiboko\Contract\Pipeline\ExecutingActionInterface;
-use Kiboko\Contract\Pipeline\RejectionInterface;
-use Kiboko\Contract\Pipeline\StateInterface;
+use Kiboko\Contract\Action\ActionState;
+use Kiboko\Contract\Action\ActionInterface;
+use Kiboko\Contract\Action\ExecutingActionInterface;
+use Kiboko\Contract\Action\RejectionInterface;
+use Kiboko\Contract\Action\StateInterface;
 use Symfony\Component\Console\Output\ConsoleOutput;
 
 final class Console implements ActionRuntimeInterface
@@ -26,7 +27,7 @@ public function execute(
         RejectionInterface $rejection,
         StateInterface $state,
     ): self {
-        $this->action->execute($action, $rejection, $state = new State\MemoryState($state));
+        $this->action->execute($action, $rejection, $state = new ActionState($state));
 
         $this->state
             ->addMetric('read', $state->observeAccept())
@@ -38,14 +39,8 @@ public function execute(
 
     public function run(int $interval = 1000): int
     {
-        $line = 0;
-        foreach ($this->action->walk() as $item) {
-            if ($line++ % $interval === 0) {
-                $this->state->update();
-            }
-        };
         $this->state->update();
 
-        return $line;
+        return 1;
     }
 }