comodojo / extender.framework

src/Comodojo/Extender/Jobs/Job.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
 
     use DataAccessTrait;
     
-    public function __construct($name, $id, $task, $class, $parameters=array()) {
+    public function __construct($name, $id, $task, $class, $parameters = array()) {
         
         $this->name = $name;
         $this->id = $id;

src/Comodojo/Extender/Tasks/TaskInterface.php

Doc Comments -3 removed lines

@@ -32,10 +32,7 @@
      * 
      * @param   array           $parameters     Array of parameters (if any)
      * @param   \Monolog\Logger $logger
-     * @param   int             $pid            Task PID (if any)
      * @param   string          $name           Task Name
-     * @param   int             $timestamp      Start timestamp (if null will be retrieved directly)
-     * @param   bool            $multithread    Multithread switch
      * 
      * @return  Object  $this 
      */

src/Comodojo/Extender/Components/ArrayAccess.php

Doc Comments +1 added lines

@@ -27,6 +27,7 @@
     /**
      * Return the value at index
      *
+     * @param string $index
      * @return string $index The offset
      */
      public function offsetGet($index) {

Indentation +29 added lines, -29 removed lines

@@ -29,45 +29,45 @@
      *
      * @return string $index The offset
      */
-     public function offsetGet($index) {
+        public function offsetGet($index) {
 
-         return $this->data[$index];
+            return $this->data[$index];
 
-     }
+        }
 
-     /**
-     * Assigns a value to index offset
-     *
-     * @param string $index The offset to assign the value to
-     * @param mixed  $value The value to set
-     */
-     public function offsetSet($index, $value) {
+        /**
+         * Assigns a value to index offset
+         *
+         * @param string $index The offset to assign the value to
+         * @param mixed  $value The value to set
+         */
+        public function offsetSet($index, $value) {
 
-         $this->data[$index] = $value;
+            $this->data[$index] = $value;
 
-     }
+        }
 
-     /**
-     * Unsets an index
-     *
-     * @param string $index The offset to unset
-     */
-     public function offsetUnset($index) {
+        /**
+         * Unsets an index
+         *
+         * @param string $index The offset to unset
+         */
+        public function offsetUnset($index) {
 
-         unset($this->data[$index]);
+            unset($this->data[$index]);
 
-     }
+        }
 
-     /**
-     * Check if an index exists
-     *
-     * @param string $index Offset
-     * @return boolean
-     */
-     public function offsetExists($index) {
+        /**
+         * Check if an index exists
+         *
+         * @param string $index Offset
+         * @return boolean
+         */
+        public function offsetExists($index) {
 
-         return $this->offsetGet($index) !== null;
+            return $this->offsetGet($index) !== null;
 
-     }
+        }
 
 }

src/Comodojo/Extender/Tasks/AbstractTask.php

Doc Comments -3 removed lines

@@ -32,10 +32,7 @@
      * 
      * @param   array           $parameters     Array of parameters (if any)
      * @param   \Monolog\Logger $logger
-     * @param   int             $pid            Task PID (if any)
      * @param   string          $name           Task Name
-     * @param   int             $timestamp      Start timestamp (if null will be retrieved directly)
-     * @param   bool            $multithread    Multithread switch
      * 
      * @return  Object  $this 
      */

src/Comodojo/Extender/Tasks/Table.php

Spacing +1 added lines, -1 removed lines

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

src/Comodojo/Extender/Base/Process.php

Spacing +4 added lines, -4 removed lines

@@ -44,7 +44,7 @@ 
         LoggerInterface $logger,
         Emitter $events,
         $niceness = null
-    ){
+    ) {
 
         // Setup parent Model
         parent::_construct($configuration, $logger);
@@ -122,7 +122,7 @@ 
 
             $this->logger->info("Received TERM signal, shutting down process gracefully");
 
-            $this->events->emit( new SignalEvent($signal, $this) );
+            $this->events->emit(new SignalEvent($signal, $this));
 
             $this->end(0);
 
@@ -141,7 +141,7 @@ 
 
             $this->logger->info("Received TERM signal, shutting down process");
 
-            $this->events->emit( new SignalEvent($signal, $this) );
+            $this->events->emit(new SignalEvent($signal, $this));
 
             $this->end(1);
 
@@ -160,7 +160,7 @@ 
 
             $this->logger->info("Received $signal signal, firing associated event(s)");
 
-            $this->events->emit( new SignalEvent($signal, $this) );
+            $this->events->emit(new SignalEvent($signal, $this));
 
         }
 

Braces +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
         LoggerInterface $logger,
         Emitter $events,
         $niceness = null
-    ){
+    ) {
 
         // Setup parent Model
         parent::_construct($configuration, $logger);

src/Comodojo/Extender/Events/TaskStatusEvent.php

Doc Comments +3 added lines

@@ -30,6 +30,9 @@
 
     private $task;
 
+    /**
+     * @param string $status
+     */
     public function __construct($status, TaskInterface $task) {
 
         $name = $task->name;

src/Comodojo/Extender/Tasks/Worklog.php

Indentation +4 added lines, -4 removed lines

@@ -47,21 +47,21 @@
             ->createQueryBuilder()
             ->insert($this->table)
             ->values(array (
-				'id' => 0,
+                'id' => 0,
                 'status' => '?',
                 'pid' => '?',
                 'name' => '?',
                 'jid' => '?',
                 'task' => '?',
-				'parameters' => '?',
+                'parameters' => '?',
                 'start' => '?'
             ))
             ->setParameter(0, 'RUNNING')
-			->setParameter(1, $pid)
+            ->setParameter(1, $pid)
             ->setParameter(2, $name)
             ->setParameter(3, $jobid)
             ->setParameter(4, $task)
-			->setParameter(5, serialize($parameters))
+            ->setParameter(5, serialize($parameters))
             ->setParameter(6, $start)
             ->execute();
 

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
         $this->dbh
             ->createQueryBuilder()
             ->insert($this->table)
-            ->values(array (
+            ->values(array(
 				'id' => 0,
                 'status' => '?',
                 'pid' => '?',

src/Comodojo/Extender/Tasks/Runner.php

Spacing +6 added lines, -6 removed lines

@@ -79,7 +79,7 @@ 
 
             $thetask = $this->createTask($name, $task, $parameters);
 
-            $this->events->emit( new TaskEvent('start', $thetask) );
+            $this->events->emit(new TaskEvent('start', $thetask));
 
             $pid = $thetask->pid;
 
@@ -87,7 +87,7 @@ 
 
             $status = true;
 
-            $this->events->emit( new TaskStatusEvent('start', $thetask) );
+            $this->events->emit(new TaskStatusEvent('start', $thetask));
 
             try {
 
@@ -108,11 +108,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));
 
             $end = microtime(true);
 
@@ -127,7 +127,7 @@ 
         }
 
         return new Result(
-            array (
+            array(
                 $pid,
                 $name,
                 $status,