comodojo / extender.framework

src/Extender.php

Indentation +89 added lines, -89 removed lines

@@ -653,175 +653,175 @@
 
     private function cycle() {
 
-      // fire extender ready event
+        // fire extender ready event
 
-      $this->events->fire("extender", "VOID", $this);
+        $this->events->fire("extender", "VOID", $this);
 
-      // dispatch signals (if multithread active)
+        // dispatch signals (if multithread active)
 
-      if ( $this->getMultithreadMode() ) pcntl_signal_dispatch();
+        if ( $this->getMultithreadMode() ) pcntl_signal_dispatch();
 
-      // if extender is paused (SIGINT), skip to extend
+        // if extender is paused (SIGINT), skip to extend
 
-      if ( $this->paused ) return;
+        if ( $this->paused ) return;
 
-      // fix relative timestamp
+        // fix relative timestamp
 
-      $this->timestamp = microtime(true);
+        $this->timestamp = microtime(true);
 
-      // fire tasktable event
+        // fire tasktable event
 
-      $this->tasks = $this->events->fire("extender.tasks", "TASKSTABLE", $this->tasks);
+        $this->tasks = $this->events->fire("extender.tasks", "TASKSTABLE", $this->tasks);
 
-      // get the next planned activity interval
+        // get the next planned activity interval
 
-      $plans = Planner::get();
+        $plans = Planner::get();
 
-      if ( !is_null($plans) AND $this->timestamp < $plans ) {
+        if ( !is_null($plans) AND $this->timestamp < $plans ) {
 
-          // nothing to do right now, still waiting if in daemon mode
+            // nothing to do right now, still waiting if in daemon mode
 
-          $this->logger->info("Next planned job: ".date('c', $plans));
+            $this->logger->info("Next planned job: ".date('c', $plans));
 
-          $this->logger->notice("Extender completed\n");
+            $this->logger->notice("Extender completed\n");
 
-          if ( $this->getDaemonMode() === false ) {
+            if ( $this->getDaemonMode() === false ) {
 
-              $this->shutdown(true);
+                $this->shutdown(true);
 
-              self::end(0);
+                self::end(0);
 
-          }
+            }
 
-          return;
+            return;
 
-      }
+        }
 
-      // if no plan is retrieved, try to retrieve it from scheduler
+        // if no plan is retrieved, try to retrieve it from scheduler
 
-      try {
+        try {
 
-          // get schedules and dispatch schedule event
+            // get schedules and dispatch schedule event
 
-          list($schedules, $planned) = Scheduler::getSchedules($this->logger, $this->timestamp);
+            list($schedules, $planned) = Scheduler::getSchedules($this->logger, $this->timestamp);
 
-          // write next planned activity interval
+            // write next planned activity interval
 
-          if ( !is_null($planned) AND $planned != 0 ) Planner::set($planned);
+            if ( !is_null($planned) AND $planned != 0 ) Planner::set($planned);
 
-          $scheduled = new Schedule();
+            $scheduled = new Schedule();
 
-          $scheduled->setSchedules($schedules);
+            $scheduled->setSchedules($schedules);
 
-          // expose the current shcedule via events
+            // expose the current shcedule via events
 
-          $scheduled = $this->events->fire("extender.schedule", "SCHEDULE", $scheduled);
+            $scheduled = $this->events->fire("extender.schedule", "SCHEDULE", $scheduled);
 
-          // if no jobs in queue, exit gracefully
+            // if no jobs in queue, exit gracefully
 
-          if ( $scheduled->howMany() == 0 ) {
+            if ( $scheduled->howMany() == 0 ) {
 
-              $this->logger->info("No jobs to process right now, exiting");
+                $this->logger->info("No jobs to process right now, exiting");
 
-              $this->logger->notice("Extender completed\n");
+                $this->logger->notice("Extender completed\n");
 
-              if ( $this->getDaemonMode() === false ) {
+                if ( $this->getDaemonMode() === false ) {
 
-                  $this->shutdown(true);
+                    $this->shutdown(true);
 
-                  self::end(0);
+                    self::end(0);
 
-              }
+                }
 
-              return;
+                return;
 
-          }
+            }
 
-          // compose jobs
+            // compose jobs
 
-          foreach ( $scheduled->getSchedules() as $schedule ) {
+            foreach ( $scheduled->getSchedules() as $schedule ) {
 
-              if ( $this->tasks->isRegistered($schedule['task']) ) {
+                if ( $this->tasks->isRegistered($schedule['task']) ) {
 
-                  $job = new Job();
+                    $job = new Job();
 
-                  $job->setName($schedule['name'])
-                      ->setId($schedule['id'])
-                      ->setParameters(unserialize($schedule['params']))
-                      ->setTask($schedule['task'])
-                      ->setClass($this->tasks->getClass($schedule['task']));
+                    $job->setName($schedule['name'])
+                        ->setId($schedule['id'])
+                        ->setParameters(unserialize($schedule['params']))
+                        ->setTask($schedule['task'])
+                        ->setClass($this->tasks->getClass($schedule['task']));
 
-                  $this->runner->addJob($job);
+                    $this->runner->addJob($job);
 
-              } else {
+                } else {
 
-                  $this->logger->warning("Skipping job due to unknown task", array(
-                      "ID"     => $schedule['id'],
-                      "NAME"   => $schedule['name'],
-                      "TASK"   => $schedule['task']
-                  ));
+                    $this->logger->warning("Skipping job due to unknown task", array(
+                        "ID"     => $schedule['id'],
+                        "NAME"   => $schedule['name'],
+                        "TASK"   => $schedule['task']
+                    ));
 
-              }
+                }
 
-          }
+            }
 
-          // lauch runner
+            // lauch runner
 
-          $result = $this->runner->run();
+            $result = $this->runner->run();
 
-          // free runner for next cycle
+            // free runner for next cycle
 
-          $this->runner->free();
+            $this->runner->free();
 
-          // compose results
+            // compose results
 
-          $results = new JobsResult($result);
+            $results = new JobsResult($result);
 
-          // update schedules
+            // update schedules
 
-          Scheduler::updateSchedules($this->logger, $result);
+            Scheduler::updateSchedules($this->logger, $result);
 
-          // increment counters
+            // increment counters
 
-          foreach ( $result as $r ) {
+            foreach ( $result as $r ) {
 
-              if ( $r[2] ) $this->completed_processes++;
+                if ( $r[2] ) $this->completed_processes++;
 
-              else $this->failed_processes++;
+                else $this->failed_processes++;
 
-          }
+            }
 
-      } catch (Exception $e) {
+        } catch (Exception $e) {
 
-          $this->logger->error($e->getMessage());
+            $this->logger->error($e->getMessage());
 
-          if ( $this->getDaemonMode() === false ) {
+            if ( $this->getDaemonMode() === false ) {
 
-              self::end(1);
+                self::end(1);
 
-          }
+            }
 
-      }
+        }
 
-      // fire result event
+        // fire result event
 
-      $this->events->fire("extender.result", "VOID", $results);
+        $this->events->fire("extender.result", "VOID", $results);
 
-      $this->logger->notice("Extender completed\n");
+        $this->logger->notice("Extender completed\n");
 
-      // show summary (if -s)
+        // show summary (if -s)
 
-      if ( $this->summary_mode ) self::showSummary($this->timestamp, $result, $this->color);
+        if ( $this->summary_mode ) self::showSummary($this->timestamp, $result, $this->color);
 
-      Status::dump($this->timestamp_absolute, $this->parent_pid, $this->completed_processes, $this->failed_processes, $this->paused);
+        Status::dump($this->timestamp_absolute, $this->parent_pid, $this->completed_processes, $this->failed_processes, $this->paused);
 
-      if ( $this->getDaemonMode() === false ) {
+        if ( $this->getDaemonMode() === false ) {
 
-          $this->shutdown(true);
+            $this->shutdown(true);
 
-          self::end(0);
+            self::end(0);
 
-      }
+        }
 
     }
 

