cerbero90 / lazy-json-pages

src/Sources/AnySource.php

<?php

declare(strict_types=1);

namespace Cerbero\LazyJsonPages\Sources;

use Cerbero\LazyJsonPages\Exceptions\UnsupportedSourceException;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * The aggregator of sources.
 */
class AnySource extends Source
{
    /**
     * @var class-string<Source>[]

The doc comment class-string<Source>[] at position 0 could not be parsed: Unknown type name 'class-string' at position 0 in class-string<Source>[].

     */
    protected array $supportedSources = [
        CustomSource::class,
        Endpoint::class,
        LaravelClientRequest::class,
        LaravelClientResponse::class,
        Psr7Request::class,
        SymfonyRequest::class,
    ];

    /**
     * The matching source.
     */
    protected Source $matchingSource;

    /**
     * The cached HTTP response.
     */
    protected ?ResponseInterface $response;

    /**
     * Retrieve the HTTP request.
     */
    public function request(): RequestInterface
    {
        return $this->matchingSource()->request();
    }

    /**
     * Retrieve the matching source.
     *
     * @throws UnsupportedSourceException
     */
    protected function matchingSource(): Source
    {
        if (isset($this->matchingSource)) {
            return $this->matchingSource;
        }

        foreach ($this->supportedSources as $class) {
            $source = new $class($this->source);

            if ($source->matches()) {
                return $this->matchingSource = $source->setClient($this->client);
            }
        }

        throw new UnsupportedSourceException($this->source);
    }

    /**
     * Retrieve the HTTP response.
     *
     * @return ResponseInterface
     */
    public function response(): ResponseInterface
    {
        return $this->response ??= $this->matchingSource()->response();
    }

    /**
     * Retrieve the HTTP response and forget it to save memory.
     */
    public function pullResponse(): ResponseInterface
    {
        $response = $this->response();

        $this->response = null;

        return $response;
    }
}