Client::combinedMiddlewares() - 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-13 08:25 UTC

Client::combinedMiddlewares() A

↳ Parent: Client

Complexity

Conditions	3
Paths	3

Size

Total Lines	14
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	14
rs	9.4285
c	0
b	0
f	0
cc	3
eloc	7
nc	3
nop	1

<?php declare(strict_types=1);

namespace ApiClients\Foundation\Transport;

use ApiClients\Foundation\Middleware\MiddlewareRunner;
use ApiClients\Foundation\Middleware\MiddlewareInterface;
use ApiClients\Foundation\Transport\CommandBus;
use Clue\React\Buzz\Browser;
use RingCentral\Psr7\Request as Psr7Request;
use RingCentral\Psr7\Uri;
use Interop\Container\ContainerInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use React\EventLoop\LoopInterface;
use React\Promise\PromiseInterface;
use function React\Promise\reject;
use function React\Promise\resolve;
use function WyriHaximus\React\futureFunctionPromise;

class Client
{
    const DEFAULT_OPTIONS = [
        Options::SCHEMA => 'https',
        Options::PATH => '/',
        Options::USER_AGENT => 'WyriHaximus/php-api-client',
        Options::HEADERS => [],
    ];

    /**
     * @var LoopInterface
     */
    protected $loop;

    /**
     * @var ContainerInterface
     */
    protected $container;

    /**
     * @var Browser
     */
    protected $browser;

    /**
     * @var array
     */
    protected $options = [];

    /**
     * @var MiddlewareInterface[]
     */
    protected $middleware = [];

    /**
     * @param LoopInterface $loop
     * @param ContainerInterface $container
     * @param Browser $buzz
     * @param array $options
     */
    public function __construct(
        LoopInterface $loop,
        ContainerInterface $container,
        Browser $buzz,
        array $options = []
    ) {
        $this->loop = $loop;
        $this->container = $container;
        $this->browser = $buzz;
        $this->options = $options + self::DEFAULT_OPTIONS;

        if (isset($this->options[Options::MIDDLEWARE])) {
            $this->middleware = $this->options[Options::MIDDLEWARE];
        }
    }

    protected function constructMiddlewares(array $options): MiddlewareRunner
    {
        $set = $this->middleware;

        if (isset($options[Options::MIDDLEWARE])) {
            $set = $this->combinedMiddlewares($options[Options::MIDDLEWARE]);
        }

        $args = [];
        $args[] = $options;
        foreach ($set as $middleware) {
            if (!is_subclass_of($middleware, MiddlewareInterface::class)) {

                continue;
            }

            $args[] = $this->container->get($middleware);
        }

        return new MiddlewareRunner(...$args);
    }

    protected function combinedMiddlewares(array $extraMiddlewares): array
    {
        $set = $this->middleware;

        foreach ($extraMiddlewares as $middleware) {
            if (in_array($middleware, $set)) {
                continue;
            }

            $set[] = $middleware;
        }

        return $set;
    }

    /**
     * @param RequestInterface $request
     * @param array $options
     * @return PromiseInterface
     */
    public function request(RequestInterface $request, array $options = []): PromiseInterface
    {
        $request = $this->applyApiSettingsToRequest($request);
        $options = $this->applyRequestOptions($options);
        $executioner = $this->constructMiddlewares($options);

        return $executioner->pre($request)->then(function ($request) use ($options) {
            return resolve($this->browser->send(
                $request
            ));
        }, function (ResponseInterface $response) {
            return resolve($response);
        })->then(function (ResponseInterface $response) use ($executioner) {
            return $executioner->post($response);
        });
    }

    protected function applyApiSettingsToRequest(RequestInterface $request): RequestInterface
    {
        $uri = $request->getUri();
        if (strpos((string)$uri, '://') === false) {
            $uri = Uri::resolve(
                new Uri(
                    $this->options[Options::SCHEMA] .
                    '://' .
                    $this->options[Options::HOST] .
                    $this->options[Options::PATH]
                ),
                $request->getUri()
            );
        }

        return new Psr7Request(
            $request->getMethod(),
            $uri,
            $this->options[Options::HEADERS] + $request->getHeaders(),
            $request->getBody(),
            $request->getProtocolVersion()
        );
    }

    public function applyRequestOptions(array $options): array
    {
        if (!isset($this->options[Options::DEFAULT_REQUEST_OPTIONS])) {
            return $options;
        }

        return array_merge_recursive(
            $this->options[Options::DEFAULT_REQUEST_OPTIONS],
            $options
        );
    }
}


