Tgallice\Wit\Client

Complexity

Total Complexity

15

Size/Duplication

Total Lines	166
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	2
A	post()	0	4	1
A	get()	0	4	1
A	put()	0	4	1
A	delete()	0	4	1
A	send()	0	18	3
A	getLastResponse()	0	4	1
A	getHttpClient()	0	4	1
A	getDefaultHeaders()	0	8	1
A	validateResponse()	0	10	3

<?php

namespace Tgallice\Wit;

use GuzzleHttp\Client as HttpClient;
use GuzzleHttp\ClientInterface;
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 ClientInterface client
     */
    private $client;

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

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

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

    public function __construct($accessToken, ClientInterface $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 $uri
     * @param array $params
     *
     * @return ResponseInterface
     */
    public function post($uri, array $params = [])
    {
        return $this->send('POST', $uri, [], $params);
    }

    /**
     * @param $uri
     * @param array $params
     *
     * @return ResponseInterface
     */
    public function get($uri, array $params = [])
    {
        return $this->send('GET', $uri, $params);
    }

    /**
     * @param $uri
     * @param array $params
     *
     * @return ResponseInterface
     */
    public function put($uri, array $params = [])
    {
        return $this->send('PUT', $uri, [], $params);
    }

    /**
     * @param $uri
     * @param array $params

There is no parameter named $params. Was it maybe removed?

     *
     * @return ResponseInterface
     */
    public function delete($uri)
    {
        return $this->send('DELETE', $uri);
    }

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

        if (!empty($postParams)) {
            $type = is_array($postParams) ? RequestOptions::JSON : RequestOptions::BODY;
            $options[$type] = $postParams;
        }

        $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 getHttpClient()
    {
        return $this->client;
    }

    /**
     * Get the defaults headers like the Authorization field
     *
     * @return array
     */
    private 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
     */
    private 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;
    }
}