gyselroth / mongodb-php-task-scheduler

src/Scheduler.php

Spacing +12 added lines, -12 removed lines

@@ -171,7 +171,7 @@ 
     /**
      * Init queue.
      */
-    public function __construct(Database $db, LoggerInterface $logger, array $config = [], ?Emitter $emitter=null)
+    public function __construct(Database $db, LoggerInterface $logger, array $config = [], ?Emitter $emitter = null)
     {
         $this->db = $db;
         $this->logger = $logger;
@@ -412,15 +412,15 @@ 
      *
      * @param Process[] $stack
      */
-    public function waitFor(array $stack, int $options=0): Scheduler
+    public function waitFor(array $stack, int $options = 0): Scheduler
     {
         $orig = [];
         $jobs = array_map(function($job) use(&$orig) {
-            if(!($job instanceof Process)) {
+            if (!($job instanceof Process)) {
                 throw new InvalidArgumentException('waitFor() requires a stack of Process[]');
             }
 
-            $orig[(string)$job->getId()] = $job;
+            $orig[(string) $job->getId()] = $job;
             return $job->getId();
         }, $stack);
 
@@ -440,7 +440,7 @@ 
                     return $this->waitFor($stack, $options);
                 }
 
-                $this->events->next($cursor, function () use($stack, $options) {
+                $this->events->next($cursor, function() use($stack, $options) {
                     $this->waitFor($stack, $options);
                 });
 
@@ -448,17 +448,17 @@ 
             }
 
             $event = $cursor->current();
-            $this->events->next($cursor, function () use($stack, $options) {
+            $this->events->next($cursor, function() use($stack, $options) {
                 $this->waitFor($stack, $options);
             });
 
-            $process = $orig[(string)$event['job']];
+            $process = $orig[(string) $event['job']];
             $data = $process->toArray();
             $data['status'] = $event['status'];
             $process->replace(new Process($data, $this));
             $this->emit($process);
 
-            if($event['status'] < JobInterface::STATUS_DONE) {
+            if ($event['status'] < JobInterface::STATUS_DONE) {
                 continue;
             } elseif (JobInterface::STATUS_FAILED === $event['status'] && isset($event['exception']) && $options & self::OPTION_THROW_EXCEPTION) {
                 throw new $event['exception']['class'](
@@ -469,7 +469,7 @@ 
 
             $done++;
 
-            if($done >= $expected) {
+            if ($done >= $expected) {
                 return $this;
             }
         }
@@ -500,7 +500,7 @@ 
                     return $this->listen($callback, $query);
                 }
 
-                $this->events->next($cursor, function () use ($callback, $query) {
+                $this->events->next($cursor, function() use ($callback, $query) {
                     return $this->listen($callback, $query);
                 });
 
@@ -508,7 +508,7 @@ 
             }
 
             $result = $cursor->current();
-            $this->events->next($cursor, function () use ($callback, $query) {
+            $this->events->next($cursor, function() use ($callback, $query) {
                 $this->listen($callback, $query);
             });
 
@@ -583,7 +583,7 @@ 
      */
     public function updateJobProgress(JobInterface $job, float $progress): self
     {
-        if($progress < 0 || $progress > 100) {
+        if ($progress < 0 || $progress > 100) {
             throw new LogicException('progress may only be between 0 to 100');
         }
 

src/Queue.php

Spacing +7 added lines, -7 removed lines

@@ -82,7 +82,7 @@ 
     /**
      * Init queue.
      */
-    public function __construct(Scheduler $scheduler, Database $db, WorkerFactoryInterface $factory, LoggerInterface $logger, ?Emitter $emitter=null)
+    public function __construct(Scheduler $scheduler, Database $db, WorkerFactoryInterface $factory, LoggerInterface $logger, ?Emitter $emitter = null)
     {
         $this->scheduler = $scheduler;
         $this->db = $db;
@@ -199,17 +199,17 @@ 
                         break;
                     }
 
-                    $this->events->next($cursor_events, function () {
+                    $this->events->next($cursor_events, function() {
                         $this->main();
                     });
                 }
 
                 $event = $cursor_events->current();
-                $this->events->next($cursor_events, function () {
+                $this->events->next($cursor_events, function() {
                     $this->main();
                 });
 
-                if($event === null) {
+                if ($event === null) {
                     break;
                 }
 
@@ -228,7 +228,7 @@ 
                     break;
                 }
 
-                $this->jobs->next($cursor_jobs, function () {
+                $this->jobs->next($cursor_jobs, function() {
                     $this->main();
                 });
 
@@ -237,7 +237,7 @@ 
 
             $job = $cursor_jobs->current();
 
-            $this->jobs->next($cursor_jobs, function () {
+            $this->jobs->next($cursor_jobs, function() {
                 $this->main();
             });
 
@@ -252,7 +252,7 @@ 
     {
         $this->emit($this->scheduler->getJob($event['job']));
 
-        if($event['status'] > JobInterface::STATUS_POSTPONED) {
+        if ($event['status'] > JobInterface::STATUS_POSTPONED) {
             $this->logger->debug('received event ['.$event['status'].'] for job ['.$event['job'].'], write into systemv queue', [
                 'category' => get_class($this),
             ]);

src/EventsTrait.php

Indentation +7 added lines, -7 removed lines

@@ -43,25 +43,25 @@
     protected function emit(Process $process): bool
     {
         switch ($process->getStatus()) {
-             case JobInterface::STATUS_WAITING:
+                case JobInterface::STATUS_WAITING:
                 $this->emitter->emit('taskscheduler.onWaiting', $process);
                 return true;
-             case JobInterface::STATUS_PROCESSING:
+                case JobInterface::STATUS_PROCESSING:
                 $this->emitter->emit('taskscheduler.onStart', $process);
                 return true;
-             case JobInterface::STATUS_DONE:
+                case JobInterface::STATUS_DONE:
                 $this->emitter->emit('taskscheduler.onDone', $process);
                 return true;
-             case JobInterface::STATUS_POSTPONED:
+                case JobInterface::STATUS_POSTPONED:
                 $this->emitter->emit('taskscheduler.onPostponed', $process);
                 return true;
-             case JobInterface::STATUS_FAILED:
+                case JobInterface::STATUS_FAILED:
                 $this->emitter->emit('taskscheduler.onFailed', $process);
                 return true;
-             case JobInterface::STATUS_TIMEOUT:
+                case JobInterface::STATUS_TIMEOUT:
                 $this->emitter->emit('taskscheduler.onTimeout', $process);
                 return true;
-             case JobInterface::STATUS_CANCELED:
+                case JobInterface::STATUS_CANCELED:
                 $this->emitter->emit('taskscheduler.onCancel', $process);
                 return true;
         }

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
      */
     public function on(string $event, Closure $handler)
     {
-        if(!in_array($event, Scheduler::VALID_EVENTS)) {
+        if (!in_array($event, Scheduler::VALID_EVENTS)) {
             $name = 'taskscheduler.on'.ucfirst($event);
         }