spiral / framework

src/Queue/src/Interceptor/Consume/Handler.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
 {
     public function __construct(
         private readonly CoreInterface $core
-    ) {
+    ){
     }
 
     public function handle(

src/Queue/src/Job/CallableJob.php

Spacing +3 added lines, -3 removed lines

@@ -12,16 +12,16 @@
 {
     public function __construct(
         private readonly InvokerInterface $invoker
-    ) {
+    ){
     }
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        if (!isset($payload['callback'])) {
+        if (!isset($payload['callback'])){
             throw new InvalidArgumentException('Payload `callback` key is required.');
         }
 
-        if (!$payload['callback'] instanceof \Closure) {
+        if (!$payload['callback'] instanceof \Closure){
             throw new InvalidArgumentException('Payload `callback` key value type should be a closure.');
         }
 

Braces +4 added lines, -2 removed lines

@@ -17,11 +17,13 @@
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        if (!isset($payload['callback'])) {
+        if (!isset($payload['callback']))
+        {
             throw new InvalidArgumentException('Payload `callback` key is required.');
         }
 
-        if (!$payload['callback'] instanceof \Closure) {
+        if (!$payload['callback'] instanceof \Closure)
+        {
             throw new InvalidArgumentException('Payload `callback` key value type should be a closure.');
         }
 

src/Queue/src/Job/ObjectJob.php

Spacing +3 added lines, -3 removed lines

@@ -12,16 +12,16 @@
 {
     public function __construct(
         private readonly InvokerInterface $invoker
-    ) {
+    ){
     }
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        if (!isset($payload['object'])) {
+        if (!isset($payload['object'])){
             throw new InvalidArgumentException('Payload `object` key is required.');
         }
 
-        if (!\is_object($payload['object'])) {
+        if (!\is_object($payload['object'])){
             throw new InvalidArgumentException('Payload `object` key value type should be an object.');
         }
 

Braces +4 added lines, -2 removed lines

@@ -17,11 +17,13 @@
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        if (!isset($payload['object'])) {
+        if (!isset($payload['object']))
+        {
             throw new InvalidArgumentException('Payload `object` key is required.');
         }
 
-        if (!\is_object($payload['object'])) {
+        if (!\is_object($payload['object']))
+        {
             throw new InvalidArgumentException('Payload `object` key value type should be an object.');
         }
 

src/Queue/src/JobHandler.php

Spacing +3 added lines, -3 removed lines

@@ -19,17 +19,17 @@
 
     public function __construct(
         protected InvokerInterface $invoker
-    ) {
+    ){
     }
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        try {
+        try{
             $this->invoker->invoke(
                 [$this, $this->getHandlerMethod()],
                 \array_merge(['payload' => $payload, 'id' => $id, 'context' => $context], $payload)
             );
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $message = \sprintf('[%s] %s', $this::class, $e->getMessage());
             throw new JobException($message, (int)$e->getCode(), $e);
         }

Braces +5 added lines, -2 removed lines

@@ -24,12 +24,15 @@
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        try {
+        try
+        {
             $this->invoker->invoke(
                 [$this, $this->getHandlerMethod()],
                 \array_merge(['payload' => $payload, 'id' => $id, 'context' => $context], $payload)
             );
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $message = \sprintf('[%s] %s', $this::class, $e->getMessage());
             throw new JobException($message, (int)$e->getCode(), $e);
         }

src/Queue/src/Event/JobProcessing.php

Spacing +1 added lines, -1 removed lines

@@ -13,6 +13,6 @@
         public readonly string $id,
         public readonly array $payload,
         public readonly array $context = []
-    ) {
+    ){
     }
 }

src/Queue/src/Event/JobProcessed.php

Spacing +1 added lines, -1 removed lines

@@ -13,6 +13,6 @@
         public readonly string $id,
         public readonly array $payload,
         public readonly array $context = []
-    ) {
+    ){
     }
 }