Rogierw\RwAcme\Http\Client

Complexity

Total Complexity

18

Size/Duplication

Total Lines	132
Duplicated Lines	0 %

Importance

Changes	5
Bugs	0	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	head()	0	3	1
A	get()	0	3	1
A	post()	0	5	1
A	__construct()	0	2	1
B	makeCurlRequest()	0	58	8
A	getCurlHandle()	0	24	2
A	parseRawHeaders()	0	16	3
A	attachRequestPayload()	0	5	1

<?php

namespace Rogierw\RwAcme\Http;

use CurlHandle;
use Rogierw\RwAcme\Interfaces\HttpClientInterface;

class Client implements HttpClientInterface
{
    public function __construct(private readonly int $timeout = 10)
    {
    }

    public function head(string $url): Response
    {
        return $this->makeCurlRequest('head', $url);
    }

    public function get(string $url, array $headers = [], array $arguments = [], int $maxRedirects = 0): Response
    {
        return $this->makeCurlRequest('get', $url, $headers, $arguments, $maxRedirects);
    }

    public function post(string $url, array $payload = [], array $headers = [], int $maxRedirects = 0): Response
    {
        $headers = array_merge(['Content-Type: application/jose+json'], $headers);

        return $this->makeCurlRequest('post', $url, $headers, $payload, $maxRedirects);
    }

    private function makeCurlRequest(
        string $httpVerb,
        string $fullUrl,
        array $headers = [],
        array $payload = [],
        int $maxRedirects = 0,
        int $retries = 3
    ): Response {
        $allHeaders = array_merge([
            'Content-Type: ' . ($httpVerb === 'post') ? 'application/jose+json' : 'application/json',
        ], $headers);

        $curlHandle = $this->getCurlHandle($fullUrl, $allHeaders, $maxRedirects);

        switch ($httpVerb) {
            case 'head':
                curl_setopt($curlHandle, CURLOPT_CUSTOMREQUEST, 'HEAD');
                curl_setopt($curlHandle, CURLOPT_NOBODY, true);
                break;

            case 'get':
                curl_setopt($curlHandle, CURLOPT_URL, $fullUrl . '?' . http_build_query($payload));
                break;

            case 'post':
                curl_setopt($curlHandle, CURLOPT_POST, true);
                $this->attachRequestPayload($curlHandle, $payload);
                break;
        }

        $rawResponse = curl_exec($curlHandle);
        $headerSize = curl_getinfo($curlHandle, CURLINFO_HEADER_SIZE);
        $allHeaders = curl_getinfo($curlHandle);

        $rawHeaders = mb_substr($rawResponse, 0, $headerSize);

It seems like $rawResponse can also be of type true; however, parameter $string of mb_substr() does only seem to accept string, maybe add an additional type check?

        $rawBody = mb_substr($rawResponse, $headerSize);
        $body = $rawBody;

        $allHeaders = array_merge($allHeaders, $this->parseRawHeaders($rawHeaders));

        if (json_validate($rawBody)) {
            $body = json_decode($rawBody, true, 512, JSON_THROW_ON_ERROR);
        }

        $httpCode = $allHeaders['http_code'] ?? null;

        // Catch HTTP status code 0 when Let's Encrypt API is having problems.
        if ($httpCode === 0) {
            // Retry.
            if ($retries > 0) {
                return $this->makeCurlRequest($httpVerb, $fullUrl, $headers, $payload, $maxRedirects, --$retries);
            }

            // Return 504 Gateway Timeout.
            $httpCode = 504;
        }

        return new Response($allHeaders, $allHeaders['url'] ?? '', $httpCode, $body);
    }

    private function attachRequestPayload(CurlHandle $curlHandle, array $data): void
    {
        $encoded = json_encode($data, JSON_THROW_ON_ERROR);

        curl_setopt($curlHandle, CURLOPT_POSTFIELDS, $encoded);
    }

    private function getCurlHandle(string $fullUrl, array $headers = [], int $maxRedirects = 0): CurlHandle
    {
        $curlHandle = curl_init();

        curl_setopt($curlHandle, CURLOPT_URL, $fullUrl);

        curl_setopt($curlHandle, CURLOPT_HTTPHEADER, array_merge([
            'Accept: application/json',
        ], $headers));

        curl_setopt($curlHandle, CURLOPT_USERAGENT, 'rogierw/rw-acme-client');
        curl_setopt($curlHandle, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curlHandle, CURLOPT_TIMEOUT, $this->timeout);
        curl_setopt($curlHandle, CURLOPT_SSL_VERIFYPEER, true);
        curl_setopt($curlHandle, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
        curl_setopt($curlHandle, CURLOPT_ENCODING, '');
        curl_setopt($curlHandle, CURLOPT_HEADER, true);

        if ($maxRedirects > 0) {
            curl_setopt($curlHandle, CURLOPT_FOLLOWLOCATION, true);
            curl_setopt($curlHandle, CURLOPT_MAXREDIRS, $maxRedirects);
        }

        return $curlHandle;
    }

    private function parseRawHeaders(string $rawHeaders): array
    {
        $headers = explode("\n", $rawHeaders);
        $headersArr = [];

        foreach ($headers as $header) {
            if (!str_contains($header, ':')) {
                continue;
            }

            [$name, $value] = explode(':', $header, 2);

            $headersArr[str_replace('_', '-', strtolower($name))] = trim($value);
        }

        return $headersArr;
    }
}