ButterAMQP\Message

Complexity

Total Complexity

17

Size/Duplication

Total Lines	183
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getBody()	0	4	1
A	getProperties()	0	4	1
A	hasProperty()	0	4	1
A	getProperty()	0	4	2
A	withProperty()	0	4	1
A	withoutProperty()	0	8	1
A	withProperties()	0	4	1
A	getHeaders()	0	4	1
A	hasHeader()	0	6	1
A	getHeader()	0	6	2
A	withHeader()	0	4	1
A	withoutHeader()	0	11	1
A	withHeaders()	0	6	1
A	__debugInfo()	0	7	1

<?php

namespace ButterAMQP;

class Message
{
    const FLAG_MANDATORY = 0b01;
    const FLAG_IMMEDIATE = 0b10;

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

    /**
     * @var array
     */
    private $properties = [];

    /**
     * @param string $body
     * @param array  $properties
     */
    public function __construct($body, array $properties = [])
    {
        $this->body = $body;
        $this->properties = $properties;
    }

    /**
     * @return string
     */
    public function getBody()
    {
        return $this->body;
    }

    /**
     * @return array
     */
    public function getProperties()
    {
        return $this->properties;
    }

    /**
     * @param string $name
     *
     * @return bool
     */
    public function hasProperty($name)
    {
        return isset($this->properties[$name]);
    }

    /**
     * @param string $name
     * @param mixed  $default
     *
     * @return mixed
     */
    public function getProperty($name, $default = null)
    {
        return $this->hasProperty($name) ? $this->properties[$name] : $default;
    }

    /**
     * @param string $name
     * @param mixed  $value
     *
     * @return Message
     */
    public function withProperty($name, $value)
    {
        return $this->withProperties([$name => $value]);
    }

    /**
     * @param string $name
     *
     * @return Message
     */
    public function withoutProperty($name)
    {
        $properties = $this->properties;

        unset($properties[$name]);

        return new self($this->body, $properties);
    }

    /**
     * @param array $properties
     *
     * @return Message
     */
    public function withProperties(array $properties)
    {
        return new self($this->body, array_merge($this->properties, $properties));
    }

    /**
     * @return array
     */
    public function getHeaders()
    {
        return $this->getProperty('headers', []);
    }

    /**
     * @param string $name
     *
     * @return bool
     */
    public function hasHeader($name)
    {
        $headers = $this->getHeaders();

        return isset($headers[$name]);
    }

    /**
     * @param string $name
     * @param mixed  $default
     *
     * @return mixed
     */
    public function getHeader($name, $default = null)
    {
        $headers = $this->getHeaders();

        return isset($headers[$name]) ? $headers[$name] : $default;
    }

    /**
     * @param string $name
     * @param mixed  $value
     *
     * @return Message
     */
    public function withHeader($name, $value)
    {
        return $this->withHeaders([$name => $value]);
    }

    /**
     * @param string $name
     *
     * @return Message
     */
    public function withoutHeader($name)
    {
        $headers = $this->getHeaders();

        unset($headers[$name]);

        $properties = $this->properties;
        $properties['headers'] = $headers;

        return new self($this->body, $properties);
    }

    /**
     * @param array $headers
     *
     * @return Message
     */
    public function withHeaders(array $headers)
    {
        $headers = array_merge($this->getHeaders(), $headers);

        return $this->withProperty('headers', $headers);
    }

    /**
     * Define how to print object when dumping.
     *
     * @return array
     */
    public function __debugInfo()
    {
        return [
            'properties' => $this->getProperties(),
            'body' => $this->getBody(),
        ];
    }
}