Yoanm\JsonRpcServer\App\Serialization\JsonRpcCallSerializer

Complexity

Total Complexity

10

Size/Duplication

Total Lines	100
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	deserialize()	0	4	1
A	decode()	0	19	4
A	denormalize()	0	3	1
A	serialize()	0	4	1
A	normalize()	0	3	1
A	encode()	0	3	1

<?php
namespace Yoanm\JsonRpcServer\App\Serialization;

use Yoanm\JsonRpcServer\Domain\Exception\JsonRpcInvalidRequestException;
use Yoanm\JsonRpcServer\Domain\Exception\JsonRpcParseErrorException;
use Yoanm\JsonRpcServer\Domain\Model\JsonRpcCall;
use Yoanm\JsonRpcServer\Domain\Model\JsonRpcCallResponse;

/**
 * Class JsonRpcCallSerializer
 */
class JsonRpcCallSerializer
{
    /** @var JsonRpcCallDenormalizer */
    private $callDenormalizer;
    /** @var JsonRpcCallResponseNormalizer */
    private $callResponseNormalizer;

    /**
     * @param JsonRpcCallDenormalizer       $callDenormalizer
     * @param JsonRpcCallResponseNormalizer $callResponseNormalizer
     */
    public function __construct(
        JsonRpcCallDenormalizer $callDenormalizer,
        JsonRpcCallResponseNormalizer $callResponseNormalizer
    ) {
        $this->callDenormalizer = $callDenormalizer;
        $this->callResponseNormalizer = $callResponseNormalizer;
    }

    /**
     * @param string $content
     *
     * @return JsonRpcCall
     */
    public function deserialize(string $content) : JsonRpcCall
    {
        return $this->denormalize(
            $this->decode($content)
        );
    }

    /**
     * @param JsonRpcCallResponse $jsonRpcCallResponse
     *
     * @return string
     */
    public function serialize(JsonRpcCallResponse $jsonRpcCallResponse) : string
    {
        return $this->encode(
            $this->normalize($jsonRpcCallResponse)
        );
    }

    /**
     * @param mixed $normalizedContent Could be an array or null for instance
     *
     * @return string
     */
    public function encode($normalizedContent) : string
    {
        return json_encode($normalizedContent);
    }

    /**
     * @param string $requestContent
     *
     * @return array Decoded content
     *
     * @throws JsonRpcParseErrorException
     * @throws JsonRpcInvalidRequestException
     */
    public function decode(string $requestContent) : array
    {
        $decodedContent = json_decode($requestContent, true);

        // Check if parsing is ok => Parse error
        if (JSON_ERROR_NONE !== json_last_error()) {
            throw new JsonRpcParseErrorException($requestContent, json_last_error(), json_last_error_msg());
        }

        // Content must be either an array (normal request) or an array of array (batch request)
        //  => so must be an array
        // In case it's a batch call, at least one sub request must exist
        // and in case not, some required properties must exist
        // => array must have at least one child
        if (!is_array($decodedContent) || count($decodedContent) === 0) {
            throw new JsonRpcInvalidRequestException($requestContent);
        }

        return $decodedContent;
    }

    /**
     * @param array $decodedContent
     *
     * @return JsonRpcCall
     */
    public function denormalize(array $decodedContent) : JsonRpcCall
    {
        return $this->callDenormalizer->denormalize($decodedContent);
    }

    /**
     * @param JsonRpcCallResponse $jsonRpcCallResponse
     *
     * @return array|null
     */
    public function normalize(JsonRpcCallResponse $jsonRpcCallResponse)
    {
        return $this->callResponseNormalizer->normalize($jsonRpcCallResponse);
    }
}