Bangpound\oEmbed\Consumer

Complexity

Total Complexity

6

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes	8
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	get()	0	10	1
A	getFormat()	0	17	4

<?php

namespace Bangpound\oEmbed;

use Bangpound\oEmbed\Exception\UnknownFormatException;
use Bangpound\oEmbed\Provider\ProviderInterface;
use GuzzleHttp\ClientInterface;
use Negotiation\FormatNegotiatorInterface;
use Psr\Http\Message\ResponseInterface;
use Symfony\Component\Serializer\SerializerInterface;

/**
 * Class Consumer.
 */
class Consumer
{
    /**
     * @var ClientInterface
     */
    private $client;

    /**
     * @var ProviderInterface
     */
    private $provider;

    /**
     * @var SerializerInterface
     */
    private $serializer;

    /**
     * @var FormatNegotiatorInterface
     */
    private $negotiator;

    /**
     * @param ClientInterface           $client
     * @param ProviderInterface         $provider
     * @param SerializerInterface       $serializer
     * @param FormatNegotiatorInterface $negotiator
     */
    public function __construct(ClientInterface $client, ProviderInterface $provider, SerializerInterface $serializer, FormatNegotiatorInterface $negotiator)
    {
        $this->client = $client;
        $this->provider = $provider;
        $this->serializer = $serializer;
        $this->negotiator = $negotiator;
    }

    /**
     * @param $url
     * @param array $params
     *
     * @return array
     */
    public function get($url, $params = array())
    {
        $request = $this->provider->request($url, $params);
        $response = $this->client->send($request);

        $data = $response->getBody()->getContents();
        $format = $this->getFormat($params, $response);

        return $this->serializer->deserialize($data, null, $format);
    }

    /**
     * @param array             $params
     * @param ResponseInterface $response
     *
     * @return null|string
     *
     * @throws UnknownFormatException
     */
    private function getFormat(array $params, ResponseInterface $response)
    {
        if ($response->hasHeader('content-type')) {
            $header = $response->getHeaderLine('content-type');
            $format = $this->negotiator->getFormat($header);
        }

        if (isset($params['format'])) {
            $format = $params['format'];
        }

        if (!isset($format)) {
            throw new UnknownFormatException('Unable to figure out the format');
        }

        return $format;
    }
}