message.php

<?php
 
namespace Bitrix\Main\Web\Http;
 
use Bitrix\Main\Web\HttpHeaders;
use Psr\Http\Message\MessageInterface;
use Psr\Http\Message\StreamInterface;
 
class Message implements MessageInterface
{
    protected HttpHeaders $headers;
    protected StreamInterface $body;
 
    public function __construct(array $headers = null, StreamInterface $body = null, string $version = null)
    {
        $this->headers = new HttpHeaders($headers);
 
        if ($version !== null)
        {
            $this->headers->setVersion($version);
        }
 
        $this->body = $body ?? new Stream('php://temp', 'r+');
    }
 
    public function getProtocolVersion(): string
    {
        return $this->headers->getVersion();
    }
 
    public function withProtocolVersion(string $version): MessageInterface
    {
        if ($this->getProtocolVersion() === $version)
        {
            return $this;
        }
 
        $new = clone $this;
        $new->headers->setVersion($version);
 
        return $new;
    }
 
    public function getHeadersCollection(): HttpHeaders
    {
        return $this->headers;
    }
 
    public function getHeaders(): array
    {
        return $this->headers->getHeaders();
    }
 
    public function hasHeader(string $name): bool
    {
        return $this->headers->has($name);
    }
 
    public function getHeader(string $name): array
    {
        return $this->headers->get($name, true) ?? [];
    }
 
    public function getHeaderLine(string $name): string
    {
        return implode(',', $this->getHeader($name));
    }
 
    public function withHeader(string $name, $value): MessageInterface
    {
        $new = clone $this;
        $new->headers->set($name, $value);
 
        return $new;
    }
 
    public function withAddedHeader(string $name, $value): MessageInterface
    {
        $new = clone $this;
        $new->headers->add($name, $value);
 
        return $new;
    }
 
    public function withoutHeader(string $name): MessageInterface
    {
        $new = clone $this;
        $new->headers->delete($name);
 
        return $new;
    }
 
    public function getBody(): StreamInterface
    {
        return $this->body;
    }
 
    public function withBody(StreamInterface $body): MessageInterface
    {
        $new = clone $this;
        $new->body = $body;
 
        return $new;
    }
 
    public function __clone()
    {
        $this->headers = clone $this->headers;
        $this->body = clone $this->body;
    }
}