kaliop-uk / ezmigrationbundle

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;
             }
         }