PubPeerFoundation\PublicationDataExtractor\ApiDataFetcher

Complexity

Total Complexity

13

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getErrors()	0	3	1
A	fetchComplementaryData()	0	15	4
A	getData()	0	10	2
A	instantiateResource()	0	3	1
A	__construct()	0	5	1
A	getPromises()	0	12	2
A	getResourceAtIndex()	0	3	1
A	fetch()	0	13	1

<?php

namespace PubPeerFoundation\PublicationDataExtractor;

use Generator;
use Tightenco\Collect\Support\Arr;
use GuzzleHttp\Promise\EachPromise;
use Psr\Http\Message\ResponseInterface;
use GuzzleHttp\Exception\RequestException;
use GrahamCampbell\GuzzleFactory\GuzzleFactory;
use PubPeerFoundation\PublicationDataExtractor\Resources\Resource;
use PubPeerFoundation\PublicationDataExtractor\Identifiers\Identifier;

class ApiDataFetcher
{
    protected $identifier;

    protected $client;

    protected $apiData;

    protected $resources = [];

    protected $resourcesToFetch = [];

    protected $errors = [];

    public function __construct(Identifier $identifier)
    {
        $this->identifier = $identifier;
        $this->resourcesToFetch = $identifier->getRelatedResources();
        $this->client = GuzzleFactory::make(compact('headers'), 100);
    }

    /**
     * Fetch data from API calls promises.
     */
    public function fetch(): void
    {
        (new EachPromise($this->getPromises(), [
            'concurrency' => 5,
            'fulfilled' => function (ResponseInterface $response, $index) {
                $this->apiData[] = $this->getResourceAtIndex($index)
                    ->getDataFrom((string) $response->getBody());
            },
            'rejected' => function (RequestException $exception, $index) {
                $resourceName = get_class_name($this->getResourceAtIndex($index));
                $this->errors[$resourceName] = $exception->getCode();
            },
        ]))->promise()->wait();
    }

    /**
     * Get list of API calls promises.
     *
     * @return Generator
     */
    protected function getPromises(): Generator
    {
        foreach ($this->resourcesToFetch as $resourceClass) {
            $resource = $this->instantiateResource($resourceClass);

            $promise = $this->client->requestAsync(
                'GET',
                $resource->getApiUrl(),
                $resource->getRequestOptions()
            );

            yield $promise;
        }
    }

    public function getData(): array
    {
        if (0 === count(array_filter(Arr::pluck($this->apiData, 'publication')))) {
            return [];
        }

        $this->fetchComplementaryData();

        return array_values(
            array_filter($this->apiData)
        );
    }

    public function getErrors(): array
    {
        return $this->errors;
    }

    /**
     * Get resource instance from resources array.
     *
     * @param int $index
     *
     * @return resource
     */
    protected function getResourceAtIndex(int $index): Resource
    {
        return $this->resources[$index];
    }

    /**
     * Create and store an instance of the Resource class.
     *
     * @param string $resourceClass
     *
     * @return resource
     */
    protected function instantiateResource($resourceClass): Resource
    {
        return $this->resources[] = new $resourceClass($this->identifier);
    }

    protected function fetchComplementaryData()
    {
        $flatIdentifiers = Arr::flatten(Arr::pluck($this->apiData, 'identifiers'));

        foreach ($this->identifier->getComplementaryResources() as $key => $value) {
            if (false !== $valueKey = array_search($key, $flatIdentifiers)) {
                try {
                    $this->identifier = (new IdentifierResolver($flatIdentifiers[$valueKey - 1]))->handle();

                    $this->resourcesToFetch = [$value];
                    $this->resources = [];

                    $this->fetch();
                } catch (Exceptions\UnknownIdentifierException $e) {
                    var_dump('an error occured');

var_dump('an error occured') looks like debug code. Are you sure you do not want to remove it?

                }
            }
        }
    }
}