spiral / framework

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

Spacing +15 added lines, -15 removed lines

@@ -78,9 +78,9 @@ 
                 retryPolicy: new \Spiral\Queue\RetryPolicy(maxAttempts: 2, delay: 4)
             ));
 
-        try {
+        try{
             $this->interceptor->process('foo-job', 'bar', [], $this->core);
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(4, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['1']], $e->getOptions()->getHeaders());
         }
@@ -111,9 +111,9 @@ 
             ->with(self::class, 'bar', [])
             ->willThrowException(new TestRetryException());
 
-        try {
+        try{
             $this->interceptor->process(self::class, 'bar', [], $this->core);
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(1, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['1']], $e->getOptions()->getHeaders());
         }
@@ -131,9 +131,9 @@ 
                 retryPolicy: new \Spiral\Queue\RetryPolicy(maxAttempts: 2, delay: 4)
             ));
 
-        try {
+        try{
             $this->interceptor->process(self::class, 'bar', [], $this->core);
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(4, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['1']], $e->getOptions()->getHeaders());
         }
@@ -151,14 +151,14 @@ 
             ->with(self::class, 'bar', ['headers' => ['attempts' => ['1']]])
             ->willThrowException(new TestRetryException());
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(8, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }
@@ -178,14 +178,14 @@ 
                 retryPolicy: new \Spiral\Queue\RetryPolicy(maxAttempts: 3, delay: 4, multiplier: 2)
             ));
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(8, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }
@@ -202,7 +202,7 @@ 
             ->method('callAction')
             ->with(self::class, 'bar', ['headers' => ['attempts' => ['1']]])
             ->willThrowException(new TestRetryException(
-                retryPolicy: new class implements RetryPolicyInterface {
+                retryPolicy: new class implements RetryPolicyInterface{
                     public function isRetryable(\Throwable $exception, int $attempts = 0): bool
                     {
                         return true;
@@ -215,14 +215,14 @@ 
                 }
             ));
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(5, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }
@@ -244,14 +244,14 @@ 
                 )
             ));
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(8, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }

src/Queue/src/Interceptor/Consume/RetryPolicyInterceptor.php

Spacing +6 added lines, -6 removed lines

@@ -18,27 +18,27 @@ 
 {
     public function __construct(
         private readonly ReaderInterface $reader,
-    ) {
+    ){
     }
 
     public function process(string $controller, string $action, array $parameters, CoreInterface $core): mixed
     {
-        try {
+        try{
             return $core->callAction($controller, $action, $parameters);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             // In some cases job handler class may not exist or be just a string.
             // In this case we can't get retry policy from it.
             $class = \class_exists($controller) ? new \ReflectionClass($controller) : null;
             $policy = $this->getRetryPolicy($e, $class);
 
-            if ($policy === null) {
+            if ($policy === null){
                 throw $e;
             }
 
             $headers = $parameters['headers'] ?? [];
             $attempts = (int)($headers['attempts'][0] ?? 0);
 
-            if ($policy->isRetryable($e, $attempts) === false) {
+            if ($policy->isRetryable($e, $attempts) === false){
                 throw $e;
             }
 
@@ -57,7 +57,7 @@ 
             ? $this->reader->firstClassMetadata($handler, Attribute::class)
             : null;
 
-        if ($exception instanceof JobException && $exception->getPrevious() !== null) {
+        if ($exception instanceof JobException && $exception->getPrevious() !== null){
             $exception = $exception->getPrevious();
         }