Message::addHeader() - Code Metrics - Inspection of "feat(messages): handle binary messages" - puzzle-org/amqp - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Pull Request — master (#9)

by Nicolas

created 2017-03-13 17:35 UTC

Message::addHeader() A

↳ Parent: Message

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	6
c	0
b	0
f	0
rs	9.4285
cc	1
eloc	3
nc	1
nop	2

<?php

namespace Puzzle\AMQP\Messages;

use Psr\Log\InvalidArgumentException;
use Puzzle\AMQP\WritableMessage;
use Puzzle\AMQP\ReadableMessage;
use Puzzle\AMQP\Messages\Bodies\NullBody;

class Message implements WritableMessage
{
    use BodySetter;
    
    private
        $body,
class A {
    var $property;
}
        $flags,
        $headers,
        $attributes;

    public function __construct($routingKey = '')
    {
        $this->body = new NullBody();
        $this->flags = AMQP_NOPARAM;
        $this->headers = array();
        $this->initializeAttributes();
        $this->setAttribute('routing_key', $routingKey);
    }
    
    private function initializeAttributes()
    {
        $this->attributes = array(
            'routing_key' => null,
            'content_type' => $this->getContentType(),
            'content_encoding' => 'utf8',
            'message_id' => function($timestamp) {
                return sha1($this->getRoutingKey() . $timestamp . $this->body->footprint() . mt_rand());
            },
            'user_id' => null,
            'app_id' => null,
            'delivery_mode' => self::PERSISTENT,
            'priority' => null,
            'timestamp' => function($timestamp) {
                return $timestamp;
            },
            'expiration' => null,
            'type' => null,
            'reply_to' => null,
            'correlation_id' => null,
            'headers' => function($timestamp) {
                return $this->packHeaders($timestamp);
            },
        );
    }

    public function getContentType()
    {
        return $this->body->getContentType();
    }

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

    public function getFormattedBody()
    {
        return $this->body->format();
    }

    public function setBody(Body $body)
    {
        $this->body = $body;
        $this->updateContentType();
        
        return $this;
    }
    
    private function updateContentType()
    {
        $this->attributes['content_type'] = $this->body->getContentType();
    }
    
    public function getFlags()
    {
        return $this->flags;
    }

    public function setFlags($flags)
    {
        $this->flags = $flags;

        return $this;
    }

    public function addHeader($headerName, $value)
    {
        $this->headers[$headerName] = $value;

        return $this;
    }

    public function addHeaders(array $headers)
    {
        foreach($headers as $name => $value)
        {
            $this->addHeader($name, $value);
        }

        return $this;
    }

    public function setAuthor($author)
    {
        $this->addHeader('author', $author);

        return $this;
    }

    public function packAttributes($timestamp = false)
    {
        $this->updateContentType();
        
        if($timestamp === false)
        {
            $timestamp = (new \DateTime("now"))->getTimestamp();
        }

        return array_map(function($value) use($timestamp) {

            if($value instanceof \Closure)
            {
                $value = $value($timestamp);
            }

            return $value;

        }, $this->attributes);
    }

    private function packHeaders($timestamp)
    {
        $this->headers['message_datetime'] = date('Y-m-d H:i:s', $timestamp);

        return $this->headers;
    }

    public function setAttribute($attributeName, $value)
    {
        if($attributeName !== 'headers')
        {
            if(array_key_exists($attributeName, $this->attributes))
            {
                $this->attributes[$attributeName] = $value;
            }
        }

        return $this;
    }

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

    public function getHeaders()
    {
        $attributes = $this->packAttributes();

        return $attributes['headers'];
    }

    public function getAttribute($attributeName)
    {
        if(array_key_exists($attributeName, $this->attributes))
        {
            return $this->attributes[$attributeName];
        }

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

    public function __toString()
    {
        return json_encode(array(
            'routing_key' => $this->getRoutingKey(),
            'body' => (string) $this->body,
            'attributes' => $this->attributes,
            'flags' => $this->flags
        ));
    }

    public function setExpiration($expirationInSeconds)
    {
        $ttlInMs = 1000 * (int) $expirationInSeconds;

        $this->setAttribute('expiration', (string) $ttlInMs);

        return $this;
    }

    public static function buildFromReadableMessage(ReadableMessage $readableMessage, $newRoutingKey = false)
    {
        $routingKey = $readableMessage->getRoutingKey();

        if($newRoutingKey !== false)
        {
            $routingKey = $newRoutingKey;
        }

        $writableMessage = new static($routingKey);

        // FIXME TODO
        $decodedBody = $readableMessage->getDecodedBody();
        if(! is_array($decodedBody))
        {
            $decodedBody = array($decodedBody);
        }

        // FIXME TODO
        $writableMessage->setText($decodedBody);

        $writableMessage->addHeaders($readableMessage->getHeaders());

        $attributes = $readableMessage->getAttributes();
        $skippedAttributes = array('timestamp', 'headers', 'app_id', 'routing_key');
        foreach($attributes as $attributeName => $value)
        {
            if(! in_array($attributeName, $skippedAttributes))
            {
                $writableMessage->setAttribute($attributeName, $value);
            }
        }

        return $writableMessage;
    }
}


1			<?php
2
3			namespace Puzzle\AMQP\Messages;
4
5			use Psr\Log\InvalidArgumentException;
6			use Puzzle\AMQP\WritableMessage;
7			use Puzzle\AMQP\ReadableMessage;
8			use Puzzle\AMQP\Messages\Bodies\NullBody;
9
10			class Message implements WritableMessage
11			{
12			use BodySetter;
13
14			private
15			$body,
			1 ignored issue – show Coding Style introduced 2017-03-09 13:53 UTC by Report Bug Copy Issue Report The visibility should be declared for property `$body`. The PSR-2 coding standard requires that all properties in a class have their visibility explicitly declared. If you declare a property using class A { var $property; } the property is implicitly global. To learn more about the PSR-2, please see the PHP-FIG site on the PSR-2. Loading history...
16			$flags,
17			$headers,
18			$attributes;
19
20			public function __construct($routingKey = '')
21			{
22			$this->body = new NullBody();
23			$this->flags = AMQP_NOPARAM;
24			$this->headers = array();
25			$this->initializeAttributes();
26			$this->setAttribute('routing_key', $routingKey);
27			}
28
29			private function initializeAttributes()
30			{
31			$this->attributes = array(
32			'routing_key' => null,
33			'content_type' => $this->getContentType(),
34			'content_encoding' => 'utf8',
35			'message_id' => function($timestamp) {
36			return sha1($this->getRoutingKey() . $timestamp . $this->body->footprint() . mt_rand());
37			},
38			'user_id' => null,
39			'app_id' => null,
40			'delivery_mode' => self::PERSISTENT,
41			'priority' => null,
42			'timestamp' => function($timestamp) {
43			return $timestamp;
44			},
45			'expiration' => null,
46			'type' => null,
47			'reply_to' => null,
48			'correlation_id' => null,
49			'headers' => function($timestamp) {
50			return $this->packHeaders($timestamp);
51			},
52			);
53			}
54
55			public function getContentType()
56			{
57			return $this->body->getContentType();
58			}
59
60			public function getRoutingKey()
61			{
62			return $this->getAttribute('routing_key');
63			}
64
65			public function getFormattedBody()
66			{
67			return $this->body->format();
68			}
69
70			public function setBody(Body $body)
71			{
72			$this->body = $body;
73			$this->updateContentType();
74
75			return $this;
76			}
77
78			private function updateContentType()
79			{
80			$this->attributes['content_type'] = $this->body->getContentType();
81			}
82
83			public function getFlags()
84			{
85			return $this->flags;
86			}
87
88			public function setFlags($flags)
89			{
90			$this->flags = $flags;
91
92			return $this;
93			}
94
95			public function addHeader($headerName, $value)
96			{
97			$this->headers[$headerName] = $value;
98
99			return $this;
100			}
101
102			public function addHeaders(array $headers)
103			{
104			foreach($headers as $name => $value)
105			{
106			$this->addHeader($name, $value);
107			}
108
109			return $this;
110			}
111
112			public function setAuthor($author)
113			{
114			$this->addHeader('author', $author);
115
116			return $this;
117			}
118
119			public function packAttributes($timestamp = false)
120			{
121			$this->updateContentType();
122
123			if($timestamp === false)
124			{
125			$timestamp = (new \DateTime("now"))->getTimestamp();
126			}
127
128			return array_map(function($value) use($timestamp) {
129
130			if($value instanceof \Closure)
131			{
132			$value = $value($timestamp);
133			}
134
135			return $value;
136
137			}, $this->attributes);
138			}
139
140			private function packHeaders($timestamp)
141			{
142			$this->headers['message_datetime'] = date('Y-m-d H:i:s', $timestamp);
143
144			return $this->headers;
145			}
146
147			public function setAttribute($attributeName, $value)
148			{
149			if($attributeName !== 'headers')
150			{
151			if(array_key_exists($attributeName, $this->attributes))
152			{
153			$this->attributes[$attributeName] = $value;
154			}
155			}
156
157			return $this;
158			}
159
160			public function getAppId()
161			{
162			return $this->getAttribute('app_id');
163			}
164
165			public function getHeaders()
166			{
167			$attributes = $this->packAttributes();
168
169			return $attributes['headers'];
170			}
171
172			public function getAttribute($attributeName)
173			{
174			if(array_key_exists($attributeName, $this->attributes))
175			{
176			return $this->attributes[$attributeName];
177			}
178
179			throw new InvalidArgumentException(sprintf('Property "%s" is unknown or is not a message property', $attributeName));
180			}
181
182			public function __toString()
183			{
184			return json_encode(array(
185			'routing_key' => $this->getRoutingKey(),
186			'body' => (string) $this->body,
187			'attributes' => $this->attributes,
188			'flags' => $this->flags
189			));
190			}
191
192			public function setExpiration($expirationInSeconds)
193			{
194			$ttlInMs = 1000 * (int) $expirationInSeconds;
195
196			$this->setAttribute('expiration', (string) $ttlInMs);
197
198			return $this;
199			}
200
201			public static function buildFromReadableMessage(ReadableMessage $readableMessage, $newRoutingKey = false)
202			{
203			$routingKey = $readableMessage->getRoutingKey();
204
205			if($newRoutingKey !== false)
206			{
207			$routingKey = $newRoutingKey;
208			}
209
210			$writableMessage = new static($routingKey);
211
212			// FIXME TODO
213			$decodedBody = $readableMessage->getDecodedBody();
214			if(! is_array($decodedBody))
215			{
216			$decodedBody = array($decodedBody);
217			}
218
219			// FIXME TODO
220			$writableMessage->setText($decodedBody);
221
222			$writableMessage->addHeaders($readableMessage->getHeaders());
223
224			$attributes = $readableMessage->getAttributes();
225			$skippedAttributes = array('timestamp', 'headers', 'app_id', 'routing_key');
226			foreach($attributes as $attributeName => $value)
227			{
228			if(! in_array($attributeName, $skippedAttributes))
229			{
230			$writableMessage->setAttribute($attributeName, $value);
231			}
232			}
233
234			return $writableMessage;
235			}
236			}
237

puzzle-org / amqp

Pull Request — master (#9)

Message::addHeader() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like