comodojo / extender.framework

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

@@ -94,7 +94,7 @@ 
 
             $thetask = $task_def->getInstance($name, $parameters);
 
-            $this->events->emit( new TaskEvent('start', $thetask) );
+            $this->events->emit(new TaskEvent('start', $thetask));
 
             $pid = $thetask->getPid();
 
@@ -117,7 +117,7 @@ 
 
                 $status = Worklog::STATUS_COMPLETE;
 
-                $this->events->emit( new TaskEvent('complete', $thetask) );
+                $this->events->emit(new TaskEvent('complete', $thetask));
 
             } catch (TaskException $te) {
 
@@ -125,7 +125,7 @@ 
 
                 $result = $te->getMessage();
 
-                $this->events->emit( new TaskEvent('abort', $thetask) );
+                $this->events->emit(new TaskEvent('abort', $thetask));
 
             } catch (Exception $e) {
 
@@ -133,13 +133,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();
 
@@ -161,7 +161,7 @@ 
                 $this->worklog_id
             ]);
 
-            $this->events->emit( new TaskEvent(self::statusToEvent($status), $thetask, $result) );
+            $this->events->emit(new TaskEvent(self::statusToEvent($status), $thetask, $result));
 
         } catch (Exception $e) {
 
@@ -247,7 +247,7 @@ 
                 $worklog->setJid($schedule);
             }
 
-            $this->events->emit( new WorklogEvent('open', $worklog) );
+            $this->events->emit(new WorklogEvent('open', $worklog));
 
             $em->persist($worklog);
             $em->flush();
@@ -286,7 +286,7 @@ 
                 $worklog->setJid($schedule);
             }
 
-            $this->events->emit( new WorklogEvent('close', $worklog) );
+            $this->events->emit(new WorklogEvent('close', $worklog));
 
             $em->persist($worklog);
             $em->flush();
@@ -301,7 +301,7 @@ 
 
     protected function statusToEvent($status) {
 
-        switch ($status) {
+        switch ( $status ) {
             case Worklog::STATUS_COMPLETE:
                 return 'complete';
                 break;

src/Comodojo/Extender/Queue/Manager.php

Spacing +5 added lines, -5 removed lines

@@ -84,7 +84,7 @@ 
 
     public function __destruct() {
 
-        if ($this->destroy_em) {
+        if ( $this->destroy_em ) {
             $em = $this->getEntityManager();
             $em->getConnection()->close();
             $em->close();
@@ -102,11 +102,11 @@ 
 
     public function flush(array $queue) {
 
-        $this->getEvents()->emit( new QueueEvent('flush', null, $queue) );
+        $this->getEvents()->emit(new QueueEvent('flush', null, $queue));
 
         $em = $this->getEntityManager();
 
-        foreach ($queue as $record) {
+        foreach ( $queue as $record ) {
             $em->remove($record);
         }
 
@@ -132,7 +132,7 @@ 
 
         $records = [];
 
-        foreach ($queue as $name => $request) {
+        foreach ( $queue as $name => $request ) {
             $records[] = $request instanceof Request ? $this->doAddRequest($request, $em) : false;
         }
 
@@ -144,7 +144,7 @@ 
 
     protected function doAddRequest(Request $request, EntityManager $em) {
 
-        $this->getEvents()->emit( new QueueEvent('add', $request) );
+        $this->getEvents()->emit(new QueueEvent('add', $request));
 
         $record = new Queue();
         $record->setName($request->getName())->setRequest($request);

src/Comodojo/Extender/Schedule/Manager.php

Spacing +11 added lines, -11 removed lines

@@ -78,7 +78,7 @@ 
 
     public function __destruct() {
 
-        if ($this->destroy_em) {
+        if ( $this->destroy_em ) {
             $em = $this->getEntityManager();
             $em->getConnection()->close();
             $em->close();
@@ -153,7 +153,7 @@ 
 
         $schedule->setFirstrun($schedule->getNextPlannedRun($time));
 
-        $this->getEvents()->emit( new ScheduleEvent('add', $schedule) );
+        $this->getEvents()->emit(new ScheduleEvent('add', $schedule));
 
         $em = $this->getEntityManager();
 
@@ -171,13 +171,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);
 
@@ -211,7 +211,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);
 
@@ -231,7 +231,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);
 
@@ -249,7 +249,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);
 
@@ -267,7 +267,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);
 
@@ -287,7 +287,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);
 
@@ -307,7 +307,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);
 
@@ -327,7 +327,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);