spiral / framework

src/Http/tests/SapiEmitter/SapiEmitterTest.php

Indentation +6 added lines, -6 removed lines

@@ -133,12 +133,12 @@
     {
         $body = 'Example body';
         $response = $this->createResponse(200, [], $body)
-                         ->withHeader('X-Test', '1')
-                         ->withAddedHeader('X-Test', '2')
-                         ->withAddedHeader('X-Test', '3; 3.5')
-                         ->withHeader('Cookie-Set', '1')
-                         ->withAddedHeader('cookie-Set', '2')
-                         ->withAddedHeader('Cookie-set', '3');
+                            ->withHeader('X-Test', '1')
+                            ->withAddedHeader('X-Test', '2')
+                            ->withAddedHeader('X-Test', '3; 3.5')
+                            ->withHeader('Cookie-Set', '1')
+                            ->withAddedHeader('cookie-Set', '2')
+                            ->withAddedHeader('Cookie-set', '3');
 
         (new SapiEmitter(new HttpConfig(['chunkSize' => null])))->emit($response);
         $this->assertEquals(200, $this->getResponseCode());

Spacing +8 added lines, -8 removed lines

@@ -66,7 +66,7 @@ 
         $this->assertEquals(200, $this->getResponseCode());
         $this->assertCount(2, $this->getHeaders());
         $this->assertContains('X-Test: 1', $this->getHeaders());
-        $this->assertContains('Content-Length: ' . $length, $this->getHeaders());
+        $this->assertContains('Content-Length: '.$length, $this->getHeaders());
         $this->expectOutputString('Example body');
     }
 
@@ -119,12 +119,12 @@ 
         $this->expectException(EmitterException::class);
         $this->expectExceptionMessage('Unable to emit response, found non closed buffered output.');
 
-        try {
+        try{
             echo 'some data';
             $this->createEmitter()->emit($response);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw $e;
-        } finally {
+        }finally{
             \ob_end_clean();
         }
     }
