EventSauce\EventSourcing\Serialization\TypeValidatingPayloadSerializer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	unserializePayload()	0	10	2
A	serializePayload()	0	10	2

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing\Serialization;

final class TypeValidatingPayloadSerializer implements PayloadSerializer
{
    private $serializer;
    private $eventClassName;

    public function __construct(
        PayloadSerializer $serializer,
        string $eventClassName
    ) {
        $this->serializer = $serializer;
        $this->eventClassName = $eventClassName;
    }

    public function serializePayload(object $event): array
    {
        if ( ! $event instanceof $this->eventClassName) {
            throw new \InvalidArgumentException(sprintf(
                'Cannot serialize event that does not implement "%s".',
                $this->eventClassName
            ));
        }

        return $this->serializer->serializePayload($event);
    }

    public function unserializePayload(string $className, array $payload): object
    {
        if ( ! is_subclass_of($className, $this->eventClassName)) {
            throw new \InvalidArgumentException(sprintf(
                'Cannot unserialize payload into an event that does not implement "%s".',
                $this->eventClassName
            ));
        }

        return $this->serializer->unserializePayload($className, $payload);
    }
}