Yoanm\JsonRpcServer\Infra\Serialization\RawResponseSerializer

Complexity

Total Complexity

9

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

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

<?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 {
            return $this->responseNormalizer->normalize(array_shift($rawResponse->getResponseList()));

$rawResponse->getResponseList() cannot be passed to array_shift() as the parameter $array expects a reference.

        }
    }

    /**
     * @param JsonRpcResponse[] $responseList
     *
     * @return array|null
     */
    private function normalizeBatchResponse(array $responseList)
    {
        $resultList = [];
        $hasResult = false;

        foreach ($responseList as $response) {
            if ($response->isNotification()) {
                continue;
            }

            $resultList[] = $this->responseNormalizer->normalize($response);
            $hasResult = true;
        }

        if (!$hasResult) { // It was a batch call with only notifications => return null response
            return null;
        }

        return $resultList;
    }
}