JsonDecodeMiddleware::post() - Code Metrics - Inspection of "PSR-7 Middleware" - php-api-clients/transport - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#2)

by Cees-Jan

created 2016-11-12 21:04 UTC

JsonDecodeMiddleware::post() A

↳ Parent: JsonDecodeMiddleware

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	11
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	6
nc	2
nop	2

<?php declare(strict_types=1);

namespace ApiClients\Foundation\Transport\Middleware;

use ApiClients\Foundation\Middleware\MiddlewareInterface;
use ApiClients\Foundation\Middleware\PreTrait;
use ApiClients\Foundation\Transport\JsonStream;
use ApiClients\Foundation\Transport\Service\JsonDecodeService as JsonDecodeService;
use Psr\Http\Message\ResponseInterface;
use React\Promise\CancellablePromiseInterface;
use function React\Promise\resolve;
use React\Stream\ReadableStreamInterface;

class JsonDecodeMiddleware implements MiddlewareInterface
{
    use PreTrait;

    /**
     * @var JsonDecodeService
     */
    private $jsonDecodeService;

    /**
     * JsonDecode constructor.
     * @param JsonDecodeService $jsonDecodeService
     */
    public function __construct(JsonDecodeService $jsonDecodeService)
    {
        $this->jsonDecodeService = $jsonDecodeService;
    }

    /**
     * @return int
     */
    public function priority(): int
    {
        return 1000;
    }

    /**
     * @param ResponseInterface $response
     * @param array $options
     * @return CancellablePromiseInterface
     */
    public function post(ResponseInterface $response, array $options = []): CancellablePromiseInterface
    {
        if ($response->getBody() instanceof ReadableStreamInterface) {
            return resolve($response);
        }

        return $this->jsonDecodeService->handle((string)$response->getBody())->then(function ($json) use ($response) {
            $body = new JsonStream($json);
            return resolve($response->withBody($body));
        });
    }
}


1			<?php declare(strict_types=1);
2
3			namespace ApiClients\Foundation\Transport\Middleware;
4
5			use ApiClients\Foundation\Middleware\MiddlewareInterface;
6			use ApiClients\Foundation\Middleware\PreTrait;
7			use ApiClients\Foundation\Transport\JsonStream;
8			use ApiClients\Foundation\Transport\Service\JsonDecodeService as JsonDecodeService;
9			use Psr\Http\Message\ResponseInterface;
10			use React\Promise\CancellablePromiseInterface;
11			use function React\Promise\resolve;
12			use React\Stream\ReadableStreamInterface;
13
14			class JsonDecodeMiddleware implements MiddlewareInterface
15			{
16			use PreTrait;
17
18			/**
19			* @var JsonDecodeService
20			*/
21			private $jsonDecodeService;
22
23			/**
24			* JsonDecode constructor.
25			* @param JsonDecodeService $jsonDecodeService
26			*/
27			public function __construct(JsonDecodeService $jsonDecodeService)
28			{
29			$this->jsonDecodeService = $jsonDecodeService;
30			}
31
32			/**
33			* @return int
34			*/
35			public function priority(): int
36			{
37			return 1000;
38			}
39
40			/**
41			* @param ResponseInterface $response
42			* @param array $options
43			* @return CancellablePromiseInterface
44			*/
45			public function post(ResponseInterface $response, array $options = []): CancellablePromiseInterface
46			{
47			if ($response->getBody() instanceof ReadableStreamInterface) {
48			return resolve($response);
49			}
50
51			return $this->jsonDecodeService->handle((string)$response->getBody())->then(function ($json) use ($response) {
52			$body = new JsonStream($json);
53			return resolve($response->withBody($body));
54			});
55			}
56			}
57

php-api-clients / transport

GitHub Access Token became invalid

Pull Request — master (#2)

JsonDecodeMiddleware::post() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like