spiral / framework

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, array $payload, \Throwable $e): void

src/Queue/src/ContainerRegistry.php

Spacing +4 added lines, -4 removed lines

@@ -16,19 +16,19 @@
 
     public function __construct(
         private readonly ContainerInterface $container
-    ) {
+    ){
         $this->inflector = (new InflectorFactory())->build();
     }
 
     public function getHandler(string $jobType): HandlerInterface
     {
-        try {
+        try{
             $handler = $this->container->get($this->className($jobType));
-        } catch (ContainerException $e) {
+        }catch (ContainerException $e){
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
 
-        if (!$handler instanceof HandlerInterface) {
+        if (!$handler instanceof HandlerInterface){
             throw new JobException(\sprintf('Unable to resolve job handler for `%s`', $jobType));
         }
 

Braces +7 added lines, -3 removed lines

@@ -22,13 +22,17 @@
 
     public function getHandler(string $jobType): HandlerInterface
     {
-        try {
+        try
+        {
             $handler = $this->container->get($this->className($jobType));
-        } catch (ContainerException $e) {
+        }
+        catch (ContainerException $e)
+        {
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
 
-        if (!$handler instanceof HandlerInterface) {
+        if (!$handler instanceof HandlerInterface)
+        {
             throw new JobException(\sprintf('Unable to resolve job handler for `%s`', $jobType));
         }
 

src/Queue/src/Core/QueueInjector.php

Spacing +8 added lines, -8 removed lines

@@ -18,26 +18,26 @@ 
 {
     public function __construct(
         private readonly QueueConnectionProviderInterface $queueManager
-    ) {
+    ){
     }
 
     public function createInjection(ReflectionClass $class, string $context = null): QueueInterface
     {
-        try {
-            if ($context === null) {
+        try{
+            if ($context === null){
                 $connection = $this->queueManager->getConnection();
-            } else {
+            }else{
                 // Get Queue by context
-                try {
+                try{
                     $connection = $this->queueManager->getConnection($context);
-                } catch (InvalidArgumentException) {
+                }catch (InvalidArgumentException){
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
 
             $this->matchType($class, $context, $connection);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 
@@ -52,7 +52,7 @@ 
     private function matchType(ReflectionClass $class, ?string $context, QueueInterface $connection): void
     {
         $className = $class->getName();
-        if ($className !== QueueInterface::class && !$connection instanceof $className) {
+        if ($className !== QueueInterface::class && !$connection instanceof $className){
             throw new \RuntimeException(
                 \sprintf(
                     "The queue obtained by the context `%s` doesn't match the type `%s`.",

Braces +17 added lines, -7 removed lines

@@ -23,21 +23,30 @@ 
 
     public function createInjection(ReflectionClass $class, string $context = null): QueueInterface
     {
-        try {
-            if ($context === null) {
+        try
+        {
+            if ($context === null)
+            {
                 $connection = $this->queueManager->getConnection();
-            } else {
+            }
+            else
+            {
                 // Get Queue by context
-                try {
+                try
+                {
                     $connection = $this->queueManager->getConnection($context);
-                } catch (InvalidArgumentException) {
+                }
+                catch (InvalidArgumentException)
+                {
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
 
             $this->matchType($class, $context, $connection);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 
@@ -52,7 +61,8 @@ 
     private function matchType(ReflectionClass $class, ?string $context, QueueInterface $connection): void
     {
         $className = $class->getName();
-        if ($className !== QueueInterface::class && !$connection instanceof $className) {
+        if ($className !== QueueInterface::class && !$connection instanceof $className)
+        {
             throw new \RuntimeException(
                 \sprintf(
                     "The queue obtained by the context `%s` doesn't match the type `%s`.",

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, array $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, array $payload = [], OptionsInterface $options = null): string
     {
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay())
+        {
             \sleep($options->getDelay());
         }
 

src/Queue/src/Bootloader/QueueBootloader.php

Spacing +11 added lines, -11 removed lines

@@ -50,7 +50,7 @@ 
 
     public function __construct(
         private readonly ConfiguratorInterface $config
-    ) {
+    ){
     }
 
     public function init(
@@ -68,11 +68,11 @@ 
             $registry = $container->get(QueueRegistry::class);
             $config = $container->get(QueueConfig::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler){
                 $registry->setHandler($jobType, $handler);
             }
 
-            foreach ($config->getRegistrySerializers() as $jobType => $serializer) {
+            foreach ($config->getRegistrySerializers() as $jobType => $serializer){
                 $registry->setSerializer($jobType, $serializer);
             }
         });
@@ -81,7 +81,7 @@ 
     /**
      * @param class-string<CoreInterceptorInterface>|CoreInterceptorInterface|Autowire $interceptor
      */
-    public function addConsumeInterceptor(string|CoreInterceptorInterface|Autowire $interceptor): void
+    public function addConsumeInterceptor(string | CoreInterceptorInterface | Autowire $interceptor): void
     {
         $this->config->modify(
             QueueConfig::CONFIG,
@@ -92,7 +92,7 @@ 
     /**
      * @param class-string<CoreInterceptorInterface>|CoreInterceptorInterface|Autowire $interceptor
      */
-    public function addPushInterceptor(string|CoreInterceptorInterface|Autowire $interceptor): void
+    public function addPushInterceptor(string | CoreInterceptorInterface | Autowire $interceptor): void
     {
         $this->config->modify(
             QueueConfig::CONFIG,
@@ -117,7 +117,7 @@ 
         ContainerInterface $container,
         FactoryInterface $factory,
         ContainerRegistry $registry
-    ) {
+    ){
         return new QueueRegistry($container, $factory, $registry);
     }
 
@@ -130,10 +130,10 @@ 
     ): Handler {
         $core = new InterceptableCore($core, $dispatcher);
 
-        foreach ($config->getConsumeInterceptors() as $interceptor) {
-            if (\is_string($interceptor)) {
+        foreach ($config->getConsumeInterceptors() as $interceptor){
+            if (\is_string($interceptor)){
                 $interceptor = $container->get($interceptor);
-            } elseif ($interceptor instanceof Autowire) {
+            } elseif ($interceptor instanceof Autowire){
                 $interceptor = $interceptor->resolve($factory);
             }
 
@@ -152,8 +152,8 @@ 
     ): Queue {
         $core = new InterceptableCore(new PushCore($manager->getConnection()), $dispatcher);
 
-        foreach ($config->getPushInterceptors() as $interceptor) {
-            if (\is_string($interceptor) || $interceptor instanceof Autowire) {
+        foreach ($config->getPushInterceptors() as $interceptor){
+            if (\is_string($interceptor) || $interceptor instanceof Autowire){
                 $interceptor = $container->get($interceptor);
             }
 

Braces +15 added lines, -7 removed lines

@@ -68,11 +68,13 @@ 
             $registry = $container->get(QueueRegistry::class);
             $config = $container->get(QueueConfig::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler)
+            {
                 $registry->setHandler($jobType, $handler);
             }
 
-            foreach ($config->getRegistrySerializers() as $jobType => $serializer) {
+            foreach ($config->getRegistrySerializers() as $jobType => $serializer)
+            {
                 $registry->setSerializer($jobType, $serializer);
             }
         });
@@ -130,10 +132,14 @@ 
     ): Handler {
         $core = new InterceptableCore($core, $dispatcher);
 
-        foreach ($config->getConsumeInterceptors() as $interceptor) {
-            if (\is_string($interceptor)) {
+        foreach ($config->getConsumeInterceptors() as $interceptor)
+        {
+            if (\is_string($interceptor))
+            {
                 $interceptor = $container->get($interceptor);
-            } elseif ($interceptor instanceof Autowire) {
+            }
+            elseif ($interceptor instanceof Autowire)
+            {
                 $interceptor = $interceptor->resolve($factory);
             }
 
@@ -152,8 +158,10 @@ 
     ): Queue {
         $core = new InterceptableCore(new PushCore($manager->getConnection()), $dispatcher);
 
-        foreach ($config->getPushInterceptors() as $interceptor) {
-            if (\is_string($interceptor) || $interceptor instanceof Autowire) {
+        foreach ($config->getPushInterceptors() as $interceptor)
+        {
+            if (\is_string($interceptor) || $interceptor instanceof Autowire)
+            {
                 $interceptor = $container->get($interceptor);
             }
 

src/Queue/src/Interceptor/Consume/Core.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
     public function __construct(
         private readonly HandlerRegistryInterface $registry,
         private readonly ?EventDispatcherInterface $dispatcher = null
-    ) {
+    ){
     }
 
     /**

src/Queue/src/Interceptor/Consume/ErrorHandlerInterceptor.php

Spacing +4 added lines, -4 removed lines

@@ -13,16 +13,16 @@
 {
     public function __construct(
         private readonly FailedJobHandlerInterface $handler
-    ) {
+    ){
     }
 
     /** @psalm-suppress ParamNameMismatch */
     public function process(string $name, string $action, array $parameters, CoreInterface $core): mixed
     {
-        try {
+        try{
             return $core->callAction($name, $action, $parameters);
-        } catch (\Throwable $e) {
-            if (!$e instanceof StateException) {
+        }catch (\Throwable $e){
+            if (!$e instanceof StateException){
                 $this->handler->handle(
                     $parameters['driver'],
                     $parameters['queue'],

Braces +7 added lines, -3 removed lines

@@ -19,10 +19,14 @@
     /** @psalm-suppress ParamNameMismatch */
     public function process(string $name, string $action, array $parameters, CoreInterface $core): mixed
     {
-        try {
+        try
+        {
             return $core->callAction($name, $action, $parameters);
-        } catch (\Throwable $e) {
-            if (!$e instanceof StateException) {
+        }
+        catch (\Throwable $e)
+        {
+            if (!$e instanceof StateException)
+            {
                 $this->handler->handle(
                     $parameters['driver'],
                     $parameters['queue'],

src/Queue/src/Interceptor/Push/Core.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
 {
     public function __construct(
         private readonly QueueInterface $connection
-    ) {
+    ){
     }
 
     /**

src/Queue/src/Queue.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
 {
     public function __construct(
         private readonly CoreInterface $core
-    ) {
+    ){
     }
 
     /**