Spacing +1 added lines, -1 removed lines

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

src/Scheduler/Scheduler.php

Braces +5 added lines, -10 removed lines

@@ -340,8 +340,7 @@ 
 
             $db->tablePrefix(EXTENDER_DATABASE_PREFIX)->table(EXTENDER_DATABASE_TABLE_JOBS)->keys("lastrun")->values($lastrun)->where('name', '=', $name)->update();
 
-        }
-        catch (DatabaseException $de) {
+        } catch (DatabaseException $de) {
 
             unset($db);
 
@@ -474,8 +473,7 @@ 
 
             if ( $e_count == 5 ) $e_array[] = "*";
 
-        }
-        catch (Exception $e) {
+        } catch (Exception $e) {
 
             throw $e;
 
@@ -516,8 +514,7 @@ 
                 ->where("enabled", "=", true)
                 ->get();
 
-        }
-        catch (DatabaseException $de) {
+        } catch (DatabaseException $de) {
 
             unset($db);
 
@@ -565,8 +562,7 @@ 
 
                 $next_calculated_run = $cron->getNextRunDate($last_date)->format('U');
 
-            }
-            catch (Exception $e) {
+            } catch (Exception $e) {
 
                 $logger->error("Job ".$job['name']." cannot be executed due to cron parsing error", array(
                     "ERROR" => $e->getMessage(),
@@ -619,8 +615,7 @@ 
 
                 $next_calculated_run = $cron->getNextRunDate($last_date)->format('U');
 
-            }
-            catch (Exception $e) {
+            } catch (Exception $e) {
 
                 return false;
 

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"]);
 

Doc Comments +1 added lines, -3 removed lines

@@ -74,8 +74,6 @@ 
     /**
      * Class constructor
      *
-     * @param \Console_CommandLine  $parser
-     * @param \Monolog\logger       $logger
      */
     public function add($command, $parameters) {
 
@@ -140,7 +138,7 @@ 
     /**
      * Execute command
      *
-     * @param   string          $command   Command to execute
+     * @param   string          $command_name   Command to execute
      * @param   array           $options   Options provided
      * @param   array           $args      Arguments provided
      * @param   Console_Color2  $color     Injected Console_Color2 instance

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/Components/Ipc.php

Doc Comments +3 added lines

@@ -66,6 +66,9 @@
 
     }
 
+    /**
+     * @param string $data
+     */
     public function write($uid, $data) {
 
         $writer = $this->ipc[$uid][self::WRITER];

src/Comodojo/Extender/Jobs/Runner.php

Doc Comments +3 added lines

@@ -384,6 +384,9 @@
 
     }
 
+    /**
+     * @param string $message
+     */
     private function abortQueued($message) {
 
         foreach ($this->manager->queued() as $uid => $job) {

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