One\Http\Message

Complexity

Total Complexity

25

Size/Duplication

Total Lines	193
Duplicated Lines	0 %

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	getHeaders()	0	3	1
A	withoutHeader()	0	10	2
A	getBody()	0	6	2
A	getHeaderLine()	0	3	1
A	withAddedHeader()	0	16	3
A	getProtocolVersion()	0	3	1
A	hasHeader()	0	3	1
A	setHeaders()	0	15	4
A	trimHeaderValues()	0	5	1
A	withProtocolVersion()	0	11	2
A	getHeader()	0	9	2
A	withBody()	0	8	2
A	withHeader()	0	14	3

<?php

namespace One\Http;

use Psr\Http\Message\StreamInterface;

/**
 *
 */
class Message implements \Psr\Http\Message\MessageInterface
{
    protected $headers = [];

    protected $headerNames = [];

    protected $protocol = '1.1';

    protected $stream;

    /**
     * @inheritDoc
     */
    public function getProtocolVersion()
    {
        return $this->protocol;
    }
  
    /**
     * @inheritDoc
     */
    public function withProtocolVersion($version)
    {
        if ($this->protocol == $version) {
            return $this;
        }

        $new = clone $this;

        $new->protocol = $version;

        return $new;
    }
  
    /**
     * @inheritDoc
     */
    public function getHeaders()
    {
        return $this->headers;
    }
  
    /**
     * @inheritDoc
     */
    public function hasHeader($name)
    {
        return isset($this->headerNames[strtolower($name)]);
    }
  
    /**
     * @inheritDoc
     */
    public function getHeader($name)
    {
        $lower = strtolower($name);

        if (!isset($this->headerNames[$lower])) {
            return array();
        }

        return $this->headers[$this->headerNames[$lower]];
    }
  
    /**
     * @inheritDoc
     */
    public function getHeaderLine($header)
    {
        return implode(', ', $this->getHeader($header));
    }
  
    /**
     * @inheritDoc
     */
    public function withHeader($header, $value)
    {
        if (!is_array($value)) {
            $value = [$value];
        }
        $value      = $this->trimHeaderValues($value);
        $normalized = strtolower($header);
        $new        = clone $this;
        if (isset($new->headerNames[$normalized])) {
            unset($new->headers[$new->headerNames[$normalized]]);
        }
        $new->headerNames[$normalized] = $header;
        $new->headers[$header]         = $value;
        return $new;
    }
  
    /**
     * @inheritDoc
     */
    public function withAddedHeader($header, $value)
    {
        if (!is_array($value)) {
            $value = [$value];
        }
        $value      = $this->trimHeaderValues($value);
        $normalized = strtolower($header);
        $new        = clone $this;
        if (isset($new->headerNames[$normalized])) {
            $header                = $this->headerNames[$normalized];
            $new->headers[$header] = array_merge($this->headers[$header], $value);
        } else {
            $new->headerNames[$normalized] = $header;
            $new->headers[$header]         = $value;
        }
        return $new;
    }
  
    /**
     * @inheritDoc
     */
    public function withoutHeader($header)
    {
        $normalized = strtolower($header);
        if (!isset($this->headerNames[$normalized])) {
            return $this;
        }
        $header = $this->headerNames[$normalized];
        $new    = clone $this;
        unset($new->headers[$header], $new->headerNames[$normalized]);
        return $new;
    }
  
    /**
     * @inheritDoc
     */
    public function getBody()
    {
        if (!$this->stream) {
            $this->stream = \One\stream_for('');
        }
        return $this->stream;
    }
  
    /**
     * @inheritDoc
     */
    public function withBody(\Psr\Http\Message\StreamInterface $body)
    {
        if ($body === $this->stream) {
            return $this;
        }
        $new = clone $this;
        $new->stream = $body;
        return $new;
    }
  
    /**
     * Set header
     * @param array $headers
     */
    protected function setHeaders(array $headers)
    {
        $this->headerNames = $this->headers = [];
        foreach ($headers as $header => $value) {
            if (!is_array($value)) {
                $value = [$value];
            }
            $value = $this->trimHeaderValues($value);
            $normalized = strtolower($header);
            if (isset($this->headerNames[$normalized])) {
                $header = $this->headerNames[$normalized];
                $this->headers[$header] = array_merge($this->headers[$header], $value);
            } else {
                $this->headerNames[$normalized] = $header;
                $this->headers[$header] = $value;
            }
        }
    }
    
    /**
     * Trims whitespace from the header values.
     *
     * Spaces and tabs ought to be excluded by parsers when extracting the field value from a header field.
     *
     * header-field = field-name ":" OWS field-value OWS
     * OWS          = *( SP / HTAB )
     *
     * @param string[] $values Header values
     *
     * @return string[] Trimmed header values
     *
     * @see https://tools.ietf.org/html/rfc7230#section-3.2.4
     */
    protected function trimHeaderValues(array $values)
    {
        return array_map(function ($value) {
            return trim($value, " \t");
        }, $values);
    }
}