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/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;
         }

src/Queue/tests/Interceptor/Push/CoreTest.php

Spacing +6 added lines, -6 removed lines

@@ -25,7 +25,7 @@ 
             $queue = m::mock(QueueInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload)){
             $this->markTestIncomplete('QueueInterface does not support non-array payloads');
             return;
         }
@@ -51,7 +51,7 @@ 
             $queue = m::mock(QueueInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload)){
             $this->markTestIncomplete('QueueInterface does not support non-array payloads');
             return;
         }
@@ -79,18 +79,18 @@ 
 
 
         $tracer->shouldReceive('getContext')->once()->andReturn(['foo' => ['bar']]);
-        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback) {
+        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback){
             return $callback();
         });
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null) {
+            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null){
                 return $name === 'foo'
                     && $payload === ['baz' => 'baf']
                     && $options->getHeader('foo') === ['bar'];
             });
 
-        ContainerScope::runScope($container, function() use($core) {
+        ContainerScope::runScope($container, function () use($core) {
             $core->callAction('foo', 'bar', [
                 'id' => 'job-id',
                 'payload' => ['baz' => 'baf'],
@@ -109,7 +109,7 @@ 
         $tracer->shouldNotReceive('getContext');
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null) {
+            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null){
                 return $name === 'foo'
                     && $payload === ['baz' => 'baf']
                     && $options !== null;

Braces +14 added lines, -7 removed lines

@@ -25,13 +25,15 @@ 
             $queue = m::mock(QueueInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload))
+        {
             $this->markTestIncomplete('QueueInterface does not support non-array payloads');
             return;
         }
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, mixed $p = [], OptionsInterface $options = null) use($payload) {
+            ->withArgs(function (string $name, mixed $p = [], OptionsInterface $options = null) use($payload)
+            {
                 return $name === 'foo' && $payload === $p && $options instanceof Options;
             });
 
@@ -51,7 +53,8 @@ 
             $queue = m::mock(QueueInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload))
+        {
             $this->markTestIncomplete('QueueInterface does not support non-array payloads');
             return;
         }
@@ -79,18 +82,21 @@ 
 
 
         $tracer->shouldReceive('getContext')->once()->andReturn(['foo' => ['bar']]);
-        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback) {
+        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback)
+        {
             return $callback();
         });
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null) {
+            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null)
+            {
                 return $name === 'foo'
                     && $payload === ['baz' => 'baf']
                     && $options->getHeader('foo') === ['bar'];
             });
 
-        ContainerScope::runScope($container, function() use($core) {
+        ContainerScope::runScope($container, function() use($core)
+        {
             $core->callAction('foo', 'bar', [
                 'id' => 'job-id',
                 'payload' => ['baz' => 'baf'],
@@ -109,7 +115,8 @@ 
         $tracer->shouldNotReceive('getContext');
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null) {
+            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null)
+            {
                 return $name === 'foo'
                     && $payload === ['baz' => 'baf']
                     && $options !== null;