oliverde8 / phpEtlBundle

DependencyInjection/Oliverde8PhpEtlExtension.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
      */
     public function load(array $configs, ContainerBuilder $container)
     {
-        $loader = new YamlFileLoader($container, new FileLocator(\dirname(__DIR__).'/Resources/config'));
+        $loader = new YamlFileLoader($container, new FileLocator(\dirname(__DIR__) . '/Resources/config'));
         $loader->load('parameters.yml');
         $loader->load('services.yml');
         $loader->load('service-rule-transformers.yml');

Entity/EtlExecution.php

Spacing +2 added lines, -2 removed lines

@@ -10,8 +10,8 @@
  */
 class EtlExecution
 {
-    public const STATUS_WAITING ="waiting";
-    public const STATUS_QUEUED ="queued";
+    public const STATUS_WAITING = "waiting";
+    public const STATUS_QUEUED = "queued";
     public const STATUS_RUNNING = "running";
     public const STATUS_SUCCESS = "success";
     public const STATUS_FAILURE = "failure";

Twig/TimeIntervalExtension.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
         $hour = str_pad(floor($time / 60 / 60), 1, '0');
 
         $formattedPieces = [];
-        if ($time > (60*60)) {
+        if ($time > (60 * 60)) {
             $formattedPieces[] = $hour . "h";
         }
         if ($time > (60)) {

EventSubscriber/EtlExecutionEventSubscriber.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      * @param ChainProcessorsManager $chainProcessorManager
      * @param MessageBusInterface $messageBus
      */
-    public function __construct(EntityManagerInterface $em, ChainProcessorsManager $chainProcessorManager, ?MessageBusInterface $messageBus =null)
+    public function __construct(EntityManagerInterface $em, ChainProcessorsManager $chainProcessorManager, ?MessageBusInterface $messageBus = null)
     {
         $this->em = $em;
         $this->chainProcessorManager = $chainProcessorManager;

Model/ExecutionContext.php

Spacing +1 added lines, -1 removed lines

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

Etl/Operation/Cleanup/DeleteFilesForOldExecutionOperation.php

Spacing +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
         }
         try {
             $fileSystem->delete("");
-        } catch (\Exception $exception){}
+        } catch (\Exception $exception) {}
 
         $executionWorkDir = $this->chainWorkDirManager->getLocalTmpWorkDir($entity);
         if (!file_exists($executionWorkDir)) {
@@ -85,7 +85,7 @@ 
                 continue;
             }
 
-            $files[] =$item;
+            $files[] = $item;
         }
 
         return $files;