Happyr\Mq2phpBundle\Service\MessageSerializerDecorator

Complexity

Total Complexity

10

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

85.19%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	unwrapAndDeserialize()	0	4	1
A	__construct()	0	11	2
B	wrapAndSerialize()	0	22	4
A	setHeader()	0	6	1
A	getHeader()	0	8	2

<?php

namespace Happyr\Mq2phpBundle\Service;

use Happyr\Mq2phpBundle\Event\PrePublishMessage;
use SimpleBus\Serialization\Envelope\Serializer\MessageInEnvelopeSerializer;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * This service adds some extra headers on the message envelope.
 *
 * @author Tobias Nyholm <tobias.nyholm@gmail.com>
 */
class MessageSerializerDecorator implements MessageInEnvelopeSerializer, HeaderAwareInterface
{
    /**
     * @var MessageInEnvelopeSerializer
     */
    private $serializer;

    /**
     * @var array
     */
    private $headers;

    /**
     * @var string
     */
    private $secretKey;

    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

    /**
     * @param MessageInEnvelopeSerializer $serializer
     * @param array                      $headers
     * @param string                     $secretKey
     * @param EventDispatcherInterface   $eventDispatcher
     */
    public function __construct(
        MessageInEnvelopeSerializer $serializer,
        EventDispatcherInterface $eventDispatcher,
        array $headers = [],
        $secretKey = null
    ) {
        $this->serializer = $serializer;
        $this->eventDispatcher = $eventDispatcher;
        $this->headers = $headers;
        $this->secretKey = empty($secretKey) ? '' : $secretKey;
    }

    /**
     * Serialize a Message by wrapping it in an Envelope and serializing the envelope. This decoration will
     * take the SimpleBus envelope and add it in a json message.
     *
     * {@inheritdoc}
     */
    public function wrapAndSerialize($originalMessage)
    {
        $serializedMessage = $this->serializer->wrapAndSerialize($originalMessage);

        $message = [];
        foreach ($this->headers as $name => $value) {
            if (empty($value)) {
                continue;
            }

            $message['headers'][] = ['key' => $name, 'value' => $value];
        }
        $message['body'] = $serializedMessage;

        // Add a hash where the secret key is baked in.
        $message['headers'][] = ['key' => 'hash', 'value' => sha1($this->secretKey.$serializedMessage)];

        $event = new PrePublishMessage($message, is_object($originalMessage) ? get_class($originalMessage) : gettype($originalMessage));
        $this->eventDispatcher->dispatch(PrePublishMessage::NAME, $event);

        return json_encode($event->getMessage());
    }

    /**
     * Deserialize a Message that was wrapped in an Envelope.
     *
     * {@inheritdoc}
     */
    public function unwrapAndDeserialize($serializedEnvelope)
    {
        return $this->serializer->unwrapAndDeserialize($serializedEnvelope);
    }

    /**
     * @param string $name
     * @param mixed  $value
     *
     * @return $this
     */
    public function setHeader($name, $value)
    {
        $this->headers[$name] = $value;

        return $this;
    }

    /**
     * @param string $name
     */
    public function getHeader($name)
    {
        if (isset($this->headers[$name])) {
            return $this->headers[$name];
        }

        return;
    }
}