news_producer/vendor/hyperf/http-message/src/Server/ResponseProxyTrait.php

<?php

declare(strict_types=1);
/**
 * This file is part of Hyperf.
 *
 * @link     https://www.hyperf.io
 * @document https://hyperf.wiki
 * @contact  group@hyperf.io
 * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
 */

namespace Hyperf\HttpMessage\Server;

use Hyperf\HttpMessage\Cookie\Cookie;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;
use RuntimeException;

trait ResponseProxyTrait
{
    protected ?ResponseInterface $response = null;

    public function setResponse(ResponseInterface $response)
    {
        $this->response = $response;
    }

    public function getResponse(): ResponseInterface
    {
        if (! $this->response instanceof ResponseInterface) {
            throw new RuntimeException('response is invalid.');
        }
        return $this->response;
    }

    public function getProtocolVersion(): string
    {
        return $this->getResponse()->getProtocolVersion();
    }

    public function withProtocolVersion($version): static
    {
        $this->setResponse($this->getResponse()->withProtocolVersion($version));
        return $this;
    }

    public function getHeaders(): array
    {
        return $this->getResponse()->getHeaders();
    }

    public function hasHeader($name): bool
    {
        return $this->getResponse()->hasHeader($name);
    }

    public function getHeader($name): array
    {
        return $this->getResponse()->getHeader($name);
    }

    public function getHeaderLine($name): string
    {
        return $this->getResponse()->getHeaderLine($name);
    }

    public function withHeader($name, $value): static
    {
        $this->setResponse($this->getResponse()->withHeader($name, $value));
        return $this;
    }

    public function withAddedHeader($name, $value): static
    {
        $this->setResponse($this->getResponse()->withAddedHeader($name, $value));
        return $this;
    }

    public function withoutHeader($name): static
    {
        $this->setResponse($this->getResponse()->withoutHeader($name));
        return $this;
    }

    public function getBody(): StreamInterface
    {
        return $this->getResponse()->getBody();
    }

    public function withBody(StreamInterface $body): static
    {
        $this->setResponse($this->getResponse()->withBody($body));
        return $this;
    }

    public function getStatusCode(): int
    {
        return $this->getResponse()->getStatusCode();
    }

    public function withStatus($code, $reasonPhrase = ''): static
    {
        $this->setResponse($this->getResponse()->withStatus($code, $reasonPhrase));
        return $this;
    }

    public function getReasonPhrase(): string
    {
        return $this->getResponse()->getReasonPhrase();
    }

    /**
     * Returns an instance with specified cookies.
     */
    public function withCookie(Cookie $cookie): static
    {
        $response = $this->getResponse();
        if (! method_exists($response, 'withCookie')) {
            throw new RuntimeException('Method withCookie is invalid.');
        }

        $this->setResponse($response->withCookie($cookie));
        return $this;
    }

    /**
     * Retrieves all cookies.
     */
    public function getCookies(): array
    {
        $response = $this->getResponse();
        if (! method_exists($response, 'getCookies')) {
            throw new RuntimeException('Method getCookies is invalid.');
        }
        return $response->getCookies();
    }

    /**
     * Returns an instance with specified trailer.
     * @param string $value
     */
    public function withTrailer(string $key, $value): static
    {
        $response = $this->getResponse();
        if (! method_exists($response, 'withTrailer')) {
            throw new RuntimeException('Method withTrailer is invalid.');
        }
        $this->setResponse($response->withTrailer($key, $value));
        return $this;
    }

    /**
     * Retrieves a specified trailer value, returns null if the value does not exists.
     */
    public function getTrailer(string $key)
    {
        $response = $this->getResponse();
        if (! method_exists($response, 'getTrailer')) {
            throw new RuntimeException('Method getTrailer is invalid.');
        }
        return $response->getTrailer($key);
    }

    /**
     * Retrieves all trailers values.
     */
    public function getTrailers(): array
    {
        $response = $this->getResponse();
        if (! method_exists($response, 'getTrailers')) {
            throw new RuntimeException('Method getTrailers is invalid.');
        }
        return $response->getTrailers();
    }
}