Speicher210\Monsum\Api\AbstractService

Complexity

Total Complexity

5

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

93.75%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	sendRequest()	0	20	4

<?php

namespace Speicher210\Monsum\Api;

use JMS\Serializer\SerializerInterface;
use Speicher210\Monsum\Api\Exception\ApiResponseException;
use Speicher210\Monsum\Api\Transport\TransportInterface;

/**
 * Abstract service.
 */
abstract class AbstractService implements ServiceInterface
{
    /**
     * Transport for the requests.
     *
     * @var TransportInterface
     */
    protected $transport;

    /**
     * @var SerializerInterface
     */
    protected $serializer;

    /**
     * Constructor.
     *
     * @param TransportInterface $transport Transport for the requests.
     * @param SerializerInterface $serializer Serializer interface to serialize / deserialize the request / responses.
     */
    public function __construct(TransportInterface $transport, SerializerInterface $serializer)
    {
        $this->transport = $transport;
        $this->serializer = $serializer;
    }

    /**
     * Send a request to Monsum.
     *
     * @param mixed $request The request to send.
     * @param string $responseClass The class that should be used to unserialize the response.
     * @return ApiResponseInterface
     * @throws ApiResponseException If the API response has errors.
     */
    protected function sendRequest(RequestInterface $request, $responseClass)
    {
        if (!in_array(ApiResponseInterface::class, class_implements($responseClass), true)) {
            throw new \InvalidArgumentException('The response class must implement "'.ApiResponseInterface::class.'".');
        }

        $body = $this->serializer->serialize($request, 'json');
        $response = $this->transport->sendRequest($body);

        /** @var ApiResponseInterface $apiResponse */
        $apiResponse = $this->serializer->deserialize($response, $responseClass, 'json');
        if ($apiResponse->getResponse() !== null && $apiResponse->getResponse()->hasErrors()) {
            throw new ApiResponseException(
                sprintf('Error calling "%s"', $request->getService()),
                $apiResponse->getResponse()->getErrors()
            );
        }

        return $apiResponse;
    }
}