Completed
Push — master ( 1c4593...ca959b )
by Tomasz
09:01
created

JmsSerializer::serialize()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 4
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 3
CRAP Score 1

Importance

Changes 1
Bugs 0 Features 0
Metric Value
dl 0
loc 4
ccs 3
cts 3
cp 1
rs 10
c 1
b 0
f 0
cc 1
eloc 2
nc 1
nop 1
crap 1
1
<?php
2
3
namespace Gendoria\CommandQueueBundle\Serializer;
4
5
use Exception;
6
use Gendoria\CommandQueue\Command\CommandInterface;
7
use Gendoria\CommandQueue\Serializer\Exception\UnserializeErrorException;
8
use Gendoria\CommandQueue\Serializer\SerializedCommandData;
9
use Gendoria\CommandQueue\Serializer\SerializerInterface;
10
use JMS\Serializer\Serializer;
11
12
/**
13
 * Serializer using JMS serializer module
14
 *
15
 * @author Tomasz Struczyński <[email protected]>
16
 */
17
class JmsSerializer implements SerializerInterface
18
{
19
    /**
20
     *
21
     * @var Serializer
22
     */
23
    private $serializer;
24
    
25
    /**
26
     * Serialization format.
27
     * 
28
     * @var string
29
     */
30
    private $format;
31
    
32
    /**
33
     * Class constructor.
34
     * 
35
     * @param Serializer $serializer
36
     * @param string $format Serialization format.
37
     */
38 4
    public function __construct(Serializer $serializer, $format = "json")
39
    {
40 4
        $this->serializer = $serializer;
41 4
        $this->format = $format;
42
    }
43
    
44
    /**
45
     * {@inheritdoc}
46
     */
47 2
    public function serialize(CommandInterface $command)
48
    {
49 1
        return new SerializedCommandData($this->serializer->serialize($command, $this->format), get_class($command));
50 2
    }
51
52
    /**
53
     * {@inheritdoc}
54
     */
55 3
    public function unserialize(SerializedCommandData $serializedCommandData)
56
    {
57
        try {
58
            $command = $this->serializer->deserialize($serializedCommandData->getSerializedCommand(), $serializedCommandData->getCommandClass(), $this->format);
59
        } catch (Exception $e) {
60
            throw new UnserializeErrorException($serializedCommandData, $e->getMessage(), $e->getCode(), $e);
61 3
        }
62
        if (!is_object($command) || !$command instanceof CommandInterface) {
63
            throw new UnserializeErrorException($serializedCommandData, "Unserialized command should implement CommandInterface.");
64
        }
65 1
        return $command;
66 3
    }
67
}
68