kaliop-uk / ezmigrationbundle

Core/Executor/MigrationDefinitionExecutor.php

Spacing +2 added lines, -2 removed lines

@@ -168,7 +168,7 @@ 
 
         foreach ($dsl['references'] as $key => $reference) {
             // BC
-            if (is_array($reference) && isset($reference['json_path']) && !isset($reference['attribute'] )) {
+            if (is_array($reference) && isset($reference['json_path']) && !isset($reference['attribute'])) {
                 $reference['attribute'] = $reference['json_path'];
             }
             $reference = $this->parseReferenceDefinition($key, $reference);
@@ -197,7 +197,7 @@ 
     {
         $migrationService = $this->migrationService;
         $executors = $migrationService->listExecutors();
-        foreach($executors as $key => $name) {
+        foreach ($executors as $key => $name) {
             $executor = $migrationService->getExecutor($name);
             if (!$executor instanceof MigrationGeneratorInterface) {
                 unset($executors[$key]);

Core/Executor/RepositoryExecutor.php

Spacing +2 added lines, -2 removed lines

@@ -216,7 +216,7 @@ 
 
         $multivalued = ($this->expectedResultsType($step) == self::$RESULT_TYPE_MULTIPLE);
 
-        if ($item instanceof AbstractCollection  || is_array($item)) {
+        if ($item instanceof AbstractCollection || is_array($item)) {
             $items = $item;
         } else {
             $items = array($item);
@@ -261,7 +261,7 @@ 
         // allow setting *some* refs even when we have 0 or N matches
         foreach ($referencesDefinition as $key => $reference) {
             $reference = $this->parseReferenceDefinition($key, $reference);
-            switch($reference['attribute']) {
+            switch ($reference['attribute']) {
 
                 case 'count':
                     $value = count($entity);

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;

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/FieldHandler/FileFieldHandler.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
     protected $ioDecorator;
     protected $ioService;
 
-    public function __construct($ioRootDir, UrlDecorator $ioDecorator=null, $ioService=null)
+    public function __construct($ioRootDir, UrlDecorator $ioDecorator = null, $ioService = null)
     {
         $this->ioRootDir = $ioRootDir;
         $this->ioDecorator = $ioDecorator;

Command/MassMigrateCommand.php

Spacing +15 added lines, -15 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('%.3f', $time)." secs</info>");
+        $this->writeln("<info>Time taken: " . sprintf('%.3f', $time) . " secs</info>");
 
         return $subprocessesFailed + $this->migrationsDone[Migration::STATUS_FAILED] + $missed;
     }
@@ -211,7 +211,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 \Exception("Invalid php ini specification: '$iniSpec'");
@@ -240,7 +240,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;
             }
@@ -280,7 +280,7 @@ 
                     $this->executeMigrationInProcess($migrationDefinition, $force, $migrationService, $input);
 
                     $executed++;
-                } catch(\Exception $e) {
+                } catch (\Exception $e) {
                     $failed++;
 
                     $errorMessage = $e->getMessage();
@@ -313,7 +313,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));
 
@@ -331,7 +331,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 {
@@ -365,7 +365,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;
             }
@@ -407,7 +407,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>');
         }
@@ -420,7 +420,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;
@@ -497,12 +497,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/AbstractCommand.php

Spacing +2 added lines, -2 removed lines

@@ -94,13 +94,13 @@
     protected function normalizePaths($paths)
     {
         $rootDir = realpath($this->getContainer()->get('kernel')->getRootDir() . '/..') . '/';
-        foreach($paths as $i => $path) {
+        foreach ($paths as $i => $path) {
             if ($path === $rootDir || $path === './') {
                 $paths[$i] = './';
             } else if (strpos($path, './') === 0) {
                 $paths[$i] = substr($path, 2);
             // q: should we also call realpath on $path? what if there are symlinks at play?
-            } elseif (strpos($path, $rootDir) === 0 ) {
+            } elseif (strpos($path, $rootDir) === 0) {
                 $paths[$i] = substr($path, strlen($rootDir));
             } elseif ($path === '') {
                 unset($paths[$i]);

Command/StatusCommand.php

Spacing +3 added lines, -3 removed lines

@@ -93,7 +93,7 @@ 
         // which is misleading. We add the following loop to fix that, so that the status command will match more closely
         // the 'migrate' command
         if (count($paths)) {
-            foreach($index as $migrationName => $data) {
+            foreach ($index as $migrationName => $data) {
                 if (!isset($data['migration'])) {
                     $migration = $migrationsService->getMigration($migrationName);
                     if ($migration !== null) {
@@ -231,7 +231,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;
         }
@@ -260,7 +260,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) {