comodojo / extender.framework

src/Comodojo/Extender/Task/Runner.php

Spacing +9 added lines, -9 removed lines

@@ -89,7 +89,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();
 
@@ -112,7 +112,7 @@ 
 
                 $status = Worklog::STATUS_COMPLETE;
 
-                $this->events->emit( new TaskEvent('complete', $thetask) );
+                $this->events->emit(new TaskEvent('complete', $thetask));
 
             } catch (TaskException $te) {
 
@@ -120,7 +120,7 @@ 
 
                 $result = $te->getMessage();
 
-                $this->events->emit( new TaskEvent('abort', $thetask) );
+                $this->events->emit(new TaskEvent('abort', $thetask));
 
             } catch (Exception $e) {
 
@@ -128,13 +128,13 @@ 
 
                 $result = $e->getMessage();
 
-                $this->events->emit( new TaskEvent('error', $thetask) );
+                $this->events->emit(new TaskEvent('error', $thetask));
 
             }
 
             $this->restoreErrorHandler();
 
-            $this->events->emit( new TaskEvent('stop', $thetask) );
+            $this->events->emit(new TaskEvent('stop', $thetask));
 
             $this->stopwatch->stop();
 
@@ -168,7 +168,7 @@ 
 
         ob_end_clean();
 
-        $this->events->emit( new TaskEvent(self::statusToEvent($status), $thetask, $result) );
+        $this->events->emit(new TaskEvent(self::statusToEvent($status), $thetask, $result));
 
         return $result;
 
@@ -227,7 +227,7 @@ 
                 $worklog->setJid($schedule);
             }
 
-            $this->events->emit( new WorklogEvent('open', $worklog) );
+            $this->events->emit(new WorklogEvent('open', $worklog));
 
             $em->persist($worklog);
             $em->flush();
@@ -266,7 +266,7 @@ 
                 $worklog->setJid($schedule);
             }
 
-            $this->events->emit( new WorklogEvent('close', $worklog) );
+            $this->events->emit(new WorklogEvent('close', $worklog));
 
             $em->persist($worklog);
             $em->flush();
@@ -281,7 +281,7 @@ 
 
     protected function statusToEvent($status) {
 
-        switch ($status) {
+        switch ( $status ) {
             case Worklog::STATUS_COMPLETE:
                 return 'complete';
                 break;

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;
 

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