Completed
Push — v3.0 ( 928391...a7a97e )
by Masiukevich
03:12
created

DefaultEventSerializer::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 3
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 2
CRAP Score 1

Importance

Changes 0
Metric Value
cc 1
eloc 1
nc 1
nop 0
dl 0
loc 3
ccs 2
cts 2
cp 1
crap 1
rs 10
c 0
b 0
f 0
1
<?php
2
3
/**
4
 * Event Sourcing implementation
5
 *
6
 * @author  Maksim Masiukevich <[email protected]>
7
 * @license MIT
8
 * @license https://opensource.org/licenses/MIT
9
 */
10
11
declare(strict_types = 1);
12
13
namespace ServiceBus\EventSourcing\EventStream\Serializer;
14
15
use ServiceBus\EventSourcing\EventStream\Serializer\Exceptions\SerializeEventFailed;
16
use ServiceBus\MessageSerializer\Symfony\SymfonyMessageSerializer;
17
18
/**
19
 *
20
 */
21
final class DefaultEventSerializer implements EventSerializer
22
{
23
    /**
24
     * @var SymfonyMessageSerializer
25
     */
26
    private $serializer;
27
28
29 9
    public function __construct()
30
    {
31 9
        $this->serializer = new SymfonyMessageSerializer();
32 9
    }
33
34
    /**
35
     * @inheritDoc
36
     */
37 7
    public function serialize(object $event): string
38
    {
39
        try
40
        {
41 7
            return $this->serializer->encode($event);
42
        }
43
        catch(\Throwable $throwable)
44
        {
45
            throw SerializeEventFailed::fromThrowable($throwable);
46
        }
47
    }
48
49
    /**
50
     * @inheritDoc
51
     */
52 5
    public function unserialize(string $eventClass, string $payload): object
53
    {
54
        try
55
        {
56 5
            return $this->serializer->decode($payload);
57
        }
58 1
        catch(\Throwable $throwable)
59
        {
60 1
            throw SerializeEventFailed::fromThrowable($throwable);
61
        }
62
    }
63
}
64