Puzzle\AMQP\Workers\ReadableMessageModifier

Complexity

Total Complexity

20

Size/Duplication

Total Lines	136
Duplicated Lines	30.15 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	changeRoutingKey()	0	6	1
A	changeBody()	0	6	1
A	changeAttribute()	0	6	1
A	addHeader()	0	6	1
A	dropHeader()	0	6	1
A	build()	0	14	1
A	extractHeaders()	0	11	2
A	buildBody()	0	9	2
A	buildAttributes()	19	19	4
B	buildHeaders()	22	22	5

<?php

namespace Puzzle\AMQP\Workers;

use Puzzle\AMQP\ReadableMessage;
use Puzzle\AMQP\Messages\Body;

class ReadableMessageModifier
{
    private
        $originalMessage,
        $newRoutingKey,
        $newBody,
        $newAttributeValues,
        $newHeaders,
        $droppedHeaders;
    
    public function __construct(ReadableMessage $originalMessage)
    {
        $this->originalMessage = $originalMessage;
        
        $this->newRoutingKey= $originalMessage->getRoutingKey();
        $this->newBody = null;
        
        $this->newAttributeValues = [];
        $this->newHeaders = [];
        $this->droppedHeaders = [];
    }
    
    public function changeRoutingKey($newRoutingKey)
    {
        $this->newRoutingKey = $newRoutingKey;
        
        return $this;
    }
    
    public function changeBody(Body $newBody)
    {
        $this->newBody = $newBody;
        
        return $this;
    }
    
    public function changeAttribute($name, $value)
    {
        $this->newAttributeValues[$name] = $value;
        
        return $this;
    }
    
    public function addHeader($headerName, $value)
    {
        $this->newHeaders[$headerName] = $value;
        
        return $this;
    }
    public function dropHeader($headerName)
    {
        $this->droppedHeaders[] = $headerName;
        
        return $this;
    }
    
    public function build()
    {
        $properties = $this->buildAttributes(
            $this->originalMessage->getAttributes()
        );
        
        $properties['headers'] = $this->buildHeaders(
            $this->extractHeaders($properties)
        );
        
        return new MessageAdapter(
            new \Swarrot\Broker\Message($this->buildBody(), $properties)
        );
    }
    
    private function extractHeaders(array $properties)
    {
        $headers = [];

        if(isset($properties['headers']))
        {
            $headers = $properties['headers'];
        }
        
        return $headers;
    }
    
    private function buildBody()
    {
        if($this->newBody instanceof Body)
        {
            return $this->newBody->asTransported();
        }
        
        return $this->originalMessage->getBodyAsTransported();
    }
    
    private function buildAttributes(array $attributes)

This method seems to be duplicated in your project.

    {
        if($this->newBody instanceof Body)
        {
            $attributes['content_type'] = $this->newBody->getContentType();
        }
        
        $attributes['routing_key'] = $this->newRoutingKey;
        
        foreach($this->newAttributeValues as $name => $value)
        {
            if(isset($attributes[$name]))
            {
                $attributes[$name] = $value;
            }
        }
        
        return $attributes;
    }
    
    private function buildHeaders(array $headers)

This method seems to be duplicated in your project.

    {
        foreach($this->droppedHeaders as $droppedHeader)
        {
            if(isset($headers[$droppedHeader]))
            {
                unset($headers[$droppedHeader]);
            }
        }
        
        if($this->newBody instanceof Body)
        {
            $headers['transport_content_type'] = $this->newBody->getContentType();
        }

        foreach($this->newHeaders as $name => $value)
        {
            $headers[$name] = $value;
        }
        
        return $headers;
    }
}