Cmp\Queues\Domain\Event\JSONDomainEventFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	34
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	create()	0	25	5

<?php

namespace Cmp\Queues\Domain\Event;

use Cmp\Queues\Domain\Event\Exception\DomainEventException;
use Cmp\Queues\Domain\Event\Exception\InvalidJSONDomainEventException;
use Cmp\Queues\Domain\Queue\JSONMessageFactory;

class JSONDomainEventFactory implements JSONMessageFactory
{
    /**
     * @param string $json
     *
     * @return DomainEvent
     * @throws InvalidJSONDomainEventException
     */
    public function create($json)
    {
        $domainEventArray = json_decode($json, true);

        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new InvalidJSONDomainEventException("String is not valid JSON");
        }

        if (!isset($domainEventArray['origin'], $domainEventArray['name'], $domainEventArray['version'], $domainEventArray['occurredOn'], $domainEventArray['body'])) {
            throw new InvalidJSONDomainEventException("Cannot reconstruct domain event. Origin, name, version, occurredOn or body fields are missing");
        }

        try {
            return new DomainEvent(
                $domainEventArray['origin'],
                $domainEventArray['name'],
                $domainEventArray['version'],
                $domainEventArray['occurredOn'],
                $domainEventArray['body'],
                isset($domainEventArray['isDeprecated']) ? $domainEventArray['isDeprecated'] : false
            );
        } catch (DomainEventException $e) {
            throw new InvalidJSONDomainEventException("Failed creating DomainEvent instance", 0, $e);
        }
    }
}