comodojo / extender.framework

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

Spacing +1 added lines, -2 removed lines

@@ -22,8 +22,7 @@
 
         try {
 
-            $remove = empty($id) ? $manager->removeByName($name) :
-                $manager->remove($id);
+            $remove = empty($id) ? $manager->removeByName($name) : $manager->remove($id);
 
         } catch (InvalidArgumentException $iae) {
             throw new RpcException("No record could be found", -31002);

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

Spacing +1 added lines, -2 removed lines

@@ -22,8 +22,7 @@
 
         try {
 
-            $enable = empty($id) ? $manager->enableByName($name) :
-                $manager->enable($id);
+            $enable = empty($id) ? $manager->enableByName($name) : $manager->enable($id);
 
         } catch (InvalidArgumentException $iae) {
             throw new RpcException("No record could be found", -31002);

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

Spacing +2 added lines, -3 removed lines

@@ -21,8 +21,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);
 
         if ( empty($schedule) ) throw new RpcException("No record could be found", -31002);
 
@@ -32,7 +31,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();

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

Spacing +1 added lines, -2 removed lines

@@ -22,8 +22,7 @@
 
         try {
 
-            $disable = empty($id) ? $manager->disableByName($name) :
-                $manager->disable($id);
+            $disable = empty($id) ? $manager->disableByName($name) : $manager->disable($id);
 
         } catch (InvalidArgumentException $iae) {
             throw new RpcException("No record could be found", -31002);

src/Comodojo/Extender/Socket/SocketInjector.php

Indentation +38 added lines, -38 removed lines

@@ -35,8 +35,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')
         );
@@ -44,8 +44,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "scheduler.info",
-                 'Comodojo\Extender\Socket\Commands\Scheduler\Info::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Scheduler\Info::execute',
+                    $daemon)
             ->setDescription("Show current scheduler status")
             ->setReturnType('array')
         );
@@ -53,8 +53,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')
@@ -64,8 +64,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')
         );
@@ -73,8 +73,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')
@@ -86,8 +86,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')
@@ -97,8 +97,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')
@@ -110,8 +110,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')
@@ -123,8 +123,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')
@@ -140,8 +140,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')
         );
@@ -149,8 +149,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')
@@ -159,8 +159,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')
@@ -173,8 +173,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')
         );
@@ -182,8 +182,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()
@@ -194,8 +194,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')
@@ -204,8 +204,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')
@@ -214,8 +214,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')
@@ -228,8 +228,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')
@@ -242,8 +242,8 @@ 
         $mmanager->add(
             RpcMethod::create(
                 "worklog.byPuid",
-                 'Comodojo\Extender\Socket\Commands\Worklog\ByPuid::execute',
-                 $daemon)
+                    'Comodojo\Extender\Socket\Commands\Worklog\ByPuid::execute',
+                    $daemon)
             ->setDescription("Get worklogs from parent uid")
             ->addParameter('string', 'puid')
             ->setReturnType('array')

src/Comodojo/Extender/Transformers/WorklogTransformer.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 
 class WorklogTransformer extends TransformerAbstract {
 
-    public function transform (Worklog $worklog) {
+    public function transform(Worklog $worklog) {
 
         $parameters = $worklog->getParameters()->export();
         if ( isset($parameters['parent']) && $parameters['parent'] instanceof \Comodojo\Extender\Task\Result ) {

src/Comodojo/Extender/Task/Runner.php

Spacing +9 added lines, -9 removed lines

@@ -89,7 +89,7 @@ 
 
             $thetask = $this->table->get($name)->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/Schedule/Manager.php

Spacing +10 added lines, -10 removed lines

@@ -130,7 +130,7 @@ 
 
         $schedule->setFirstrun($schedule->getNextPlannedRun($time));
 
-        $this->getEvents()->emit( new ScheduleEvent('add', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('add', $schedule));
 
         $em = $this->getEntityManager();
 
@@ -148,13 +148,13 @@ 
         $records = [];
         $em = $this->getEntityManager();
 
-        foreach ($schedules as $key => $schedule) {
+        foreach ( $schedules as $key => $schedule ) {
 
             try {
 
                 $schedule->setFirstrun($schedule->getNextPlannedRun($time));
 
-                $this->getEvents()->emit( new ScheduleEvent('add', $schedule) );
+                $this->getEvents()->emit(new ScheduleEvent('add', $schedule));
 
                 $em->persist($schedule);
 
@@ -188,7 +188,7 @@ 
 
         if ( empty($old_schedule) ) throw new InvalidArgumentException("Cannot find schedule with id $id");
 
-        $this->getEvents()->emit( new ScheduleEvent('edit', $schedule, $old_schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('edit', $schedule, $old_schedule));
 
         $old_schedule->merge($schedule);
 
@@ -208,7 +208,7 @@ 
 
         if ( is_null($schedule) ) throw new InvalidArgumentException("Cannot find scheule $id");
 
-        $this->getEvents()->emit( new ScheduleEvent('remove', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('remove', $schedule));
 
         $em->remove($schedule);
 
@@ -226,7 +226,7 @@ 
 
         if ( is_null($schedule) ) throw new InvalidArgumentException("Cannot find scheule $name");
 
-        $this->getEvents()->emit( new ScheduleEvent('remove', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('remove', $schedule));
 
         $em->remove($schedule);
 
@@ -244,7 +244,7 @@ 
 
         if ( is_null($schedule) ) throw new InvalidArgumentException("Cannot find scheule $id");
 
-        $this->getEvents()->emit( new ScheduleEvent('enable', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('enable', $schedule));
 
         $schedule->setEnabled(true);
 
@@ -264,7 +264,7 @@ 
 
         if ( is_null($schedule) ) throw new InvalidArgumentException("Cannot find scheule $name");
 
-        $this->getEvents()->emit( new ScheduleEvent('enable', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('enable', $schedule));
 
         $schedule->setEnabled(true);
 
@@ -284,7 +284,7 @@ 
 
         if ( is_null($schedule) ) throw new InvalidArgumentException("Cannot find scheule $id");
 
-        $this->getEvents()->emit( new ScheduleEvent('disable', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('disable', $schedule));
 
         $schedule->setEnabled(false);
 
@@ -304,7 +304,7 @@ 
 
         if ( is_null($schedule) ) throw new InvalidArgumentException("Cannot find scheule $name");
 
-        $this->getEvents()->emit( new ScheduleEvent('disable', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('disable', $schedule));
 
         $schedule->setEnabled(false);