Updated generated code dependencies

php-etl · Nov 21, 2023 · d1357cb · d1357cb
1 parent 2f32599
commit d1357cb
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 9 deletions.
diff --git a/src/Pipeline/Extractor.php b/src/Pipeline/Extractor.php
@@ -67,13 +67,19 @@ public function __invoke(array $config, Pipeline $pipeline, StepRepositoryInterf
         }
 
         if (array_key_exists('code', $config)) {
-            $code = new Node\Scalar\String_($config['code']);
+            $code = $config['code'];
         } else {
-            $code = new node\Scalar\String_(sprintf('%s.%s', $this->plugin, $this->key));
+            $code = sprintf('%s.%s', $this->plugin, $this->key);
         }
 
         $pipeline->addExtractor(
-            $code,
+            new Node\Expr\StaticCall(
+                new Node\Name\FullyQualified('Kiboko\\Component\\Pipeline\\StepCode'),
+                new Node\Identifier('fromString'),
+                [
+                    new Node\Arg(new Node\Scalar\String_($code))
+                ]
+            ),
             $repository->getBuilder()
                 ->withLogger($logger)
                 ->withRejection($rejection)

diff --git a/src/Pipeline/Loader.php b/src/Pipeline/Loader.php
@@ -67,13 +67,19 @@ public function __invoke(array $config, Pipeline $pipeline, StepRepositoryInterf
         }
 
         if (array_key_exists('code', $config)) {
-            $code = new Node\Scalar\String_($config['code']);
+            $code = $config['code'];
         } else {
-            $code = new node\Scalar\String_(sprintf('%s.%s', $this->plugin, $this->key));
+            $code = sprintf('%s.%s', $this->plugin, $this->key);
         }
 
         $pipeline->addLoader(
-            $code,
+            new Node\Expr\StaticCall(
+                new Node\Name\FullyQualified('Kiboko\\Component\\Pipeline\\StepCode'),
+                new Node\Identifier('fromString'),
+                [
+                    new Node\Arg(new Node\Scalar\String_($code))
+                ]
+            ),
             $repository->getBuilder()
                 ->withLogger($logger)
                 ->withRejection($rejection)

diff --git a/src/Pipeline/Transformer.php b/src/Pipeline/Transformer.php
@@ -67,13 +67,19 @@ public function __invoke(array $config, Pipeline $pipeline, StepRepositoryInterf
         }
 
         if (array_key_exists('code', $config)) {
-            $code = new Node\Scalar\String_($config['code']);
+            $code = $config['code'];
         } else {
-            $code = new node\Scalar\String_(sprintf('%s.%s', $this->plugin, $this->key));
+            $code = sprintf('%s.%s', $this->plugin, $this->key);
         }
 
         $pipeline->addTransformer(
-            $code,
+            new Node\Expr\StaticCall(
+                new Node\Name\FullyQualified('Kiboko\\Component\\Pipeline\\StepCode'),
+                new Node\Identifier('fromString'),
+                [
+                    new Node\Arg(new Node\Scalar\String_($code))
+                ]
+            ),
             $repository->getBuilder()
                 ->withLogger($logger)
                 ->withRejection($rejection)