WBW\Library\Core\Network\CURL\Request\AbstractCurlRequest

Complexity

Total Complexity

53

Size/Duplication

Total Lines	407
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

27 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	addHeader()	0	4	1
A	addPostData()	0	4	1
A	addQueryData()	0	4	1
B	call()	0	55	8
A	clearHeaders()	0	3	1
A	clearPostData()	0	3	1
A	clearQueryData()	0	3	1
A	getConfiguration()	0	3	1
A	getHeaders()	0	3	1
A	getMethod()	0	3	1
A	getPostData()	0	3	1
A	getQueryData()	0	3	1
A	getResourcePath()	0	3	1
A	mergeHeaders()	0	9	2
A	mergeUrl()	0	12	3
B	parseHeader()	0	28	7
A	prepareResponse()	0	12	1
A	removeHeader()	0	6	2
A	removePostData()	0	6	2
A	removeQueryData()	0	6	2
A	setConfiguration()	0	4	1
A	setHeaders()	0	4	1
B	setMethod()	0	18	8
A	setPostData()	0	4	1
A	setQueryData()	0	4	1
A	setResourcePath()	0	4	1

<?php

/*
 * This file is part of the core-library package.
 *
 * (c) 2018 WEBEWEB
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace WBW\Library\Core\Network\CURL\Request;

use DateTime;
use InvalidArgumentException;
use WBW\Library\Core\Network\CURL\API\CurlRequestInterface;
use WBW\Library\Core\Network\CURL\API\CurlResponseInterface;
use WBW\Library\Core\Network\CURL\Configuration\CurlConfiguration;
use WBW\Library\Core\Network\CURL\Exception\CurlRequestCallException;
use WBW\Library\Core\Network\CURL\Factory\CurlFactory;
use WBW\Library\Core\Network\CURL\Helper\CurlHelper;
use WBW\Library\Core\Network\HTTP\HttpInterface;

/**
 * Abstract cURL request.
 *
 * @author webeweb <https://github.com/webeweb/>
 * @package WBW\Library\Core\Network\CURL\Request
 * @abstract
 */
abstract class AbstractCurlRequest implements CurlRequestInterface, HttpInterface {

    /**
     * Configuration.
     *
     * @var CurlConfiguration
     */
    private $configuration;

    /**
     * Headers.
     *
     * @var array
     */
    private $headers;

    /**
     * Method.
     *
     * @var string
     */
    private $method;

    /**
     * POST data.
     *
     * @var array
     */
    private $postData;

    /**
     * Query data.
     *
     * @var array
     */
    private $queryData;

    /**
     * Resource path.
     *
     * @var string
     */
    private $resourcePath;

    /**
     * Constructor.
     *
     * @param string $method The Method.
     * @param CurlConfiguration $configuration The configuration.
     * @param string|null $resourcePath The resource path.
     * @throws InvalidArgumentException Throws an invalid argument exception if the method is invalid.
     */
    protected function __construct(string $method, CurlConfiguration $configuration, ?string $resourcePath) {
        $this->setConfiguration($configuration);
        $this->setHeaders([]);
        $this->setMethod($method);
        $this->setQueryData([]);
        $this->setPostData([]);
        $this->setResourcePath($resourcePath);
    }

