EchoBodyMiddleware::process() - Code Metrics - Inspection of "Rewind stream content and buffering write" - coisa/http - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Push — master ( a9ed36...6a08f6 )

by Felipe

created 2019-05-12 14:25 UTC

EchoBodyMiddleware::process() A

↳ Parent: EchoBodyMiddleware

Complexity

Conditions	3
Paths	4

Size

Total Lines	14
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes

Metric	Value
eloc	7
dl	0
loc	14
ccs	0
cts	0
cp	0
rs	10
c	0
b	0
f	0
cc	3
nc	4
nop	2
crap	12

<?php

/**
 * This file is part of coisa/http.
 *
 * (c) Felipe Sayão Lobato Abreu <[email protected]>
 *
 * This source file is subject to the license that is bundled
 * with this source code in the file LICENSE.
 */

declare(strict_types=1);

namespace CoiSA\Http\Middleware;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

/**
 * Class EchoBodyMiddleware
 *
 * @package CoiSA\Http\Middleware
 */
final class EchoBodyMiddleware implements MiddlewareInterface
{
    /**
     * @const string
     */
    const DEFAULT_BUFFER_SIZE = 1024 * 8;

    /**
     * @var int
     */
    private $bufferSize;

    /**
     * EchoBodyMiddleware constructor.
     *
     * @param int $bufferSize
     */
    public function __construct(int $bufferSize = self::DEFAULT_BUFFER_SIZE)
    {
        $this->bufferSize = $bufferSize;
    }

    /**
     * {@inheritdoc}
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $response = $handler->handle($request);
        $stream   = $response->getBody();

        if ($stream->isSeekable()) {
            $stream->rewind();
        }

        while (!$stream->eof()) {
            echo $stream->read($this->bufferSize);
        }

        return $response;
    }
}


1		<?php
2
3		/**
4		* This file is part of coisa/http.
5		*
6		* (c) Felipe Sayão Lobato Abreu <[email protected]>
7		*
8		* This source file is subject to the license that is bundled
9		* with this source code in the file LICENSE.
10		*/
11
12		declare(strict_types=1);
13
14		namespace CoiSA\Http\Middleware;
15
16		use Psr\Http\Message\ResponseInterface;
17		use Psr\Http\Message\ServerRequestInterface;
18		use Psr\Http\Server\MiddlewareInterface;
19		use Psr\Http\Server\RequestHandlerInterface;
20
21		/**
22		* Class EchoBodyMiddleware
23		*
24		* @package CoiSA\Http\Middleware
25		*/
26		final class EchoBodyMiddleware implements MiddlewareInterface
27		{
28		/**
29		* @const string
30		*/
31	2	const DEFAULT_BUFFER_SIZE = 1024 * 8;
32
33	2	/**
34	2	* @var int
35		*/
36	2	private $bufferSize;
37
38		/**
39		* EchoBodyMiddleware constructor.
40		*
41		* @param int $bufferSize
42		*/
43		public function __construct(int $bufferSize = self::DEFAULT_BUFFER_SIZE)
44		{
45		$this->bufferSize = $bufferSize;
46		}
47
48		/**
49		* {@inheritdoc}
50		*/
51		public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
52		{
53		$response = $handler->handle($request);
54		$stream = $response->getBody();
55
56		if ($stream->isSeekable()) {
57		$stream->rewind();
58		}
59
60		while (!$stream->eof()) {
61		echo $stream->read($this->bufferSize);
62		}
63
64		return $response;
65		}
66		}
67

coisa / http

Push — master ( a9ed36...6a08f6 )

EchoBodyMiddleware::process() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like