kaliop-uk / ezmigrationbundle

Core/Matcher/QueryBasedMatcher.php

Spacing +7 added lines, -7 removed lines

@@ -148,7 +148,7 @@ 
                 return new Query\Criterion\DateMetadata(Query\Criterion\DateMetadata::CREATED, self::$operatorsMap[$operator], $match);
 
             case self::MATCH_GROUP:
-                foreach($values as &$value) {
+                foreach ($values as &$value) {
                     if (!ctype_digit($value)) {
                         $value = $this->groupMatcher->matchOneByKey($value)->id;
                     }
@@ -167,7 +167,7 @@ 
                 return new Query\Criterion\DateMetadata(Query\Criterion\DateMetadata::MODIFIED, self::$operatorsMap[$operator], $match);
 
             case self::MATCH_OBJECT_STATE:
-                foreach($values as &$value) {
+                foreach ($values as &$value) {
                     if (!ctype_digit($value)) {
                         $value = $this->stateMatcher->matchOneByKey($value)->id;
                     }
@@ -175,7 +175,7 @@ 
                 return new Query\Criterion\ObjectStateId($values);
 
             case self::MATCH_OWNER:
-                foreach($values as &$value) {
+                foreach ($values as &$value) {
                     if (!ctype_digit($value)) {
                         $value = $this->userMatcher->matchOneByKey($value)->id;
                     }
@@ -195,7 +195,7 @@ 
                 return new Query\Criterion\ParentLocationId($locationIds);
 
             case self::MATCH_SECTION:
-                foreach($values as &$value) {
+                foreach ($values as &$value) {
                     if (!ctype_digit($value)) {
                         $value = $this->sectionMatcher->matchOneByKey($value)->id;
                     }
@@ -216,7 +216,7 @@ 
 
             case self::MATCH_AND:
                 $subCriteria = array();
-                foreach($values as $subCriterion) {
+                foreach ($values as $subCriterion) {
                     $value = reset($subCriterion);
                     $subCriteria[] = $this->getQueryCriterion(key($subCriterion), $value);
                 }
@@ -224,7 +224,7 @@ 
 
             case self::MATCH_OR:
                 $subCriteria = array();
-                foreach($values as $subCriterion) {
+                foreach ($values as $subCriterion) {
                     $value = reset($subCriterion);
                     $subCriteria[] = $this->getQueryCriterion(key($subCriterion), $value);
                 }
@@ -266,7 +266,7 @@ 
 
             $direction = $this->hash2SortOrder($sortItem['sort_order']);
 
-            switch($sortItem['sort_field']) {
+            switch ($sortItem['sort_field']) {
                 case self::SORT_CONTENT_ID:
                     $out[] = new SortClause\ContentId($direction);
                     break;

Core/FieldHandler/EzSelection.php

Spacing +2 added lines, -2 removed lines

@@ -36,7 +36,7 @@ 
 
         // allow user to pass in selection values by name
         $fieldSettings = null;
-        foreach($fieldValue as $key => $val) {
+        foreach ($fieldValue as $key => $val) {
 
             $val = $this->referenceResolver->resolveReference($val);
 
@@ -47,7 +47,7 @@ 
                     if ($fieldSettings === null) {
                         $fieldSettings = $this->loadFieldSettings($context['contentTypeIdentifier'], $context['fieldIdentifier']);
                     }
-                    foreach($fieldSettings['options'] as $pos => $name) {
+                    foreach ($fieldSettings['options'] as $pos => $name) {
                         if ($name === $val) {
                             $fieldValue[$key] = $pos;
                             break;

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/MassMigrateCommand.php

Spacing +12 added lines, -12 removed lines

@@ -132,7 +132,7 @@ 
 
         $processes = array();
         /** @var MigrationDefinition $migrationDefinition */
-        foreach($paths as $path => $count) {
+        foreach ($paths as $path => $count) {
             $this->writeln("<info>Queueing processing of: $path ($count migrations)</info>", OutputInterface::VERBOSITY_VERBOSE);
 
             $process = $builder
@@ -179,14 +179,14 @@ 
         }
 
         $missed = $total - $this->migrationsDone[Migration::STATUS_DONE] - $this->migrationsDone[Migration::STATUS_FAILED] - $this->migrationsDone[Migration::STATUS_SKIPPED];
-        $this->writeln("\nExecuted ".$this->migrationsDone[Migration::STATUS_DONE].' migrations'.
-            ', failed '.$this->migrationsDone[Migration::STATUS_FAILED].
-            ', skipped '.$this->migrationsDone[Migration::STATUS_SKIPPED].
+        $this->writeln("\nExecuted " . $this->migrationsDone[Migration::STATUS_DONE] . ' migrations' .
+            ', failed ' . $this->migrationsDone[Migration::STATUS_FAILED] .
+            ', skipped ' . $this->migrationsDone[Migration::STATUS_SKIPPED] .
             ($missed ? ", missed $missed" : ''));
 
         $time = microtime(true) - $start;
         // since we use subprocesses, we can not measure max memory used
-        $this->writeln("<info>Time taken: ".sprintf('%.2f', $time)." secs</info>");
+        $this->writeln("<info>Time taken: " . sprintf('%.2f', $time) . " secs</info>");
 
         return $subprocessesFailed + $this->migrationsDone[Migration::STATUS_FAILED] + $missed;
     }
@@ -228,7 +228,7 @@ 
         foreach ($toExecute as  $name => $migrationDefinition) {
             // let's skip migrations that we know are invalid - user was warned and he decided to proceed anyway
             if ($migrationDefinition->status == MigrationDefinition::STATUS_INVALID) {
-                $this->writeln("<comment>Skipping migration (invalid definition?) Path: ".$migrationDefinition->path."</comment>", self::VERBOSITY_CHILD);
+                $this->writeln("<comment>Skipping migration (invalid definition?) Path: " . $migrationDefinition->path . "</comment>", self::VERBOSITY_CHILD);
                 $skipped++;
                 continue;
             }
@@ -268,7 +268,7 @@ 
                     $this->executeMigrationInProcess($migrationDefinition, $force, $migrationService, $input);
 
                     $executed++;
-                } catch(\Exception $e) {
+                } catch (\Exception $e) {
                     $failed++;
 
                     $errorMessage = $e->getMessage();
@@ -301,7 +301,7 @@ 
      * @param string $buffer
      * @param null|\Symfony\Component\Process\Process $process
      */
-    public function onChildProcessOutput($type, $buffer, $process=null)
+    public function onChildProcessOutput($type, $buffer, $process = null)
     {
         $lines = explode("\n", trim($buffer));
 
@@ -319,7 +319,7 @@ 
 
             // we tag the output with the id of the child process
             if (trim($line) !== '') {
-                $msg = '[' . ($process ? $process->getPid() : ''). '] ' . trim($line);
+                $msg = '[' . ($process ? $process->getPid() : '') . '] ' . trim($line);
                 if ($type == 'err') {
                     $this->writeErrorln($msg, OutputInterface::VERBOSITY_QUIET, OutputInterface::OUTPUT_RAW);
                 } else {
@@ -353,7 +353,7 @@ 
 
         // filter away all migrations except 'to do' ones
         $toExecute = array();
-        foreach($migrationDefinitions as $name => $migrationDefinition) {
+        foreach ($migrationDefinitions as $name => $migrationDefinition) {
             if (!isset($migrations[$name]) || (($migration = $migrations[$name]) && in_array($migration->status, $allowedStatuses))) {
                 $toExecute[$name] = $isChild ? $migrationService->parseMigrationDefinition($migrationDefinition) : $migrationDefinition;
             }
@@ -395,7 +395,7 @@ 
     {
         $output->writeln('Found ' . count($toExecute) . ' migrations in ' . count($paths) . ' directories');
         $output->writeln('In the same directories, migrations previously executed: ' . $this->migrationsAlreadyDone[Migration::STATUS_DONE] .
-            ', failed: ' . $this->migrationsAlreadyDone[Migration::STATUS_FAILED] . ', skipped: '. $this->migrationsAlreadyDone[Migration::STATUS_SKIPPED]);
+            ', failed: ' . $this->migrationsAlreadyDone[Migration::STATUS_FAILED] . ', skipped: ' . $this->migrationsAlreadyDone[Migration::STATUS_SKIPPED]);
         if ($this->migrationsAlreadyDone[Migration::STATUS_STARTED]) {
             $output->writeln('<info>In the same directories, migrations currently executing: ' . $this->migrationsAlreadyDone[Migration::STATUS_STARTED] . '</info>');
         }
@@ -408,7 +408,7 @@ 
     protected function groupMigrationsByPath($toExecute)
     {
         $paths = array();
-        foreach($toExecute as $name => $migrationDefinition) {
+        foreach ($toExecute as $name => $migrationDefinition) {
             $path = dirname($migrationDefinition->path);
             if (!isset($paths[$path])) {
                 $paths[$path] = 1;

Command/MigrateCommand.php

Spacing +3 added lines, -3 removed lines

@@ -213,9 +213,9 @@ 
         $time = microtime(true) - $start;
         if ($input->getOption('separate-process')) {
             // in case of using subprocesses, we can not measure max memory used
-            $this->writeln("<info>Time taken: ".sprintf('%.2f', $time)." secs</info>");
+            $this->writeln("<info>Time taken: " . sprintf('%.2f', $time) . " secs</info>");
         } else {
-            $this->writeln("<info>Time taken: ".sprintf('%.2f', $time)." secs, memory: ".sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)). ' MB</info>');
+            $this->writeln("<info>Time taken: " . sprintf('%.2f', $time) . " secs, memory: " . sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)) . ' MB</info>');
         }
 
         return $failed;
@@ -442,7 +442,7 @@ 
             $builderArgs[] = '--no-debug';
         }
         if ($input->getOption('siteaccess')) {
-            $builderArgs[] = '--siteaccess='.$input->getOption('siteaccess');
+            $builderArgs[] = '--siteaccess=' . $input->getOption('siteaccess');
         }
         switch ($this->verbosity) {
             case OutputInterface::VERBOSITY_VERBOSE:

Core/Executor/TagManager.php

Spacing +4 added lines, -4 removed lines

@@ -161,7 +161,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;
         });
@@ -266,7 +266,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;
                 });
@@ -274,7 +274,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;
                 });
@@ -352,7 +352,7 @@ 
     protected function getTagKeywords($tag)
     {
         $out = array();
-        foreach($tag->languageCodes as $languageCode) {
+        foreach ($tag->languageCodes as $languageCode) {
             $out[$languageCode] = $tag->getKeyword($languageCode);
         }
         return $out;

Core/Matcher/TagMatcher.php

Spacing +1 added lines, -1 removed lines

@@ -156,7 +156,7 @@
             $childTags = $this->findTagsByParentTagIds(array_keys($parentTags));
             $tags = array_merge($tags, $childTags);
             $parentTags = $childTags;
-        } while (count( $childTags ) > 0);
+        } while (count($childTags) > 0);
 
         return $tags;
     }

Core/MigrationService.php

Spacing +9 added lines, -9 removed lines

@@ -264,7 +264,7 @@ 
         }
 
         if ($migrationDefinition->status == MigrationDefinition::STATUS_INVALID) {
-            throw new \Exception("Can not execute " . $this->getEntityName($migrationDefinition). " '{$migrationDefinition->name}': {$migrationDefinition->parsingError}");
+            throw new \Exception("Can not execute " . $this->getEntityName($migrationDefinition) . " '{$migrationDefinition->name}': {$migrationDefinition->parsingError}");
         }
 
         /// @todo add support for setting in $migrationContext a userContentType, userGroupContentType ?
@@ -298,7 +298,7 @@ 
 
         try {
 
-            $i = $stepOffset+1;
+            $i = $stepOffset + 1;
             $finalStatus = Migration::STATUS_DONE;
             $finalMessage = null;
 
@@ -433,12 +433,12 @@ 
     public function resumeMigration(Migration $migration, $useTransaction = true)
     {
         if ($migration->status != Migration::STATUS_SUSPENDED) {
-            throw new \Exception("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': it is not in suspended status");
+            throw new \Exception("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 \Exception("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': its definition is missing");
+            throw new \Exception("Can not resume " . $this->getEntityName($migration) . " '{$migration->name}': its definition is missing");
         }
 
         $defs = $migrationDefinitions->getArrayCopy();
@@ -446,18 +446,18 @@ 
 
         $migrationDefinition = $this->parseMigrationDefinition($migrationDefinition);
         if ($migrationDefinition->status == MigrationDefinition::STATUS_INVALID) {
-            throw new \Exception("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': {$migrationDefinition->parsingError}");
+            throw new \Exception("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 \Exception("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': the stored context is missing");
+            throw new \Exception("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 \Exception("Can not resume ".$this->getEntityName($migration)." '{$migration->name}': the stored context is invalid");
+        if (!is_array($restoredContext) || !isset($restoredContext['context']) || !isset($restoredContext['step'])) {
+            throw new \Exception("Can not resume " . $this->getEntityName($migration) . " '{$migration->name}': the stored context is invalid");
         }
 
         // update migration status
@@ -478,7 +478,7 @@ 
      * @param bool|null $forceSigchildEnabled
      * @return array
      */
-    protected function migrationContextFromParameters($defaultLanguageCode = null, $adminLogin = null, $forceSigchildEnabled = null )
+    protected function migrationContextFromParameters($defaultLanguageCode = null, $adminLogin = null, $forceSigchildEnabled = null)
     {
         $properties = array();