DevOp\Core\Http\Traits\MessageTrait

Complexity

Total Complexity

20

Size/Duplication

Total Lines	169
Duplicated Lines	0 %

Test Coverage

Coverage

13.21%

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	getHeaderLine()	0	3	1
A	getHeader()	0	6	2
A	withBody()	0	10	2
A	getHeaders()	0	3	1
A	withHeader()	0	15	3
A	hasHeader()	0	3	1
A	withProtocolVersion()	0	10	2
A	getProtocolVersion()	0	3	1
A	withoutHeader()	0	12	2
A	getBody()	0	3	1
A	withAddedHeader()	0	14	4

<?php
namespace DevOp\Core\Http\Traits;

use Psr\Http\Message\StreamInterface;

trait MessageTrait
{

    /**
     * @var StreamInterface
     */
    protected $body;

    /**
     * @var array
     */
    protected $headers = [];

    /**
     * @var array
     */
    protected $headersName = [];

    /**
     * @var string
     */
    protected $protocolVersion = 1.1;

    /**
     * @var StreamInterface
     */
    protected $stream;

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

    /**
     * @param StreamInterface $body
     * @return self
     */
    public function withBody(StreamInterface $body)
    {
        if ($body === $this->stream) {
            return $this;
        }

        $clone = clone $this;
        $clone->stream = $body;

        return $clone;
    }

    /**
     * @param string $name
     * @return boolean
     */
    public function hasHeader($name)
    {
        return isset($this->headersName[strtolower($name)]);
    }

    /**
     * @param string $name
     * @return mixed
     */
    public function getHeader($name)
    {
        if ($this->hasHeader($name)) {
            return [$this->headers[$this->headersName[strtolower($name)]]];
        }
        return [];
    }

    public function getHeaderLine($name)
    {
        return implode(', ', $this->getHeader($name));
    }

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

    /**
     * @param string $name
     * @param mixed $value
     * @return self
     */
    public function withHeader($name, $value)
    {
        $clone = new $this;

        $normalize = strtolower($name);

        if ($clone->hasHeader($name)) {
            unset($clone->headers[$this->headersName[$normalize]]);
            unset($clone->headersName[$normalize]);
        }

        $clone->headersName[$normalize] = $name;
        $clone->headers[$normalize] = !is_array($value) ? [$value] : $value;

        return $clone;
    }

    /**
     * @param string $name
     * @param mixed $value
     * @return self
     */
    public function withAddedHeader($name, $value)
    {
        $clone = new $this;

        $normalize = strtolower($name);

        if ($clone->hasHeader($name)) {
            $clone->headers[$normalize] = array_merge($this->headers, (!is_array($value) ? [$value] : $value));
        } else {
            $clone->headersName[$normalize] = $name;
            $clone->headers[$normalize] = !is_array($value) ? [$value] : $value;
        }

        return $clone;
    }

    /**
     * @param string $name
     * @return self
     */
    public function withoutHeader($name)
    {
        $clone = new $this;

        $normalize = strtolower($name);

        if ($clone->hasHeader($name)) {
            unset($clone->headers[$this->headersName[$normalize]]);
            unset($clone->headersName[$normalize]);
        }

        return $clone;
    }

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

    /**
     * @param string $version
     * @return self
     */
    public function withProtocolVersion($version)
    {
        if ($version === $this->protocolVersion) {
            return $this;
        }

        $clone = clone $this;
        $clone->protocolVersion = $version;

        return $clone;
    }
}