comodojo / extender.framework

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