<?php
/**
 * User: junade
 * Date: 13/01/2017
 * Time: 18:26
 */

namespace Cloudflare\API\Adapter;

use Cloudflare\API\Auth\Auth;
use GuzzleHttp\Client;
use Psr\Http\Message\ResponseInterface;

class Guzzle implements Adapter
{
    private $client;

    /**
     * @inheritDoc
     */
    public function __construct(Auth $auth, string $baseURI = null)
    {
        if ($baseURI === null) {
            $baseURI = 'https://api.cloudflare.com/client/v4/';
        }

        $headers = $auth->getHeaders();

        $this->client = new Client([
            'base_uri' => $baseURI,
            'headers' => $headers,
            'Accept' => 'application/json'
        ]);
    }


    /**
     * @inheritDoc
     */
    public function get(string $uri, array $query = [], array $headers = []): ResponseInterface
    {
        $response = $this->client->get($uri, ['query' => $query, 'headers' => $headers]);

        $this->checkError($response);
        return $response;
    }

    /**
     * @inheritDoc
     */
    public function post(string $uri, array $headers = [], array $body = []): ResponseInterface
    {
        $response = $this->client->post(
            $uri,
            [
                'headers' => $headers,
                'json' => $body
            ]
        );

        $this->checkError($response);
        return $response;
    }

    /**
     * @inheritDoc
     */
    public function put(string $uri, array $headers = [], array $body = []): ResponseInterface
    {
        $response = $this->client->put(
            $uri,
            [
                'headers' => $headers,
                'json' => $body
            ]
        );

        $this->checkError($response);
        return $response;
    }

    /**
     * @inheritDoc
     */
    public function patch(string $uri, array $headers = [], array $body = []): ResponseInterface
    {
        $response = $this->client->patch(
            $uri,
            [
                'headers' => $headers,
                'json' => $body
            ]
        );

        $this->checkError($response);
        return $response;
    }

    /**
     * @inheritDoc
     */
    public function delete(string $uri, array $headers = [], array $body = []): ResponseInterface
    {
        $response = $this->client->delete(
            $uri,
            [
                'headers' => $headers,
                'json' => $body
            ]
        );

        $this->checkError($response);
        return $response;
    }

    private function checkError(ResponseInterface $response)
    {
        $json = json_decode($response->getBody());

        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new JSONException();
        }

        if (isset($json->errors)) {
            throw new ResponseException($json->errors[0]->message, $json->errors[0]->code);
        }

        if (isset($json->success) && ($json->success === false)) {
            throw new ResponseException('Request was unsuccessful.');
        }
    }
}