Sylius\Api\GenericApi

Complexity

Total Complexity

30

Size/Duplication

Total Lines	208
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	4
A	setUri()	0	10	4
A	getUri()	0	9	2
A	get()	0	6	1
A	getAll()	0	12	3
A	getPaginated()	0	9	3
A	createPaginator()	0	6	2
A	create()	0	6	1
A	update()	0	11	2
A	put()	0	7	1
A	delete()	0	6	1
A	responseToArray()	0	6	1
A	getResponseType()	0	13	4
A	json()	0	4	1

<?php

/*
 * This file is part of the Lakion package.
 *
 * (c) Lakion
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sylius\Api;

use Psr\Http\Message\ResponseInterface;
use Sylius\Api\Factory\AdapterFactoryInterface;
use Sylius\Api\Factory\ApiAdapterFactory;
use Sylius\Api\Factory\PaginatorFactory;
use Sylius\Api\Factory\PaginatorFactoryInterface;
use Symfony\Component\Serializer\Encoder\JsonDecode;
use Symfony\Component\Serializer\Encoder\XmlEncoder;

/**
 * @author Michał Marcinkowski <michal.marcinkowski@lakion.com>
 */
class GenericApi implements ApiInterface
{

    /**
     * @var array
     */
    static $formats = [

The visibility should be declared for property $formats.

        'json' => ['application/json', 'application/x-json'],
    ];

    /**
     * @var ClientInterface $client
     */
    private $client;
    /**
     * @var string $uri
     */
    private $uri;
    /**
     * @var PaginatorFactoryInterface $paginatorFactory
     */
    private $paginatorFactory;

    /**
     * @var AdapterFactoryInterface $apiAdapterFactory
     */
    private $apiAdapterFactory;

    /**
     * @var JsonDecode $jsonDecoder
     */
    private $jsonDecoder;

    /**
     * @param ClientInterface $client
     * @param string $uri
     * @param null|AdapterFactoryInterface $apiAdapterFactory
     * @param null|PaginatorFactoryInterface $paginatorFactory
     * @param null|JsonDecode $jsonDecoder
     */
    public function __construct(
        ClientInterface $client,
        $uri,
        AdapterFactoryInterface $apiAdapterFactory = null,
        PaginatorFactoryInterface $paginatorFactory = null,
        JsonDecode $jsonDecoder = null
    ) {
        $this->setUri($uri);
        $this->client = $client;
        $this->apiAdapterFactory = $apiAdapterFactory ?: new ApiAdapterFactory($this);
        $this->paginatorFactory = $paginatorFactory ?: new PaginatorFactory();
        $this->jsonDecoder = $jsonDecoder ?: new JsonDecode(true);
    }

    /**
     * @param  string $uri
     * @throws \InvalidArgumentException
     */
    private function setUri($uri)
    {
        if (empty($uri) || !is_string($uri)) {
            throw new \InvalidArgumentException('You must specify uri for Api');
        }
        if (($uri[strlen($uri) - 1]) !== '/') {
            $uri = sprintf('%s/', $uri);
        }
        $this->uri = $uri;
    }

    /**
     * @param  array $uriParameters
     * @return string
     */
    private function getUri(array $uriParameters = [])
    {
        $uri = $this->uri;
        foreach ($uriParameters as $uriParameterKey => $uriParameterValue) {
            $uri = str_ireplace(sprintf('{%s}', $uriParameterKey), $uriParameterValue, $uri);
        }

        return $uri;
    }

    /**
     * {@inheritdoc}
     */
    public function get($id, array $queryParameters = [], array $uriParameters = [])
    {
        $response = $this->client->get(sprintf('%s%s', $this->getUri($uriParameters), $id), $queryParameters);

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

    /**
     * {@inheritdoc}
     */
    public function getAll(array $queryParameters = [], array $uriParameters = [])
    {
        $queryParameters['limit'] = isset($queryParameters['limit']) ? $queryParameters['limit'] : 100;
        $paginator = $this->createPaginator($queryParameters, $uriParameters);
        $results = $paginator->getCurrentPageResults();
        while ($paginator->hasNextPage()) {
            $paginator->nextPage();
            $results = array_merge($results, $paginator->getCurrentPageResults());
        }

        return $results;
    }

    /**
     * {@inheritdoc}
     */
    public function getPaginated(array $queryParameters = [], array $uriParameters = [])
    {
        $queryParameters['page'] = isset($queryParameters['page']) ? $queryParameters['page'] : 1;
        $queryParameters['limit'] = isset($queryParameters['limit']) ? $queryParameters['limit'] : 10;

        $response = $this->client->get($this->getUri($uriParameters), $queryParameters);

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

    /**
     * {@inheritdoc}
     */
    public function createPaginator(array $queryParameters = [], array $uriParameters = [])
    {
        $queryParameters['limit'] = isset($queryParameters['limit']) ? $queryParameters['limit'] : 10;

        return $this->paginatorFactory->create($this->apiAdapterFactory->create(), $queryParameters, $uriParameters);
    }

    /**
     * {@inheritdoc}
     */
    public function create(array $body, array $uriParameters = [], array $files = [])
    {
        $response = $this->client->post($this->getUri($uriParameters), $body, $files);

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

    /**
     * {@inheritdoc}
     */
    public function update($id, array $body, array $uriParameters = [], array $files = [])
    {
        $uri = sprintf('%s%s', $this->getUri($uriParameters), $id);
        if (empty($files)) {
            $response = $this->client->patch($uri, $body);
        } else {
            $response = $this->client->post($uri, $body, $files);
        }

        return (204 === $response->getStatusCode());
    }

    /**
     * {@inheritdoc}
     */
    public function put($id, array $body, array $uriParameters = [])
    {
        $uri = sprintf('%s%s', $this->getUri($uriParameters), $id);
        $response = $this->client->put($uri, $body);

        return (204 === $response->getStatusCode());
    }

    /**
     * {@inheritdoc}
     */
    public function delete($id, array $uriParameters = [])
    {
        $response = $this->client->delete(sprintf('%s%s', $this->getUri($uriParameters), $id));

        return (204 === $response->getStatusCode());
    }

    private function responseToArray(ResponseInterface $response)

The return type could not be reliably inferred; please add a @return annotation.

    {
        $responseType = $this->getResponseType($response);

        return $this->{$responseType}((string)$response->getBody());
    }

    private function getResponseType(ResponseInterface $response)
    {
        $responseContentType = $response->getHeaderLine('Content-Type');
        foreach (self::$formats as $format => $contentTypes) {
            foreach ($contentTypes as $contentType) {
                if (strpos($responseContentType, $contentType) !== false) {
                    return $format;
                }
            }
        }

        throw new InvalidResponseFormatException((string)$response->getBody(), $response->getStatusCode());
    }

    /**
     * @param $body
     * @return mixed
     */
    private function json($body)
    {
        return $this->jsonDecoder->decode($body, 'json');
    }
}