spiral / framework

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

Spacing +4 added lines, -4 removed lines

@@ -27,7 +27,7 @@ 
 
     public function __construct(
         private readonly ?EventDispatcherInterface $dispatcher = null
-    ) {
+    ){
     }
 
     /**
@@ -36,7 +36,7 @@ 
     public function withInterceptors(InterceptorInterface ...$interceptors): self
     {
         $clone = clone $this;
-        foreach ($interceptors as $interceptor) {
+        foreach ($interceptors as $interceptor){
             $clone->interceptors[] = $interceptor;
         }
 
@@ -55,11 +55,11 @@ 
      */
     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));

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

Spacing +4 added lines, -4 removed lines

@@ -20,7 +20,7 @@ 
     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 +39,7 @@ 
         $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;
@@ -125,8 +125,8 @@ 
      */
     private function createPipeline(
         array $interceptors = [],
-        HandlerInterface|null $lastHandler = null,
-        EventDispatcherInterface|null $dispatcher = null,
+        HandlerInterface | null $lastHandler = null,
+        EventDispatcherInterface | null $dispatcher = null,
     ): InterceptorPipeline {
         $pipeline = new InterceptorPipeline($dispatcher);
 

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/Interceptors/Context/Target.php

Spacing +15 added lines, -15 removed lines

@@ -20,8 +20,8 @@ 
         private ?\ReflectionFunctionAbstract $reflection = null,
         private readonly ?object $object = null,
         private string $delimiter = '.',
-        private \Closure|array|null $callable = null,
-    ) {
+        private \Closure | array | null $callable = null,
+    ){
     }
 
     public function __toString(): string
@@ -45,7 +45,7 @@ 
      */
     public static function fromReflectionMethod(
         \ReflectionFunctionAbstract $reflection,
-        string|object $classOrObject,
+        string | object $classOrObject,
     ): self {
         $method = $reflection->getName();
         $isStatic = $reflection->isStatic();
@@ -53,17 +53,17 @@ 
         /** @var self<T> $result */
         $result = \is_object($classOrObject)
             ? new self(
-                path: [$classOrObject::class, $method],
-                reflection: $reflection,
-                object: $classOrObject,
-                delimiter: $isStatic ? '::' : '->',
-                callable: [$classOrObject, $method],
+                path : [$classOrObject::class, $method],
+                reflection : $reflection,
+                object : $classOrObject,
+                delimiter : $isStatic ? '::' : '->',
+                callable : [$classOrObject, $method],
             )
             : new self(
-                path: [$classOrObject, $method],
-                reflection: $reflection,
-                delimiter: $isStatic ? '::' : '->',
-                callable: [$classOrObject, $method],
+                path : [$classOrObject, $method],
+                reflection : $reflection,
+                delimiter : $isStatic ? '::' : '->',
+                callable : [$classOrObject, $method],
             );
         return $result;
     }
@@ -133,10 +133,10 @@ 
      *
      * @return ($controller is class-string|T ? self<T> : self<null>)
      */
-    public static function fromPair(string|object $controller, string $action): self
+    public static function fromPair(string | object $controller, string $action): self
     {
         /** @psalm-suppress ArgumentTypeCoercion */
-        if (\is_object($controller) || \method_exists($controller, $action)) {
+        if (\is_object($controller) || \method_exists($controller, $action)){
             /** @var T|class-string<T> $controller */
             return self::fromReflectionMethod(new \ReflectionMethod($controller, $action), $controller);
         }
@@ -167,7 +167,7 @@ 
         return $this->object;
     }
 
-    public function getCallable(): callable|array|null
+    public function getCallable(): callable | array | null
     {
         return $this->callable;
     }

src/Hmvc/src/Interceptors/Context/TargetInterface.php

Spacing +1 added lines, -1 removed lines

@@ -58,5 +58,5 @@
      *
      * @return callable|array{class-string, non-empty-string}|null
      */
-    public function getCallable(): callable|array|null;
+    public function getCallable(): callable | array | null;
 }

src/Hmvc/src/Core/CompatiblePipelineBuilder.php

Spacing +3 added lines, -3 removed lines

