WyriHaximus\React\Guzzle\HttpClient\RequestFactory

Complexity

Total Complexity

8

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

7.41%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	9	1
A	convertOptions()	0	4	1
A	extractConnector()	0	7	1
A	createSender()	0	11	2
A	extractResolver()	0	11	3

<?php

/**
 * This file is part of ReactGuzzleRing.
 *
 ** (c) 2014 Cees-Jan Kiewiet
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace WyriHaximus\React\Guzzle\HttpClient;

use Clue\React\Buzz\Browser;
use Clue\React\Buzz\Io\Sender;
use Clue\React\Socks\Client as SocksClient;
use Psr\Http\Message\RequestInterface;
use React\EventLoop\LoopInterface;
use React\HttpClient\Client as HttpClient;
use React\SocketClient\Connector;
use React\SocketClient\ConnectorInterface;
use React\SocketClient\DnsConnector;
use ReflectionObject;

/**
 * Class RequestFactory
 *
 * @package WyriHaximus\React\Guzzle\HttpClient
 */
class RequestFactory
{
    /**
     *
     * @param RequestInterface $request
     * @param array $options
     * @param HttpClient $httpClient
     * @param LoopInterface $loop
     * @return \React\Promise\Promise
     */
    public function create(RequestInterface $request, array $options, HttpClient $httpClient, LoopInterface $loop)
    {
        return \WyriHaximus\React\futurePromise($loop)->then(function () use ($request, $options, $httpClient, $loop) {
            $sender = $this->createSender($options, $httpClient, $loop);
            return (new Browser($loop, $sender))
                ->withOptions($this->convertOptions($options))
                ->send($request);
        });
    }

    protected function createSender(array $options, HttpClient $httpClient, LoopInterface $loop)
    {
        $connector = $this->extractConnector($httpClient);

        if (isset($options['proxy'])) {
            $resolver = $this->extractResolver($connector);
            $connector = (new SocksClient($options['proxy'], $loop, $connector, $resolver))->createConnector();
        }

        return Sender::createFromLoopConnectors($loop, $connector);
    }

    protected function convertOptions(array $options)
    {
        return $options;
    }

    protected function extractConnector(HttpClient $httpClient)
    {
        $reflection = new ReflectionObject($httpClient);
        $property = $reflection->getProperty('connector');
        $property->setAccessible(true);
        return $property->getValue($httpClient);
    }

    protected function extractResolver(ConnectorInterface $connector)
    {
        if ($connector instanceof Connector || $connector instanceof DnsConnector) {
            $reflection = new ReflectionObject($connector);
            $property = $reflection->getProperty('resolver');
            $property->setAccessible(true);
            return $property->getValue($connector);
        }

        return null;
    }
}