AMQPAL\Adapter\PhpAmqpLib\MessageMapper

Complexity

Total Complexity

22

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	1	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getMessagePrototype()	0	7	2
A	setMessagePrototype()	0	5	1
D	toMessage()	0	28	19

<?php

namespace AMQPAL\Adapter\PhpAmqpLib;

use PhpAmqpLib\Message\AMQPMessage;
use AMQPAL\Adapter\Message;
use DateTime;

class MessageMapper
{
    /**
     * @var Message
     */
    protected $messagePrototype;

    /**
     * @return Message
     */
    public function getMessagePrototype()
    {
        if (!$this->messagePrototype) {
            $this->messagePrototype = new Message();
        }
        return $this->messagePrototype;
    }

    /**
     * @param Message $messagePrototype
     * @return $this
     */
    public function setMessagePrototype(Message $messagePrototype)
    {
        $this->messagePrototype = $messagePrototype;
        return $this;
    }

    /**
     * @param AMQPMessage $libMessage
     * @return Message
     * @throws \OutOfBoundsException
     */
    public function toMessage(AMQPMessage $libMessage)
    {
        $message = clone $this->getMessagePrototype();
        $message->setBody($libMessage->getBody());
        $message->setRoutingKey($libMessage->get($libMessage->has('routing_key') ? 'routing_key' : null));
        $message->setDeliveryTag($libMessage->has('delivery_tag') ? $libMessage->get('delivery_tag') : null);
        $message->setDeliveryMode($libMessage->has('delivery_mode') ? $libMessage->get('delivery_mode') : null);
        $message->setExchangeName($libMessage->has('exchange') ? $libMessage->get('exchange') : null);
        $message->setRedelivered($libMessage->has('redelivered') ? $libMessage->get('redelivered') : false);
        $message->setContentType($libMessage->has('content_type') ? $libMessage->get('content_type') : null);
        $message->setContentEncoding(
            $libMessage->has('content_encoding') ? $libMessage->get('content_encoding') : null
        );
        $message->setType($libMessage->has('type') ? $libMessage->get('type') : null);
        $message->setDateTime(
            $libMessage->has('timestamp') ? (new DateTime())->setTimestamp($libMessage->get('timestamp')) : null
        );
        $message->setPriority($libMessage->has('priority') ? $libMessage->get('priority') : null);
        $expiration = $libMessage->has('expiration') ? $libMessage->get('expiration') : null;
        $message->setExpiration(!empty($expiration) ? new \DateTime($libMessage->get('expiration')) : null);
        $message->setUserId($libMessage->has('user_id') ? $libMessage->get('user_id') : null);
        $message->setAppId($libMessage->has('app_id') ? $libMessage->get('app_id') : null);
        $message->setMessageId($libMessage->has('message_id') ? $libMessage->get('message_id') : null);
        $message->setReplyTo($libMessage->has('reply_to') ? $libMessage->get('reply_to') : null);
        $message->setCorrelationId($libMessage->has('correlation_id') ? $libMessage->get('correlation_id') : null);
        $message->setHeaders($libMessage->has('application_headers') ? $libMessage->get('application_headers') : []);
        return $message;
    }
}