@@ -174,7 +174,7 @@ 
     private function createEmitter(?int $bufferSize = null): SapiEmitter
     {
         $emitter = new SapiEmitter(new HttpConfig(['chunkSize' => null]));
-        if ($bufferSize !== null) {
+        if ($bufferSize !== null){
             $emitter->bufferSize = $bufferSize;
         }
         return $emitter;
@@ -189,12 +189,12 @@ 
         $response = (new Response())
             ->withStatus($status)
             ->withProtocolVersion($version);
-        foreach ($headers as $header => $value) {
+        foreach ($headers as $header => $value){
             $response = $response->withHeader($header, $value);
         }
-        if ($body instanceof StreamInterface) {
+        if ($body instanceof StreamInterface){
             $response = $response->withBody($body);
-        } elseif (is_string($body)) {
+        } elseif (is_string($body)){
             $response->getBody()->write($body);
         }
         return $response;

Braces +17 added lines, -7 removed lines

@@ -119,12 +119,17 @@ 
         $this->expectException(EmitterException::class);
         $this->expectExceptionMessage('Unable to emit response, found non closed buffered output.');
 
-        try {
+        try
+        {
             echo 'some data';
             $this->createEmitter()->emit($response);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw $e;
-        } finally {
+        }
+        finally
+        {
             \ob_end_clean();
         }
     }
@@ -174,7 +179,8 @@ 
     private function createEmitter(?int $bufferSize = null): SapiEmitter
     {
         $emitter = new SapiEmitter(new HttpConfig(['chunkSize' => null]));
-        if ($bufferSize !== null) {
+        if ($bufferSize !== null)
+        {
             $emitter->bufferSize = $bufferSize;
         }
         return $emitter;
@@ -189,12 +195,16 @@ 
         $response = (new Response())
             ->withStatus($status)
             ->withProtocolVersion($version);
-        foreach ($headers as $header => $value) {
+        foreach ($headers as $header => $value)
+        {
             $response = $response->withHeader($header, $value);
         }
-        if ($body instanceof StreamInterface) {
+        if ($body instanceof StreamInterface)
+        {
             $response = $response->withBody($body);
-        } elseif (is_string($body)) {
+        }
+        elseif (is_string($body))
+        {
             $response->getBody()->write($body);
         }
         return $response;

src/Http/src/Config/HttpConfig.php

Spacing +1 added lines, -1 removed lines

@@ -58,6 +58,6 @@
      */
     public function getChunkSize(): ?int
     {
-        return !\is_null($this->config['chunkSize']) ? (int) $this->config['chunkSize'] : null;
+        return !\is_null($this->config['chunkSize']) ? (int)$this->config['chunkSize'] : null;
     }
 }

src/Http/src/Emitter/SapiEmitter.php

Spacing +9 added lines, -9 removed lines

@@ -32,7 +32,7 @@ 
 
     public function __construct(HttpConfig $config)
     {
-        if (($chunkSize = $config->getChunkSize()) !== null) {
+        if (($chunkSize = $config->getChunkSize()) !== null){
             $this->bufferSize = $chunkSize;
         }
     }
@@ -62,13 +62,13 @@ 
     private function emitBody(ResponseInterface $response): void
     {
         $body = $response->getBody();
-        if ($body->isSeekable()) {
+        if ($body->isSeekable()){
             $body->rewind();
         }
-        if (!$body->isReadable()) {
+        if (!$body->isReadable()){
             return;
         }
-        while (!$body->eof()) {
+        while (!$body->eof()){
             echo $body->read($this->bufferSize);
             flush();
         }
@@ -85,11 +85,11 @@ 
      */
     private function assertNoPreviousOutput(): void
     {
-        if (headers_sent()) {
+        if (headers_sent()){
             throw new EmitterException('Unable to emit response, headers already send.');
         }
 
-        if (ob_get_level() > 0 && ob_get_length() > 0) {
+        if (ob_get_level() > 0 && ob_get_length() > 0){
             throw new EmitterException('Unable to emit response, found non closed buffered output.');
         }
     }
@@ -115,7 +115,7 @@ 
             'HTTP/%s %d%s',
             $response->getProtocolVersion(),
             $statusCode,
-            ($reasonPhrase ? ' ' . $reasonPhrase : '')
+            ($reasonPhrase ? ' '.$reasonPhrase : '')
         ), true, $statusCode);
     }
 
@@ -133,10 +133,10 @@ 
     {
         $statusCode = $response->getStatusCode();
 
-        foreach ($response->getHeaders() as $header => $values) {
+        foreach ($response->getHeaders() as $header => $values){
             $name = $this->filterHeader($header);
             $first = $name === 'Set-Cookie' ? false : true;
-            foreach ($values as $value) {
+            foreach ($values as $value){
                 header(sprintf(
                     '%s: %s',
                     $name,

Braces +16 added lines, -8 removed lines

@@ -32,7 +32,8 @@ 
 
     public function __construct(HttpConfig $config)
     {
-        if (($chunkSize = $config->getChunkSize()) !== null) {
+        if (($chunkSize = $config->getChunkSize()) !== null)
+        {
             $this->bufferSize = $chunkSize;
         }
     }
@@ -62,13 +63,16 @@ 
     private function emitBody(ResponseInterface $response): void
     {
         $body = $response->getBody();
-        if ($body->isSeekable()) {
+        if ($body->isSeekable())
+        {
             $body->rewind();
         }
-        if (!$body->isReadable()) {
+        if (!$body->isReadable())
+        {
             return;
         }
-        while (!$body->eof()) {
+        while (!$body->eof())
+        {
             echo $body->read($this->bufferSize);
             flush();
         }
@@ -85,11 +89,13 @@ 
      */
     private function assertNoPreviousOutput(): void
     {
-        if (headers_sent()) {
+        if (headers_sent())
+        {
             throw new EmitterException('Unable to emit response, headers already send.');
         }
 
-        if (ob_get_level() > 0 && ob_get_length() > 0) {
+        if (ob_get_level() > 0 && ob_get_length() > 0)
+        {
             throw new EmitterException('Unable to emit response, found non closed buffered output.');
         }
     }
@@ -133,10 +139,12 @@ 
     {
         $statusCode = $response->getStatusCode();
 
-        foreach ($response->getHeaders() as $header => $values) {
+        foreach ($response->getHeaders() as $header => $values)
+        {
             $name = $this->filterHeader($header);
             $first = $name === 'Set-Cookie' ? false : true;
-            foreach ($values as $value) {
+            foreach ($values as $value)
+            {
                 header(sprintf(
                     '%s: %s',
                     $name,