RemotelyLiving\PHPDNS\Resolvers\CloudFlare

Complexity

Total Complexity

12

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	doQuery()	0	8	3
A	doApiQuery()	0	11	1
A	parseResult()	0	11	3
A	doAnyApiQuery()	0	19	1
A	generateEachTypeQuery()	0	11	3
A	__construct()	0	7	1

<?php

namespace RemotelyLiving\PHPDNS\Resolvers;

use Generator;
use GuzzleHttp\Client;
use GuzzleHttp\ClientInterface;
use GuzzleHttp\Promise\EachPromise;
use Psr\Http\Message\ResponseInterface;
use RemotelyLiving\PHPDNS\Entities\DNSRecordCollection;
use RemotelyLiving\PHPDNS\Entities\DNSRecordType;
use RemotelyLiving\PHPDNS\Entities\Hostname;
use RemotelyLiving\PHPDNS\Mappers\CloudFlare as CloudFlareMapper;
use RemotelyLiving\PHPDNS\Resolvers\Exceptions\QueryFailure;
use Throwable;

use function array_merge;
use function http_build_query;
use function json_decode;

final class CloudFlare extends ResolverAbstract
{
    protected const BASE_URI = 'https://cloudflare-dns.com';
    protected const DEFAULT_TIMEOUT = 5.0;
    public const DEFAULT_OPTIONS = [
        'base_uri' => self::BASE_URI,
        'connect_timeout' => self::DEFAULT_TIMEOUT,
        'strict' => true,
        'allow_redirects' => false,
        'protocols' => ['https'],
        'headers' => [
            'Accept' => 'application/dns-json',
        ],
    ];

    private ClientInterface $http;

    private CloudFlareMapper $mapper;

    /**
     * @param array<string, mixed> $options
     */
    public function __construct(
        ClientInterface $http = null,
        CloudFlareMapper $mapper = null,
        private array $options = self::DEFAULT_OPTIONS
    ) {
        $this->http = $http ?? new Client();
        $this->mapper = $mapper ?? new CloudFlareMapper();
    }

    protected function doQuery(Hostname $hostname, DNSRecordType $recordType): DNSRecordCollection
    {
        try {
            return ($recordType->isA(DNSRecordType::TYPE_ANY))
                ? $this->doAnyApiQuery($hostname)
                : $this->doApiQuery($hostname, $recordType);
        } catch (Throwable $e) {
            throw new QueryFailure("Unable to query CloudFlare API", 0, $e);
        }
    }

    /**
     * Cloudflare does not support ANY queries, so we must ask for all record types individually
     */
    private function doAnyApiQuery(Hostname $hostname): DNSRecordCollection
    {
        $results = [];
        $eachPromise = new EachPromise($this->generateEachTypeQuery($hostname), [
            'concurrency' => 4,
            'fulfilled' => function (ResponseInterface $response) use (&$results) {
                $results = array_merge(
                    $results,
                    $this->parseResult((array) json_decode((string)$response->getBody(), true))
                );
            },
            'rejected' => function (Throwable $e): void {
                throw $e;
            },
        ]);

        $eachPromise->promise()->wait(true);

        return $this->mapResults($this->mapper, $results);
    }

    private function generateEachTypeQuery(Hostname $hostname): Generator
    {
        foreach (DNSRecordType::VALID_TYPES as $type) {
            if ($type === DNSRecordType::TYPE_ANY) {
                continue 1;
            }

            yield $this->http->requestAsync(
                'GET',
                '/dns-query?' . http_build_query(['name' => (string)$hostname, 'type' => $type]),
                $this->options
            );
        }
    }

    private function doApiQuery(Hostname $hostname, DNSRecordType $type): DNSRecordCollection
    {
        $url = '/dns-query?' . http_build_query(['name' => (string)$hostname, 'type' => (string)$type]);
        $decoded = (array)json_decode(
            (string)$this->http->requestAsync('GET', $url, $this->options)->wait(true)->getBody(),
            true,
            512,
            JSON_THROW_ON_ERROR
        );

        return $this->mapResults($this->mapper, $this->parseResult($decoded));
    }

    private function parseResult(array $result): array
    {
        if (isset($result['Answer'])) {
            return $result['Answer'];
        }

        if (isset($result['Authority'])) {
            return $result['Authority'];
        }

        return [];
    }
}