Zapheus\Bridge\Psr\Message

Complexity

Total Complexity

17

Size/Duplication

Total Lines	199
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	hasHeader()	0	3	1
A	withoutHeader()	0	14	2
A	getHeaderLine()	0	3	2
A	withAddedHeader()	0	9	1
A	withBody()	0	9	1
A	getHeaders()	0	3	1
A	getHeader()	0	3	2
A	withProtocolVersion()	0	7	1
A	__construct()	0	16	3
A	withHeader()	0	9	1
A	getBody()	0	3	1
A	getProtocolVersion()	0	3	1

<?php

namespace Zapheus\Bridge\Psr;

use Psr\Http\Message\MessageInterface;
use Psr\Http\Message\StreamInterface;

/**
 * Message
 *
 * @package Zapheus
 * @author  Rougin Gutib <rougingutib@gmail.com>
 */
class Message implements MessageInterface
{
    /**
     * @var \Psr\Http\Message\StreamInterface
     */
    protected $body;

    /**
     * @var array
     */
    protected $headers = array();

    /**
     * @var string
     */
    protected $version = '1.1';

    /**
     * Initializes the message instance.
     *
     * @param \Psr\Http\Message\StreamInterface|null $body
     * @param array                                  $headers
     * @param string                                 $version
     */
    public function __construct(StreamInterface $body = null, array $headers = array(), $version = '1.1')
    {
        if ($body === null)
        {
            $resource = fopen('php://temp', 'r+');

            $resource = $resource === false ? null : $resource;

            $body = new Stream($resource);
        }

        $this->body = $body;

        $this->headers = $headers;

        $this->version = $version;
    }

    /**
     * Returns the body of the message.
     *
     * @return \Psr\Http\Message\StreamInterface
     */
    public function getBody()
    {
        return $this->body;
    }

    /**
     * Retrieves a message header value by the given case-insensitive name.
     *
     * @param  string $name
     * @return string[]
     */
    public function getHeader($name)
    {
        return $this->hasHeader($name) ? $this->headers[$name] : array();
    }

    /**
     * Retrieves a comma-separated string of the values for a single header.
     *
     * @param  string $name
     * @return string
     */
    public function getHeaderLine($name)
    {
        return $this->hasHeader($name) ? implode(',', $this->headers[$name]) : '';
    }

    /**
     * Retrieves all message header values.
     *
     * @return string[][]
     */
    public function getHeaders()
    {
        return $this->headers;
    }

    /**
     * Retrieves the HTTP protocol version as a string.
     *
     * @return string
     */
    public function getProtocolVersion()
    {
        return $this->version;
    }

    /**
     * Retrieves a message header value by the given case-insensitive name.
     *
     * @param  string $name
     * @return string[]
     */
    public function hasHeader($name)
    {
        return isset($this->headers[$name]);
    }

    /**
     * Returns an instance with the specified header appended with the given value.
     *
     * @param  string          $name
     * @param  string|string[] $value
     * @return static
     *
     * @throws \InvalidArgumentException
     */
    public function withAddedHeader($name, $value)
    {
        // TODO: Add \InvalidArgumentException

        $static = clone $this;

        $static->headers[$name][] = $value;

        return $static;
    }

    /**
     * Returns an instance with the specified message body.
     *
     * @param  \Psr\Http\Message\StreamInterface $body
     * @return static
     *
     * @throws \InvalidArgumentException
     */
    public function withBody(StreamInterface $body)
    {
        // TODO: Add \InvalidArgumentException

        $static = clone $this;

        $static->body = $body;

        return $static;
    }

    /**
     * Returns an instance with the provided value replacing the specified header.
     *
     * @param  string          $name
     * @param  string|string[] $value
     * @return static
     *
     * @throws \InvalidArgumentException
     */
    public function withHeader($name, $value)
    {
        // TODO: Add \InvalidArgumentException

        $static = clone $this;

        $static->headers[$name] = (array) $value;

        return $static;
    }

    /**
     * Returns an instance with the specified HTTP protocol version.
     *
     * @param  string $version
     * @return static
     */
    public function withProtocolVersion($version)
    {
        $static = clone $this;

        $static->version = $version;

        return $static;
    }

    /**
     * Returns an instance without the specified header.
     *
     * @param  string $name
     * @return static
     */
    public function withoutHeader($name)
    {
        $instance = clone $this;

        if ($this->hasHeader($name))
        {
            $static = clone $this;

            unset($static->headers[$name]);

            $instance = $static;
        }

        return $instance;
    }
}