    /**
     * {@inheritDoc}
     */
    public function addHeader(string $name, string $value): CurlRequestInterface {
        $this->headers[$name] = $value;
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function addPostData(string $name, string $value): CurlRequestInterface {
        $this->postData[$name] = $value;
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function addQueryData(string $name, string $value): CurlRequestInterface {
        $this->queryData[$name] = $value;
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function call(): CurlResponseInterface {

        $requestHeader = $this->mergeHeaders();
        $requestBody   = http_build_query($this->getPostData());

        if (true === in_array("Content-Type: application/json", $requestHeader)) {
            $requestBody = json_encode($this->getPostData());
        }

        $requestUrl = $this->mergeUrl();
        if (0 < count($this->getQueryData())) {
            $requestUrl = implode("?", [$requestUrl, http_build_query($this->getQueryData())]);
        }

        $stream = CurlHelper::initStream($requestUrl, $this->getConfiguration());

        CurlHelper::setHeaders($stream, $requestHeader);
        CurlHelper::setPost($stream, $this->getMethod(), $requestBody);
        CurlHelper::setProxy($stream, $this->getConfiguration());
        CurlHelper::setReturnTransfer($stream);
        CurlHelper::setSsl($stream, $this->getConfiguration());
        CurlHelper::setTimeout($stream, $this->getConfiguration());
        CurlHelper::setUserAgent($stream, $this->getConfiguration());
        CurlHelper::setVerbose($stream, $this->getConfiguration(), $requestUrl, $requestBody);

        $curlExec    = curl_exec($stream);
        $curlGetInfo = curl_getinfo($stream, CURLINFO_HEADER_SIZE);

        $responseHeader = $this->parseheader(substr($curlExec, 0, $curlGetInfo));
        $responseBody   = substr($curlExec, $curlGetInfo);
        $responseInfo   = curl_getinfo($stream);

        if (true === $this->getConfiguration()->getDebug()) {
            $msg = (new DateTime())->format("c") . " [DEBUG] {$requestUrl}" . PHP_EOL . "HTTP response body ~BEGIN~" . PHP_EOL . print_r($responseBody, true) . PHP_EOL . "~END~" . PHP_EOL;
            error_log($msg, 3, $this->getConfiguration()->getDebugFile());
        }

        $response = $this->prepareResponse($requestBody, $requestHeader, $requestUrl, $responseBody, $responseHeader, $responseInfo);

        $curlHttpCode = $responseInfo["http_code"];
        if (200 <= $curlHttpCode && $curlHttpCode <= 299) {
            return $response;
        }

        $msg = curl_errno($stream);
        if (0 === $curlHttpCode) {
            if (false === empty(curl_error($stream))) {
                $msg = "Call to {$requestUrl} failed : " . curl_error($stream);
            } else {
                $msg = "Call to {$requestUrl} failed, but for an unknown reason. This could happen if you are disconnected from the network.";
            }
        }

        throw new CurlRequestCallException($msg, $curlHttpCode, $response);
    }

    /**
     * {@inheritDoc}
     */
    public function clearHeaders(): CurlRequestInterface {
        return $this->setHeaders([]);
    }

    /**
     * {@inheritDoc}
     */
    public function clearPostData(): CurlRequestInterface {
        return $this->setPostData([]);
    }

    /**
     * {@inheritDoc}
     */
    public function clearQueryData(): CurlRequestInterface {
        return $this->setQueryData([]);
    }

    /**
     * {@inheritDoc}
     */
    public function getConfiguration(): CurlConfiguration {
        return $this->configuration;
    }

    /**
     * {@inheritDoc}
     */
    public function getHeaders(): array {
        return $this->headers;
    }

    /**
     * {@inheritDoc}
     */
    public function getMethod(): string {
        return $this->method;
    }

    /**
     * {@inheritDoc}
     */
    public function getPostData(): array {
        return $this->postData;
    }

    /**
     * {@inheritDoc}
     */
    public function getQueryData(): array {
        return $this->queryData;
    }

    /**
     * {@inheritDoc}
     */
    public function getResourcePath(): string {
        return $this->resourcePath;
    }

    /**
     * Merge the headers.
     *
     * @return array Returns the merged headers.
     */
    private function mergeHeaders(): array {

        $headers = [];
        foreach (array_merge($this->getConfiguration()->getHeaders(), $this->getHeaders()) as $key => $value) {
            $headers[] = implode(": ", [$key, $value]);
        }

        return $headers;
    }

    /**
     * Merge the URL.
     *
     * @return string Returns the merged URL.
     */
    private function mergeUrl(): string {

        $mergedURL = [
            $this->getConfiguration()->getHost(),
        ];

        if (null !== $this->getResourcePath() && "" !== $this->getResourcePath()) {
            $mergedURL[] = $this->getResourcePath();
        }

        return implode("/", $mergedURL);
    }

    /**
     * Parse the raw header.
     *
     * @param string $rawHeader The raw header.
     * @return array Returns the headers.
     */
    private function parseHeader(string $rawHeader): array {

        $headers = [];
        $key     = "";

        foreach (explode("\n", $rawHeader) as $h) {
            $h = explode(":", $h, 2);
            if (true === isset($h[1])) {
                if (false === isset($headers[$h[0]])) {
                    $headers[$h[0]] = trim($h[1]);
                } else if (true === is_array($headers[$h[0]])) {
                    $headers[$h[0]] = array_merge($headers[$h[0]], [trim($h[1])]);
                } else {
                    $headers[$h[0]] = array_merge([$headers[$h[0]]], [trim($h[1])]);
                }
                $key = $h[0];
            } else {
                if ("\t" === substr($h[0], 0, 1)) {
                    $headers[$key] .= "\r\n\t" . trim($h[0]);
                } else if (!$key) {
                    $headers[0] = trim($h[0]);
                }
                trim($h[0]);
            }
        }

        return $headers;
    }

    /**
     * Prepare a response.
     *
     * @param string $requestBody The request body.
     * @param array $requestHeader The request header.
     * @param string $requestUri The request URI.
     * @param string $responseBody The response body.
     * @param array $responseHeader The response header.
     * @param array $responseInfo The response info.
     * @return CurlResponseInterface Returns the response.
     */
    private function prepareResponse(string $requestBody, array $requestHeader, string $requestUri, string $responseBody, array $responseHeader, array $responseInfo): CurlResponseInterface {

        $response = CurlFactory::newCURLResponse();
        $response->setRequestBody($requestBody);
        $response->setRequestHeader($requestHeader);
        $response->setRequestUrl($requestUri);
        $response->setResponseBody($responseBody);
        $response->setResponseHeader($responseHeader);
        $response->setResponseInfo($responseInfo);

        return $response;
    }

    /**
     * {@inheritDoc}
     */
    public function removeHeader(string $name): CurlRequestInterface {
        if (true === array_key_exists($name, $this->headers)) {
            unset($this->headers[$name]);
        }
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function removePostData(string $name): CurlRequestInterface {
        if (true === array_key_exists($name, $this->postData)) {
            unset($this->postData[$name]);
        }
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function removeQueryData(string $name): CurlRequestInterface {
        if (true === array_key_exists($name, $this->queryData)) {
            unset($this->queryData[$name]);
        }
        return $this;
    }

    /**
     * Set the configuration.
     *
     * @param CurlConfiguration $configuration The configuration.
     * @return CurlRequestInterface Returns this cURL request.
     */
    protected function setConfiguration(CurlConfiguration $configuration): CurlRequestInterface {
        $this->configuration = $configuration;
        return $this;
    }

    /**
     * Set the headers.
     *
     * @param array $headers The headers.
     * @return CurlRequestInterface Returns this cURL request.
     */
    protected function setHeaders(array $headers): CurlRequestInterface {
        $this->headers = $headers;
        return $this;
    }

    /**
     * Set the method.
     *
     * @param string $method The method.
     * @return CurlRequestInterface Returns this cURL request.
     * @throws InvalidArgumentException Throws an invalid argument exception if the method is invalid.
     */
    protected function setMethod(string $method): CurlRequestInterface {

        switch ($method) {
            case self::HTTP_METHOD_DELETE:
            case self::HTTP_METHOD_GET:
            case self::HTTP_METHOD_HEAD:
            case self::HTTP_METHOD_OPTIONS:
            case self::HTTP_METHOD_PATCH:
            case self::HTTP_METHOD_POST:
            case self::HTTP_METHOD_PUT:
                $this->method = $method;
                break;
            default:
                throw new InvalidArgumentException(sprintf('The HTTP method "%s" is invalid', $method));
        }

        return $this;
    }

    /**
     * Set the POST data.
     *
     * @param array $postData The POST data.
     * @return CurlRequestInterface Returns this cURL request.
     */
    protected function setPostData(array $postData): CurlRequestInterface {
        $this->postData = $postData;
        return $this;
    }

    /**
     * Set the query data.
     *
     * @param array $queryData The query data.
     * @return CurlRequestInterface Returns this cURL request.
     */
    protected function setQueryData(array $queryData): CurlRequestInterface {
        $this->queryData = $queryData;
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function setResourcePath(?string $resourcePath): CurlRequestInterface {
        $this->resourcePath = preg_replace("/^\//", "", trim($resourcePath));
        return $this;
    }
}