whm\Smoke\Extensions\SmokeResponseRetriever\Retriever\Koalamon\Retriever

Complexity

Total Complexity

8

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	4
Bugs	1	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getComingFrom()	0	4	1
A	init()	0	5	1
A	setHttpClient()	0	5	1
A	getSystems()	0	8	1
A	prepareUrl()	0	7	1
A	next()	0	13	2
A	getOriginUri()	0	4	1

<?php

namespace whm\Smoke\Extensions\SmokeResponseRetriever\Retriever\Koalamon;

use Ivory\HttpAdapter\HttpAdapterInterface;
use Ivory\HttpAdapter\Message\Request;
use Psr\Http\Message\UriInterface;
use whm\Html\Uri;
use whm\Smoke\Extensions\SmokeResponseRetriever\Retriever\Retriever as SmokeRetriever;

class Retriever implements SmokeRetriever
{
    private $apiKey;
    private $systems;
    private $project;

    /**
     * @var HttpAdapterInterface
     */
    private $client;

    const ENDPOINT_SYSTEMS = 'http://www.koalamon.com/rest/#project#/systems/?api_key=#api_key#';

    public function init($apiKey, $project)
    {
        $this->apiKey = $apiKey;
        $this->project = $project;
    }

    public function setHttpClient(HttpAdapterInterface $httpClient)
    {
        $this->client = $httpClient;
        $this->systems = $this->getSystems($httpClient);
    }

    public function getSystems(HttpAdapterInterface $httpClient)
    {
        $url = $this->prepareUrl(self::ENDPOINT_SYSTEMS);

        $systems = $httpClient->get(new Uri($url));

        return json_decode($systems->getBody(), true);
    }

    private function prepareUrl($url)
    {
        $preparedUrl = str_replace('#project#', $this->project, $url);
        $preparedUrl = str_replace('#api_key#', $this->apiKey, $preparedUrl);

        return $preparedUrl;
    }

    public function next()
    {
        if (empty($this->systems)) {
            return false;
        }

        $system = array_pop($this->systems);

        $request = new Request(new Uri($system['url']), 'GET', 'php://memory', ['Accept-Encoding' => 'gzip']);
        $responses = $this->client->sendRequests(array($request));

        return $responses[0];
    }

    public function getComingFrom(UriInterface $uri)
    {
        return new Uri('http://www.koalamon.com');
    }

    public function getOriginUri(UriInterface $uri)
    {
        return $uri;
    }
}