@@ -28,17 +28,17 @@
         $this->pipeline = clone $this->pipeline;
     }
 
-    public function withInterceptors(CoreInterceptorInterface|InterceptorInterface ...$interceptors): static
+    public function withInterceptors(CoreInterceptorInterface | InterceptorInterface ...$interceptors): static
     {
         $clone = clone $this;
-        foreach ($interceptors as $interceptor) {
+        foreach ($interceptors as $interceptor){
             $clone->pipeline->addInterceptor($interceptor);
         }
 
         return $clone;
     }
 
-    public function build(HandlerInterface|CoreInterface $last): InterceptorPipeline
+    public function build(HandlerInterface | CoreInterface $last): InterceptorPipeline
     {
         /** @psalm-suppress InvalidArgument */
         return $last instanceof HandlerInterface

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

Spacing +3 added lines, -3 removed lines

@@ -20,7 +20,7 @@ 
 {
     public function __construct(
         private readonly ContainerInterface $container,
-    ) {
+    ){
     }
 
     /**
@@ -30,13 +30,13 @@ 
         array $interceptors,
         ?EventDispatcherInterface $eventDispatcher = null,
         ?PipelineBuilderInterface $pipelineBuilder = null,
-    ): CoreInterface|HandlerInterface {
+    ): CoreInterface | HandlerInterface {
         /** @var CommandCore $core */
         $core = $this->container->get(CommandCore::class);
         $pipelineBuilder ??= new CompatiblePipelineBuilder($eventDispatcher);
 
         $resolved = [];
-        foreach ($interceptors as $interceptor) {
+        foreach ($interceptors as $interceptor){
             $resolved[] = $this->container->get($interceptor);
         }
 

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/Console/src/Command.php

Spacing +4 added lines, -4 removed lines

@@ -83,13 +83,13 @@ 
      */
     protected function execute(InputInterface $input, OutputInterface $output): int
     {
-        if ($this->container === null) {
+        if ($this->container === null){
             throw new ScopeException('Container is not set');
         }
 
         $method = method_exists($this, 'perform') ? 'perform' : '__invoke';
 
-        try {
+        try{
             [$this->input, $this->output] = [$this->prepareInput($input), $this->prepareOutput($input, $output)];
 
             $this->eventDispatcher?->dispatch(new CommandStarting($this, $this->input, $this->output));
@@ -122,7 +122,7 @@ 
             $this->eventDispatcher?->dispatch(new CommandFinished($this, $code, $this->input, $this->output));
 
             return $code;
-        } finally {
+        }finally{
             [$this->input, $this->output] = [null, null];
         }
     }
@@ -130,7 +130,7 @@ 
     /**
      * @deprecated This method will be removed in v4.0.
      */
-    protected function buildCore(): CoreInterface|HandlerInterface
+    protected function buildCore(): CoreInterface | HandlerInterface
     {
         /** @var InvokerInterface $invoker */
         $invoker = $this->container->get(InvokerInterface::class);

src/Queue/src/QueueManager.php

Spacing +5 added lines, -5 removed lines

@@ -26,7 +26,7 @@ 
         private readonly FactoryInterface $factory,
         ?EventDispatcherInterface $dispatcher = null,
         ?PipelineBuilderInterface $builder = null,
-    ) {
+    ){
         $this->builder = $builder ?? new CompatiblePipelineBuilder($dispatcher);
     }
 
@@ -36,7 +36,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);
         }
 
@@ -51,18 +51,18 @@ 
     {
         $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`',

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

Spacing +9 added lines, -9 removed lines

@@ -55,7 +55,7 @@ 
 
     public function __construct(
         private readonly ConfiguratorInterface $config,
-    ) {
+    ){
     }
 
     public function init(
@@ -73,11 +73,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);
             }
         });
@@ -95,7 +95,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,
@@ -106,7 +106,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,
@@ -131,7 +131,7 @@ 
         ContainerInterface $container,
         FactoryInterface $factory,
         ContainerRegistry $registry,
-    ) {
+    ){
         return new QueueRegistry($container, $factory, $registry);
     }
 
@@ -147,10 +147,10 @@ 
         $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);
             }
         }

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);
             }
         }