spiral / framework

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

Spacing +6 added lines, -6 removed lines

@@ -20,7 +20,7 @@ 
 {
     public function __construct(
         private readonly QueueInterface $connection,
-    ) {
+    ){
     }
 
     /**
@@ -31,14 +31,14 @@ 
         string $action,
         array $parameters = ['options' => null, 'payload' => []],
     ): string {
-        if ($parameters['options'] === null) {
+        if ($parameters['options'] === null){
             $parameters['options'] = new Options();
         }
 
         $tracer = $this->getTracer();
 
-        if (\method_exists($parameters['options'], 'withHeader')) {
-            foreach ($tracer->getContext() as $key => $data) {
+        if (\method_exists($parameters['options'], 'withHeader')){
+            foreach ($tracer->getContext() as $key => $data){
                 $parameters['options'] = $parameters['options']->withHeader($key, $data);
             }
         }
@@ -58,9 +58,9 @@ 
 
     private function getTracer(): TracerInterface
     {
-        try {
+        try{
             return ContainerScope::getContainer()->get(TracerInterface::class);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             return new NullTracer();
         }
     }

Braces +11 added lines, -5 removed lines

@@ -31,14 +31,17 @@ 
         string $action,
         array $parameters = ['options' => null, 'payload' => []],
     ): string {
-        if ($parameters['options'] === null) {
+        if ($parameters['options'] === null)
+        {
             $parameters['options'] = new Options();
         }
 
         $tracer = $this->getTracer();
 
-        if (\method_exists($parameters['options'], 'withHeader')) {
-            foreach ($tracer->getContext() as $key => $data) {
+        if (\method_exists($parameters['options'], 'withHeader'))
+        {
+            foreach ($tracer->getContext() as $key => $data)
+            {
                 $parameters['options'] = $parameters['options']->withHeader($key, $data);
             }
         }
@@ -58,9 +61,12 @@ 
 
     private function getTracer(): TracerInterface
     {
-        try {
+        try
+        {
             return ContainerScope::getContainer()->get(TracerInterface::class);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             return new NullTracer();
         }
     }

src/Queue/src/Bootloader/QueueBootloader.php

Spacing +9 added lines, -9 removed lines

@@ -47,7 +47,7 @@ 
 
     public function __construct(
         private readonly ConfiguratorInterface $config,
-    ) {
+    ){
     }
 
     public function init(
@@ -65,11 +65,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);
             }
         });
@@ -78,7 +78,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,
@@ -89,7 +89,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,
@@ -114,7 +114,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);
             }