comodojo / extender.framework

src/Comodojo/Extender/Task/Request.php

Doc Comments +5 added lines, -1 removed lines

@@ -164,7 +164,7 @@ 
     /**
      * Get start timestamp (microseconds)
      *
-     * @return float
+     * @return integer
      */
     public function getStartTimestamp() {
 
@@ -283,6 +283,10 @@ 
 
     }
 
+    /**
+     * @param string $name
+     * @param string $task
+     */
     public static function create($name, $task, TaskParameters $parameters = null) {
 
         return new Request($name, $task, $parameters);

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;
 

src/Comodojo/Extender/Socket/SocketInjector.php

Indentation +36 added lines, -36 removed lines

@@ -32,8 +32,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.refresh",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Refresh::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Refresh::execute',
+                    $daemon)
             ->setDescription("Refresh current scheduler's schedule")
             ->setReturnType('boolean')
         );
@@ -41,8 +41,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.info",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Info::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Info::execute',
+                    $daemon)
             ->setDescription("Refresh current scheduler status")
             ->setReturnType('array')
         );
@@ -50,8 +50,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.add",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Add::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Add::execute',
+                    $daemon)
             ->setDescription("Set new schedule")
             ->addParameter('struct', 'schedule')
             ->addParameter('struct', 'request')
@@ -61,8 +61,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.list",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\GetList::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\GetList::execute',
+                    $daemon)
             ->setDescription("List all installed schedules")
             ->setReturnType('array')
         );
@@ -70,8 +70,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.get",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Get::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Get::execute',
+                    $daemon)
             ->setDescription("Get a schedule and related task request by id (int) or name (string)")
             ->addParameter('int', 'id')
             ->setReturnType('array')
@@ -83,8 +83,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.edit",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Edit::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Edit::execute',
+                    $daemon)
             ->setDescription("Edit a schedule")
             ->addParameter('struct', 'schedule')
             ->addParameter('struct', 'request')
@@ -94,8 +94,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.disable",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Disable::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Disable::execute',
+                    $daemon)
             ->setDescription("Disable a schedule by id (int) or name (string)")
             ->addParameter('int', 'id')
             ->setReturnType('boolean')
@@ -107,8 +107,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.enable",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Enable::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Enable::execute',
+                    $daemon)
             ->setDescription("Enable a schedule by id (int) or name (string)")
             ->addParameter('int', 'id')
             ->setReturnType('boolean')
@@ -120,8 +120,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.remove",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Remove::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Remove::execute',
+                    $daemon)
             ->setDescription("Remove a schedule by id (int) or name (string)")
             ->addParameter('int', 'id')
             ->setReturnType('boolean')
@@ -137,8 +137,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "queue.info",
-                 'Comodojo\Extender\Socket\Commands\Queue\Info::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Queue\Info::execute',
+                    $daemon)
             ->setDescription("Get current queue status")
             ->setReturnType('array')
         );
@@ -146,8 +146,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "queue.add",
-                 'Comodojo\Extender\Socket\Commands\Queue\Add::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Queue\Add::execute',
+                    $daemon)
             ->setDescription("Push new request to queue")
             ->addParameter('struct', 'request')
             ->setReturnType('string')
@@ -156,8 +156,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "queue.addBulk",
-                 'Comodojo\Extender\Socket\Commands\Queue\AddBulk::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Queue\AddBulk::execute',
+                    $daemon)
             ->setDescription("Push new requests to queue")
             ->addParameter('array', 'requests')
             ->setReturnType('array')
@@ -170,8 +170,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "worklog.count",
-                 'Comodojo\Extender\Socket\Commands\Worklog\Count::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Worklog\Count::execute',
+                    $daemon)
             ->setDescription("Count recorded worklogs")
             ->setReturnType('int')
         );
@@ -179,8 +179,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "worklog.list",
-                 'Comodojo\Extender\Socket\Commands\Worklog\GetList::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Worklog\GetList::execute',
+                    $daemon)
             ->setDescription("Get a list of worklog according to (optional) filter")
             ->setReturnType('array')
             ->addSignature()
@@ -191,8 +191,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "worklog.byId",
-                 'Comodojo\Extender\Socket\Commands\Worklog\ById::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Worklog\ById::execute',
+                    $daemon)
             ->setDescription("Get a worklog from id")
             ->addParameter('int', 'id')
             ->setReturnType('struct')
@@ -201,8 +201,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "worklog.byUid",
-                 'Comodojo\Extender\Socket\Commands\Worklog\ByUid::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Worklog\ByUid::execute',
+                    $daemon)
             ->setDescription("Get a worklog from uid")
             ->addParameter('string', 'uid')
             ->setReturnType('struct')
