spiral / framework

src/Router/src/CoreHandler.php

Braces +28 added lines, -12 removed lines

@@ -66,7 +66,8 @@ 
      */
     public function handle(Request $request): Response
     {
-        if ($this->controller === null) {
+        if ($this->controller === null)
+        {
             throw new HandlerException('Controller and action pair is not set');
         }
 
@@ -76,7 +77,8 @@ 
         $output = $result = null;
 
         $response = $this->responseFactory->createResponse(200);
-        try {
+        try
+        {
             $action = $this->getAction($request);
 
             // run the core withing PSR-7 Request/Response scope
@@ -99,14 +101,21 @@ 
                     ]
                 )
             );
-        } catch (ControllerException $e) {
+        }
+        catch (ControllerException $e)
+        {
             \ob_get_clean();
             throw $this->mapException($e);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             \ob_get_clean();
             throw $e;
-        } finally {
-            while (\ob_get_level() > $outputLevel + 1) {
+        }
+        finally
+        {
+            while (\ob_get_level() > $outputLevel + 1)
+            {
                 $output = \ob_get_clean() . $output;
             }
         }
@@ -120,7 +129,8 @@ 
 
     private function getAction(Request $request): string
     {
-        if ($this->verbActions) {
+        if ($this->verbActions)
+        {
             return \strtolower($request->getMethod()) . \ucfirst($this->action);
         }
 
@@ -136,21 +146,27 @@ 
      */
     private function wrapResponse(Response $response, mixed $result = null, string $output = ''): Response
     {
-        if ($result instanceof Response) {
-            if ($output !== '' && $result->getBody()->isWritable()) {
+        if ($result instanceof Response)
+        {
+            if ($output !== '' && $result->getBody()->isWritable())
+            {
                 $result->getBody()->write($output);
             }
 
             return $result;
         }
 
-        if ($result instanceof \Generator) {
+        if ($result instanceof \Generator)
+        {
             return $response->withBody(new GeneratorStream($result));
         }
 
-        if (\is_array($result) || $result instanceof \JsonSerializable) {
+        if (\is_array($result) || $result instanceof \JsonSerializable)
+        {
             $response = $this->writeJson($response, $result);
-        } else {
+        }
+        else
+        {
             $response->getBody()->write((string)$result);
         }
 

src/Router/src/Router.php

Braces +46 added lines, -21 removed lines

@@ -63,14 +63,19 @@ 
 
         return $this->tracer->trace(
             name: 'Routing',
-            callback: function (SpanInterface $span) use ($request) {
-                try {
+            callback: function (SpanInterface $span) use ($request)
+            {
+                try
+                {
                     $route = $this->matchRoute($request, $routeName);
-                } catch (RouteException $e) {
+                }
+                catch (RouteException $e)
+                {
                     throw new RouterException('Invalid route definition', $e->getCode(), $e);
                 }
 
-                if ($route === null) {
+                if ($route === null)
+                {
                     $this->eventDispatcher?->dispatch(new RouteNotFound($request));
                     throw new RouteNotFoundException($request->getUri());
                 }
@@ -105,7 +110,8 @@ 
 
     public function getRoute(string $name): RouteInterface
     {
-        if (isset($this->routes[$name])) {
+        if (isset($this->routes[$name]))
+        {
             return $this->routes[$name];
         }
 
@@ -114,7 +120,8 @@ 
 
     public function getRoutes(): array
     {
-        if (!empty($this->default)) {
+        if (!empty($this->default))
+        {
             return $this->routes + [null => $this->default];
         }
 
@@ -123,9 +130,12 @@ 
 
     public function uri(string $route, iterable $parameters = []): UriInterface
     {
-        try {
+        try
+        {
             return $this->getRoute($route)->uri($parameters);
-        } catch (UndefinedRouteException) {
+        }
+        catch (UndefinedRouteException)
+        {
             //In some cases route name can be provided as controller:action pair, we can try to
             //generate such route automatically based on our default/fallback route
             return $this->castRoute($route)->uri($parameters);
@@ -137,9 +147,11 @@ 
         /** @var GroupRegistry $groups */
         $groups = $this->container->get(GroupRegistry::class);
 
-        foreach ($routes->getCollection() as $name => $configurator) {
+        foreach ($routes->getCollection() as $name => $configurator)
+        {
             $target = $configurator->target;
-            if ($configurator->core !== null && $target instanceof AbstractTarget) {
+            if ($configurator->core !== null && $target instanceof AbstractTarget)
+            {
                 $target = $target->withCore($configurator->core);
             }
 
@@ -149,19 +161,23 @@ 
                 $configurator->defaults
             );
 
-            if ($configurator->middleware !== null) {
+            if ($configurator->middleware !== null)
+            {
                 $route = $route->withMiddleware(...$configurator->middleware);
             }
 
-            if ($configurator->methods !== null) {
+            if ($configurator->methods !== null)
+            {
                 $route = $route->withVerbs(...$configurator->methods);
             }
 
-            if (!isset($this->routes[$name]) && $name !== RoutingConfigurator::DEFAULT_ROUTE_NAME) {
+            if (!isset($this->routes[$name]) && $name !== RoutingConfigurator::DEFAULT_ROUTE_NAME)
+            {
                 $groups->getGroup($configurator->group ?? $groups->getDefaultGroup())->addRoute($name, $route);
             }
 
-            if ($name === RoutingConfigurator::DEFAULT_ROUTE_NAME) {
+            if ($name === RoutingConfigurator::DEFAULT_ROUTE_NAME)
+            {
                 $this->setDefault($route);
             }
         }
@@ -172,17 +188,20 @@ 
      */
     protected function matchRoute(ServerRequestInterface $request, string &$routeName = null): ?RouteInterface
     {
-        foreach ($this->routes as $name => $route) {
+        foreach ($this->routes as $name => $route)
+        {
             // Matched route will return new route instance with matched parameters
             $matched = $route->match($request);
 
-            if ($matched !== null) {
+            if ($matched !== null)
+            {
                 $routeName = $name;
                 return $matched;
             }
         }
 
-        if ($this->default !== null) {
+        if ($this->default !== null)
+        {
             return $this->default->match($request);
         }
 
@@ -195,7 +214,8 @@ 
      */
     protected function configure(RouteInterface $route): RouteInterface
     {
-        if ($route instanceof ContainerizedInterface && !$route->hasContainer()) {
+        if ($route instanceof ContainerizedInterface && !$route->hasContainer())
+        {
             // isolating route in a given container
             $route = $route->withContainer($this->container);
         }
@@ -225,11 +245,16 @@ 
             );
         }
 
-        if (!empty($matches['name'])) {
+        if (!empty($matches['name']))
+        {
             $routeObject = $this->getRoute($matches['name']);
-        } elseif ($this->default !== null) {
+        }
+        elseif ($this->default !== null)
+        {
             $routeObject = $this->default;
-        } else {
+        }
+        else
+        {
             throw new UndefinedRouteException(\sprintf('Unable to locate route candidate for `%s`', $route));
         }
 

src/Queue/tests/Interceptor/Push/CoreTest.php

Braces +6 added lines, -3 removed lines

@@ -20,7 +20,8 @@ 
             $queue = m::mock(QueueInterface::class)
         );
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null) {
+            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null)
+            {
                 return $name === 'foo' && $payload === ['baz' => 'baf'] && $options instanceof Options;
             });
 
@@ -59,7 +60,8 @@ 
         $tracer->shouldReceive('getContext')->once()->andReturn(['foo' => ['bar']]);
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null) {
+            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null)
+            {
                 return $name === 'foo'
                     && $payload === ['baz' => 'baf']
                     && $options->getHeader('foo') === ['bar'];
@@ -82,7 +84,8 @@ 
         $tracer->shouldNotReceive('getContext');
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null) {
+            ->withArgs(function (string $name, array $payload = [], OptionsInterface $options = null)
+            {
                 return $name === 'foo'
                     && $payload === ['baz' => 'baf']
                     && $options !== null;

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

Braces +6 added lines, -3 removed lines

@@ -34,12 +34,15 @@
         \assert($parameters['options'] === null || $parameters['options'] instanceof OptionsInterface);
         \assert(\is_array($parameters['payload']));
 
-        if ($parameters['options'] === null) {
+        if ($parameters['options'] === null)
+        {
             $parameters['options'] = new Options();
         }
 
-        if (\method_exists($parameters['options'], 'withHeader')) {
-            foreach ($this->tracer->getContext() as $key => $data) {
+        if (\method_exists($parameters['options'], 'withHeader'))
+        {
+            foreach ($this->tracer->getContext() as $key => $data)
+            {
                 $parameters['options'] = $parameters['options']->withHeader($key, $data);
             }
         }

src/Prototype/src/Command/DumpCommand.php

Braces +15 added lines, -7 removed lines

@@ -22,7 +22,8 @@ 
     public function perform(PrototypeBootloader $prototypeBootloader): int
     {
         $dependencies = $this->registry->getPropertyBindings();
-        if ($dependencies === []) {
+        if ($dependencies === [])
+        {
             $this->writeln('<comment>No prototyped shortcuts found.</comment>');
 
             return self::SUCCESS;
@@ -32,7 +33,8 @@ 
 
         $trait = new \ReflectionClass(PrototypeTrait::class);
         $docComment = $trait->getDocComment();
-        if ($docComment === false) {
+        if ($docComment === false)
+        {
             $this->write('<fg=red>DOCComment is missing</fg=red>');
 
             return self::FAILURE;
@@ -40,7 +42,8 @@ 
 
         $filename = $trait->getFileName();
 
-        try {
+        try
+        {
             \file_put_contents(
                 $filename,
                 \str_replace(
@@ -49,7 +52,9 @@ 
                     \file_get_contents($filename)
                 )
             );
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $this->write('<fg=red>' . $e->getMessage() . "</fg=red>\n");
 
             return self::FAILURE;
@@ -57,10 +62,12 @@ 
 
         $this->write("<fg=green>complete</fg=green>\n");
 
-        if ($this->isVerbose()) {
+        if ($this->isVerbose())
+        {
             $grid = $this->table(['Property:', 'Target:']);
 
-            foreach ($dependencies as $dependency) {
+            foreach ($dependencies as $dependency)
+            {
                 $grid->addRow([$dependency->var, $dependency->type->fullName]);
             }
 
@@ -78,7 +85,8 @@ 
         );
         $an->lines[] = new Annotation\Line('');
 
-        foreach ($dependencies as $dependency) {
+        foreach ($dependencies as $dependency)
+        {
             $an->lines[] = new Annotation\Line(
                 \sprintf('\\%s $%s', $dependency->type->fullName, $dependency->var),
                 'property'

src/Telemetry/src/Config/TelemetryConfig.php

Braces +8 added lines, -4 removed lines

@@ -25,7 +25,8 @@ 
      */
     public function getDefaultDriver(): string
     {
-        if (!\is_string($this->config['default'])) {
+        if (!\is_string($this->config['default']))
+        {
             throw new InvalidArgumentException('Default trace driver config value must be a string');
         }
 
@@ -39,7 +40,8 @@ 
      */
     public function getDriverConfig(string $name): string|Autowire|TracerFactoryInterface
     {
-        if (!isset($this->config['drivers'][$name])) {
+        if (!isset($this->config['drivers'][$name]))
+        {
             throw new InvalidArgumentException(
                 \sprintf('Config for telemetry driver `%s` is not defined.', $name)
             );
@@ -47,11 +49,13 @@ 
 
         $driver = $this->config['drivers'][$name];
 
-        if ($driver instanceof TracerFactoryInterface) {
+        if ($driver instanceof TracerFactoryInterface)
+        {
             return $driver;
         }
 
-        if (!\is_string($driver) && !$driver instanceof Autowire) {
+        if (!\is_string($driver) && !$driver instanceof Autowire)
+        {
             throw new InvalidArgumentException(
                 \sprintf('Trace type value for `%s` must be a string or %s', $name, Autowire::class)
             );

src/Telemetry/src/Monolog/TelemetryProcessor.php

Braces +2 added lines, -1 removed lines

@@ -22,7 +22,8 @@
 
         $context = $tracer->getContext();
 
-        if (!empty($context)) {
+        if (!empty($context))
+        {
             $record['extra']['telemetry'] = $context;
         }
 

src/Http/tests/HttpTest.php

Braces +28 added lines, -14 removed lines

@@ -45,7 +45,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             return 'hello world';
         });
 
@@ -67,7 +68,8 @@ 
     {
         $core = $this->getCore();
         $core->setHandler(
-            new CallableHandler(function () {
+            new CallableHandler(function ()
+            {
                 return 'hello world';
             }, new ResponseFactory(new HttpConfig(['headers' => []])))
         );
@@ -80,7 +82,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function ($req, $resp) {
+        $core->setHandler(function ($req, $resp)
+        {
             return $resp->withAddedHeader('hello', 'value');
         });
 
@@ -93,7 +96,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function ($req, $resp) {
+        $core->setHandler(function ($req, $resp)
+        {
             echo 'hello!';
 
             return $resp->withAddedHeader('hello', 'value');
@@ -109,7 +113,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function ($req, $resp) {
+        $core->setHandler(function ($req, $resp)
+        {
             echo 'hello!';
             $resp->getBody()->write('world ');
 
@@ -126,7 +131,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             ob_start();
             ob_start();
             echo 'hello!';
@@ -147,7 +153,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             return [
                 'status' => 404,
                 'message' => 'not found',
@@ -163,7 +170,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             return new Json([
                 'status' => 404,
                 'message' => 'not found',
@@ -179,7 +187,8 @@ 
     {
         $core = $this->getCore([HeaderMiddleware::class]);
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             return 'hello?';
         });
 
@@ -196,7 +205,8 @@ 
         $core->getPipeline()->pushMiddleware(new Header2Middleware());
         $core->getPipeline()->riseMiddleware(new HeaderMiddleware());
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             return 'hello?';
         });
 
@@ -213,7 +223,8 @@ 
         $core->getPipeline()->pushMiddleware(new HeaderMiddleware());
         $core->getPipeline()->riseMiddleware(new Header2Middleware());
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             return 'hello?';
         });
 
@@ -227,7 +238,8 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             $this->assertTrue($this->container->has(ServerRequestInterface::class));
 
             return 'OK';
@@ -265,7 +277,8 @@ 
 
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function ()
+        {
             return 'hello world';
         });
 
@@ -287,7 +300,8 @@ 
             $tracerFactory = m::mock(TracerFactoryInterface::class),
         );
 
-        $http->setHandler(function () {
+        $http->setHandler(function ()
+        {
             return 'hello world';
         });
 

src/Http/src/Http.php

Braces +6 added lines, -3 removed lines

@@ -33,7 +33,8 @@ 
         private readonly ContainerInterface $container,
         ?TracerFactoryInterface $tracerFactory = null
     ) {
-        foreach ($this->config->getMiddleware() as $middleware) {
+        foreach ($this->config->getMiddleware() as $middleware)
+        {
             $this->pipeline->pushMiddleware($this->container->get($middleware));
         }
 
@@ -67,7 +68,8 @@ 
 
             $dispatcher?->dispatch(new RequestReceived($request));
 
-            if ($this->handler === null) {
+            if ($this->handler === null)
+            {
                 throw new HttpException('Unable to run HttpCore, no handler is set.');
             }
 
@@ -104,7 +106,8 @@ 
             traceKind: TraceKind::SERVER
         );
 
-        foreach ($tracer->getContext() as $key => $value) {
+        foreach ($tracer->getContext() as $key => $value)
+        {
             $response = $response->withHeader($key, $value);
         }