spiral / framework

src/Queue/src/Driver/SyncDriver.php

Spacing +2 added lines, -2 removed lines

@@ -19,13 +19,13 @@
 
     public function __construct(
         private readonly Handler $coreHandler
-    ) {
+    ){
     }
 
     /** @inheritdoc */
     public function push(string $name, mixed $payload = [], OptionsInterface $options = null): string
     {
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay()){
             \sleep($options->getDelay());
         }
 

Braces +2 added lines, -1 removed lines

@@ -25,7 +25,8 @@
     /** @inheritdoc */
     public function push(string $name, mixed $payload = [], OptionsInterface $options = null): string
     {
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay())
+        {
             \sleep($options->getDelay());
         }
 

src/Queue/src/Failed/LogFailedJobHandler.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
 {
     public function __construct(
         private readonly ExceptionReporterInterface $reporter
-    ) {
+    ){
     }
 
     public function handle(string $driver, string $queue, string $job, mixed $payload, \Throwable $e): void

src/Queue/src/Queue.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
 {
     public function __construct(
         private readonly CoreInterface $core,
-    ) {
+    ){
     }
 
     public function push(string $name, mixed $payload = [], mixed $options = null): string

src/Queue/src/Event/JobProcessed.php

Spacing +1 added lines, -1 removed lines

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

src/Queue/src/Event/JobProcessing.php

Spacing +1 added lines, -1 removed lines

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

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

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
     public function __construct(
         private readonly CoreInterface $core,
         ?TracerFactoryInterface $tracerFactory = null,
-    ) {
+    ){
         $this->tracerFactory = $tracerFactory ?? new NullTracerFactory(new Container());
     }
 

src/Queue/src/JobHandler.php

Spacing +4 added lines, -4 removed lines

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

Braces +7 added lines, -3 removed lines

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

src/Queue/tests/ContainerRegistryT.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
 
 final class ContainerRegistryT extends TestCase
 {
-    private ContainerInterface|m\MockInterface $container;
+    private ContainerInterface | m\MockInterface $container;
     private ContainerRegistry $registry;
 
     protected function setUp(): void

src/Queue/tests/Interceptor/Consume/ErrorHandlerInterceptorTest.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
             $handler = m::mock(FailedJobHandlerInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload)){
             $this->markTestIncomplete('FailedJobHandlerInterface does not support non-array payloads');
             return;
         }

Braces +2 added lines, -1 removed lines

@@ -24,7 +24,8 @@
             $handler = m::mock(FailedJobHandlerInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload))
+        {
             $this->markTestIncomplete('FailedJobHandlerInterface does not support non-array payloads');
             return;
         }