spiral / framework

src/Queue/src/QueueManager.php

Spacing +6 added lines, -6 removed lines

@@ -24,7 +24,7 @@ 
         private readonly ContainerInterface $container,
         private readonly FactoryInterface $factory,
         private readonly ?EventDispatcherInterface $dispatcher = null
-    ) {
+    ){
     }
 
     public function getConnection(?string $name = null): QueueInterface
@@ -33,7 +33,7 @@ 
         // Replaces alias with real pipeline name
         $name = $this->config->getAliases()[$name] ?? $name;
 
-        if (!isset($this->pipelines[$name])) {
+        if (!isset($this->pipelines[$name])){
             $this->pipelines[$name] = $this->resolveConnection($name);
         }
 
@@ -48,7 +48,7 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try{
             $driver = $this->factory->make($config['driver'], $config);
 
             $core = new InterceptableCore(
@@ -56,8 +56,8 @@ 
                 $this->dispatcher
             );
 
-            foreach ($this->config->getPushInterceptors() as $interceptor) {
-                if (\is_string($interceptor) || $interceptor instanceof Autowire) {
+            foreach ($this->config->getPushInterceptors() as $interceptor){
+                if (\is_string($interceptor) || $interceptor instanceof Autowire){
                     $interceptor = $this->container->get($interceptor);
                 }
 
@@ -66,7 +66,7 @@ 
             }
 
             return new Queue($core);
-        } catch (ContainerException $e) {
+        }catch (ContainerException $e){
             throw new Exception\NotSupportedDriverException(
                 \sprintf(
                     'Driver `%s` is not supported. Connection `%s` cannot be created. Reason: `%s`',

Braces +11 added lines, -5 removed lines

@@ -33,7 +33,8 @@ 
         // Replaces alias with real pipeline name
         $name = $this->config->getAliases()[$name] ?? $name;
 
-        if (!isset($this->pipelines[$name])) {
+        if (!isset($this->pipelines[$name]))
+        {
             $this->pipelines[$name] = $this->resolveConnection($name);
         }
 
@@ -48,7 +49,8 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try
+        {
             $driver = $this->factory->make($config['driver'], $config);
 
             $core = new InterceptableCore(
@@ -56,8 +58,10 @@ 
                 $this->dispatcher
             );
 
-            foreach ($this->config->getPushInterceptors() as $interceptor) {
-                if (\is_string($interceptor) || $interceptor instanceof Autowire) {
+            foreach ($this->config->getPushInterceptors() as $interceptor)
+            {
+                if (\is_string($interceptor) || $interceptor instanceof Autowire)
+                {
                     $interceptor = $this->container->get($interceptor);
                 }
 
@@ -66,7 +70,9 @@ 
             }
 
             return new Queue($core);
-        } catch (ContainerException $e) {
+        }
+        catch (ContainerException $e)
+        {
             throw new Exception\NotSupportedDriverException(
                 \sprintf(
                     'Driver `%s` is not supported. Connection `%s` cannot be created. Reason: `%s`',

src/Queue/src/Bootloader/QueueBootloader.php

Spacing +9 added lines, -9 removed lines

@@ -48,7 +48,7 @@ 
 
     public function __construct(
         private readonly ConfiguratorInterface $config
-    ) {
+    ){
     }
 
     public function init(
@@ -66,11 +66,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);
             }
         });
@@ -79,7 +79,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,
@@ -90,7 +90,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,
@@ -115,7 +115,7 @@ 
         ContainerInterface $container,
         FactoryInterface $factory,
         ContainerRegistry $registry
-    ) {
+    ){
         return new QueueRegistry($container, $factory, $registry);
     }
 
@@ -128,10 +128,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);
             }
 

Braces +11 added lines, -5 removed lines

@@ -66,11 +66,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);
             }
         });
@@ -128,10 +130,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);
             }
 

src/Queue/tests/QueueManagerTest.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
 
 final class QueueManagerTest extends TestCase
 {
-    private m\MockInterface|FactoryInterface $factory;
+    private m\MockInterface | FactoryInterface $factory;
 
     protected function setUp(): void
     {

src/Queue/tests/Core/QueueInjectorTest.php

Spacing +1 added lines, -1 removed lines

@@ -88,7 +88,7 @@
             var_dump($name);
             $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null;
 
-            if ($result === null) {
+            if ($result === null){
                 throw new NotFoundException();
             }
             return $result;

Braces +2 added lines, -1 removed lines

@@ -88,7 +88,8 @@
             var_dump($name);
             $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null;
 
-            if ($result === null) {
+            if ($result === null)
+            {
                 throw new NotFoundException();
             }
             return $result;

src/Queue/src/Core/QueueInjector.php

Spacing +7 added lines, -7 removed lines

@@ -18,24 +18,24 @@
 {
     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();
                 }
             }
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 

Braces +15 added lines, -6 removed lines

@@ -23,19 +23,28 @@
 
     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();
                 }
             }
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }