Puzzle\AMQP\Workers\MessageAdapter

Complexity

Total Complexity

32

Size/Duplication

Total Lines	174
Duplicated Lines	6.32 %

Coupling/Cohesion

Components	2
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

22 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getRoutingKey()	0	4	1
A	getContentType()	0	4	1
A	getAppId()	0	4	1
A	getHeaders()	0	4	1
A	getDecodedBody()	0	4	1
A	decodeBody()	0	12	2
A	getRawBody()	0	4	1
A	applyHooks()	0	13	4
A	getFlags()	0	4	1
A	getAttribute()	0	10	2
A	getFormatterStrategy()	0	13	2
A	__toString()	0	8	1
A	isBinary()	0	4	1
A	bodyToString()	0	9	2
A	getService()	0	4	1
A	getAction()	0	4	1
A	getAuthor()	0	4	1
A	getHeader()	0	10	2
A	getAttributes()	0	4	1
A	isLastRetry()	0	6	2
A	getRoutingKeyFromHeader()	11	11	2

<?php

namespace Puzzle\AMQP\Workers;

use Psr\Log\InvalidArgumentException;
use Puzzle\AMQP\ReadableMessage;
use Puzzle\AMQP\Collections\MessageHookCollection;
use Puzzle\AMQP\Hooks\MessageHook;
use Puzzle\AMQP\Messages\ContentType;

class MessageAdapter implements ReadableMessage
{
    private
        $message,

The visibility should be declared for property $message.

        $decodedBody,
        $messageHooks;

The property $messageHooks is not used and could be removed.

    public function __construct(\Swarrot\Broker\Message $message)
    {
        $this->message = $message;
        $this->decodedBody = $this->decodeBody();
    }

    public function getRoutingKey()
    {
        return $this->getAttribute('routing_key');
    }

    public function getContentType()
    {
        return $this->getAttribute('content_type');
    }

    public function getAppId()
    {
        return $this->getAttribute('app_id');
    }

    public function getHeaders()
    {
        return $this->getAttribute('headers');
    }

    public function getDecodedBody()
    {
        return $this->decodedBody;
    }

    private function decodeBody()
    {
        $callable = $this->getFormatterStrategy($this->getContentType());
        $body = $this->getRawBody();

        if($callable instanceof \Closure)
        {
            $body = $callable($body);
        }

        return $body;
    }

    public function getRawBody()
    {
        return $this->message->getBody();
    }

    public function applyHooks(MessageHookCollection $messageHookCollection)
    {
        if(!empty($messageHookCollection))
        {
            foreach($messageHookCollection as $messageHook)
            {
                if($messageHook instanceof MessageHook)
                {
                    $this->decodedBody = $messageHook->process($this->decodedBody);
                }
            }
        }
    }

    public function getFlags()
    {
        throw new \LogicException('Consumed messages have no flags');
    }

    public function getAttribute($attributeName)
    {
        $messageProperties = $this->message->getProperties();
        if(array_key_exists($attributeName, $messageProperties))
        {
            return $messageProperties[$attributeName];
        }

        throw new InvalidArgumentException(sprintf('Property "%s" is unknown or is not a message property', $attributeName));
    }

    private function getFormatterStrategy($contentType)
    {
        $formatterStrategies = array(
            ContentType::JSON => function($body) {
                return json_decode($body, true);
            },
        );

        if(array_key_exists($contentType, $formatterStrategies) === true)
        {
            return $formatterStrategies[$contentType];
        }
    }
    
    public function __toString()
    {
        return json_encode(array(
            'routing_key' => $this->getRoutingKey(),
            'body' => $this->bodyToString(),
            'attributes' => $this->message->getProperties(),
        ));
    }
    
    private function isBinary()
    {
        return $this->getContentType() === ContentType::BINARY;
    }

    private function bodyToString()
    {
        if($this->isBinary())
        {
            return sprintf('<binary stream of %d bytes>', strlen($this->getRawBody()));
        }
        
        return $this->getRawBody();
    }

    public function getService()
    {
        return $this->getHeader('service');
    }

    public function getAction()
    {
        return $this->getHeader('action');
    }

    public function getAuthor()
    {
        return $this->getHeader('author');
    }

    private function getHeader($headerName)
    {
        $headers = $this->getHeaders();
        if(array_key_exists($headerName, $headers))
        {
            return $headers[$headerName];
        }

        return null;
    }

    public function getAttributes()
    {
        return $this->message->getProperties();
    }

    public function isLastRetry($retryOccurence = \Puzzle\AMQP\Consumers\Retry::DEFAULT_RETRY_OCCURENCE)
    {
        $retryHeader = $this->getHeader(\Puzzle\AMQP\Consumers\Retry::DEFAULT_RETRY_HEADER);

        return (!empty($retryHeader) && (int) $retryHeader === $retryOccurence);
    }

    public function getRoutingKeyFromHeader()

This method seems to be duplicated in your project.

    {
        $headers = $this->getHeaders();

        if(! array_key_exists('routing_key', $headers))
        {
            return null;
        }

        return $headers['routing_key'];
    }
}