1			<?php declare(strict_types=1);
2
3			namespace ApiClients\Foundation\Transport;
4
5			use ApiClients\Foundation\Middleware\MiddlewareRunner;
6			use ApiClients\Foundation\Middleware\MiddlewareInterface;
7			use ApiClients\Foundation\Transport\CommandBus;
8			use Clue\React\Buzz\Browser;
9			use RingCentral\Psr7\Request as Psr7Request;
10			use RingCentral\Psr7\Uri;
11			use Interop\Container\ContainerInterface;
12			use Psr\Http\Message\RequestInterface;
13			use Psr\Http\Message\ResponseInterface;
14			use React\EventLoop\LoopInterface;
15			use React\Promise\PromiseInterface;
16			use function React\Promise\reject;
17			use function React\Promise\resolve;
18			use function WyriHaximus\React\futureFunctionPromise;
19
20			class Client
21			{
22			const DEFAULT_OPTIONS = [
23			Options::SCHEMA => 'https',
24			Options::PATH => '/',
25			Options::USER_AGENT => 'WyriHaximus/php-api-client',
26			Options::HEADERS => [],
27			];
28
29			/**
30			* @var LoopInterface
31			*/
32			protected $loop;
33
34			/**
35			* @var ContainerInterface
36			*/
37			protected $container;
38
39			/**
40			* @var Browser
41			*/
42			protected $browser;
43
44			/**
45			* @var array
46			*/
47			protected $options = [];
48
49			/**
50			* @var MiddlewareInterface[]
51			*/
52			protected $middleware = [];
53
54			/**
55			* @param LoopInterface $loop
56			* @param ContainerInterface $container
57			* @param Browser $buzz
58			* @param array $options
59			*/
60			public function __construct(
61			LoopInterface $loop,
62			ContainerInterface $container,
63			Browser $buzz,
64			array $options = []
65			) {
66			$this->loop = $loop;
67			$this->container = $container;
68			$this->browser = $buzz;
69			$this->options = $options + self::DEFAULT_OPTIONS;
70
71			if (isset($this->options[Options::MIDDLEWARE])) {
72			$this->middleware = $this->options[Options::MIDDLEWARE];
73			}
74			}
75
76			protected function constructMiddlewares(array $options): MiddlewareRunner
77			{
78			$set = $this->middleware;
79
80			if (isset($options[Options::MIDDLEWARE])) {
81			$set = $this->combinedMiddlewares($options[Options::MIDDLEWARE]);
82			}
83
84			$args = [];
85			$args[] = $options;
86			foreach ($set as $middleware) {
87			if (!is_subclass_of($middleware, MiddlewareInterface::class)) {
			0 ignored issues – show Bug introduced 2016-10-26 19:12 UTC by Report Bug Copy Issue Report Due to PHP Bug #53727, `is_subclass_of` might return inconsistent results on some PHP versions if `\ApiClients\Foundation\M...dlewareInterface::class` can be an interface. If so, you could instead use `ReflectionClass::implementsInterface`. Loading history...
88			continue;
89			}
90
91			$args[] = $this->container->get($middleware);
92			}
93
94			return new MiddlewareRunner(...$args);
95			}
96
97			protected function combinedMiddlewares(array $extraMiddlewares): array
98			{
99			$set = $this->middleware;
100
101			foreach ($extraMiddlewares as $middleware) {
102			if (in_array($middleware, $set)) {
103			continue;
104			}
105
106			$set[] = $middleware;
107			}
108
109			return $set;
110			}
111
112			/**
113			* @param RequestInterface $request
114			* @param array $options
115			* @return PromiseInterface
116			*/
117			public function request(RequestInterface $request, array $options = []): PromiseInterface
118			{
119			$request = $this->applyApiSettingsToRequest($request);
120			$options = $this->applyRequestOptions($options);
121			$executioner = $this->constructMiddlewares($options);
122
123			return $executioner->pre($request)->then(function ($request) use ($options) {
124			return resolve($this->browser->send(
125			$request
126			));
127			}, function (ResponseInterface $response) {
128			return resolve($response);
129			})->then(function (ResponseInterface $response) use ($executioner) {
130			return $executioner->post($response);
131			});
132			}
133
134			protected function applyApiSettingsToRequest(RequestInterface $request): RequestInterface
135			{
136			$uri = $request->getUri();
137			if (strpos((string)$uri, '://') === false) {
138			$uri = Uri::resolve(
139			new Uri(
140			$this->options[Options::SCHEMA] .
141			'://' .
142			$this->options[Options::HOST] .
143			$this->options[Options::PATH]
144			),
145			$request->getUri()
146			);
147			}
148
149			return new Psr7Request(
150			$request->getMethod(),
151			$uri,
152			$this->options[Options::HEADERS] + $request->getHeaders(),
153			$request->getBody(),
154			$request->getProtocolVersion()
155			);
156			}
157
158			public function applyRequestOptions(array $options): array
159			{
160			if (!isset($this->options[Options::DEFAULT_REQUEST_OPTIONS])) {
161			return $options;
162			}
163
164			return array_merge_recursive(
165			$this->options[Options::DEFAULT_REQUEST_OPTIONS],
166			$options
167			);
168			}
169			}
170

php-api-clients / transport

GitHub Access Token became invalid

Pull Request — master (#2)

Client::combinedMiddlewares() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like