kaliop-uk / ezmigrationbundle

Command/MigrationCommand.php

Spacing +1 added lines, -1 removed lines

@@ -95,7 +95,7 @@
 
             $output->writeln('<info>Migration: ' . $migration->name . '</info>');
             $output->writeln('Status: ' . $status);
-            $output->writeln('Executed on: <info>' . ($migration->executionDate != null ? date("Y-m-d H:i:s", $migration->executionDate) : '--'). '</info>');
+            $output->writeln('Executed on: <info>' . ($migration->executionDate != null ? date("Y-m-d H:i:s", $migration->executionDate) : '--') . '</info>');
             $output->writeln('Execution notes: <info>' . $migration->executionError . '</info>');
 
             if ($migration->status == Migration::STATUS_SUSPENDED) {

Core/Helper/ProcessManager.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
         $currentProcesses = array_splice($processesQueue, 0, $maxParallel);
         // start the initial stack of processes
         foreach ($currentProcesses as $process) {
-            $process->start(function ($type, $buffer) use ($callback, $process) {
+            $process->start(function($type, $buffer) use ($callback, $process) {
                 if ($callback) {
                     $callback($type, $buffer, $process);
                 }
@@ -44,7 +44,7 @@ 
                     // directly add and start new process after the previous finished
                     if (count($processesQueue) > 0) {
                         $nextProcess = array_shift($processesQueue);
-                        $nextProcess->start(function ($type, $buffer) use ($callback, $nextProcess) {
+                        $nextProcess->start(function($type, $buffer) use ($callback, $nextProcess) {
                             if ($callback) {
                                 $callback($type, $buffer, $nextProcess);
                             }

Core/ReferenceResolver/EmbeddedRegexpReferenceResolverTrait.php

Spacing +2 added lines, -2 removed lines

@@ -18,7 +18,7 @@ 
     public function hasEmbeddedReferences($string)
     {
         $regexp = $this->getEmbeddedRegexp();
-        return (bool) preg_match_all($regexp, $string, $matches);
+        return (bool)preg_match_all($regexp, $string, $matches);
     }
     
     /**
@@ -52,7 +52,7 @@ 
     {
         // we need to alter the regexp we usr for std ref resolving, as it will be used to match parts of text, not the whole string
         $regexp = substr($this->getRegexp(), 1, -1);
-        return '/' . preg_quote($this->beginToken). preg_replace(array('/^\^/'), array(''), $regexp) . '[^' . $this->endToken . ']+' . preg_quote($this->endToken) . '/';
+        return '/' . preg_quote($this->beginToken) . preg_replace(array('/^\^/'), array(''), $regexp) . '[^' . $this->endToken . ']+' . preg_quote($this->endToken) . '/';
     }
 
     /**

Core/Process/Process.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 
     public static function forceSigchildEnabled($force)
     {
-        self::$forceSigchildEnabled = (bool) $force;
+        self::$forceSigchildEnabled = (bool)$force;
     }
 
     protected function isSigchildEnabled()

Core/Process/ProcessBuilder.php

Spacing +9 added lines, -9 removed lines

@@ -22,23 +22,23 @@
     public function getProcess()
     {
         $parentClass = get_parent_class($this);
-        $this_prefix = \Closure::bind(function(ProcessBuilder $builder){return $builder->prefix;}, null, $parentClass);
+        $this_prefix = \Closure::bind(function(ProcessBuilder $builder) {return $builder->prefix; }, null, $parentClass);
         $this_prefix = $this_prefix($this);
-        $this_arguments = \Closure::bind(function(ProcessBuilder $builder){return $builder->arguments;}, null, $parentClass);
+        $this_arguments = \Closure::bind(function(ProcessBuilder $builder) {return $builder->arguments; }, null, $parentClass);
         $this_arguments = $this_arguments($this);
-        $this_options = \Closure::bind(function(ProcessBuilder $builder){return $builder->options;}, null, $parentClass);
+        $this_options = \Closure::bind(function(ProcessBuilder $builder) {return $builder->options; }, null, $parentClass);
         $this_options = $this_options($this);
-        $this_inheritEnv = \Closure::bind(function(ProcessBuilder $builder){return $builder->inheritEnv;}, null, $parentClass);
+        $this_inheritEnv = \Closure::bind(function(ProcessBuilder $builder) {return $builder->inheritEnv; }, null, $parentClass);
         $this_inheritEnv = $this_inheritEnv($this);
-        $this_env = \Closure::bind(function(ProcessBuilder $builder){return $builder->env;}, null, $parentClass);
+        $this_env = \Closure::bind(function(ProcessBuilder $builder) {return $builder->env; }, null, $parentClass);
         $this_env = $this_env($this);
-        $this_cwd = \Closure::bind(function(ProcessBuilder $builder){return $builder->cwd;}, null, $parentClass);
+        $this_cwd = \Closure::bind(function(ProcessBuilder $builder) {return $builder->cwd; }, null, $parentClass);
         $this_cwd = $this_cwd($this);
-        $this_input = \Closure::bind(function(ProcessBuilder $builder){return $builder->input;}, null, $parentClass);
+        $this_input = \Closure::bind(function(ProcessBuilder $builder) {return $builder->input; }, null, $parentClass);
         $this_input = $this_input($this);
-        $this_timeout = \Closure::bind(function(ProcessBuilder $builder){return $builder->timeout;}, null, $parentClass);
+        $this_timeout = \Closure::bind(function(ProcessBuilder $builder) {return $builder->timeout; }, null, $parentClass);
         $this_timeout = $this_timeout($this);
-        $this_outputDisabled = \Closure::bind(function(ProcessBuilder $builder){return $builder->outputDisabled;}, null, $parentClass);
+        $this_outputDisabled = \Closure::bind(function(ProcessBuilder $builder) {return $builder->outputDisabled; }, null, $parentClass);
         $this_outputDisabled = $this_outputDisabled($this);
 
         if (0 === count($this_prefix) && 0 === count($this_arguments)) {

Command/AbstractCommand.php

Braces +1 added lines, -2 removed lines

@@ -78,8 +78,7 @@
                 $this->errOutput->setVerbosity(OutputInterface::VERBOSITY_NORMAL);
                 $this->errOutput->writeln($message, $type);
                 $this->errOutput->setVerbosity(OutputInterface::VERBOSITY_QUIET);
-            }
-            else
+            } else
             {
                 $this->errOutput->writeln($message, $type);
             }

Core/Executor/TagManager.php

Braces +9 added lines, -3 removed lines

@@ -162,7 +162,9 @@ 
         // sort tags by depth so that there will be no errors in case we are deleting parent and child
         $tagsCollection = $tagsCollection->getArrayCopy();
         uasort($tagsCollection, function ($t1, $t2) {
-            if ($t1->depth == $t2->depth) return 0;
+            if ($t1->depth == $t2->depth) {
+                return 0;
+            }
             return ($t1->depth > $t2->depth) ? -1 : 1;
         });
 
@@ -267,7 +269,9 @@ 
                 // sort top to bottom
                 $tagCollection = $tagCollection->getArrayCopy();
                 uasort($tagCollection, function ($t1, $t2) {
-                    if ($t1->depth == $t2->depth) return 0;
+                    if ($t1->depth == $t2->depth) {
+                        return 0;
+                    }
                     return ($t1->depth > $t2->depth) ? 1 : -1;
                 });
                 break;
@@ -275,7 +279,9 @@ 
                 // sort bottom to top
                 $tagCollection = $tagCollection->getArrayCopy();
                 uasort($tagCollection, function ($t1, $t2) {
-                    if ($t1->depth == $t2->depth) return 0;
+                    if ($t1->depth == $t2->depth) {
+                        return 0;
+                    }
                     return ($t1->depth > $t2->depth) ? -1 : 1;
                 });
                 break;

Spacing +3 added lines, -3 removed lines

@@ -165,7 +165,7 @@ 
 
         // sort tags by depth so that there will be no errors in case we are deleting parent and child
         $tagsCollection = $tagsCollection->getArrayCopy();
-        uasort($tagsCollection, function ($t1, $t2) {
+        uasort($tagsCollection, function($t1, $t2) {
             if ($t1->depth == $t2->depth) return 0;
             return ($t1->depth > $t2->depth) ? -1 : 1;
         });
@@ -272,7 +272,7 @@ 
             case 'create':
                 // sort top to bottom
                 $tagCollection = $tagCollection->getArrayCopy();
-                uasort($tagCollection, function ($t1, $t2) {
+                uasort($tagCollection, function($t1, $t2) {
                     if ($t1->depth == $t2->depth) return 0;
                     return ($t1->depth > $t2->depth) ? 1 : -1;
                 });
@@ -280,7 +280,7 @@ 
             case 'delete':
                 // sort bottom to top
                 $tagCollection = $tagCollection->getArrayCopy();
-                uasort($tagCollection, function ($t1, $t2) {
+                uasort($tagCollection, function($t1, $t2) {
                     if ($t1->depth == $t2->depth) return 0;
                     return ($t1->depth > $t2->depth) ? -1 : 1;
                 });

Core/Matcher/TrashMatcher.php

Braces +3 added lines, -1 removed lines

@@ -56,7 +56,9 @@
 
             $query = new Query();
             $query->limit = $this->queryLimit;
-            if (isset($query->performCount)) $query->performCount = false;
+            if (isset($query->performCount)) {
+                $query->performCount = false;
+            }
             $query->filter = $this->getQueryCriterion($key, $values);
             $results = $this->repository->getTrashService()->findTrashItems($query);
 

Core/MigrationService.php

Braces +3 added lines, -2 removed lines

@@ -599,8 +599,9 @@
      */
     public function getCurrentContext($migrationName)
     {
-        if (!isset($this->migrationContext[$migrationName]))
-            return null;
+        if (!isset($this->migrationContext[$migrationName])) {
+                    return null;
+        }
         $context = $this->migrationContext[$migrationName];
         // avoid attempting to store the current outputInterface when saving the context
         if (isset($context['output'])) {

Spacing +9 added lines, -9 removed lines

@@ -314,7 +314,7 @@ 
         }
 
         if ($migrationDefinition->status == MigrationDefinition::STATUS_INVALID) {
-            throw new MigrationBundleException("Can not execute " . $this->getEntityName($migrationDefinition). " '{$migrationDefinition->name}': {$migrationDefinition->parsingError}");
+            throw new MigrationBundleException("Can not execute " . $this->getEntityName($migrationDefinition) . " '{$migrationDefinition->name}': {$migrationDefinition->parsingError}");
         }
 
         // BC: handling of legacy method call signature
@@ -382,7 +382,7 @@ 
 
         try {
 
-            $i = $stepOffset+1;
+            $i = $stepOffset + 1;
             $finalStatus = Migration::STATUS_DONE;
             $finalMessage = '';
 
@@ -433,7 +433,7 @@ 
                 $finalMessage = "Suspended in execution of step $i: " . $e->getMessage();
             }
 
-            $finalMessage = ($finalMessage != '' && $messageSuffix != '') ? $finalMessage . '. '. $messageSuffix : $finalMessage . $messageSuffix;
+            $finalMessage = ($finalMessage != '' && $messageSuffix != '') ? $finalMessage . '. ' . $messageSuffix : $finalMessage . $messageSuffix;
 
             // in case we have an exception thrown in the commit phase after the last step, make sure we report the correct step
             $i--;
@@ -491,7 +491,7 @@ 
                 }
             }
 
-            $errorMessage = ($errorMessage != '' && $messageSuffix != '') ? $errorMessage . '. '. $messageSuffix : $errorMessage . $messageSuffix;
+            $errorMessage = ($errorMessage != '' && $messageSuffix != '') ? $errorMessage . '. ' . $messageSuffix : $errorMessage . $messageSuffix;
 
             // set migration as failed
             // NB: we use the 'force' flag here because we might be catching an exception happened during the call to
@@ -534,12 +534,12 @@ 
         }
 
         if ($migration->status != Migration::STATUS_SUSPENDED) {
-            throw new MigrationBundleException("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': it is not in suspended status");
+            throw new MigrationBundleException("Can not resume " . $this->getEntityName($migration) . " '{$migration->name}': it is not in suspended status");
         }
 
         $migrationDefinitions = $this->getMigrationsDefinitions(array($migration->path));
         if (!count($migrationDefinitions)) {
-            throw new MigrationBundleException("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': its definition is missing");
+            throw new MigrationBundleException("Can not resume " . $this->getEntityName($migration) . " '{$migration->name}': its definition is missing");
         }
 
         $defs = $migrationDefinitions->getArrayCopy();
@@ -547,17 +547,17 @@ 
 
         $migrationDefinition = $this->parseMigrationDefinition($migrationDefinition);
         if ($migrationDefinition->status == MigrationDefinition::STATUS_INVALID) {
-            throw new MigrationBundleException("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': {$migrationDefinition->parsingError}");
+            throw new MigrationBundleException("Can not resume " . $this->getEntityName($migration) . " '{$migration->name}': {$migrationDefinition->parsingError}");
         }
 
         // restore context
         $this->contextHandler->restoreCurrentContext($migration->name);
         if (!isset($this->migrationContext[$migration->name])) {
-            throw new MigrationBundleException("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': the stored context is missing");
+            throw new MigrationBundleException("Can not resume " . $this->getEntityName($migration) . " '{$migration->name}': the stored context is missing");
         }
         $restoredContext = $this->migrationContext[$migration->name];
         if (!is_array($restoredContext) || !isset($restoredContext['context']) || !isset($restoredContext['step'])) {
-            throw new MigrationBundleException("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': the stored context is invalid");
+            throw new MigrationBundleException("Can not resume " . $this->getEntityName($migration) . " '{$migration->name}': the stored context is invalid");
         }
 
         // update migration status