Happyr\MessageSerializer\SerializerRouter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

78.95%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	decode()	0	21	7
A	encode()	0	8	2

<?php

declare(strict_types=1);

namespace Happyr\MessageSerializer;

use Happyr\MessageSerializer\Transformer\Exception\TransformerNotFoundException;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Exception\MessageDecodingFailedException;
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;

/**
 * @author Radoje Albijanic <radoje.albijanic@gmail.com>
 */
final class SerializerRouter implements SerializerInterface
{
    private $happyrSerializer;
    private $symfonySerializer;

    public function __construct(SerializerInterface $happyrSerializer, SerializerInterface $symfonySerializer)
    {
        $this->happyrSerializer = $happyrSerializer;
        $this->symfonySerializer = $symfonySerializer;
    }

    /**
     * {@inheritdoc}
     */
    public function decode(array $encodedEnvelope): Envelope
    {
        if (empty($encodedEnvelope['body'])) {
            throw new MessageDecodingFailedException('Encoded envelope should have at least a "body".');
        }

        if (null === $envelopeBodyArray = \json_decode($encodedEnvelope['body'], true)) {
            return $this->symfonySerializer->decode($encodedEnvelope);
        }

        if (
            array_key_exists('version', $envelopeBodyArray)
            && array_key_exists('identifier', $envelopeBodyArray)
            && array_key_exists('timestamp', $envelopeBodyArray)
            && array_key_exists('payload', $envelopeBodyArray)
        ) {
            return $this->happyrSerializer->decode($encodedEnvelope);
        }

        return $this->symfonySerializer->decode($encodedEnvelope);
    }

    /**
     * {@inheritdoc}
     */
    public function encode(Envelope $envelope): array
    {
        try {
            return $this->happyrSerializer->encode($envelope);
        } catch (TransformerNotFoundException $e) {
            return $this->symfonySerializer->encode($envelope);
        }
    }
}