@@ -211,8 +211,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "worklog.byJid",
-                 'Comodojo\Extender\Socket\Commands\Worklog\ByJid::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Worklog\ByJid::execute',
+                    $daemon)
             ->setDescription("Get a list of worklog from job id according to (optional) filter")
             ->addParameter('int', 'jid')
             ->setReturnType('array')
@@ -225,8 +225,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "worklog.byPid",
-                 'Comodojo\Extender\Socket\Commands\Worklog\ByPid::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Worklog\ByPid::execute',
+                    $daemon)
             ->setDescription("Get a list of worklog from system pid according to (optional) filter")
             ->addParameter('int', 'pid')
             ->setReturnType('array')

src/Comodojo/Extender/Socket/Messages/Scheduler/Schedule.php

Spacing +1 added lines, -1 removed lines

@@ -72,7 +72,7 @@
 
     public function setEnabled($enabled) {
 
-        $this->enabled =  DataFilter::filterBoolean($enabled);
+        $this->enabled = DataFilter::filterBoolean($enabled);
 
         return $this;
 

src/Comodojo/Extender/Socket/Commands/Queue/AddBulk.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
         $requests = [];
 
         try {
-            foreach ($messages as $message) {
+            foreach ( $messages as $message ) {
                 $requests[] = TaskRequest::createFromMessage(
                     TaskRequestMessage::createFromExport($message)
                 );

src/Comodojo/Extender/Socket/Commands/Scheduler/Disable.php

Spacing +1 added lines, -2 removed lines

@@ -17,8 +17,7 @@
         $id = $params->get('id');
         $name = $params->get('name');
 
-        $disable = empty($id) ? $manager->disableByName($name) :
-            $manager->disable($id);
+        $disable = empty($id) ? $manager->disableByName($name) : $manager->disable($id);
 
         $refresh = Refresh::execute($params, $daemon);
 

src/Comodojo/Extender/Socket/Commands/Scheduler/Enable.php

Spacing +1 added lines, -2 removed lines

@@ -17,8 +17,7 @@
         $id = $params->get('id');
         $name = $params->get('name');
 
-        $enable = empty($id) ? $manager->enableByName($name) :
-            $manager->enable($id);
+        $enable = empty($id) ? $manager->enableByName($name) : $manager->enable($id);
 
         $refresh = Refresh::execute($params, $daemon);
 

src/Comodojo/Extender/Socket/Commands/Scheduler/Add.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
         $schedule_message = $params->get('schedule');
         $request_message = $params->get('request');
 
-        if (empty($schedule_message['name']) || empty($schedule_message['expression'])) {
+        if ( empty($schedule_message['name']) || empty($schedule_message['expression']) ) {
             throw new RpcException("Missing schedule name or invalid expression", -32600);
         }
 

src/Comodojo/Extender/Socket/Commands/Scheduler/GetList.php

Spacing +2 added lines, -2 removed lines

@@ -19,12 +19,12 @@
         $schedule_messages = [];
         $schedules = $manager->getAll();
 
-        foreach ($schedules as $schedule) {
+        foreach ( $schedules as $schedule ) {
             $schedule_message = new ScheduleMessage();
             $schedule_message->setId($schedule->getId());
             $schedule_message->setName($schedule->getName());
             $schedule_message->setDescription($schedule->getDescription());
-            $schedule_message->setExpression((string)$schedule->getExpression());
+            $schedule_message->setExpression((string) $schedule->getExpression());
             $schedule_message->setEnabled($schedule->getEnabled());
             $schedule_messages[] = $schedule_message->export();
         }

src/Comodojo/Extender/Socket/Commands/Scheduler/Get.php

Spacing +2 added lines, -3 removed lines

@@ -19,8 +19,7 @@ 
         $id = $params->get('id');
         $name = $params->get('name');
 
-        $schedule = empty($id) ? $manager->getByName($name) :
-            $manager->get($id);
+        $schedule = empty($id) ? $manager->getByName($name) : $manager->get($id);
 
         $request = $schedule->getRequest();
 
@@ -28,7 +27,7 @@ 
         $schedule_message->setId($schedule->getId());
         $schedule_message->setName($schedule->getName());
         $schedule_message->setDescription($schedule->getDescription());
-        $schedule_message->setExpression((string)$schedule->getExpression());
+        $schedule_message->setExpression((string) $schedule->getExpression());
         $schedule_message->setEnabled($schedule->getEnabled());
 
         $request_message = $request->convertToMessage();