kaliop-uk / ezmigrationbundle

Core/Loader/Filesystem.php

Spacing +1 added lines, -1 removed lines

@@ -120,6 +120,6 @@
     {
         $rootDir = realpath($this->kernel->getRootDir() . '/..') . '/';
         // note: we handle the case of 'path = root dir', but path is expected to include a filename...
-        return $path === $rootDir ? './' : preg_replace('#^' . preg_quote($rootDir, '#'). '#', '', $path);
+        return $path === $rootDir ? './' : preg_replace('#^' . preg_quote($rootDir, '#') . '#', '', $path);
     }
 }

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) {
 
             // NB: this might result in double reference-resolving when the original value is a string, given preResolveReferences...
             $val = $this->referenceResolver->resolveReference($val);
@@ -48,7 +48,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/Matcher/QueryBasedMatcher.php

Spacing +8 added lines, -8 removed lines

@@ -155,7 +155,7 @@ 
                     return new Query\Criterion\Field($attribute, self::$operatorsMap[$operator], $match);
                 } else {
                     /// @todo make the list of unary operators more flexible
-                    switch($spec) {
+                    switch ($spec) {
                         case 'empty':
                             return new Query\Criterion\IsFieldEmpty($attribute);
                         default:
@@ -180,7 +180,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;
                     }
@@ -199,7 +199,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;
                     }
@@ -207,7 +207,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;
                     }
@@ -227,7 +227,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;
                     }
@@ -248,7 +248,7 @@ 
 
             case self::MATCH_AND:
                 $subCriteria = array();
-                foreach($values as $subCriterion) {
+                foreach ($values as $subCriterion) {
                     $value = reset($subCriterion);
                     $subCriteria[] = $this->getQueryCriterion(key($subCriterion), $value);
                 }
@@ -256,7 +256,7 @@ 
 
             case self::MATCH_OR:
                 $subCriteria = array();
-                foreach($values as $subCriterion) {
+                foreach ($values as $subCriterion) {
                     $value = reset($subCriterion);
                     $subCriteria[] = $this->getQueryCriterion(key($subCriterion), $value);
                 }
@@ -301,7 +301,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/Matcher/UrlWildcardMatcher.php

Spacing +1 added lines, -1 removed lines

@@ -93,7 +93,7 @@
                 // return unique contents
                 $urlWildcard = $this->repository->getURLWildcardService()->load($urlId);
                 $urls[$urlWildcard->id] = $urlWildcard;
-            } catch(NotFoundException $e) {
+            } catch (NotFoundException $e) {
                 if (!$tolerateMisses) {
                     throw $e;
                 }

Core/Matcher/UrlAliasMatcher.php

Spacing +3 added lines, -3 removed lines

@@ -108,7 +108,7 @@ 
                 // return unique items
                 $UrlAlias = $this->repository->getUrlAliasService()->load($urlId);
                 $urls[$UrlAlias->id] = $UrlAlias;
-            } catch(NotFoundException $e) {
+            } catch (NotFoundException $e) {
                 if (!$tolerateMisses) {
                     throw $e;
                 }
@@ -133,7 +133,7 @@ 
                 // return unique contents
                 $UrlAlias = $this->repository->getUrlAliasService()->lookup($url);
                 $urls[$UrlAlias->id] = $UrlAlias;
-            } catch(NotFoundException $e) {
+            } catch (NotFoundException $e) {
                 if (!$tolerateMisses) {
                     throw $e;
                 }
@@ -173,7 +173,7 @@ 
                         $urls[$UrlAlias->id] = $UrlAlias;
                     }
                 }
