spiral / framework

src/Queue/src/Driver/SyncDriver.php

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/JobHandler.php

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/Interceptor/Consume/ErrorHandlerInterceptorTest.php

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

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;