comodojo / extender.framework

src/Comodojo/Extender/Utils/Validator.php

Braces +1 added lines, -2 removed lines

@@ -55,8 +55,7 @@
 
             if ( $e_count == 5 ) $e_array[] = "*";
 
-        }
-        catch (Exception $e) {
+        } catch (Exception $e) {
 
             throw $e;
 

src/Comodojo/Extender/Task/Result.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
  */
 
 
-class Result extends Model{
+class Result extends Model {
 
     protected $mode = self::READONLY;
 

Braces +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
  */
 
 
-class Result extends Model{
+class Result extends Model {
 
     protected $mode = self::READONLY;
 

src/Comodojo/Extender/Utils/StopWatch.php

Spacing +2 added lines, -2 removed lines

@@ -111,9 +111,9 @@
 
         $t = microtime(true);
 
-        $micro = sprintf("%06d",($t - floor($t)) * 1000000);
+        $micro = sprintf("%06d", ($t - floor($t)) * 1000000);
 
-        return new DateTime( date('Y-m-d H:i:s.'.$micro, $t) );
+        return new DateTime(date('Y-m-d H:i:s.'.$micro, $t));
 
     }
 

src/Comodojo/Extender/Components/Database.php

Spacing +3 added lines, -3 removed lines

@@ -84,7 +84,7 @@ 
                 false
             ];
 
-            switch (strtoupper($metadata_mode)) {
+            switch ( strtoupper($metadata_mode) ) {
 
                 case 'YAML':
                     $db_config = Setup::createYAMLMetadataConfiguration(...$config_args);
@@ -178,7 +178,7 @@ 
         $repos = $configuration->get('database-repositories');
 
         return array_map(function($repo) use ($base_folder) {
-            return substr($repo, 0, 1 ) === "/" ? $repo : "$base_folder/$repo";
+            return substr($repo, 0, 1) === "/" ? $repo : "$base_folder/$repo";
         }, $repos);
 
     }
@@ -188,7 +188,7 @@ 
         $base_folder = $configuration->get('base-path');
         $folder = $configuration->get('database-proxies');
 
-        return substr($folder, 0, 1 ) === "/" ? $folder : "$base_folder/$folder";
+        return substr($folder, 0, 1) === "/" ? $folder : "$base_folder/$folder";
 
     }
 

src/Comodojo/Extender/Schedule/Updater.php

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,7 @@ 
 
         $em = Database::init($this->getConfiguration())->getEntityManager();
 
-        foreach ($results as $result) {
+        foreach ( $results as $result ) {
 
             $id = $result->jid;
 
@@ -93,7 +93,7 @@ 
         $date = new DateTime();
         $timestamps = [];
 
-        foreach ($items as $schedule) {
+        foreach ( $items as $schedule ) {
 
             $timestamps[] = $schedule->getNextPlannedRun($date)->getTimestamp();
 

Indentation +6 added lines, -6 removed lines

@@ -34,12 +34,12 @@
     use EventsTrait;
 
     /**
-    * Class constructor
-    *
-    * @param Configuration $configuration
-    * @param LoggerInterface $logger
-    * @param EventsManager $events
-    */
+     * Class constructor
+     *
+     * @param Configuration $configuration
+     * @param LoggerInterface $logger
+     * @param EventsManager $events
+     */
     public function __construct(
         Configuration $configuration,
         LoggerInterface $logger,

src/Comodojo/Extender/Task/Table.php

Spacing +1 added lines, -1 removed lines

@@ -139,7 +139,7 @@
 
         $result = [];
 
-        foreach($tasks as $name => $task) {
+        foreach ( $tasks as $name => $task ) {
 
             if ( empty($task['class']) ) {
 

src/Comodojo/Extender/Workers/QueueWorker.php

Spacing +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
 
         if ( !empty($queue) ) {
 
-            $events->emit( new QueueEvent('process', null, $queue) );
+            $events->emit(new QueueEvent('process', null, $queue));
 
             $requests = $this->jobsToRequests($queue);
 

src/Comodojo/Extender/Task/Manager.php

Spacing +4 added lines, -4 removed lines

@@ -128,9 +128,9 @@ 
 
     public function addBulk(array $requests) {
 
-        foreach ($requests as $id => $request) {
+        foreach ( $requests as $id => $request ) {
 
-            if ($request instanceof \Comodojo\Extender\Task\Request) {
+            if ( $request instanceof \Comodojo\Extender\Task\Request ) {
                 $this->add($request);
             } else {
                 $this->logger->error("Skipping invalid request with local id $id: class mismatch");
@@ -163,7 +163,7 @@ 
 
         $this->installErrorHandler();
 
-        foreach ($this->tracker->getQueued() as $uid => $request) {
+        foreach ( $this->tracker->getQueued() as $uid => $request ) {
 
             if ( $this->multithread === false ) {
 
@@ -191,7 +191,7 @@ 
 
                 if ( $this->max_childs > 0 && $this->tracker->countRunning() >= $this->max_childs ) {
 
-                    while( $this->tracker->countRunning() >= $this->max_childs ) {
+                    while ( $this->tracker->countRunning() >= $this->max_childs ) {
 
                         $this->catcher();
 

src/Comodojo/Extender/Task/Request.php

Spacing +4 added lines, -4 removed lines

@@ -261,7 +261,7 @@ 
 
     public function isChain() {
 
-        return ( $this->done !== null || $this->fail !== null || $this->pipe !== null );
+        return ($this->done !== null || $this->fail !== null || $this->pipe !== null);
 
     }
 
@@ -275,9 +275,9 @@ 
         $message->setMaxtime($this->getMaxtime());
         $message->setParameters($this->getParameters()->export());
 
-        if ( $this->done !== null ) $message->onDone( $this->getOnDone()->convertToMessage() );
-        if ( $this->fail !== null ) $message->onFail( $this->getOnFail()->convertToMessage() );
-        if ( $this->pipe !== null ) $message->pipe( $this->getPipe()->convertToMessage() );
+        if ( $this->done !== null ) $message->onDone($this->getOnDone()->convertToMessage());
+        if ( $this->fail !== null ) $message->onFail($this->getOnFail()->convertToMessage());
+        if ( $this->pipe !== null ) $message->pipe($this->getPipe()->convertToMessage());
 
         return $message;