spiral / framework

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

Spacing +2 added lines, -2 removed lines

@@ -39,7 +39,7 @@ 
     {
         $handler = $this->createHandler();
         // Call Context
-        $ctx = new CallContext(Target::fromReflection(new class extends \ReflectionFunctionAbstract {
+        $ctx = new CallContext(Target::fromReflection(new class extends \ReflectionFunctionAbstract{
             /** @psalm-immutable */
             public function getName(): string
             {
@@ -123,7 +123,7 @@ 
     public function createHandler(array $definitions = [], bool $resolveFromPath = true): ReflectionHandler
     {
         $container = new Container();
-        foreach ($definitions as $id => $definition) {
+        foreach ($definitions as $id => $definition){
             $container->bind($id, $definition);
         }
 

Braces +2 added lines, -1 removed lines

@@ -123,7 +123,8 @@
     public function createHandler(array $definitions = [], bool $resolveFromPath = true): ReflectionHandler
     {
         $container = new Container();
-        foreach ($definitions as $id => $definition) {
+        foreach ($definitions as $id => $definition)
+        {
             $container->bind($id, $definition);
         }
 

src/Hmvc/tests/Core/Unit/Stub/MultipleCallNextInterceptor.php

Spacing +2 added lines, -2 removed lines

@@ -14,13 +14,13 @@
 
     public function __construct(
         private readonly int $counter,
-    ) {
+    ){
     }
 
     public function intercept(CallContextInterface $context, HandlerInterface $handler): mixed
     {
         $this->result = [];
-        for ($i = 0; $i < $this->counter; ++$i) {
+        for ($i = 0; $i < $this->counter; ++$i){
             $this->result[] = $handler->handle($context);
         }
 

Braces +2 added lines, -1 removed lines

@@ -20,7 +20,8 @@
     public function intercept(CallContextInterface $context, HandlerInterface $handler): mixed
     {
         $this->result = [];
-        for ($i = 0; $i < $this->counter; ++$i) {
+        for ($i = 0; $i < $this->counter; ++$i)
+        {
             $this->result[] = $handler->handle($context);
         }
 

src/Hmvc/src/Interceptors/Handler/ReflectionHandler.php

Spacing +5 added lines, -5 removed lines

@@ -22,7 +22,7 @@ 
         /** @internal */
         protected ContainerInterface $container,
         protected bool $resolveFromPath = true,
-    ) {
+    ){
     }
 
     /**
@@ -34,14 +34,14 @@ 
     {
         // Resolve controller method
         $method = $context->getTarget()->getReflection();
-        if ($method === null) {
+        if ($method === null){
             $this->resolveFromPath or throw new TargetCallException(
                 "Reflection not provided for target `{$context->getTarget()}`.",
                 TargetCallException::NOT_FOUND,
             );
 
             $path = $context->getTarget()->getPath();
-            if (\count($path) !== 2) {
+            if (\count($path) !== 2){
                 throw new TargetCallException(
                     "Invalid target path to resolve reflection for `{$context->getTarget()}`."
                     . ' Expected two parts: class and method.',
@@ -52,13 +52,13 @@ 
             $method = ActionResolver::pathToReflection(\reset($path), \end($path));
         }
 
-        if ($method instanceof \ReflectionFunction) {
+        if ($method instanceof \ReflectionFunction){
             return $method->invokeArgs(
                 $this->resolveArguments($method, $context)
             );
         }
 
-        if (!$method instanceof \ReflectionMethod) {
+        if (!$method instanceof \ReflectionMethod){
             throw new TargetCallException("Action not found for target `{$context->getTarget()}`.");
         }
 

Braces +8 added lines, -4 removed lines

@@ -34,14 +34,16 @@ 
     {
         // Resolve controller method
         $method = $context->getTarget()->getReflection();
-        if ($method === null) {
+        if ($method === null)
+        {
             $this->resolveFromPath or throw new TargetCallException(
                 "Reflection not provided for target `{$context->getTarget()}`.",
                 TargetCallException::NOT_FOUND,
             );
 
             $path = $context->getTarget()->getPath();
-            if (\count($path) !== 2) {
+            if (\count($path) !== 2)
+            {
                 throw new TargetCallException(
                     "Invalid target path to resolve reflection for `{$context->getTarget()}`."
                     . ' Expected two parts: class and method.',
@@ -52,13 +54,15 @@ 
             $method = ActionResolver::pathToReflection(\reset($path), \end($path));
         }
 
-        if ($method instanceof \ReflectionFunction) {
+        if ($method instanceof \ReflectionFunction)
+        {
             return $method->invokeArgs(
                 $this->resolveArguments($method, $context)
             );
         }
 
-        if (!$method instanceof \ReflectionMethod) {
+        if (!$method instanceof \ReflectionMethod)
+        {
             throw new TargetCallException("Action not found for target `{$context->getTarget()}`.");
         }
 

src/Hmvc/src/Interceptors/Internal/ActionResolver.php

Spacing +5 added lines, -5 removed lines

@@ -19,10 +19,10 @@ 
      */
     public static function pathToReflection(string $controller, string $action): \ReflectionMethod
     {
-        try {
+        try{
             /** @psalm-suppress ArgumentTypeCoercion */
             $method = new \ReflectionMethod($controller, $action);
-        } catch (\ReflectionException $e) {
+        }catch (\ReflectionException $e){
             throw new TargetCallException(
                 \sprintf('Invalid action `%s`->`%s`', $controller, $action),
                 TargetCallException::BAD_ACTION,
@@ -39,7 +39,7 @@ 
      */
     public static function validateControllerMethod(\ReflectionMethod $method, mixed $controller = null): void
     {
-        if ($method->isStatic() || !$method->isPublic()) {
+        if ($method->isStatic() || !$method->isPublic()){
             throw new TargetCallException(
                 \sprintf(
                     'Invalid action `%s`->`%s`',
@@ -50,11 +50,11 @@ 
             );
         }
 
-        if ($controller === null) {
+        if ($controller === null){
             return;
         }
 
-        if (!\is_object($controller) || !$method->getDeclaringClass()->isInstance($controller)) {
+        if (!\is_object($controller) || !$method->getDeclaringClass()->isInstance($controller)){
             throw new TargetCallException(
                 \sprintf(
                     'Invalid controller. Expected instance of `%s`, got `%s`.',

Braces +11 added lines, -5 removed lines

@@ -19,10 +19,13 @@ 
      */
     public static function pathToReflection(string $controller, string $action): \ReflectionMethod
     {
-        try {
+        try
+        {
             /** @psalm-suppress ArgumentTypeCoercion */
             $method = new \ReflectionMethod($controller, $action);
-        } catch (\ReflectionException $e) {
+        }
+        catch (\ReflectionException $e)
+        {
             throw new TargetCallException(
                 \sprintf('Invalid action `%s`->`%s`', $controller, $action),
                 TargetCallException::BAD_ACTION,
@@ -39,7 +42,8 @@ 
      */
     public static function validateControllerMethod(\ReflectionMethod $method, mixed $controller = null): void
     {
-        if ($method->isStatic() || !$method->isPublic()) {
+        if ($method->isStatic() || !$method->isPublic())
+        {
             throw new TargetCallException(
                 \sprintf(
                     'Invalid action `%s`->`%s`',
@@ -50,11 +54,13 @@ 
             );
         }
 
-        if ($controller === null) {
+        if ($controller === null)
+        {
             return;
         }
 
-        if (!\is_object($controller) || !$method->getDeclaringClass()->isInstance($controller)) {
+        if (!\is_object($controller) || !$method->getDeclaringClass()->isInstance($controller))
+        {
             throw new TargetCallException(
                 \sprintf(
                     'Invalid controller. Expected instance of `%s`, got `%s`.',

src/Hmvc/src/Core/AbstractCore.php

Spacing +6 added lines, -6 removed lines

@@ -28,7 +28,7 @@ 
     public function __construct(
         /** @internal */
         protected ContainerInterface $container
-    ) {
+    ){
         // resolver is usually the container itself
         /** @psalm-suppress MixedAssignment */
         $this->resolver = $container->get(ResolverInterface::class);
@@ -59,13 +59,13 @@ 
 
     protected function resolveArguments(\ReflectionMethod $method, array $parameters): array
     {
-        foreach ($method->getParameters() as $parameter) {
+        foreach ($method->getParameters() as $parameter){
             $name = $parameter->getName();
             if (
                 \array_key_exists($name, $parameters) &&
                 $parameters[$name] === null &&
                 $parameter->isDefaultValueAvailable()
-            ) {
+            ){
                 /** @psalm-suppress MixedAssignment */
                 $parameters[$name] = $parameter->getDefaultValue();
             }
@@ -80,9 +80,9 @@ 
      */
     public function invoke(\ReflectionMethod $method, array $arguments): mixed
     {
-        try {
+        try{
             $args = $this->resolveArguments($method, $arguments);
-        } catch (ArgumentResolvingException | InvalidArgumentException $e) {
+        }catch (ArgumentResolvingException | InvalidArgumentException $e){
             throw new ControllerException(
                 \sprintf(
                     'Missing/invalid parameter %s of `%s`->`%s`',
@@ -93,7 +93,7 @@ 
                 ControllerException::BAD_ARGUMENT,
                 $e,
             );
-        } catch (ContainerExceptionInterface $e) {
+        }catch (ContainerExceptionInterface $e){
             throw new ControllerException(
                 $e->getMessage(),
                 ControllerException::ERROR,

Braces +10 added lines, -4 removed lines

@@ -59,7 +59,8 @@ 
 
     protected function resolveArguments(\ReflectionMethod $method, array $parameters): array
     {
-        foreach ($method->getParameters() as $parameter) {
+        foreach ($method->getParameters() as $parameter)
+        {
             $name = $parameter->getName();
             if (
                 \array_key_exists($name, $parameters) &&
@@ -80,9 +81,12 @@ 
      */
     public function invoke(\ReflectionMethod $method, array $arguments): mixed
     {
-        try {
+        try
+        {
             $args = $this->resolveArguments($method, $arguments);
-        } catch (ArgumentResolvingException | InvalidArgumentException $e) {
+        }
+        catch (ArgumentResolvingException | InvalidArgumentException $e)
+        {
             throw new ControllerException(
                 \sprintf(
                     'Missing/invalid parameter %s of `%s`->`%s`',
@@ -93,7 +97,9 @@ 
                 ControllerException::BAD_ARGUMENT,
                 $e,
             );
-        } catch (ContainerExceptionInterface $e) {
+        }
+        catch (ContainerExceptionInterface $e)
+        {
             throw new ControllerException(
                 $e->getMessage(),
                 ControllerException::ERROR,

src/Console/src/Command.php

Spacing +5 added lines, -5 removed lines

@@ -79,7 +79,7 @@ 
      */
     protected function execute(InputInterface $input, OutputInterface $output): int
     {
-        if ($this->container === null) {
+        if ($this->container === null){
             throw new ScopeException('Container is not set');
         }
 
@@ -87,7 +87,7 @@ 
 
         $core = $this->buildCore();
 
-        try {
+        try{
             [$this->input, $this->output] = [$this->prepareInput($input), $this->prepareOutput($input, $output)];
 
             $this->eventDispatcher?->dispatch(new CommandStarting($this, $this->input, $this->output));
@@ -105,18 +105,18 @@ 
             $this->eventDispatcher?->dispatch(new CommandFinished($this, $code, $this->input, $this->output));
 
             return $code;
-        } finally {
+        }finally{
             [$this->input, $this->output] = [null, null];
         }
     }
 
-    protected function buildCore(): CoreInterface|HandlerInterface
+    protected function buildCore(): CoreInterface | HandlerInterface
     {
         $core = $this->container->get(CommandCore::class);
 
         $interceptableCore = (new InterceptorPipeline($this->eventDispatcher))->withCore($core);
 
-        foreach ($this->interceptors as $interceptor) {
+        foreach ($this->interceptors as $interceptor){
             $interceptableCore->addInterceptor($this->container->get($interceptor));
         }
         $interceptableCore->addInterceptor($this->container->get(AttributeInterceptor::class));

Braces +9 added lines, -4 removed lines

@@ -79,7 +79,8 @@ 
      */
     protected function execute(InputInterface $input, OutputInterface $output): int
     {
-        if ($this->container === null) {
+        if ($this->container === null)
+        {
             throw new ScopeException('Container is not set');
         }
 
@@ -87,7 +88,8 @@ 
 
         $core = $this->buildCore();
 
-        try {
+        try
+        {
             [$this->input, $this->output] = [$this->prepareInput($input), $this->prepareOutput($input, $output)];
 
             $this->eventDispatcher?->dispatch(new CommandStarting($this, $this->input, $this->output));
@@ -105,7 +107,9 @@ 
             $this->eventDispatcher?->dispatch(new CommandFinished($this, $code, $this->input, $this->output));
 
             return $code;
-        } finally {
+        }
+        finally
+        {
             [$this->input, $this->output] = [null, null];
         }
     }
@@ -116,7 +120,8 @@ 
 
         $interceptableCore = (new InterceptorPipeline($this->eventDispatcher))->withCore($core);
 
-        foreach ($this->interceptors as $interceptor) {
+        foreach ($this->interceptors as $interceptor)
+        {
             $interceptableCore->addInterceptor($this->container->get($interceptor));
         }
         $interceptableCore->addInterceptor($this->container->get(AttributeInterceptor::class));

src/Queue/src/QueueManager.php

Spacing +6 added lines, -6 removed lines

@@ -25,7 +25,7 @@ 
         private readonly ContainerInterface $container,
         private readonly FactoryInterface $factory,
         private readonly ?EventDispatcherInterface $dispatcher = null
-    ) {
+    ){
     }
 
     public function getConnection(?string $name = null): QueueInterface
@@ -34,7 +34,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);
         }
 
@@ -49,12 +49,12 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try{
             $driver = $this->factory->make($config['driver'], $config);
             $pipeline = (new InterceptorPipeline($this->dispatcher))->withHandler(new PushCore($driver));
 
-            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);
                 }
 
@@ -63,7 +63,7 @@ 
             }
 
             return new Queue($pipeline);
-        } 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

@@ -34,7 +34,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);
         }
 
@@ -49,12 +50,15 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try
+        {
             $driver = $this->factory->make($config['driver'], $config);
             $pipeline = (new InterceptorPipeline($this->dispatcher))->withHandler(new PushCore($driver));
 
-            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);
                 }
 
@@ -63,7 +67,9 @@ 
             }
 
             return new Queue($pipeline);
-        } 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);
     }
 
@@ -145,10 +145,10 @@ 
     ): Handler {
         $pipeline = (new InterceptorPipeline($dispatcher))->withHandler($core);
 
-        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

@@ -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);
             }
         });
@@ -145,10 +147,14 @@ 
     ): Handler {
         $pipeline = (new InterceptorPipeline($dispatcher))->withHandler($core);
 
-        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/src/Interceptor/Consume/Handler.php

Spacing +7 added lines, -7 removed lines

@@ -23,9 +23,9 @@ 
     private readonly bool $isLegacy;
 
     public function __construct(
-        private readonly CoreInterface|HandlerInterface $core,
+        private readonly CoreInterface | HandlerInterface $core,
         ?TracerFactoryInterface $tracerFactory = null,
-    ) {
+    ){
         $this->tracerFactory = $tracerFactory ?? new NullTracerFactory(new Container());
         $this->isLegacy = !$core instanceof HandlerInterface;
     }
@@ -51,16 +51,16 @@ 
         return $tracer->trace(
             name: \sprintf('Job handling [%s:%s]', $name, $id),
             callback: $this->isLegacy
-                ? fn (): mixed => $this->core->callAction($name, 'handle', $arguments)
-                : fn (): mixed => $this->core->handle(new CallContext(Target::fromPair($name, 'handle'), $arguments)),
-            attributes: [
+                ? fn () : mixed => $this->core->callAction($name, 'handle', $arguments)
+                : fn () : mixed => $this->core->handle(new CallContext(Target::fromPair($name, 'handle'), $arguments)),
+            attributes : [
                 'queue.driver' => $driver,
                 'queue.name' => $queue,
                 'queue.id' => $id,
                 'queue.headers' => $headers,
             ],
-            scoped: true,
-            traceKind: TraceKind::CONSUMER,
+            scoped : true,
+            traceKind : TraceKind::CONSUMER,
         );
     }
 }