Gendoria\CommandQueueBundle\Serializer\JmsSerializer

Complexity

Total Complexity

6

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	serialize()	0	4	1
A	unserialize()	0	12	4

<?php

namespace Gendoria\CommandQueueBundle\Serializer;

use Gendoria\CommandQueue\Command\CommandInterface;
use Gendoria\CommandQueue\Serializer\SerializedCommandData;
use Gendoria\CommandQueue\Serializer\SerializerInterface;
use Gendoria\CommandQueue\Worker\Exception\TranslateErrorException;
use JMS\Serializer\Serializer;

/**
 * Serializer using JMS serializer module
 *
 * @author Tomasz Struczyński <t.struczynski@gmail.com>
 */
class JmsSerializer implements SerializerInterface
{
    /**
     *
     * @var Serializer
     */
    private $serializer;
    
    /**
     * Serialization format.
     * 
     * @var string
     */
    private $format;
    
    public function __construct(Serializer $serializer, $format = "json")
    {
        $this->serializer = $serializer;
        $this->format = $format;
    }
    
    /**
     * {@inheritdoc}
     */
    public function serialize(CommandInterface $command)
    {
        return new SerializedCommandData($this->serializer->serialize($command, $this->format), get_class($command));
    }

    /**
     * {@inheritdoc}
     */
    public function unserialize(SerializedCommandData $serializedCommandData)
    {
        try {
            $command = $this->serializer->deserialize($serializedCommandData->getSerializedCommand(), $serializedCommandData->getCommandClass(), $this->format);
        } catch (\Exception $e) {
            throw new TranslateErrorException($serializedCommandData, $e->getMessage(), $e->getCode(), $e);
        }
        if (!is_object($command) || !$command instanceof CommandInterface) {
            throw new TranslateErrorException($serializedCommandData, "Unserialized command should implement CommandInterface.");
        }
        return $command;
    }
}