spiral / framework

src/Jobs/src/JobHandler.php

Spacing +2 added lines, -2 removed lines

@@ -43,10 +43,10 @@
         $method = new \ReflectionMethod($this, static::HANDLE_FUNCTION);
         $method->setAccessible(true);
 
-        try {
+        try{
             $parameters = array_merge(['payload' => $payloadData, 'id' => $jobID], $payloadData);
             $method->invokeArgs($this, $this->resolver->resolveArguments($method, $parameters));
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new JobException(
                 sprintf('[%s] %s', get_class($this), $e->getMessage()),
                 $e->getCode(),

Braces +5 added lines, -2 removed lines

@@ -43,10 +43,13 @@
         $method = new \ReflectionMethod($this, static::HANDLE_FUNCTION);
         $method->setAccessible(true);
 
-        try {
+        try
+        {
             $parameters = array_merge(['payload' => $payloadData, 'id' => $jobID], $payloadData);
             $method->invokeArgs($this, $this->resolver->resolveArguments($method, $parameters));
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new JobException(
                 sprintf('[%s] %s', get_class($this), $e->getMessage()),
                 $e->getCode(),

src/Jobs/src/Registry/ContainerRegistry.php

Spacing +7 added lines, -7 removed lines

@@ -50,13 +50,13 @@ 
      */
     public function getHandler(string $jobType): HandlerInterface
     {
-        try {
+        try{
             $handler = $this->container->get($this->className($jobType));
-        } catch (ContainerException $e) {
+        }catch (ContainerException $e){
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
 
-        if (!$handler instanceof HandlerInterface) {
+        if (!$handler instanceof HandlerInterface){
             throw new JobException("Unable to resolve job handler for `{$jobType}`");
         }
 
@@ -69,13 +69,13 @@ 
      */
     public function getSerializer(string $jobType): SerializerInterface
     {
-        try {
+        try{
             $handler = $this->getHandler($jobType);
-        } catch (JobException $e) {
+        }catch (JobException $e){
             return $this->defaultSerializer;
         }
 
-        if ($handler instanceof SerializerInterface) {
+        if ($handler instanceof SerializerInterface){
             return $handler;
         }
 
@@ -89,7 +89,7 @@ 
     private function className(string $jobType): string
     {
         $names = explode('.', $jobType);
-        $names = array_map(function (string $value) {
+        $names = array_map(function (string $value){
             return $this->inflector->classify($value);
         }, $names);
 

Braces +16 added lines, -7 removed lines

@@ -50,13 +50,17 @@ 
      */
     public function getHandler(string $jobType): HandlerInterface
     {
-        try {
+        try
+        {
             $handler = $this->container->get($this->className($jobType));
-        } catch (ContainerException $e) {
+        }
+        catch (ContainerException $e)
+        {
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
 
-        if (!$handler instanceof HandlerInterface) {
+        if (!$handler instanceof HandlerInterface)
+        {
             throw new JobException("Unable to resolve job handler for `{$jobType}`");
         }
 
@@ -69,13 +73,17 @@ 
      */
     public function getSerializer(string $jobType): SerializerInterface
     {
-        try {
+        try
+        {
             $handler = $this->getHandler($jobType);
-        } catch (JobException $e) {
+        }
+        catch (JobException $e)
+        {
             return $this->defaultSerializer;
         }
 
-        if ($handler instanceof SerializerInterface) {
+        if ($handler instanceof SerializerInterface)
+        {
             return $handler;
         }
 
@@ -89,7 +97,8 @@ 
     private function className(string $jobType): string
     {
         $names = explode('.', $jobType);
-        $names = array_map(function (string $value) {
+        $names = array_map(function (string $value)
+        {
             return $this->inflector->classify($value);
         }, $names);
 

src/Jobs/src/Consumer.php

Spacing +5 added lines, -5 removed lines

@@ -37,18 +37,18 @@
      */
     public function serve(Worker $worker, callable $finalize = null): void
     {
-        while ($body = $worker->receive($context)) {
-            try {
+        while ($body = $worker->receive($context)){
+            try{
                 $context = json_decode($context, true);
                 $handler = $this->registry->getHandler($context['job']);
 
                 $handler->handle($context['job'], $context['id'], $body);
 
                 $worker->send('ok');
-            } catch (\Throwable $e) {
+            }catch (\Throwable $e){
                 $worker->error((string)$e->getMessage());
-            } finally {
-                if ($finalize !== null) {
+            }finally{
+                if ($finalize !== null){
                     call_user_func($finalize, $e ?? null);
                 }
             }

Braces +12 added lines, -5 removed lines

@@ -37,18 +37,25 @@
      */
     public function serve(Worker $worker, callable $finalize = null): void
     {
-        while ($body = $worker->receive($context)) {
-            try {
+        while ($body = $worker->receive($context))
+        {
+            try
+            {
                 $context = json_decode($context, true);
                 $handler = $this->registry->getHandler($context['job']);
 
                 $handler->handle($context['job'], $context['id'], $body);
 
                 $worker->send('ok');
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 $worker->error((string)$e->getMessage());
-            } finally {
-                if ($finalize !== null) {
+            }
+            finally
+            {
+                if ($finalize !== null)
+                {
                     call_user_func($finalize, $e ?? null);
                 }
             }

src/Jobs/src/ShortCircuit.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
         $payloadBody = $this->serialize($jobType, $payload);
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay()){
             sleep($options->getDelay());
         }
 

Braces +2 added lines, -1 removed lines

@@ -40,7 +40,8 @@
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
         $payloadBody = $this->serialize($jobType, $payload);
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay())
+        {
             sleep($options->getDelay());
         }
 

src/Jobs/src/Queue.php

Spacing +7 added lines, -7 removed lines

@@ -53,13 +53,13 @@ 
      */
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
-        try {
-            return $this->rpc->call(self::RR_SERVICE . '.Push', [
+        try{
+            return $this->rpc->call(self::RR_SERVICE.'.Push', [
                 'job'     => $this->jobName($jobType),
                 'payload' => $this->serialize($jobType, $payload),
                 'options' => $options ?? new Options(),
             ]);
-        } catch (RoadRunnerException | \Throwable $e) {
+        }catch (RoadRunnerException | \Throwable $e){
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -76,13 +76,13 @@ 
      */
     public function pushAsync(string $jobType, array $payload = [], Options $options = null): bool
     {
-        try {
-            return $this->rpc->call(self::RR_SERVICE . '.PushAsync', [
+        try{
+            return $this->rpc->call(self::RR_SERVICE.'.PushAsync', [
                 'job'     => $this->jobName($jobType),
                 'payload' => $this->serialize($jobType, $payload),
                 'options' => $options ?? new Options(),
             ]);
-        } catch (RoadRunnerException | \Throwable $e) {
+        }catch (RoadRunnerException | \Throwable $e){
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -94,7 +94,7 @@ 
     private function jobName(string $job): string
     {
         $names = explode('\\', $job);
-        $names = array_map(function (string $value) {
+        $names = array_map(function (string $value){
             return $this->inflector->camelize($value);
         }, $names);
 

Braces +12 added lines, -5 removed lines

@@ -53,13 +53,16 @@ 
      */
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
-        try {
+        try
+        {
             return $this->rpc->call(self::RR_SERVICE . '.Push', [
                 'job'     => $this->jobName($jobType),
                 'payload' => $this->serialize($jobType, $payload),
                 'options' => $options ?? new Options(),
             ]);
-        } catch (RoadRunnerException | \Throwable $e) {
+        }
+        catch (RoadRunnerException | \Throwable $e)
+        {
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -76,13 +79,16 @@ 
      */
     public function pushAsync(string $jobType, array $payload = [], Options $options = null): bool
     {
-        try {
+        try
+        {
             return $this->rpc->call(self::RR_SERVICE . '.PushAsync', [
                 'job'     => $this->jobName($jobType),
                 'payload' => $this->serialize($jobType, $payload),
                 'options' => $options ?? new Options(),
             ]);
-        } catch (RoadRunnerException | \Throwable $e) {
+        }
+        catch (RoadRunnerException | \Throwable $e)
+        {
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -94,7 +100,8 @@ 
     private function jobName(string $job): string
     {
         $names = explode('\\', $job);
-        $names = array_map(function (string $value) {
+        $names = array_map(function (string $value)
+        {
             return $this->inflector->camelize($value);
         }, $names);