spiral / framework

src/Hmvc/src/Interceptors/Handler/InterceptorPipeline.php

Braces +6 added lines, -3 removed lines

@@ -36,7 +36,8 @@ 
     public function withInterceptors(InterceptorInterface ...$interceptors): self
     {
         $clone = clone $this;
-        foreach ($interceptors as $interceptor) {
+        foreach ($interceptors as $interceptor)
+        {
             $clone->interceptors[] = $interceptor;
         }
 
@@ -55,11 +56,13 @@ 
      */
     public function handle(CallContext $context): mixed
     {
-        if ($this->handler === null) {
+        if ($this->handler === null)
+        {
             throw new InterceptorException('Unable to invoke pipeline without last handler.');
         }
 
-        if (isset($this->interceptors[$this->position])) {
+        if (isset($this->interceptors[$this->position]))
+        {
             $interceptor = $this->interceptors[$this->position];
 
             $this->dispatcher?->dispatch(new InterceptorCalling(context: $context, interceptor: $interceptor));

src/Hmvc/tests/Interceptors/Unit/Handler/InterceptorPipelineTest.php

Braces +4 added lines, -2 removed lines

@@ -20,7 +20,8 @@ 
     public function testInterceptorCallingEventShouldBeDispatched(): void
     {
         $context = $this->createPathContext(['test', 'test2']);
-        $interceptor = new class implements InterceptorInterface {
+        $interceptor = new class implements InterceptorInterface
+        {
             public function intercept(CallContextInterface $context, HandlerInterface $handler): mixed
             {
                 return null;
@@ -39,7 +40,8 @@ 
         $pipeline = $this->createPipeline(interceptors: [$interceptor], dispatcher: $dispatcher);
 
         $pipeline->withHandler(
-            new class implements HandlerInterface {
+            new class implements HandlerInterface
+            {
                 public function handle(CallContext $context): mixed
                 {
                     return null;

src/Hmvc/src/Core/CompatiblePipelineBuilder.php

Braces +2 added lines, -1 removed lines

@@ -31,7 +31,8 @@
     public function withInterceptors(CoreInterceptorInterface|InterceptorInterface ...$interceptors): static
     {
         $clone = clone $this;
-        foreach ($interceptors as $interceptor) {
+        foreach ($interceptors as $interceptor)
+        {
             $clone->pipeline->addInterceptor($interceptor);
         }
 

src/Console/src/CommandCoreFactory.php

Braces +2 added lines, -1 removed lines

@@ -36,7 +36,8 @@
         $pipelineBuilder ??= new CompatiblePipelineBuilder($eventDispatcher);
 
         $resolved = [];
-        foreach ($interceptors as $interceptor) {
+        foreach ($interceptors as $interceptor)
+        {
             $resolved[] = $this->container->get($interceptor);
         }
 

src/Queue/src/QueueManager.php

Braces +9 added lines, -4 removed lines

@@ -36,7 +36,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);
         }
 
@@ -51,18 +52,22 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try
+        {
             $driver = $this->factory->make($config['driver'], $config);
 
             $list = [];
-            foreach ($this->config->getPushInterceptors() as $interceptor) {
+            foreach ($this->config->getPushInterceptors() as $interceptor)
+            {
                 $list[] = \is_string($interceptor) || $interceptor instanceof Autowire
                     ? $this->container->get($interceptor)
                     : $interceptor;
             }
 
             return new Queue($this->builder->withInterceptors(...$list)->build(new PushCore($driver)));
-        } 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

Braces +11 added lines, -5 removed lines

@@ -73,11 +73,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);
             }
         });
@@ -147,10 +149,14 @@ 
         $builder ??= new CompatiblePipelineBuilder($dispatcher);
 
         $list = [];
-        foreach ($config->getConsumeInterceptors() as $interceptor) {
-            if (\is_string($interceptor)) {
+        foreach ($config->getConsumeInterceptors() as $interceptor)
+        {
+            if (\is_string($interceptor))
+            {
                 $list[] = $container->get($interceptor);
-            } elseif ($interceptor instanceof Autowire) {
+            }
+            elseif ($interceptor instanceof Autowire)
+            {
                 $list[] = $interceptor->resolve($factory);
             }
         }

src/Framework/Bootloader/DomainBootloader.php

Braces +2 added lines, -1 removed lines

@@ -32,7 +32,8 @@
         $builder = new CompatiblePipelineBuilder($dispatcher);
 
         $list = [];
-        foreach (static::defineInterceptors() as $interceptor) {
+        foreach (static::defineInterceptors() as $interceptor)
+        {
             $list[] = $interceptor instanceof CoreInterceptorInterface || $interceptor instanceof InterceptorInterface
                 ? $interceptor
                 : $container->get($interceptor);

src/Framework/Bootloader/Security/FiltersBootloader.php

Braces +2 added lines, -1 removed lines

@@ -116,7 +116,8 @@
         $builder ??= new CompatiblePipelineBuilder($dispatcher);
 
         $list = [];
-        foreach ($config->getInterceptors() as $interceptor) {
+        foreach ($config->getInterceptors() as $interceptor)
+        {
             $list[] = $container->get($interceptor);
         }
 

src/Events/src/Bootloader/EventsBootloader.php

Braces +8 added lines, -4 removed lines

@@ -72,11 +72,13 @@ 
         FinalizerInterface $finalizer,
         ?EventDispatcherInterface $eventDispatcher = null
     ): void {
-        if ($eventDispatcher !== null) {
+        if ($eventDispatcher !== null)
+        {
             $this->initEventDispatcher(new Core($eventDispatcher), $config, $container, $factory);
         }
 
-        foreach ($config->getProcessors() as $processor) {
+        foreach ($config->getProcessors() as $processor)
+        {
             $processor = $this->autowire($processor, $container, $factory);
 
             \assert($processor instanceof ProcessorInterface);
@@ -87,7 +89,8 @@ 
             $registry->process();
         });
 
-        if ($finalizer instanceof EventDispatcherAwareInterface && $eventDispatcher !== null) {
+        if ($finalizer instanceof EventDispatcherAwareInterface && $eventDispatcher !== null)
+        {
             $finalizer->setEventDispatcher($eventDispatcher);
         }
     }
@@ -109,7 +112,8 @@ 
     ): void {
         $builder = new CompatiblePipelineBuilder();
         $list = [];
-        foreach ($config->getInterceptors() as $interceptor) {
+        foreach ($config->getInterceptors() as $interceptor)
+        {
             $list[] = $this->autowire($interceptor, $container, $factory);
         }