spiral / framework

src/Boot/src/helpers.php

Spacing +6 added lines, -6 removed lines

@@ -9,7 +9,7 @@ 
 use Spiral\Core\ContainerScope;
 use Spiral\Core\Exception\ScopeException;
 
-if (!function_exists('spiral')) {
+if (!function_exists('spiral')){
     /**
      * Resolve given alias in current IoC scope.
      *
@@ -22,19 +22,19 @@ 
      */
     function spiral(string $alias): mixed
     {
-        if (!ContainerScope::getContainer() instanceof \Psr\Container\ContainerInterface) {
+        if (!ContainerScope::getContainer() instanceof \Psr\Container\ContainerInterface){
             throw new ScopeException('Container scope was not set.');
         }
 
-        try {
+        try{
             return ContainerScope::getContainer()->get($alias);
-        } catch (ContainerExceptionInterface $e) {
+        }catch (ContainerExceptionInterface $e){
             throw new ScopeException($e->getMessage(), $e->getCode(), $e);
         }
     }
 }
 
-if (!function_exists('directory')) {
+if (!function_exists('directory')){
     /**
      * Get directory alias value. Uses application core from the current global scope.
      *
@@ -49,7 +49,7 @@ 
     }
 }
 
-if (!function_exists('env')) {
+if (!function_exists('env')){
     /**
      * Gets the value of an environment variable. Uses application core from the current global scope.
      *

Braces +13 added lines, -6 removed lines

@@ -9,7 +9,8 @@ 
 use Spiral\Core\ContainerScope;
 use Spiral\Core\Exception\ScopeException;
 
-if (!function_exists('spiral')) {
+if (!function_exists('spiral'))
+{
     /**
      * Resolve given alias in current IoC scope.
      *
@@ -22,19 +23,24 @@ 
      */
     function spiral(string $alias): mixed
     {
-        if (!ContainerScope::getContainer() instanceof \Psr\Container\ContainerInterface) {
+        if (!ContainerScope::getContainer() instanceof \Psr\Container\ContainerInterface)
+        {
             throw new ScopeException('Container scope was not set.');
         }
 
-        try {
+        try
+        {
             return ContainerScope::getContainer()->get($alias);
-        } catch (ContainerExceptionInterface $e) {
+        }
+        catch (ContainerExceptionInterface $e)
+        {
             throw new ScopeException($e->getMessage(), $e->getCode(), $e);
         }
     }
 }
 
-if (!function_exists('directory')) {
+if (!function_exists('directory'))
+{
     /**
      * Get directory alias value. Uses application core from the current global scope.
      *
@@ -49,7 +55,8 @@ 
     }
 }
 
-if (!function_exists('env')) {
+if (!function_exists('env'))
+{
     /**
      * Gets the value of an environment variable. Uses application core from the current global scope.
      *

src/Queue/tests/Core/QueueInjectorTest.php

Spacing +1 added lines, -1 removed lines

@@ -87,7 +87,7 @@
         $factory->shouldReceive('make')->andReturnUsing(function (string $name): QueueInterface {
             $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null;
 
-            if (!$result instanceof \Spiral\Queue\QueueInterface) {
+            if (!$result instanceof \Spiral\Queue\QueueInterface){
                 throw new NotFoundException();
             }
             return $result;

Braces +2 added lines, -1 removed lines

@@ -87,7 +87,8 @@
         $factory->shouldReceive('make')->andReturnUsing(function (string $name): QueueInterface {
             $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null;
 
-            if (!$result instanceof \Spiral\Queue\QueueInterface) {
+            if (!$result instanceof \Spiral\Queue\QueueInterface)
+            {
                 throw new NotFoundException();
             }
             return $result;

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

Spacing +6 added lines, -6 removed lines

@@ -24,13 +24,13 @@ 
             $queue = m::mock(QueueInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload)){
             $this->markTestIncomplete('QueueInterface does not support non-array payloads');
             return;
         }
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(fn(string $name, mixed $p = [], ?OptionsInterface $options = null): bool => $name === 'foo'
+            ->withArgs(fn(string $name, mixed $p = [], ?OptionsInterface $options = null) : bool => $name === 'foo'
                 && $payload === $p
                 && $options instanceof Options,
             );
@@ -49,7 +49,7 @@ 
             $queue = m::mock(QueueInterface::class)
         );
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload)){
             $this->markTestIncomplete('QueueInterface does not support non-array payloads');
             return;
         }
@@ -80,11 +80,11 @@ 
         $tracer->shouldReceive('trace')->once()->andReturnUsing(fn($name, $callback) => $callback());
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(fn(string $name, array $payload = [], ?OptionsInterface $options = null): bool => $name === 'foo'
+            ->withArgs(fn(string $name, array $payload = [], ?OptionsInterface $options = null) : bool => $name === 'foo'
                 && $payload === ['baz' => 'baf']
                 && $options->getHeader('foo') === ['bar']);
 
-        ContainerScope::runScope($container, function() use($core): void {
+        ContainerScope::runScope($container, function () use($core): void {
             $core->callAction('foo', 'bar', [
                 'id' => 'job-id',
                 'payload' => ['baz' => 'baf'],
@@ -103,7 +103,7 @@ 
         $tracer->shouldNotReceive('getContext');
 
         $queue->shouldReceive('push')->once()
-            ->withArgs(fn(string $name, array $payload = [], ?OptionsInterface $options = null): bool => $name === 'foo'
+            ->withArgs(fn(string $name, array $payload = [], ?OptionsInterface $options = null) : bool => $name === 'foo'
                 && $payload === ['baz' => 'baf']
                 && $options instanceof \Spiral\Queue\OptionsInterface);
 

src/Queue/src/Driver/SyncDriver.php

Spacing +2 added lines, -2 removed lines

@@ -20,13 +20,13 @@
 
     public function __construct(
         private readonly Handler $coreHandler
-    ) {
+    ){
     }
 
     /** @inheritdoc */
     public function push(string $name, mixed $payload = [], ?OptionsInterface $options = null): string
     {
-        if ($options instanceof \Spiral\Queue\OptionsInterface && $options->getDelay()) {
+        if ($options instanceof \Spiral\Queue\OptionsInterface && $options->getDelay()){
             \sleep($options->getDelay());
         }
 

Braces +2 added lines, -1 removed lines

@@ -26,7 +26,8 @@
     /** @inheritdoc */
     public function push(string $name, mixed $payload = [], ?OptionsInterface $options = null): string
     {
-        if ($options instanceof \Spiral\Queue\OptionsInterface && $options->getDelay()) {
+        if ($options instanceof \Spiral\Queue\OptionsInterface && $options->getDelay())
+        {
             \sleep($options->getDelay());
         }
 

src/Queue/src/RetryPolicy.php

Spacing +6 added lines, -6 removed lines

@@ -27,21 +27,21 @@ 
      */
     public function __construct(int $maxAttempts, int $delay, float $multiplier = 1)
     {
-        if ($maxAttempts < 0) {
+        if ($maxAttempts < 0){
             throw new InvalidArgumentException(
                 \sprintf('Maximum attempts must be greater than or equal to zero: `%s` given.', $maxAttempts)
             );
         }
         $this->maxAttempts = $maxAttempts;
 
-        if ($delay < 0) {
+        if ($delay < 0){
             throw new InvalidArgumentException(
                 \sprintf('Delay must be greater than or equal to zero: `%s` given.', $delay)
             );
         }
         $this->delay = $delay;
 
-        if ($multiplier < 1) {
+        if ($multiplier < 1){
             throw new InvalidArgumentException(
                 \sprintf('Multiplier must be greater than zero: `%s` given.', $multiplier)
             );
@@ -56,7 +56,7 @@ 
      */
     public function getDelay(int $attempts = 0): int
     {
-        return (int) \ceil($this->delay * $this->multiplier ** $attempts);
+        return (int)\ceil($this->delay * $this->multiplier ** $attempts);
     }
 
     /**
@@ -64,11 +64,11 @@ 
      */
     public function isRetryable(\Throwable $exception, int $attempts = 0): bool
     {
-        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable) {
+        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable){
             $exception = $exception->getPrevious();
         }
 
-        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0) {
+        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0){
             return false;
         }
 

Braces +10 added lines, -5 removed lines

@@ -27,21 +27,24 @@ 
      */
     public function __construct(int $maxAttempts, int $delay, float $multiplier = 1)
     {
-        if ($maxAttempts < 0) {
+        if ($maxAttempts < 0)
+        {
             throw new InvalidArgumentException(
                 \sprintf('Maximum attempts must be greater than or equal to zero: `%s` given.', $maxAttempts)
             );
         }
         $this->maxAttempts = $maxAttempts;
 
-        if ($delay < 0) {
+        if ($delay < 0)
+        {
             throw new InvalidArgumentException(
                 \sprintf('Delay must be greater than or equal to zero: `%s` given.', $delay)
             );
         }
         $this->delay = $delay;
 
-        if ($multiplier < 1) {
+        if ($multiplier < 1)
+        {
             throw new InvalidArgumentException(
                 \sprintf('Multiplier must be greater than zero: `%s` given.', $multiplier)
             );
@@ -64,11 +67,13 @@ 
      */
     public function isRetryable(\Throwable $exception, int $attempts = 0): bool
     {
-        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable) {
+        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable)
+        {
             $exception = $exception->getPrevious();
         }
 
-        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0) {
+        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0)
+        {
             return false;
         }
 

src/Queue/src/Interceptor/Consume/RetryPolicyInterceptor.php

Spacing +7 added lines, -7 removed lines

@@ -20,28 +20,28 @@ 
     public function __construct(
         private readonly ReaderInterface $reader,
         private readonly HandlerRegistryInterface $registry,
-    ) {
+    ){
     }
 
     public function process(string $controller, string $action, array $parameters, CoreInterface $core): mixed
     {
-        try {
+        try{
             return $core->callAction($controller, $action, $parameters);
-        } catch (\Throwable $e) {
-            if (!\class_exists($controller)) {
+        }catch (\Throwable $e){
+            if (!\class_exists($controller)){
                 $controller = $this->registry->getHandler($controller)::class;
             }
 
             $policy = $this->getRetryPolicy($e, new \ReflectionClass($controller));
 
-            if (!$policy instanceof \Spiral\Queue\RetryPolicyInterface) {
+            if (!$policy instanceof \Spiral\Queue\RetryPolicyInterface){
                 throw $e;
             }
 
             $headers = $parameters['headers'] ?? [];
             $attempts = (int)($headers['attempts'][0] ?? 0);
 
-            if ($policy->isRetryable($e, $attempts) === false) {
+            if ($policy->isRetryable($e, $attempts) === false){
                 throw $e;
             }
 
@@ -58,7 +58,7 @@ 
     {
         $attribute = $this->reader->firstClassMetadata($handler, Attribute::class);
 
-        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable) {
+        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable){
             $exception = $exception->getPrevious();
         }
 

Braces +13 added lines, -6 removed lines

@@ -25,23 +25,29 @@ 
 
     public function process(string $controller, string $action, array $parameters, CoreInterface $core): mixed
     {
-        try {
+        try
+        {
             return $core->callAction($controller, $action, $parameters);
-        } catch (\Throwable $e) {
-            if (!\class_exists($controller)) {
+        }
+        catch (\Throwable $e)
+        {
+            if (!\class_exists($controller))
+            {
                 $controller = $this->registry->getHandler($controller)::class;
             }
 
             $policy = $this->getRetryPolicy($e, new \ReflectionClass($controller));
 
-            if (!$policy instanceof \Spiral\Queue\RetryPolicyInterface) {
+            if (!$policy instanceof \Spiral\Queue\RetryPolicyInterface)
+            {
                 throw $e;
             }
 
             $headers = $parameters['headers'] ?? [];
             $attempts = (int)($headers['attempts'][0] ?? 0);
 
-            if ($policy->isRetryable($e, $attempts) === false) {
+            if ($policy->isRetryable($e, $attempts) === false)
+            {
                 throw $e;
             }
 
@@ -58,7 +64,8 @@ 
     {
         $attribute = $this->reader->firstClassMetadata($handler, Attribute::class);
 
-        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable) {
+        if ($exception instanceof JobException && $exception->getPrevious() instanceof \Throwable)
+        {
             $exception = $exception->getPrevious();
         }
 

src/Storage/src/Bucket/WritableTrait.php

Spacing +20 added lines, -20 removed lines

@@ -19,7 +19,7 @@ 
 {
     public function create(string $pathname, array $config = []): FileInterface
     {
-        if ($this instanceof ReadableInterface && !$this->exists($pathname)) {
+        if ($this instanceof ReadableInterface && !$this->exists($pathname)){
             return $this->write($pathname, '', $config);
         }
 
@@ -32,8 +32,8 @@ 
 
         $fs = $this->getOperator();
 
-        try {
-            switch (true) {
+        try{
+            switch (true){
                 case \is_object($content):
                 case \is_string($content):
                     $fs->write($pathname, (string)$content, $config);
@@ -47,7 +47,7 @@ 
                     $message = 'Content must be a resource stream or stringable type, but %s passed';
                     throw new \InvalidArgumentException(\sprintf($message, \get_debug_type($content)));
             }
-        } catch (FilesystemException $e) {
+        }catch (FilesystemException $e){
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
 
@@ -61,9 +61,9 @@ 
     ): FileInterface {
         $fs = $this->getOperator();
 
-        try {
+        try{
             $fs->setVisibility($pathname, $this->toFlysystemVisibility($visibility));
-        } catch (FilesystemException $e) {
+        }catch (FilesystemException $e){
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
 
@@ -78,10 +78,10 @@ 
     ): FileInterface {
         $fs = $this->getOperator();
 
-        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this) {
-            try {
+        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this){
+            try{
                 $fs->copy($source, $destination, $config);
-            } catch (FilesystemException $e) {
+            }catch (FilesystemException $e){
                 throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
             }
 
@@ -99,10 +99,10 @@ 
     ): FileInterface {
         $fs = $this->getOperator();
 
-        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this) {
-            try {
+        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this){
+            try{
                 $fs->move($source, $destination, $config);
-            } catch (FilesystemException $e) {
+            }catch (FilesystemException $e){
                 throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
             }
 
@@ -120,14 +120,14 @@ 
     {
         $fs = $this->getOperator();
 
-        try {
+        try{
             $fs->delete($pathname);
 
-            if ($clean) {
+            if ($clean){
                 /** @psalm-suppress InternalMethod */
                 $this->deleteEmptyDirectories($this->getParentDirectory($pathname));
             }
-        } catch (FilesystemException $e) {
+        }catch (FilesystemException $e){
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -182,18 +182,18 @@ 
      */
     private function deleteEmptyDirectories(string $directory): void
     {
-        if (!$this->hasParentDirectory($directory)) {
+        if (!$this->hasParentDirectory($directory)){
             return;
         }
 
         $fs = $this->getOperator();
 
-        try {
-            if (!$this->hasFiles($directory)) {
+        try{
+            if (!$this->hasFiles($directory)){
                 $fs->deleteDirectory($directory);
                 $this->deleteEmptyDirectories($this->getParentDirectory($directory));
             }
-        } catch (FilesystemException $e) {
+        }catch (FilesystemException $e){
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -214,7 +214,7 @@ 
     {
         $fs = $this->getOperator();
 
-        foreach ($fs->listContents($directory) as $_) {
+        foreach ($fs->listContents($directory) as $_){
             return true;
         }
 

Braces +46 added lines, -20 removed lines

@@ -19,7 +19,8 @@ 
 {
     public function create(string $pathname, array $config = []): FileInterface
     {
-        if ($this instanceof ReadableInterface && !$this->exists($pathname)) {
+        if ($this instanceof ReadableInterface && !$this->exists($pathname))
+        {
             return $this->write($pathname, '', $config);
         }
 
@@ -32,8 +33,10 @@ 
 
         $fs = $this->getOperator();
 
-        try {
-            switch (true) {
+        try
+        {
+            switch (true)
+            {
                 case \is_object($content):
                 case \is_string($content):
                     $fs->write($pathname, (string)$content, $config);
@@ -47,7 +50,9 @@ 
                     $message = 'Content must be a resource stream or stringable type, but %s passed';
                     throw new \InvalidArgumentException(\sprintf($message, \get_debug_type($content)));
             }
-        } catch (FilesystemException $e) {
+        }
+        catch (FilesystemException $e)
+        {
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
 
@@ -61,9 +66,12 @@ 
     ): FileInterface {
         $fs = $this->getOperator();
 
-        try {
+        try
+        {
             $fs->setVisibility($pathname, $this->toFlysystemVisibility($visibility));
-        } catch (FilesystemException $e) {
+        }
+        catch (FilesystemException $e)
+        {
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
 
@@ -78,10 +86,14 @@ 
     ): FileInterface {
         $fs = $this->getOperator();
 
-        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this) {
-            try {
+        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this)
+        {
+            try
+            {
                 $fs->copy($source, $destination, $config);
-            } catch (FilesystemException $e) {
+            }
+            catch (FilesystemException $e)
+            {
                 throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
             }
 
@@ -99,10 +111,14 @@ 
     ): FileInterface {
         $fs = $this->getOperator();
 
-        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this) {
-            try {
+        if (!$storage instanceof \Spiral\Storage\BucketInterface || $storage === $this)
+        {
+            try
+            {
                 $fs->move($source, $destination, $config);
-            } catch (FilesystemException $e) {
+            }
+            catch (FilesystemException $e)
+            {
                 throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
             }
 
@@ -120,14 +136,18 @@ 
     {
         $fs = $this->getOperator();
 
-        try {
+        try
+        {
             $fs->delete($pathname);
 
-            if ($clean) {
+            if ($clean)
+            {
                 /** @psalm-suppress InternalMethod */
                 $this->deleteEmptyDirectories($this->getParentDirectory($pathname));
             }
-        } catch (FilesystemException $e) {
+        }
+        catch (FilesystemException $e)
+        {
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -182,18 +202,23 @@ 
      */
     private function deleteEmptyDirectories(string $directory): void
     {
-        if (!$this->hasParentDirectory($directory)) {
+        if (!$this->hasParentDirectory($directory))
+        {
             return;
         }
 
         $fs = $this->getOperator();
 
-        try {
-            if (!$this->hasFiles($directory)) {
+        try
+        {
+            if (!$this->hasFiles($directory))
+            {
                 $fs->deleteDirectory($directory);
                 $this->deleteEmptyDirectories($this->getParentDirectory($directory));
             }
-        } catch (FilesystemException $e) {
+        }
+        catch (FilesystemException $e)
+        {
             throw new FileOperationException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -214,7 +239,8 @@ 
     {
         $fs = $this->getOperator();
 
-        foreach ($fs->listContents($directory) as $_) {
+        foreach ($fs->listContents($directory) as $_)
+        {
             return true;
         }
 

src/Http/src/Stream/GeneratorStream.php

Spacing +18 added lines, -18 removed lines

@@ -27,23 +27,23 @@ 
 
     public function __toString(): string
     {
-        try {
+        try{
             return $this->getContents();
-        } catch (\Exception) {
+        }catch (\Exception){
             return '';
         }
     }
 
     public function close(): void
     {
-        if ($this->stream instanceof \Generator) {
+        if ($this->stream instanceof \Generator){
             $this->detach();
         }
     }
 
     public function detach()
     {
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator){
             return null;
         }
         $this->stream = null;
@@ -81,7 +81,7 @@ 
 
     public function rewind(): void
     {
-        if ($this->stream instanceof \Generator) {
+        if ($this->stream instanceof \Generator){
             $this->stream->rewind();
         }
         $this->caret = 0;
@@ -105,26 +105,26 @@ 
 
     public function read($length): string
     {
-        if (!$this->readable) {
+        if (!$this->readable){
             throw new RuntimeException('Cannot read from non-readable stream.');
         }
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator){
             throw new RuntimeException('Cannot read from detached stream.');
         }
-        do {
-            if ($this->started) {
+        do{
+            if ($this->started){
                 $read = (string)$this->stream->send(null);
-            } else {
+            }else{
                 $this->started = true;
                 $read = (string)$this->stream->current();
             }
-            if (!$this->stream->valid()) {
+            if (!$this->stream->valid()){
                 $read .= $this->stream->getReturn();
                 break;
             }
-        } while ($read === '');
+        }while ($read === '');
         $this->caret += \strlen($read);
-        if (!$this->stream->valid()) {
+        if (!$this->stream->valid()){
             $this->size = $this->caret;
         }
         return $read;
@@ -132,19 +132,19 @@ 
 
     public function getContents(): string
     {
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator){
             throw new RuntimeException('Unable to read stream contents.');
         }
         $content = '';
-        do {
+        do{
             $content .= $this->read(PHP_INT_MAX);
-        } while ($this->stream->valid());
+        }while ($this->stream->valid());
         return $content;
     }
 
     public function getMetadata($key = null)
     {
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator){
             return $key ? null : [];
         }
 
@@ -153,7 +153,7 @@ 
             'eof' => $this->eof(),
         ];
 
-        if (null === $key) {
+        if (null === $key){
             return $meta;
         }
 

Braces +34 added lines, -16 removed lines

@@ -27,23 +27,28 @@ 
 
     public function __toString(): string
     {
-        try {
+        try
+        {
             return $this->getContents();
-        } catch (\Exception) {
+        }
+        catch (\Exception)
+        {
             return '';
         }
     }
 
     public function close(): void
     {
-        if ($this->stream instanceof \Generator) {
+        if ($this->stream instanceof \Generator)
+        {
             $this->detach();
         }
     }
 
     public function detach()
     {
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator)
+        {
             return null;
         }
         $this->stream = null;
@@ -81,7 +86,8 @@ 
 
     public function rewind(): void
     {
-        if ($this->stream instanceof \Generator) {
+        if ($this->stream instanceof \Generator)
+        {
             $this->stream->rewind();
         }
         $this->caret = 0;
@@ -105,26 +111,34 @@ 
 
     public function read($length): string
     {
-        if (!$this->readable) {
+        if (!$this->readable)
+        {
             throw new RuntimeException('Cannot read from non-readable stream.');
         }
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator)
+        {
             throw new RuntimeException('Cannot read from detached stream.');
         }
-        do {
-            if ($this->started) {
+        do
+        {
+            if ($this->started)
+            {
                 $read = (string)$this->stream->send(null);
-            } else {
+            }
+            else
+            {
                 $this->started = true;
                 $read = (string)$this->stream->current();
             }
-            if (!$this->stream->valid()) {
+            if (!$this->stream->valid())
+            {
                 $read .= $this->stream->getReturn();
                 break;
             }
         } while ($read === '');
         $this->caret += \strlen($read);
-        if (!$this->stream->valid()) {
+        if (!$this->stream->valid())
+        {
             $this->size = $this->caret;
         }
         return $read;
@@ -132,11 +146,13 @@ 
 
     public function getContents(): string
     {
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator)
+        {
             throw new RuntimeException('Unable to read stream contents.');
         }
         $content = '';
-        do {
+        do
+        {
             $content .= $this->read(PHP_INT_MAX);
         } while ($this->stream->valid());
         return $content;
@@ -144,7 +160,8 @@ 
 
     public function getMetadata($key = null)
     {
-        if (!$this->stream instanceof \Generator) {
+        if (!$this->stream instanceof \Generator)
+        {
             return $key ? null : [];
         }
 
@@ -153,7 +170,8 @@ 
             'eof' => $this->eof(),
         ];
 
-        if (null === $key) {
+        if (null === $key)
+        {
             return $meta;
         }
 

src/Http/src/Http.php

Spacing +11 added lines, -11 removed lines

@@ -25,21 +25,21 @@ 
 {
     private ?RequestHandlerInterface $handler = null;
     private readonly TracerFactoryInterface $tracerFactory;
-    private readonly Pipeline|LazyPipeline $pipeline;
+    private readonly Pipeline | LazyPipeline $pipeline;
 
     public function __construct(
         private readonly HttpConfig $config,
-        Pipeline|LazyPipeline $pipeline,
+        Pipeline | LazyPipeline $pipeline,
         private readonly ResponseFactoryInterface $responseFactory,
         private readonly ContainerInterface $container,
         ?TracerFactoryInterface $tracerFactory = null,
         private readonly ?EventDispatcherInterface $dispatcher = null,
-    ) {
-        if ($pipeline instanceof Pipeline) {
-            foreach ($this->config->getMiddleware() as $middleware) {
+    ){
+        if ($pipeline instanceof Pipeline){
+            foreach ($this->config->getMiddleware() as $middleware){
                 $pipeline->pushMiddleware($this->container->get($middleware));
             }
-        } else {
+        }else{
             $pipeline = $pipeline->withAddedMiddleware(
                 ...$this->config->getMiddleware()
             );
@@ -53,12 +53,12 @@ 
     /**
      * @internal
      */
-    public function getPipeline(): Pipeline|LazyPipeline
+    public function getPipeline(): Pipeline | LazyPipeline
     {
         return $this->pipeline;
     }
 
-    public function setHandler(callable|RequestHandlerInterface $handler): self
+    public function setHandler(callable | RequestHandlerInterface $handler): self
     {
         $this->handler = $handler instanceof RequestHandlerInterface
             ? $handler
@@ -77,7 +77,7 @@ 
 
             $this->dispatcher?->dispatch(new RequestReceived($request));
 
-            if (!$this->handler instanceof \Psr\Http\Server\RequestHandlerInterface) {
+            if (!$this->handler instanceof \Psr\Http\Server\RequestHandlerInterface){
                 throw new HttpException('Unable to run HttpCore, no handler is set.');
             }
 
@@ -107,7 +107,7 @@ 
             callback: $callback,
             attributes: [
                 'http.method' => $request->getMethod(),
-                'http.url' => (string) $request->getUri(),
+                'http.url' => (string)$request->getUri(),
                 'http.headers' => \array_map(
                     static fn (array $values): string => \implode(',', $values),
                     $request->getHeaders(),
@@ -117,7 +117,7 @@ 
             traceKind: TraceKind::SERVER,
         );
 
-        foreach ($tracer->getContext() as $key => $value) {
+        foreach ($tracer->getContext() as $key => $value){
             $response = $response->withHeader($key, $value);
         }
 

Braces +11 added lines, -5 removed lines

@@ -35,11 +35,15 @@ 
         ?TracerFactoryInterface $tracerFactory = null,
         private readonly ?EventDispatcherInterface $dispatcher = null,
     ) {
-        if ($pipeline instanceof Pipeline) {
-            foreach ($this->config->getMiddleware() as $middleware) {
+        if ($pipeline instanceof Pipeline)
+        {
+            foreach ($this->config->getMiddleware() as $middleware)
+            {
                 $pipeline->pushMiddleware($this->container->get($middleware));
             }
-        } else {
+        }
+        else
+        {
             $pipeline = $pipeline->withAddedMiddleware(
                 ...$this->config->getMiddleware()
             );
@@ -77,7 +81,8 @@ 
 
             $this->dispatcher?->dispatch(new RequestReceived($request));
 
-            if (!$this->handler instanceof \Psr\Http\Server\RequestHandlerInterface) {
+            if (!$this->handler instanceof \Psr\Http\Server\RequestHandlerInterface)
+            {
                 throw new HttpException('Unable to run HttpCore, no handler is set.');
             }
 
@@ -117,7 +122,8 @@ 
             traceKind: TraceKind::SERVER,
         );
 
-        foreach ($tracer->getContext() as $key => $value) {
+        foreach ($tracer->getContext() as $key => $value)
+        {
             $response = $response->withHeader($key, $value);
         }