kaliop-uk / ezmigrationbundle

Command/StatusCommand.php

Spacing +2 added lines, -2 removed lines

@@ -197,7 +197,7 @@ 
 
         if ($input->getOption('todo')) {
             foreach ($data as $migrationData) {
-                $output->writeln("$migrationData", OutputInterface::OUTPUT_RAW|OutputInterface::VERBOSITY_QUIET);
+                $output->writeln("$migrationData", OutputInterface::OUTPUT_RAW | OutputInterface::VERBOSITY_QUIET);
             }
             return 0;
         }
@@ -226,7 +226,7 @@ 
      */
     protected function sortMigrationIndex(array &$index, $sortBy)
     {
-        switch($sortBy) {
+        switch ($sortBy) {
             case 'execution':
                 uasort($index, function($m1, $m2) {
                     if (isset($m1['migration']) && $m1['migration']->executionDate !== null) {

Core/MigrationService.php

Spacing +10 added lines, -10 removed lines

@@ -283,7 +283,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 ?
@@ -317,7 +317,7 @@ 
 
         try {
 
-            $i = $stepOffset+1;
+            $i = $stepOffset + 1;
             $finalStatus = Migration::STATUS_DONE;
             $finalMessage = null;
 
@@ -454,12 +454,12 @@ 
     public function resumeMigration(Migration $migration, $useTransaction = true, array $forcedReferences = array())
     {
         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();
@@ -467,24 +467,24 @@ 
 
         $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 ($forcedReferences) {
-            foreach($forcedReferences as $name => $value) {
+            foreach ($forcedReferences as $name => $value) {
                 $this->referenceResolver->addReference($name, $value, true);
             }
         }
 
         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
@@ -505,7 +505,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();
 

Command/ResumeCommand.php

Spacing +3 added lines, -3 removed lines

@@ -97,7 +97,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 \Exception("Invalid reference specification: '$refSpec'");
@@ -109,7 +109,7 @@ 
         $executed = 0;
         $failed = 0;
 
-        foreach($suspendedMigrations as $suspendedMigration) {
+        foreach ($suspendedMigrations as $suspendedMigration) {
             $output->writeln("<info>Resuming {$suspendedMigration->name}</info>");
 
             try {
@@ -129,7 +129,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/MigrateCommand.php

Spacing +5 added lines, -5 removed lines

@@ -132,7 +132,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 \Exception("Invalid reference specification: '$refSpec'");
@@ -232,9 +232,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;
@@ -466,7 +466,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:
@@ -498,7 +498,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;
             }
         }

Core/Executor/ReferenceExecutor.php

Spacing +3 added lines, -3 removed lines

@@ -160,7 +160,7 @@ 
             throw new \Exception("Invalid step definition: file '$fileName' for saving references already exists");
         }
 
-        if (! $this->referenceResolver instanceof EnumerableReferenceResolverInterface) {
+        if (!$this->referenceResolver instanceof EnumerableReferenceResolverInterface) {
             throw new \Exception("Can not save references as resolver is not enumerable");
         }
 
@@ -205,7 +205,7 @@ 
         $value = $this->dumpVar($this->referenceResolver->resolveReference($dsl['identifier']));
 
         if (isset($context['output']) && $context['output'] instanceof OutputInterface) {
-            $context['output']->write($label . $value, false, OutputInterface::OUTPUT_RAW|OutputInterface::VERBOSITY_NORMAL);
+            $context['output']->write($label . $value, false, OutputInterface::OUTPUT_RAW | OutputInterface::VERBOSITY_NORMAL);
         } else {
             echo $label . $value;
         }
@@ -227,7 +227,7 @@ 
 
         $dumper->dump(
             $cloner->cloneVar($var),
-            function ($line, $depth) use (&$output) {
+            function($line, $depth) use (&$output) {
                 // A negative depth means "end of dump"
                 if ($depth >= 0) {
                     // Adds a two spaces indentation to the line

Core/StorageHandler/Database/Migration.php

Spacing +8 added lines, -8 removed lines

@@ -84,9 +84,9 @@ 
             }
             if (is_array($paths) && count($paths)) {
                 $pexps = array();
-                foreach($paths as $path) {
+                foreach ($paths as $path) {
                     /// @todo use a proper db-aware escaping function
-                    $pexps[] = $q->expr->like('path', "'" . str_replace(array('_', '%', "'"), array('\_', '\%', "''"), $path).'%' . "'");
+                    $pexps[] = $q->expr->like('path', "'" . str_replace(array('_', '%', "'"), array('\_', '\%', "''"), $path) . '%' . "'");
                 }
                 $exps[] = $q->expr->lor($pexps);
             }
@@ -196,7 +196,7 @@ 
     public function endMigration(APIMigration $migration, $force = false)
     {
         if ($migration->status == APIMigration::STATUS_STARTED) {
-            throw new \Exception($this->getEntityName($migration)." '{$migration->name}' can not be ended as its status is 'started'...");
+            throw new \Exception($this->getEntityName($migration) . " '{$migration->name}' can not be ended as its status is 'started'...");
         }
 
         $this->createTableIfNeeded();
@@ -223,13 +223,13 @@ 
         if (!is_array($existingMigrationData)) {
             // commit to release the lock
             $conn->commit();
-            throw new \Exception($this->getEntityName($migration)." '{$migration->name}' can not be ended as it is not found");
+            throw new \Exception($this->getEntityName($migration) . " '{$migration->name}' can not be ended as it is not found");
         }
 
         if (($existingMigrationData['status'] != APIMigration::STATUS_STARTED) && !$force) {
             // commit to release the lock
             $conn->commit();
-            throw new \Exception($this->getEntityName($migration)." '{$migration->name}' can not be ended as it is not executing");
+            throw new \Exception($this->getEntityName($migration) . " '{$migration->name}' can not be ended as it is not executing");
         }
 
         $conn->update(
@@ -384,7 +384,7 @@ 
         if (!is_array($existingMigrationData)) {
             // commit immediately, to release the lock and avoid deadlocks
             $conn->commit();
-            throw new \Exception($this->getEntityName($migration)." '{$migration->name}' can not be resumed as it is not found");
+            throw new \Exception($this->getEntityName($migration) . " '{$migration->name}' can not be resumed as it is not found");
         }
 
         // migration exists
@@ -393,7 +393,7 @@ 
         if ($existingMigrationData['status'] != APIMigration::STATUS_SUSPENDED) {
             // commit to release the lock
             $conn->commit();
-            throw new \Exception($this->getEntityName($migration)." '{$migration->name}' can not be resumed as it is not suspended");
+            throw new \Exception($this->getEntityName($migration) . " '{$migration->name}' can not be resumed as it is not suspended");
         }
 
         $migration = new APIMigration(
@@ -455,7 +455,7 @@ 
         foreach ($schema->toSql($dbPlatform) as $sql) {
             try {
                 $this->dbHandler->exec($sql);
-            } catch(QueryException $e) {
+            } catch (QueryException $e) {
                 // work around limitations in both Mysql and Doctrine
                 // @see https://github.com/kaliop-uk/ezmigrationbundle/issues/176
                 if (strpos($e->getMessage(), '1071 Specified key was too long; max key length is 767 bytes') !== false &&

Core/FieldHandler/EzMatrix.php

Spacing +4 added lines, -4 removed lines

@@ -24,13 +24,13 @@ 
 
         if ($this->usingLegacyFieldType()) {
             $rows = array();
-            foreach($fieldValue as $data) {
+            foreach ($fieldValue as $data) {
                 $rows[] = new \EzSystems\MatrixBundle\FieldType\Matrix\Row($data);
             }
             return new \EzSystems\MatrixBundle\FieldType\Matrix\Value($rows);
         } else {
             $rows = array();
-            foreach($fieldValue as $data) {
+            foreach ($fieldValue as $data) {
                 $rows[] = new \EzSystems\EzPlatformMatrixFieldtype\FieldType\Value\Row($data);
             }
             return new \EzSystems\EzPlatformMatrixFieldtype\FieldType\Value($rows);
@@ -42,11 +42,11 @@ 
         $data = array();
 
         if ($this->usingLegacyFieldType()) {
-            foreach($fieldValue->getRows() as $row) {
+            foreach ($fieldValue->getRows() as $row) {
                 $data[] = $row->toArray();
             }
         } else {
-            foreach($fieldValue->getRows() as $row) {
+            foreach ($fieldValue->getRows() as $row) {
                 $data[] = $row->getCells();
             }
         }

Core/Executor/ContentManager.php

Spacing +3 added lines, -3 removed lines

@@ -545,7 +545,7 @@ 
                     $locations = $locationService->loadLocations($content->contentInfo);
                     if (count($locations) > 1) {
                         $otherParentLocations = array();
-                        foreach($locations as $otherLocation) {
+                        foreach ($locations as $otherLocation) {
                             if ($otherLocation->id != $location->id) {
                                 $otherParentLocations[] = $otherLocation->parentLocationId;
                             }
@@ -596,7 +596,7 @@ 
                 }
 
                 $attributes = array();
-                foreach($languages as $lang) {
+                foreach ($languages as $lang) {
                     foreach ($content->getFieldsByLanguage($lang) as $fieldIdentifier => $field) {
                         $fieldDefinition = $contentType->getFieldDefinition($fieldIdentifier);
                         $fieldValue = $this->fieldHandlerManager->fieldValueToHash(
@@ -744,7 +744,7 @@ 
             },
             array_filter(
                 $this->repository->getContentLanguageService()->loadLanguages(),
-                function ($language) {
+                function($language) {
                     return $language->enabled;
                 }
             )