kaliop-uk / ezmigrationbundle

Command/MassMigrateCommand.php

Spacing +10 added lines, -10 removed lines

@@ -102,7 +102,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
@@ -139,11 +139,11 @@ 
 
             $time = microtime(true) - $start;
 
-            $this->writeln('<info>'.$this->migrationsDone[0].' migrations executed, '.$this->migrationsDone[1].' failed, '.$this->migrationsDone[2].' skipped</info>');
+            $this->writeln('<info>' . $this->migrationsDone[0] . ' migrations executed, ' . $this->migrationsDone[1] . ' failed, ' . $this->migrationsDone[2] . ' skipped</info>');
             $this->writeln("<info>Import finished</info>\n");
 
             // since we use subprocesses, we can not measure max memory used
-            $this->writeln("Time taken: ".sprintf('%.2f', $time)." secs");
+            $this->writeln("Time taken: " . sprintf('%.2f', $time) . " secs");
 
             return $failed;
 
@@ -169,7 +169,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;
                 }
@@ -243,7 +243,7 @@ 
                         );
 
                         $executed++;
-                    } catch(\Exception $e) {
+                    } catch (\Exception $e) {
                         $failed++;
                         if ($input->getOption('ignore-failures')) {
                             $this->writeln("<error>Migration failed! Path: " . $migrationDefinition->path . ", Reason: " . $e->getMessage() . "</error>", self::VERBOSITY_CHILD);
@@ -269,7 +269,7 @@ 
         }
     }
 
-    public function onSubProcessOutput($type, $buffer, $process=null)
+    public function onSubProcessOutput($type, $buffer, $process = null)
     {
         $lines = explode("\n", trim($buffer));
 
@@ -287,7 +287,7 @@ 
 
             // we tag the output from the different processes
             if (trim($line) !== '') {
-                echo '[' . ($process ? $process->getPid() : ''). '] ' . trim($line) . "\n";
+                echo '[' . ($process ? $process->getPid() : '') . '] ' . trim($line) . "\n";
             }
         }
     }
@@ -309,7 +309,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]) && $migration->status == Migration::STATUS_TODO)) {
                 $toExecute[$name] = $isChild ? $migrationService->parseMigrationDefinition($migrationDefinition) : $migrationDefinition;
             }
@@ -351,7 +351,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]);
     }
 
     protected function askForConfirmation(InputInterface $input, OutputInterface $output)
@@ -382,7 +382,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

@@ -219,9 +219,9 @@ 
         $this->writeln("Executed $executed migrations, failed $failed, skipped $skipped");
         if ($input->getOption('separate-process')) {
             // in case of using subprocesses, we can not measure max memory used
-            $this->writeln("Time taken: ".sprintf('%.2f', $time)." secs");
+            $this->writeln("Time taken: " . sprintf('%.2f', $time) . " secs");
         } else {
-            $this->writeln("Time taken: ".sprintf('%.2f', $time)." secs, memory: ".sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)). ' MB');
+            $this->writeln("Time taken: " . sprintf('%.2f', $time) . " secs, memory: " . sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)) . ' MB');
         }
     }
 
@@ -369,7 +369,7 @@ 
             $builderArgs[] = '--no-debug';
         }
         if ($input->getOption('siteaccess')) {
-            $builderArgs[]='--siteaccess='.$input->getOption('siteaccess');
+            $builderArgs[] = '--siteaccess=' . $input->getOption('siteaccess');
         }
         // 'optional' options
         // note: options 'clear-cache', 'ignore-failures', 'no-interaction', 'path' and 'separate-process' we never propagate