Tgallice\Wit\Client

Complexity

Total Complexity

12

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	5
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	2
A	send()	0	18	4
A	getLastResponse()	0	4	1
A	getClient()	0	4	1
A	getDefaultHeaders()	0	8	1
A	validateResponse()	0	10	3

<?php

namespace Tgallice\Wit;

use GuzzleHttp\Client as HttpClient;
use GuzzleHttp\RequestOptions;
use Psr\Http\Message\ResponseInterface;
use Psr\Log\LoggerInterface;
use Tgallice\Wit\Exception\BadResponseException;

class Client
{
    /**
     * API base uri
     */
    const API_BASE_URI = 'https://api.wit.ai/';

    /*
     * API Version
     */
    const API_VERSION = '20160330';

    /**
     * Request default timeout
     */
    const DEFAULT_TIMEOUT = 5;

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

    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @var ResponseInterface|null
     */
    private $lastResponse;

    /**
     * @var string Wit app token
     */
    private $accessToken;

    public function __construct($accessToken, $httpClient = null, LoggerInterface $logger = null)
    {
        $this->accessToken = $accessToken;
        $this->client = $httpClient ?: new HttpClient([
            'base_uri' => self::API_BASE_URI,
            'timeout' => self::DEFAULT_TIMEOUT,
            'connect_timeout' => self::DEFAULT_TIMEOUT,
        ]);
        $this->logger = $logger;
    }

    /**
     * @param string $method
     * @param string $uri
     * @param array $query
     * @param mixed $content
     *
     * @return ResponseInterface
     */
    public function send($method, $uri, array $query = [], $content = null)
    {
        $options = [
            RequestOptions::QUERY => $query,
            RequestOptions::HEADERS => $this->getDefaultHeaders()
        ];

        if (!empty($content)) {
            $type = is_array($content) || $content instanceof \JsonSerializable ? RequestOptions::JSON : RequestOptions::BODY;
            $options[$type] = $content;
        }

        $this->lastResponse = $this->client->request($method, $uri, $options);

        $this->validateResponse($this->lastResponse);

        return $this->lastResponse;
    }

    /**
     * Get the last response from the API
     *
     * @return null|ResponseInterface
     */
    public function getLastResponse()
    {
        return $this->lastResponse;
    }

    public function getClient()
    {
        return $this->client;
    }

    /**
     * Get the defaults headers like the Authorization field
     *
     * @return array
     */
    protected function getDefaultHeaders()
    {
        return [
            'Authorization' => 'Bearer '.$this->accessToken,
            // Used the accept field is needed to fix the API version and avoid BC break from the API
            'Accept' => 'application/vnd.wit.'.self::API_VERSION.'+json',
        ];
    }

    /**
     * @param ResponseInterface $response
     *
     * @return bool
     *
     * @throws BadResponseException
     */
    protected function validateResponse(ResponseInterface $response)
    {
        if ($response->getStatusCode() !== 200) {
            $message = empty($response->getReasonPhrase()) ? 'Bad response status code' : $response->getReasonPhrase();

            throw new BadResponseException($message, $response);
        }

        return true;
    }
}