spiral / framework

src/Telemetry/src/SpanInterface.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      * @param non-empty-string|int $code
      * @param non-empty-string|null $description
      */
-    public function setStatus(string|int $code, string $description = null): self;
+    public function setStatus(string | int $code, string $description = null): self;
 
     /**
      * Get the current span status.

src/Http/tests/HttpTest.php

Spacing +15 added lines, -15 removed lines

@@ -45,7 +45,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             return 'hello world';
         });
 
@@ -67,7 +67,7 @@ 
     {
         $core = $this->getCore();
         $core->setHandler(
-            new CallableHandler(function () {
+            new CallableHandler(function (){
                 return 'hello world';
             }, new ResponseFactory(new HttpConfig(['headers' => []])))
         );
@@ -80,7 +80,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function ($req, $resp) {
+        $core->setHandler(function ($req, $resp){
             return $resp->withAddedHeader('hello', 'value');
         });
 
@@ -93,7 +93,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function ($req, $resp) {
+        $core->setHandler(function ($req, $resp){
             echo 'hello!';
 
             return $resp->withAddedHeader('hello', 'value');
@@ -109,7 +109,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function ($req, $resp) {
+        $core->setHandler(function ($req, $resp){
             echo 'hello!';
             $resp->getBody()->write('world ');
 
@@ -126,7 +126,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             ob_start();
             ob_start();
             echo 'hello!';
@@ -147,7 +147,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             return [
                 'status' => 404,
                 'message' => 'not found',
@@ -163,7 +163,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             return new Json([
                 'status' => 404,
                 'message' => 'not found',
@@ -179,7 +179,7 @@ 
     {
         $core = $this->getCore([HeaderMiddleware::class]);
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             return 'hello?';
         });
 
@@ -196,7 +196,7 @@ 
         $core->getPipeline()->pushMiddleware(new Header2Middleware());
         $core->getPipeline()->riseMiddleware(new HeaderMiddleware());
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             return 'hello?';
         });
 
@@ -213,7 +213,7 @@ 
         $core->getPipeline()->pushMiddleware(new HeaderMiddleware());
         $core->getPipeline()->riseMiddleware(new Header2Middleware());
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             return 'hello?';
         });
 
@@ -227,7 +227,7 @@ 
     {
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             $this->assertTrue($this->container->has(ServerRequestInterface::class));
 
             return 'OK';
@@ -260,12 +260,12 @@ 
         $dispatcher
             ->expects(self::exactly(2))
             ->method('dispatch')
-            ->with($this->callback(static fn(RequestReceived|RequestHandled $event): bool => true));
+            ->with($this->callback(static fn(RequestReceived | RequestHandled $event): bool => true));
         $this->container->bind(EventDispatcherInterface::class, $dispatcher);
 
         $core = $this->getCore();
 
-        $core->setHandler(function () {
+        $core->setHandler(function (){
             return 'hello world';
         });
 
@@ -287,7 +287,7 @@ 
             $tracerFactory = m::mock(TracerFactoryInterface::class),
         );
 
-        $http->setHandler(function () {
+        $http->setHandler(function (){
             return 'hello world';
         });
 

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/Pipeline.php

Spacing +3 added lines, -3 removed lines

@@ -32,7 +32,7 @@ 
         private readonly ScopeInterface $scope,
         private readonly ?EventDispatcherInterface $dispatcher = null,
         ?TracerInterface $tracer = null
-    ) {
+    ){
         $this->tracer = $tracer ?? new NullTracer($scope);
     }
 
@@ -57,12 +57,12 @@ 
 
     public function handle(Request $request): Response
     {
-        if ($this->handler === null) {
+        if ($this->handler === null){
             throw new PipelineException('Unable to run pipeline, no handler given.');
         }
 
         $position = $this->position++;
-        if (isset($this->middleware[$position])) {
+        if (isset($this->middleware[$position])){
             $middleware = $this->middleware[$position];
             $this->dispatcher?->dispatch(new MiddlewareProcessing($request, $middleware));
 

src/Telemetry/src/AbstractTracer.php

Spacing +2 added lines, -2 removed lines

@@ -17,7 +17,7 @@ 
 {
     public function __construct(
         private readonly ?ScopeInterface $scope = new Container(),
-    ) {
+    ){
     }
 
     /**
@@ -28,6 +28,6 @@ 
         return $this->scope->runScope([
             SpanInterface::class => $span,
             TracerInterface::class => $this,
-        ], static fn (InvokerInterface $invoker): mixed => $invoker->invoke($callback));
+        ], static fn (InvokerInterface $invoker) : mixed => $invoker->invoke($callback));
     }
 }

src/Telemetry/src/LogTracer.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
         private readonly ClockInterface $clock,
         private readonly LoggerInterface $logger,
         private readonly UuidFactoryInterface $uuidFactory
-    ) {
+    ){
         parent::__construct($scope);
     }
 

src/Queue/tests/Interceptor/Consume/HandlerTest.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
         $tracerFactory->shouldReceive('make')
             ->once()
             ->with(['some' => 'data'])
-            ->andReturn( $tracer = new NullTracer());
+            ->andReturn($tracer = new NullTracer());
 
         $handler = new Handler(
             core: $core = m::mock(CoreInterface::class),

src/Queue/src/Interceptor/Consume/Handler.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
     public function __construct(
         private readonly CoreInterface $core,
         ?TracerFactoryInterface $tracerFactory = null
-    ) {
+    ){
         $this->tracerFactory = $tracerFactory ?? new NullTracerFactory(new Container());
     }
 

src/Http/src/Http.php

Spacing +5 added lines, -5 removed lines

@@ -32,8 +32,8 @@ 
         private readonly ResponseFactoryInterface $responseFactory,
         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));
         }
 
@@ -46,7 +46,7 @@ 
         return $this->pipeline;
     }
 
-    public function setHandler(callable|RequestHandlerInterface $handler): self
+    public function setHandler(callable | RequestHandlerInterface $handler): self
     {
         $this->handler = $handler instanceof RequestHandlerInterface
             ? $handler
@@ -67,7 +67,7 @@ 
 
             $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 +104,7 @@ 
             traceKind: TraceKind::SERVER
         );
 
-        foreach ($tracer->getContext() as $key => $value) {
+        foreach ($tracer->getContext() as $key => $value){
             $response = $response->withHeader($key, $value);
         }
 

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

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

Spacing +5 added lines, -5 removed lines

@@ -22,7 +22,7 @@ 
             $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;
             });
 
@@ -62,18 +62,18 @@ 
 
 
         $tracer->shouldReceive('getContext')->once()->andReturn(['foo' => ['bar']]);
-        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback) {
+        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback){
             return $callback();
         });
 
         $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'];
             });
 
-        ContainerScope::runScope($container, function() use($core) {
+        ContainerScope::runScope($container, function () use($core) {
             $core->callAction('foo', 'bar', [
                 'id' => 'job-id',
                 'payload' => ['baz' => 'baf'],
@@ -92,7 +92,7 @@ 
         $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;

Braces +10 added lines, -5 removed lines

@@ -22,7 +22,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;
             });
 
@@ -62,18 +63,21 @@ 
 
 
         $tracer->shouldReceive('getContext')->once()->andReturn(['foo' => ['bar']]);
-        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback) {
+        $tracer->shouldReceive('trace')->once()->andReturnUsing(function ($name, $callback)
+        {
             return $callback();
         });
 
         $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'];
             });
 
-        ContainerScope::runScope($container, function() use($core) {
+        ContainerScope::runScope($container, function() use($core)
+        {
             $core->callAction('foo', 'bar', [
                 'id' => 'job-id',
                 'payload' => ['baz' => 'baf'],
@@ -92,7 +96,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;