-            } catch(NotFoundException $e) {
+            } catch (NotFoundException $e) {
                 if (!$tolerateMisses) {
                     throw $e;
                 }

Core/FieldHandler/EzMatrix.php

Spacing +2 added lines, -2 removed lines

@@ -65,11 +65,11 @@
         $data = array();
 
         if ($this->usingLegacyFieldType()) {
-            foreach($fieldValue->rows as $row) {
+            foreach ($fieldValue->rows as $row) {
                 $data[] = $row->toArray();
             }
         } else {
-            foreach($fieldValue->getRows() as $row) {
+            foreach ($fieldValue->getRows() as $row) {
                 $data[] = $row->getCells();
             }
         }

Command/ResumeCommand.php

Spacing +3 added lines, -3 removed lines

@@ -99,7 +99,7 @@ 
         $forcedRefs = array();
         if ($input->getOption('set-reference') /*&& !$input->getOption('separate-process')*/) {
             $refResolver = $this->getContainer()->get('ez_migration_bundle.reference_resolver.customreference');
-            foreach($input->getOption('set-reference') as $refSpec) {
+            foreach ($input->getOption('set-reference') as $refSpec) {
                 $ref = explode(':', $refSpec, 2);
                 if (count($ref) < 2 || $ref[0] === '') {
                     throw new MigrationBundleException("Invalid reference specification: '$refSpec'");
@@ -111,7 +111,7 @@ 
         $executed = 0;
         $failed = 0;
 
-        foreach($suspendedMigrations as $suspendedMigration) {
+        foreach ($suspendedMigrations as $suspendedMigration) {
             $output->writeln("<info>Resuming {$suspendedMigration->name}</info>");
 
             try {
@@ -131,7 +131,7 @@ 
 
         $time = microtime(true) - $start;
         $output->writeln("Resumed $executed migrations, failed $failed");
-        $output->writeln("Time taken: ".sprintf('%.3f', $time)." secs, memory: ".sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)). ' MB');
+        $output->writeln("Time taken: " . sprintf('%.3f', $time) . " secs, memory: " . sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)) . ' MB');
 
         if ($failed) {
             return 2;

Command/MassMigrateCommand.php

Spacing +15 added lines, -15 removed lines

@@ -133,7 +133,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
@@ -180,14 +180,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('%.3f', $time)." secs</info>");
+        $this->writeln("<info>Time taken: " . sprintf('%.3f', $time) . " secs</info>");
 
         return $subprocessesFailed + $this->migrationsDone[Migration::STATUS_FAILED] + $missed;
     }
@@ -212,7 +212,7 @@ 
                 $prefix = array($php);
 
                 if ($input->getOption('child-process-php-ini-config')) {
-                    foreach($input->getOption('child-process-php-ini-config') as $iniSpec) {
+                    foreach ($input->getOption('child-process-php-ini-config') as $iniSpec) {
                         $ini = explode(':', $iniSpec, 2);
                         if (count($ini) < 2 || $ini[0] === '') {
                             throw new MigrationBundleException("Invalid php ini specification: '$iniSpec'");
@@ -241,7 +241,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;
             }
@@ -281,7 +281,7 @@ 
                     $this->executeMigrationInProcess($migrationDefinition, $force, $migrationService, $input);
 
                     $executed++;
-                } catch(\Exception $e) {
+                } catch (\Exception $e) {
                     $failed++;
 
                     $errorMessage = $e->getMessage();
@@ -314,7 +314,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));
 
@@ -332,7 +332,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 {
@@ -366,7 +366,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;
             }
@@ -408,7 +408,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>');
         }
@@ -421,7 +421,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;
@@ -498,12 +498,12 @@ 
             $builderArgs[] = '--separate-process';
         }
         if ($input->getOption('set-reference')) {
-            foreach($input->getOption('set-reference') as $refSpec) {
+            foreach ($input->getOption('set-reference') as $refSpec) {
                 $builderArgs[] = '--set-reference=' . $refSpec;
             }
         }
         if ($input->getOption('child-process-php-ini-config')) {
-            foreach($input->getOption('child-process-php-ini-config') as $iniSpec) {
+            foreach ($input->getOption('child-process-php-ini-config') as $iniSpec) {
                 $builderArgs[] = '--child-process-php-ini-config=' . $iniSpec;
             }
         }

Command/MigrateCommand.php

Spacing +6 added lines, -6 removed lines

@@ -124,7 +124,7 @@ 
                 $prefix = array($php);
 
                 if ($input->getOption('child-process-php-ini-config')) {
-                    foreach($input->getOption('child-process-php-ini-config') as $iniSpec) {
+                    foreach ($input->getOption('child-process-php-ini-config') as $iniSpec) {
                         $ini = explode(':', $iniSpec, 2);
                         if (count($ini) < 2 || $ini[0] === '') {
                             throw new MigrationBundleException("Invalid php ini specification: '$iniSpec'");
@@ -150,7 +150,7 @@ 
 
         if ($input->getOption('set-reference') && !$input->getOption('separate-process')) {
             $refResolver = $this->getContainer()->get('ez_migration_bundle.reference_resolver.customreference');
-            foreach($input->getOption('set-reference') as $refSpec) {
+            foreach ($input->getOption('set-reference') as $refSpec) {
                 $ref = explode(':', $refSpec, 2);
                 if (count($ref) < 2 || $ref[0] === '') {
                     throw new MigrationBundleException("Invalid reference specification: '$refSpec'");
@@ -250,9 +250,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('%.3f', $time)." secs</info>");
+            $this->writeln("<info>Time taken: " . sprintf('%.3f', $time) . " secs</info>");
         } else {
-            $this->writeln("<info>Time taken: ".sprintf('%.3f', $time)." secs, memory: ".sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)). ' MB</info>');
+            $this->writeln("<info>Time taken: " . sprintf('%.3f', $time) . " secs, memory: " . sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)) . ' MB</info>');
         }
 
         return $failed;
@@ -484,7 +484,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:
@@ -516,7 +516,7 @@ 
             $builderArgs[] = '--no-transactions';
         }
         if ($input->getOption('set-reference')) {
-            foreach($input->getOption('set-reference') as $refSpec) {
+            foreach ($input->getOption('set-reference') as $refSpec) {
                 $builderArgs[] = '--set-reference=' . $refSpec;
             }
         }