Fnayou\InstapushPHP\Api\AbstractApi

Complexity

Total Complexity

13

Size/Duplication

Total Lines	104
Duplicated Lines	8.65 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getInstapushClient()	0	4	1
A	setInstapushClient()	0	4	1
A	transformResponse()	0	15	4
A	doGet()	0	13	2
B	handleException()	9	26	4

<?php
/**
 * This file is part of the fnayou/instapush-php project.
 *
 * Copyright (c) 2017. Aymen FNAYOU <fnayou.aymen@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Fnayou\InstapushPHP\Api;

use Fnayou\InstapushPHP\Exception\ApiException;
use Fnayou\InstapushPHP\InstapushClient;
use Fnayou\InstapushPHP\Model\Error;
use Psr\Http\Message\ResponseInterface;

/**
 * Class AbstractApi.
 */
abstract class AbstractApi
{
    /** @var \Fnayou\InstapushPHP\InstapushClient */
    protected $instapushClient;

    /**
     * @param \Fnayou\InstapushPHP\InstapushClient $instapushClient
     */
    public function __construct(InstapushClient $instapushClient)
    {
        $this->instapushClient = $instapushClient;
    }

    /**
     * @return \Fnayou\InstapushPHP\InstapushClient
     */
    protected function getInstapushClient()
    {
        return $this->instapushClient;
    }

    /**
     * @param \Fnayou\InstapushPHP\InstapushClient $instapushClient
     */
    protected function setInstapushClient(InstapushClient $instapushClient)
    {
        $this->instapushClient = $instapushClient;
    }

    /**
     * @param \Psr\Http\Message\ResponseInterface $response
     * @param string                              $class
     *
     * @return mixed|\Psr\Http\Message\ResponseInterface
     */
    protected function transformResponse(ResponseInterface $response, $class)
    {
        // return \GuzzleHttp\Psr7\Response
        if (!$this->getInstapushClient()->getTransformer()) {
            return $response;
        }

        // handle exception
        if (200 !== $response->getStatusCode() || 201 !== $response->getStatusCode()) {
            $this->handleException($response);
        }

        // transform response according to class
        return $this->getInstapushClient()->getTransformer()->transform($response, $class);
    }

    /**
     * @param string $path
     * @param array  $parameters
     * @param array  $headers
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    protected function doGet(string $path, array $parameters = [], array $headers = [])
    {
        if (0 < \count($parameters)) {
            $path .= '?'.\http_build_query($parameters);
        }

        $request = $this
            ->getInstapushClient()
            ->getRequestFactory()
            ->createRequest('GET', $path, $headers);

        return $this->instapushClient->getHttpClient()->sendRequest($request);
    }

    /**
     * @param \Psr\Http\Message\ResponseInterface $response
     *
     * @return mixed
     */
    protected function handleException(ResponseInterface $response)
    {
        if (false === $this->getInstapushClient()->isException()) {
            return $this->getInstapushClient()->getTransformer()->transform($response, Error::class);
        }

        if (0 !== \strpos($response->getHeaderLine('Content-Type'), 'application/json')) {

This code seems to be duplicated across your project.

            throw new ApiException(
                \sprintf(
                    'Waiting for json response but %s given',
                    $response->getHeaderLine('Content-Type')
                ),
                500
            );
        }

        $content = \json_decode($response->getBody()->getContents(), true);

        if (true === isset($content['message'])) {
            $message = $content['message'];
        } else {
            $message = 'An unexpected/unknown error occurred.';
        }

        throw new ApiException($message, $response->getStatusCode(), $response);
    }
}