spiral / framework

src/Queue/tests/Exception/TestRetryException.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
     public function __construct(
         private readonly bool $retryable = true,
         private readonly ?RetryPolicyInterface $retryPolicy = null
-    ) {
+    ){
     }
 
     public function isRetryable(): bool

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

Spacing +8 added lines, -8 removed lines

@@ -79,9 +79,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());
         }
@@ -99,14 +99,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());
         }
@@ -126,14 +126,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());
         }
@@ -155,14 +155,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());
         }

Braces +20 added lines, -8 removed lines

@@ -79,9 +79,12 @@ 
             ->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());
         }
@@ -99,14 +102,17 @@ 
             ->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());
         }
@@ -126,14 +132,17 @@ 
                 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());
         }
@@ -155,14 +164,17 @@ 
                 )
             ));
 
-        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/RetryPolicy.php

Spacing +6 added lines, -6 removed lines

@@ -30,21 +30,21 @@ 
      */
     public function __construct(int $maxAttempts, int $delay, float $multiplier = 1)
     {
-        if ($maxAttempts < 0) {
+        if ($maxAttempts < 0){
             throw new InvalidArgumentException(
                 \sprintf('Maximum attempts must be greater than or equal to zero: `%s` given.', $maxAttempts)
             );
         }
         $this->maxAttempts = $maxAttempts;
 
-        if ($delay < 0) {
+        if ($delay < 0){
             throw new InvalidArgumentException(
                 \sprintf('Delay must be greater than or equal to zero: `%s` given.', $delay)
             );
         }
         $this->delay = $delay;
 
-        if ($multiplier < 1) {
+        if ($multiplier < 1){
             throw new InvalidArgumentException(
                 \sprintf('Multiplier must be greater than zero: `%s` given.', $multiplier)
             );
@@ -59,7 +59,7 @@ 
      */
     public function getDelay(int $attempts = 0): int
     {
-        return (int) \ceil($this->delay * $this->multiplier ** $attempts);
+        return (int)\ceil($this->delay * $this->multiplier ** $attempts);
     }
 
     /**
@@ -67,11 +67,11 @@ 
      */
     public function isRetryable(\Throwable $exception, int $attempts = 0): bool
     {
-        if ($exception instanceof JobException && $exception->getPrevious() !== null) {
+        if ($exception instanceof JobException && $exception->getPrevious() !== null){
             $exception = $exception->getPrevious();
         }
 
-        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0) {
+        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0){
             return false;
         }
 

Braces +10 added lines, -5 removed lines

@@ -30,21 +30,24 @@ 
      */
     public function __construct(int $maxAttempts, int $delay, float $multiplier = 1)
     {
-        if ($maxAttempts < 0) {
+        if ($maxAttempts < 0)
+        {
             throw new InvalidArgumentException(
                 \sprintf('Maximum attempts must be greater than or equal to zero: `%s` given.', $maxAttempts)
             );
         }
         $this->maxAttempts = $maxAttempts;
 
-        if ($delay < 0) {
+        if ($delay < 0)
+        {
             throw new InvalidArgumentException(
                 \sprintf('Delay must be greater than or equal to zero: `%s` given.', $delay)
             );
         }
         $this->delay = $delay;
 
-        if ($multiplier < 1) {
+        if ($multiplier < 1)
+        {
             throw new InvalidArgumentException(
                 \sprintf('Multiplier must be greater than zero: `%s` given.', $multiplier)
             );
@@ -67,11 +70,13 @@ 
      */
     public function isRetryable(\Throwable $exception, int $attempts = 0): bool
     {
-        if ($exception instanceof JobException && $exception->getPrevious() !== null) {
+        if ($exception instanceof JobException && $exception->getPrevious() !== null)
+        {
             $exception = $exception->getPrevious();
         }
 
-        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0) {
+        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0)
+        {
             return false;
         }
 

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

Spacing +6 added lines, -6 removed lines

@@ -18,16 +18,16 @@ 
 {
     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){
             $attribute = $this->reader->firstClassMetadata(new \ReflectionClass($controller), Attribute::class);
-            if ($attribute === null) {
+            if ($attribute === null){
                 throw $e;
             }
 
@@ -36,7 +36,7 @@ 
             $headers = $parameters['headers'] ?? [];
             $attempts = (int)($headers['attempts'][0] ?? 0);
 
-            if ($policy->isRetryable($e, $attempts) === false) {
+            if ($policy->isRetryable($e, $attempts) === false){
                 throw $e;
             }
 
@@ -51,7 +51,7 @@ 
 
     private function getRetryPolicy(\Throwable $exception, Attribute $attribute): RetryPolicy
     {
-        if ($exception instanceof JobException && $exception->getPrevious() !== null) {
+        if ($exception instanceof JobException && $exception->getPrevious() !== null){
             $exception = $exception->getPrevious();
         }
 

Braces +11 added lines, -5 removed lines

@@ -23,11 +23,15 @@ 
 
     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)
+        {
             $attribute = $this->reader->firstClassMetadata(new \ReflectionClass($controller), Attribute::class);
-            if ($attribute === null) {
+            if ($attribute === null)
+            {
                 throw $e;
             }
 
@@ -36,7 +40,8 @@ 
             $headers = $parameters['headers'] ?? [];
             $attempts = (int)($headers['attempts'][0] ?? 0);
 
-            if ($policy->isRetryable($e, $attempts) === false) {
+            if ($policy->isRetryable($e, $attempts) === false)
+            {
                 throw $e;
             }
 
@@ -51,7 +56,8 @@ 
 
     private function getRetryPolicy(\Throwable $exception, Attribute $attribute): RetryPolicy
     {
-        if ($exception instanceof JobException && $exception->getPrevious() !== null) {
+        if ($exception instanceof JobException && $exception->getPrevious() !== null)
+        {
             $exception = $exception->getPrevious();
         }
 

src/Queue/src/Attribute/RetryPolicy.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
         protected readonly int $maxAttempts = 3,
         protected readonly int $delay = 1,
         protected readonly float $multiplier = 1
-    ) {
+    ){
     }
 
     public function getRetryPolicy(): RetryPolicyInterface