Bee4\Transport\Client

Complexity

Total Complexity

9

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	10

Test Coverage

Coverage

100%

Importance

Changes	7
Bugs	1	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	3
A	createRequest()	0	13	3
A	send()	0	21	3

<?php
/**
 * This file is part of the bee4/transport package.
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @copyright Bee4 2015
 * @author  Stephane HULARD <s.hulard@chstudio.fr>
 * @package Bee4\Transport
 */

namespace Bee4\Transport;

use Bee4\Events\DispatcherAwareTrait;
use Bee4\Transport\Events\ErrorEvent;
use Bee4\Transport\Events\MessageEvent;
use Bee4\Transport\Exception\CurlException;
use Bee4\Transport\Message\Request\AbstractRequest;
use Bee4\Transport\Message\Request\RequestFactory;
use Bee4\Transport\Message\ResponseFactory;
use Bee4\Transport\Handle\HandleFactory;

/**
 * Transport client, generate a request and return the linked response
 * @package Bee4\Transport
 */
class Client implements ClientInterface
{
    use DispatcherAwareTrait;

    /**
     * Base URL for calls
     * @var Url
     */
    protected $baseUrl;

    /**
     * The factory to build request messages
     * @var RequestFactory
     */
    protected $requestFactory;

    /**
     * HTTP Client which use cURL extension
     * @param string $baseUrl Base URL of the web service
     */
    public function __construct($baseUrl = '')
    {
        // @codeCoverageIgnoreStart
        if (!extension_loaded('curl')) {
            throw new \RuntimeException('The PHP cURL extension must be installed!');
        }
        // @codeCoverageIgnoreEnd

        if ($baseUrl != '') {
            $this->baseUrl = new Url($baseUrl);
        }

        $this->requestFactory = new RequestFactory();
    }

    /**
     * Create the request object
     * @param string $method
     * @param string $url
     * @param array $headers
     * @return AbstractRequest
     */
    public function createRequest($method, $url = '', array $headers = [])
    {
        if (!is_string($url)) {
            throw new \InvalidArgumentException('Url parameter must be a valid string!!');
        }

        $url = new Url((isset($this->baseUrl)?$this->baseUrl->toString():'').$url);

        $request = $this->requestFactory->build($method, $url, $headers);
        $request->setClient($this);

        return $request;
    }

    /**
     * Send the request
     * @param AbstractRequest $request The request to be send
     * @return Message\Response
     * @throws \Exception
     */
    public function send(AbstractRequest $request)
    {
        $handle = HandleFactory::build($request);
        $this->dispatch(MessageEvent::REQUEST, new MessageEvent($request));

        try {
            $result = $handle->execute();
        } catch (\Exception $error) {
            if ($error instanceof CurlException) {
                $response = ResponseFactory::build('', $handle, $request);
                $error->setResponse($response);
            }
            $this->dispatch(ErrorEvent::ERROR, new ErrorEvent($error));
            throw $error;
        }

        $response = ResponseFactory::build($result, $handle, $request);
        $this->dispatch(MessageEvent::RESPONSE, new MessageEvent($response));

        return $response;
    }
}