Yoanm\JsonRpcServer\Infra\Serialization\RawResponseSerializer

Complexity

Total Complexity

9

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	serialize()	0	4	1
A	encode()	0	3	1
A	normalizeBatchResponse()	0	14	4
A	normalize()	0	8	2

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

use Yoanm\JsonRpcServer\App\Serialization\ResponseNormalizer;
use Yoanm\JsonRpcServer\Domain\Model\JsonRpcResponse;
use Yoanm\JsonRpcServer\Infra\RawObject\JsonRpcRawResponse;

/**
 * Class RawResponseSerializer
 */
class RawResponseSerializer
{
    const KEY_JSON_RPC = 'json-rpc';
    const KEY_ID = 'id';
    const KEY_RESULT = 'result';
    const KEY_ERROR = 'error';

    const SUB_KEY_ERROR_CODE = 'code';
    const SUB_KEY_ERROR_MESSAGE = 'message';
    const SUB_KEY_ERROR_DATA = 'data';

    /** @var ResponseNormalizer */
    private $responseNormalizer;

    /**
     * @param ResponseNormalizer $responseNormalizer
     */
    public function __construct(ResponseNormalizer $responseNormalizer)
    {
        $this->responseNormalizer = $responseNormalizer;
    }

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

    /**
     * @param mixed $normalizedContent
     *
     * @return string
     */
    public function encode($normalizedContent) : string
    {
        return json_encode($normalizedContent);
    }

    /**
     * @param JsonRpcRawResponse $rawResponse
     *
     * @return array|null
     */
    public function normalize(JsonRpcRawResponse $rawResponse)
    {
        if ($rawResponse->isBatch()) {
            return $this->normalizeBatchResponse($rawResponse->getResponseList());
        } else {
            $responseList = $rawResponse->getResponseList();

            return $this->responseNormalizer->normalize(array_shift($responseList));
        }
    }

    /**
     * @param JsonRpcResponse[] $responseList
     *
     * @return array|null
     */
    private function normalizeBatchResponse(array $responseList)
    {
        $resultList = [];
        foreach ($responseList as $response) {
            // Notifications must not have a response, even if they are on error
            if (!$response->isNotification()) {
                $resultList[] = $this->responseNormalizer->normalize($response);
            }
        }

        // if no result, it means It was a batch call with only notifications => return null response
        return count($resultList) > 0
            ? $resultList
            : null
        ;
    }
}