oliverde8 / php-etl

src/Oliverde8/Component/PhpEtl/ChainOperation/Transformer/RuleTransformOperation.php

Spacing +1 added lines, -1 removed lines

@@ -98,7 +98,7 @@
 
         foreach ($variables as $variable) {
             $data['@new'] = $newData;
-            $variableValues[] = ['variable' => $variable,  'value' => AssociativeArray::getFromKey($data, $variable, "")];
+            $variableValues[] = ['variable' => $variable, 'value' => AssociativeArray::getFromKey($data, $variable, "")];
         }
 
         return $variableValues;

src/Oliverde8/Component/PhpEtl/Model/File/LocalFileSystem.php

Spacing +1 added lines, -1 removed lines

@@ -75,7 +75,7 @@
 
     public function listContents(string $path): array
     {
-        $files = scandir($this->rootPath . "/" .$path);
+        $files = scandir($this->rootPath . "/" . $path);
         return $files ?: [];
     }
 

src/Oliverde8/Component/PhpEtl/ChainProcessor.php

Spacing +1 added lines, -1 removed lines

@@ -111,7 +111,7 @@
      *
      * @throws ChainOperationException
      */
-    protected function processItemWithOperation(ItemInterface $item, int $chainNumber, ExecutionContext &$context): ItemInterface
+    protected function processItemWithOperation(ItemInterface $item, int $chainNumber, ExecutionContext & $context): ItemInterface
     {
         try {
             return $this->chainLinks[$chainNumber]->process($item, $context);

src/Oliverde8/Component/PhpEtl/ChainOperation/AbstractChainOperation.php

Spacing +1 added lines, -1 removed lines

@@ -68,7 +68,7 @@
             return true;
         }
 
-        while($class = get_parent_class($class)) {
+        while ($class = get_parent_class($class)) {
             if ($class == $targetClass) {
                 return true;
             }

src/Oliverde8/Component/PhpEtl/ChainOperation/ChainMergeOperation.php

Spacing +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
     {
         $returnItems = [];
         foreach ($this->chainProcessors as $chainProcessor) {
-            $returnItems[] = $chainProcessor->processItemWithChain($item, 0,  $context);
+            $returnItems[] = $chainProcessor->processItemWithChain($item, 0, $context);
         }
 
         // Nothing to process.
@@ -47,7 +47,7 @@ 
     public function processStop(StopItem $item, ExecutionContext $context): ItemInterface
     {
         foreach ($this->chainProcessors as $chainProcessor) {
-            $result = $chainProcessor->processItemWithChain($item, 0,  $context);
+            $result = $chainProcessor->processItemWithChain($item, 0, $context);
 
             if ($result !== $item) {
                 // Return a new stop item in order to continue flushing out data with stop items.

src/Oliverde8/Component/PhpEtl/ChainOperation/ChainSplitOperation.php

Spacing +2 added lines, -2 removed lines

@@ -35,7 +35,7 @@ 
     public function processData(DataItemInterface $item, ExecutionContext $context): ItemInterface
     {
         foreach ($this->chainProcessors as $chainProcessor) {
-            $chainProcessor->processItemWithChain($item, 0,  $context);
+            $chainProcessor->processItemWithChain($item, 0, $context);
         }
 
         // Nothing to process.
@@ -45,7 +45,7 @@ 
     public function processStop(StopItem $item, ExecutionContext $context): ItemInterface
     {
         foreach ($this->chainProcessors as $chainProcessor) {
-            $result = $chainProcessor->processItemWithChain($item, 0,  $context);
+            $result = $chainProcessor->processItemWithChain($item, 0, $context);
 
             if ($result !== $item) {
                 // Return a new stop item in order to continue flushing out data with stop items.

src/Oliverde8/Component/PhpEtl/Model/PerExecutionExecutionContext.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
         }
 
         $logPath = $this->workDir . "/execution.log";
-        if(file_exists($logPath)) {
+        if (file_exists($logPath)) {
             $this->fileSystem->writeStream("execution.log", fopen($logPath, 'r'));
         }
     }