kaliop-uk / ezmigrationbundle

Core/StorageHandler/Database/Migration.php

Spacing +5 added lines, -5 removed lines

@@ -171,7 +171,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();
@@ -198,13 +198,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(
@@ -355,7 +355,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
@@ -364,7 +364,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(

Core/Executor/ProcessExecutor.php

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
         $builderArgs = array($this->referenceResolver->resolveReference($dsl['command']));
 
         if (isset($dsl['arguments'])) {
-            foreach($dsl['arguments'] as $arg) {
+            foreach ($dsl['arguments'] as $arg) {
                 $builderArgs[] = $this->referenceResolver->resolveReference($arg);
             }
         }

Core/Executor/MigrationExecutor.php

Spacing +3 added lines, -3 removed lines

@@ -105,13 +105,13 @@ 
         $dsl['mode'] = 'load';
         // be kind to users and allow them not to specify this explicitly
         if (isset($dsl['references'])) {
-            foreach($dsl['references'] as &$refDef) {
+            foreach ($dsl['references'] as &$refDef) {
                 $refDef['overwrite'] = true;
             }
         }
         $step = new MigrationStep($dsl['type'], $dsl, $context);
 
-        switch($dsl['type']) {
+        switch ($dsl['type']) {
             case 'content':
                 return $this->contentManager->execute($step);
             case 'location':
@@ -139,7 +139,7 @@ 
                     return $this->matchConditions($values);
 
                 default:
-                    throw new \Exception("Unknown until condition: '$key' when suspending a migration ".var_export($conditions, true));
+                    throw new \Exception("Unknown until condition: '$key' when suspending a migration " . var_export($conditions, true));
             }
         }
     }

Command/ResumeCommand.php

Spacing +2 added lines, -2 removed lines

@@ -93,7 +93,7 @@ 
         $executed = 0;
         $failed = 0;
 
-        foreach($suspendedMigrations as $suspendedMigration) {
+        foreach ($suspendedMigrations as $suspendedMigration) {
             $output->writeln("<info>Resuming {$suspendedMigration->name}</info>");
 
             try {
@@ -113,7 +113,7 @@ 
 
         $time = microtime(true) - $start;
         $output->writeln("Resumed $executed migrations, failed $failed");
-        $output->writeln("Time taken: ".sprintf('%.2f', $time)." secs, memory: ".sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)). ' MB');
+        $output->writeln("Time taken: " . sprintf('%.2f', $time) . " secs, memory: " . sprintf('%.2f', (memory_get_peak_usage(true) / 1000000)) . ' MB');
 
         if ($failed) {
             return 2;

Core/FieldHandler/EzDateAndTime.php

Spacing +7 added lines, -7 removed lines

@@ -58,26 +58,26 @@
     {
         $format = array();
         if (0 != $dateInterval->y) {
-            $format[] = $dateInterval->y.' years';
+            $format[] = $dateInterval->y . ' years';
         }
         if (0 != $dateInterval->m) {
-            $format[] = $dateInterval->m.' months';
+            $format[] = $dateInterval->m . ' months';
         }
         if (0 != $dateInterval->d) {
-            $format[] = $dateInterval->d.' days';
+            $format[] = $dateInterval->d . ' days';
         }
         //if (0 < $dateInterval->h || 0 < $dateInterval->i || 0 < $dateInterval->s) {
         //    $format .= 'T';
         //}
         if (0 != $dateInterval->h) {
-            $format[] = $dateInterval->h.' hours';
+            $format[] = $dateInterval->h . ' hours';
         }
         if (0 != $dateInterval->i) {
-            $format[] = $dateInterval->i.' minutes';
+            $format[] = $dateInterval->i . ' minutes';
         }
         if (0 != $dateInterval->s) {
-            $format[] = $dateInterval->s.' seconds';
+            $format[] = $dateInterval->s . ' seconds';
         }
-        return implode( ', ', $format);
+        return implode(', ', $format);
     }
 }

Core/Matcher/ContentMatcherDirectLoad.php

Spacing +2 added lines, -2 removed lines

@@ -22,13 +22,13 @@
             $contents = array();
             switch ($key) {
                 case self::MATCH_CONTENT_ID:
-                    foreach($match as $contentId) {
+                    foreach ($match as $contentId) {
                         $content = $this->repository->getContentService()->loadContent($contentId);
                         $contents[$content->id] = $content;
                     }
                     break;
                 case self::MATCH_CONTENT_REMOTE_ID:
-                    foreach($match as $contentRemoteId) {
+                    foreach ($match as $contentRemoteId) {
                         $content = $this->repository->getContentService()->loadContentByRemoteId($contentRemoteId);
                         $contents[$content->id] = $content;
                     }

Core/Matcher/LocationMatcherDirectLoad.php

Spacing +2 added lines, -2 removed lines

@@ -24,13 +24,13 @@
             $locations = array();
             switch ($key) {
                 case self::MATCH_LOCATION_ID:
-                    foreach($match as $locationId) {
+                    foreach ($match as $locationId) {
                         $location = $this->repository->getLocationService()->loadLocation($locationId);
                         $locations[$location->id] = $location;
                     }
                     break;
                 case self::MATCH_LOCATION_REMOTE_ID:
-                    foreach($match as $locationRemoteId) {
+                    foreach ($match as $locationRemoteId) {
                         $location = $this->repository->getLocationService()->loadLocationByRemoteId($locationRemoteId);
                         $locations[$location->id] = $location;
                     }

Indentation -1 removed lines

@@ -15,7 +15,6 @@
      * @param array $sort
      * @param int $offset
      * @param int $limit
-
      * @return LocationCollection
      */
     public function matchLocation(array $conditions, array $sort = array(), $offset = 0, $limit = 0)

Core/Loader/FilesystemRecursive.php

Spacing +2 added lines, -2 removed lines

@@ -57,7 +57,7 @@ 
         if (empty($paths)) {
             $paths = array();
             /** @var $bundle \Symfony\Component\HttpKernel\Bundle\BundleInterface */
-            foreach($this->kernel->getBundles() as $bundle)
+            foreach ($this->kernel->getBundles() as $bundle)
             {
                 $path = $bundle->getPath() . "/" . $this->versionDirectory;
                 if (is_dir($path)) {
@@ -67,7 +67,7 @@ 
         }
 
         $definitions = array();
-        foreach($paths as $path) {
+        foreach ($paths as $path) {
             if (is_file($path)) {
                 $definitions[basename($path)] = $returnFilename ? $path : new MigrationDefinition(
                     basename($path),

Braces +1 added lines, -2 removed lines

@@ -60,8 +60,7 @@
                         }
                     }
                 }
-            }
-            else {
+            } else {
                 throw new \Exception("Path '$path' is neither a file nor directory");
             }
         }

Core/Helper/ProcessManager.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
         $currentProcesses = array_splice($processesQueue, 0, $maxParallel);
         // start the initial stack of processes
         foreach ($currentProcesses as $process) {
-            $process->start(function ($type, $buffer) use ($callback, $process) {
+            $process->start(function($type, $buffer) use ($callback, $process) {
                 if ($callback) {
                     $callback($type, $buffer, $process);
                 }
@@ -44,7 +44,7 @@ 
                     // directly add and start new process after the previous finished
                     if (count($processesQueue) > 0) {
                         $nextProcess = array_shift($processesQueue);
-                        $nextProcess->start(function ($type, $buffer) use ($callback, $nextProcess) {
+                        $nextProcess->start(function($type, $buffer) use ($callback, $nextProcess) {
                             if ($callback) {
                                 $callback($type, $buffer, $nextProcess);
                             }