OldSound\RabbitMqBundle\Serializer\JsonMessageBodySerializer

Complexity

Total Complexity

8

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	serialize()	0	9	2
A	deserialize()	0	11	3
A	__construct()	0	7	3

<?php


namespace OldSound\RabbitMqBundle\Serializer;


use OldSound\RabbitMqBundle\RabbitMq\Exception\RpcResponseException;

The type OldSound\RabbitMqBundle\RabbitMq\Exception\RpcResponseException was not found. Maybe you did not declare it correctly or list all dependencies?

use OldSound\RabbitMqBundle\RabbitMq\RpcReponse;

The type OldSound\RabbitMqBundle\RabbitMq\RpcReponse was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Serializer\Serializer;
use Symfony\Component\Serializer\SerializerInterface;

class JsonMessageBodySerializer implements MessageBodySerializerInterface
{
    /** @var SerializerInterface */
    private $serializer;
    /** @var string|null */
    private $deserializeType;

    public function __construct(string $deserializeType = null, SerializerInterface $serializer = null)
    {
        if ($this->deserializeType && !$this->serializer) {
            throw new \InvalidArgumentException('serializer is required if deserializerType specified');
        }
        $this->deserializeType = $deserializeType;
        $this->serializer = $serializer;
    }

    public function serialize($body): string
    {
        if ($body instanceof RpcResponseException) {
            return json_encode([
                'error_code' => $body->getCode(),
                'message' => $body->getMessage(),
            ]);
        }
        return json_encode($body);// $this->serializer->serialize($body, 'json');
    }

    public function deserialize(string $body)
    {
        $data = json_decode($body, true);
        if (isset($data['error_code'])) {
            return new RpcResponseException(new RpcResponseException($data['message'], $data['error_code']));
        } else if ($this->deserializeType) {
            return $this->serializer->deserialize($body, $this->deserializeType, 'json');
        }


        return $data;
    }

}