comodojo / extender.framework

src/Shell/Controller.php

Spacing +1 added lines, -1 removed lines

@@ -200,7 +200,7 @@
 
             $commands = Spyc::YAMLLoad(EXTENDER_COMMANDS_CONFIG);
 
-            foreach ($commands as $command => $parameters) {
+            foreach ( $commands as $command => $parameters ) {
                 
                 $controller->add($command, $parameters["data"]);
 

src/Extender.php

Spacing +1 added lines, -1 removed lines

@@ -482,7 +482,7 @@
                 )
             )) : 1;
 
-            while (true) {
+            while ( true ) {
 
                 $this->cycle();
 

src/Comodojo/Extender/Extender.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
     ) {
 
         // parsing configuration
-        $this->configuration = new Configuration( DefaultConfiguration::get() );
+        $this->configuration = new Configuration(DefaultConfiguration::get());
         $this->configuration->merge($configuration);
 
         // fix the daemon start time

src/Comodojo/Extender/Listeners/StopSummary.php

Spacing +7 added lines, -7 removed lines

@@ -14,24 +14,24 @@
         $chars = 60;
 
         // show the header
-        $console->br()->border('-',$chars);
+        $console->br()->border('-', $chars);
         $console->bold()->flank('Extender execution summary');
-        $console->border('-',$chars);
+        $console->border('-', $chars);
         $console->out('Total run time: '.self::calculateRunTime($daemon->starttime));
-        $console->border('-',$chars);
+        $console->border('-', $chars);
         $padding = $console->padding(26);
-        $padding->label('Total processed jobs')->result($daemon->completedjobs+$daemon->failedjobs);
+        $padding->label('Total processed jobs')->result($daemon->completedjobs + $daemon->failedjobs);
         $padding = $console->padding(30);
         $padding->label('├─ Completed')->result('<light_green>'.$daemon->completedjobs.'</green>');
         $padding->label('└─ Failed')->result('<red>'.$daemon->failedjobs.'</red>');
-        $console->border('-',$chars);
+        $console->border('-', $chars);
 
     }
 
     private static function calculateRunTime($starttime) {
 
-        $start_formatted = sprintf("%06d",($starttime - floor($starttime)) * 1000000);
-        $start = new DateTime( date('Y-m-d H:i:s.'.$start_formatted, $starttime) );
+        $start_formatted = sprintf("%06d", ($starttime - floor($starttime)) * 1000000);
+        $start = new DateTime(date('Y-m-d H:i:s.'.$start_formatted, $starttime));
         $end = new DateTime();
 
         $diff = $end->diff($start);

src/Comodojo/Extender/Listeners/LoopLimit.php

Spacing +1 added lines, -1 removed lines

@@ -9,7 +9,7 @@
 
         $daemon = $event->getDaemon();
 
-        if ( $daemon->looplimit === $daemon->loopcount) {
+        if ( $daemon->looplimit === $daemon->loopcount ) {
             $daemon->logger->info('Stopping daemon due to loop limit ('.$daemon->looplimit.') reached');
             // $daemon->stop();
             $daemon->loopactive = false;

src/Comodojo/Extender/Listeners/LoopSummary.php

Spacing +2 added lines, -2 removed lines

@@ -14,10 +14,10 @@
 
         if ( empty($jobs) ) return;
 
-        $console->border('-',30);
+        $console->border('-', 30);
         $console->bold()->green('Extender loop summary');
         $console->out("Loop duration: ".round($daemon->loopelapsed));
-        $console->border('-',30);
+        $console->border('-', 30);
         $console->out("Executed jobs: ");
         $console->table($jobs);
 

src/Comodojo/Extender/Jobs/Runner.php

Spacing +13 added lines, -13 removed lines

@@ -123,10 +123,10 @@ 
 
     public function run() {
 
-        foreach ($this->manager->queued() as $uid => $job) {
+        foreach ( $this->manager->queued() as $uid => $job ) {
 
-            $this->events->emit( new JobEvent('start', $job) );
-            $this->events->emit( new JobStatusEvent('start', $job) );
+            $this->events->emit(new JobEvent('start', $job));
+            $this->events->emit(new JobStatusEvent('start', $job));
 
             if ( $this->multithread === false ) {
 
@@ -143,8 +143,8 @@ 
 
                 $this->manager->isCompleted($uid, $result->success, $result->result, $result->wid);
 
-                $this->events->emit( new JobEvent('stop', $job) );
-                $this->events->emit( new JobStatusEvent('stop', $job) );
+                $this->events->emit(new JobEvent('stop', $job));
+                $this->events->emit(new JobStatusEvent('stop', $job));
 
                 continue;
 
@@ -158,8 +158,8 @@ 
 
                 $this->manager->isAborted($uid, $e->getMessage());
 
-                $this->events->emit( new JobEvent('stop', $job) );
-                $this->events->emit( new JobStatusEvent('stop', $job) );
+                $this->events->emit(new JobEvent('stop', $job));
+                $this->events->emit(new JobStatusEvent('stop', $job));
 
                 continue;
 
@@ -169,7 +169,7 @@ 
 
             if ( $this->max_childs > 0 && count($this->manager->running()) >= $this->max_childs ) {
 
-                while( count($this->manager->running()) >= $this->max_childs ) {
+                while ( count($this->manager->running()) >= $this->max_childs ) {
 
                     $this->catcher();
 
@@ -342,8 +342,8 @@ 
 
                 $this->logger->notice("Job ".$job->name."(id: ".$job->id.", uid: $uid) ends in $status");
 
-                $this->events->emit( new JobEvent('stop', $job) );
-                $this->events->emit( new JobStatusEvent('stop', $job) );
+                $this->events->emit(new JobEvent('stop', $job));
+                $this->events->emit(new JobStatusEvent('stop', $job));
 
             } else {
 
@@ -373,8 +373,8 @@ 
 
                     $this->logger->notice("Job ".$job->name."(id: ".$job->id.", uid: $uid) ends in error");
 
-                    $this->events->emit( new JobEvent('stop', $job) );
-                    $this->events->emit( new JobStatusEvent('stop', $job) );
+                    $this->events->emit(new JobEvent('stop', $job));
+                    $this->events->emit(new JobStatusEvent('stop', $job));
 
                 }
 
@@ -386,7 +386,7 @@ 
 
     private function abortQueued($message) {
 
-        foreach ($this->manager->queued() as $uid => $job) {
+        foreach ( $this->manager->queued() as $uid => $job ) {
 
             $this->manager->isAborted($uid, $message);
 

src/Comodojo/Extender/Task/Table.php

Spacing +1 added lines, -1 removed lines

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

src/Comodojo/Extender/Task/Runner.php

Spacing +6 added lines, -6 removed lines

@@ -88,7 +88,7 @@ 
 
             $thetask = $this->table->get($task)->getInstance($name, $parameters);
 
-            $this->events->emit( new TaskEvent('start', $thetask) );
+            $this->events->emit(new TaskEvent('start', $thetask));
 
             $pid = $thetask->getPid();
 
@@ -101,7 +101,7 @@ 
                 $this->stopwatch->getStartTime()
             );
 
-            $this->events->emit( new TaskStatusEvent('start', $thetask) );
+            $this->events->emit(new TaskStatusEvent('start', $thetask));
 
             try {
 
@@ -123,11 +123,11 @@ 
 
             }
 
-            $this->events->emit( new TaskStatusEvent($status ? 'success' : 'error', $thetask) );
+            $this->events->emit(new TaskStatusEvent($status ? 'success' : 'error', $thetask));
 
-            $this->events->emit( new TaskStatusEvent('stop', $thetask) );
+            $this->events->emit(new TaskStatusEvent('stop', $thetask));
 
-            $this->events->emit( new TaskEvent('stop', $thetask) );
+            $this->events->emit(new TaskEvent('stop', $thetask));
 
             $this->stopwatch->stop();
 
@@ -144,7 +144,7 @@ 
         }
 
         return new Result(
-            array (
+            array(
                 $pid,
                 $name,
                 $status,