sunrise-php / http-message

src/ResponseFactory.php

Indentation +7 added lines, -7 removed lines

@@ -16,11 +16,11 @@
 
 class ResponseFactory implements ResponseFactoryInterface
 {
-    /**
-     * @inheritDoc
-     */
-    public function createResponse(int $code = 200, string $reasonPhrase = ''): ResponseInterface
-    {
-        return new Response($code, $reasonPhrase);
-    }
+	/**
+	 * @inheritDoc
+	 */
+	public function createResponse(int $code = 200, string $reasonPhrase = ''): ResponseInterface
+	{
+		return new Response($code, $reasonPhrase);
+	}
 }

src/Response/HtmlResponse.php

Indentation +38 added lines, -38 removed lines

@@ -22,42 +22,42 @@
 
 final class HtmlResponse extends Response
 {
-    /**
-     * @param mixed $html
-     *
-     * @throws InvalidArgumentException
-     */
-    public function __construct(int $statusCode, $html)
-    {
-        parent::__construct($statusCode);
-
-        $this->setBody(self::createBody($html));
-        $this->setHeader('Content-Type', 'text/html; charset=utf-8');
-    }
-
-    /**
-     * @param mixed $html
-     *
-     * @throws InvalidArgumentException
-     */
-    private static function createBody($html): StreamInterface
-    {
-        if ($html instanceof StreamInterface) {
-            return $html;
-        }
-
-        if (is_object($html) && method_exists($html, '__toString')) {
-            $html = (string) $html;
-        }
-
-        if (!is_string($html)) {
-            throw new InvalidArgumentException('Unable to create the HTML response due to a unexpected HTML type');
-        }
-
-        $stream = new PhpTempStream('r+b');
-        $stream->write($html);
-        $stream->rewind();
-
-        return $stream;
-    }
+	/**
+	 * @param mixed $html
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function __construct(int $statusCode, $html)
+	{
+		parent::__construct($statusCode);
+
+		$this->setBody(self::createBody($html));
+		$this->setHeader('Content-Type', 'text/html; charset=utf-8');
+	}
+
+	/**
+	 * @param mixed $html
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private static function createBody($html): StreamInterface
+	{
+		if ($html instanceof StreamInterface) {
+			return $html;
+		}
+
+		if (is_object($html) && method_exists($html, '__toString')) {
+			$html = (string) $html;
+		}
+
+		if (!is_string($html)) {
+			throw new InvalidArgumentException('Unable to create the HTML response due to a unexpected HTML type');
+		}
+
+		$stream = new PhpTempStream('r+b');
+		$stream->write($html);
+		$stream->rewind();
+
+		return $stream;
+	}
 }

src/Request/UrlEncodedRequest.php

Indentation +40 added lines, -40 removed lines

@@ -31,51 +31,51 @@
  */
 final class UrlEncodedRequest extends Request
 {
-    public const ENCODING_TYPE_RFC1738 = PHP_QUERY_RFC1738;
-    public const ENCODING_TYPE_RFC3986 = PHP_QUERY_RFC3986;
+	public const ENCODING_TYPE_RFC1738 = PHP_QUERY_RFC1738;
+	public const ENCODING_TYPE_RFC3986 = PHP_QUERY_RFC3986;
 
-    /**
-     * @param mixed $uri
-     * @param array<array-key, mixed>|object $data
-     * @param self::ENCODING_TYPE_* $encodingType
-     *
-     * @throws InvalidArgumentException
-     */
-    public function __construct(string $method, $uri, $data, int $encodingType = self::ENCODING_TYPE_RFC1738)
-    {
-        /**
-         * @psalm-suppress DocblockTypeContradiction
-         * @phpstan-ignore-next-line
-         */
-        if (!is_array($data) && !is_object($data)) {
-            throw new TypeError(sprintf(
-                'Argument #3 ($data) must be of type string, %s given',
-                gettype($data),
-            ));
-        }
+	/**
+	 * @param mixed $uri
+	 * @param array<array-key, mixed>|object $data
+	 * @param self::ENCODING_TYPE_* $encodingType
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function __construct(string $method, $uri, $data, int $encodingType = self::ENCODING_TYPE_RFC1738)
+	{
+		/**
+		 * @psalm-suppress DocblockTypeContradiction
+		 * @phpstan-ignore-next-line
+		 */
+		if (!is_array($data) && !is_object($data)) {
+			throw new TypeError(sprintf(
+				'Argument #3 ($data) must be of type string, %s given',
+				gettype($data),
+			));
+		}
 
-        parent::__construct($method, $uri);
+		parent::__construct($method, $uri);
 
-        $this->setBody(self::createBody($data, $encodingType));
-        $this->setHeader('Content-Type', 'application/x-www-form-urlencoded; charset=utf-8');
-    }
+		$this->setBody(self::createBody($data, $encodingType));
+		$this->setHeader('Content-Type', 'application/x-www-form-urlencoded; charset=utf-8');
+	}
 
-    /**
-     * @param array<array-key, mixed>|object $data
-     * @param self::ENCODING_TYPE_* $encodingType
-     */
-    private static function createBody($data, int $encodingType): StreamInterface
-    {
-        if ($data instanceof StreamInterface) {
-            return $data;
-        }
+	/**
+	 * @param array<array-key, mixed>|object $data
+	 * @param self::ENCODING_TYPE_* $encodingType
+	 */
+	private static function createBody($data, int $encodingType): StreamInterface
+	{
+		if ($data instanceof StreamInterface) {
+			return $data;
+		}
 
-        $encodedData = http_build_query($data, '', '', $encodingType);
+		$encodedData = http_build_query($data, '', '', $encodingType);
 
-        $stream = new PhpTempStream('r+b');
-        $stream->write($encodedData);
-        $stream->rewind();
+		$stream = new PhpTempStream('r+b');
+		$stream->write($encodedData);
+		$stream->rewind();
 
-        return $stream;
-    }
+		return $stream;
+	}
 }

src/Message.php

Indentation +292 added lines, -292 removed lines

@@ -24,296 +24,296 @@
 
 abstract class Message implements MessageInterface
 {
-    /**
-     * @deprecated 3.2.0
-     */
-    public const ALLOWED_HTTP_VERSIONS = ['1.0', '1.1', '2.0', '2'];
-
-    public const HTTP_VERSION_REGEX = '/^[0-9](?:[.][0-9])?$/';
-    public const DEFAULT_HTTP_VERSION = '1.1';
-
-    private string $protocolVersion = self::DEFAULT_HTTP_VERSION;
-
-    /**
-     * @var array<string, list<string>>
-     */
-    private array $headers = [];
-
-    /**
-     * @var array<string, string>
-     */
-    private array $headerNames = [];
-
-    private ?StreamInterface $body = null;
-
-    /**
-     * @inheritDoc
-     */
-    public function getProtocolVersion(): string
-    {
-        return $this->protocolVersion;
-    }
-
-    /**
-     * @inheritDoc
-     *
-     * @throws InvalidArgumentException
-     */
-    public function withProtocolVersion($version): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->setProtocolVersion($version);
-
-        return $clone;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getHeaders(): array
-    {
-        return $this->headers;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function hasHeader($name): bool
-    {
-        $key = strtolower($name);
-
-        return isset($this->headerNames[$key]);
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getHeader($name): array
-    {
-        $key = strtolower($name);
-
-        if (!isset($this->headerNames[$key])) {
-            return [];
-        }
-
-        return $this->headers[$this->headerNames[$key]];
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getHeaderLine($name): string
-    {
-        $key = strtolower($name);
-
-        if (!isset($this->headerNames[$key])) {
-            return '';
-        }
-
-        return implode(',', $this->headers[$this->headerNames[$key]]);
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function withHeader($name, $value): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->setHeader($name, $value, true);
-
-        return $clone;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function withAddedHeader($name, $value): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->setHeader($name, $value, false);
-
-        return $clone;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function withoutHeader($name): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->deleteHeader($name);
-
-        return $clone;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getBody(): StreamInterface
-    {
-        return $this->body ??= new PhpTempStream();
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function withBody(StreamInterface $body): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->setBody($body);
-
-        return $clone;
-    }
-
-    /**
-     * Sets the given HTTP version to the message
-     *
-     * @param string $protocolVersion
-     *
-     * @throws InvalidArgumentException
-     */
-    final protected function setProtocolVersion($protocolVersion): void
-    {
-        $this->validateProtocolVersion($protocolVersion);
-
-        $this->protocolVersion = $protocolVersion;
-    }
-
-    /**
-     * Sets a new header to the message with the given name and value(s)
-     *
-     * @param string $name
-     * @param string|string[] $value
-     *
-     * @throws InvalidArgumentException
-     */
-    final protected function setHeader($name, $value, bool $replace = true): void
-    {
-        if (!is_array($value)) {
-            $value = [$value];
-        }
-
-        $this->validateHeaderName($name);
-        $this->validateHeaderValue($name, $value);
-
-        $replace and $this->deleteHeader($name);
-
-        $key = strtolower($name);
-
-        $this->headerNames[$key] ??= $name;
-        $this->headers[$this->headerNames[$key]] ??= [];
-
-        foreach ($value as $item) {
-            $this->headers[$this->headerNames[$key]][] = $item;
-        }
-    }
-
-    /**
-     * Sets the given headers to the message
-     *
-     * @param array<string, string|string[]> $headers
-     *
-     * @throws InvalidArgumentException
-     */
-    final protected function setHeaders(array $headers): void
-    {
-        foreach ($headers as $name => $value) {
-            $this->setHeader($name, $value, false);
-        }
-    }
-
-    /**
-     * Deletes a header from the message by the given name
-     *
-     * @param string $name
-     */
-    final protected function deleteHeader($name): void
-    {
-        $key = strtolower($name);
-
-        if (isset($this->headerNames[$key])) {
-            unset($this->headers[$this->headerNames[$key]]);
-            unset($this->headerNames[$key]);
-        }
-    }
-
-    /**
-     * Sets the given body to the message
-     */
-    final protected function setBody(StreamInterface $body): void
-    {
-        $this->body = $body;
-    }
-
-    /**
-     * Validates the given HTTP version
-     *
-     * @param mixed $protocolVersion
-     *
-     * @throws InvalidArgumentException
-     */
-    private function validateProtocolVersion($protocolVersion): void
-    {
-        if ($protocolVersion === '') {
-            throw new InvalidArgumentException('HTTP version cannot be an empty');
-        }
-
-        if (!is_string($protocolVersion)) {
-            throw new InvalidArgumentException('HTTP version must be a string');
-        }
-
-        if (!preg_match(self::HTTP_VERSION_REGEX, $protocolVersion)) {
-            throw new InvalidArgumentException('HTTP version is invalid');
-        }
-    }
-
-    /**
-     * Validates the given header name
-     *
-     * @param mixed $name
-     *
-     * @throws InvalidArgumentException
-     */
-    private function validateHeaderName($name): void
-    {
-        if ($name === '') {
-            throw new InvalidArgumentException('HTTP header name cannot be an empty');
-        }
-
-        if (!is_string($name)) {
-            throw new InvalidArgumentException('HTTP header name must be a string');
-        }
-
-        if (!preg_match(HeaderInterface::RFC7230_TOKEN_REGEX, $name)) {
-            throw new InvalidArgumentException('HTTP header name is invalid');
-        }
-    }
-
-    /**
-     * Validates the given header value
-     *
-     * @param array<array-key, mixed> $value
-     *
-     * @throws InvalidArgumentException
-     */
-    private function validateHeaderValue(string $name, array $value): void
-    {
-        if ($value === []) {
-            throw new InvalidArgumentException("The value of the HTTP header $name cannot be an empty array");
-        }
-
-        foreach ($value as $key => $item) {
-            if ($item === '') {
-                continue;
-            }
-
-            if (!is_string($item)) {
-                throw new InvalidArgumentException("The value of the HTTP header $name:$key must be a string");
-            }
-
-            if (!preg_match(HeaderInterface::RFC7230_FIELD_VALUE_REGEX, $item)) {
-                throw new InvalidArgumentException("The value of the HTTP header $name:$key is invalid");
-            }
-        }
-    }
+	/**
+	 * @deprecated 3.2.0
+	 */
+	public const ALLOWED_HTTP_VERSIONS = ['1.0', '1.1', '2.0', '2'];
+
+	public const HTTP_VERSION_REGEX = '/^[0-9](?:[.][0-9])?$/';
+	public const DEFAULT_HTTP_VERSION = '1.1';
+
+	private string $protocolVersion = self::DEFAULT_HTTP_VERSION;
+
+	/**
+	 * @var array<string, list<string>>
+	 */
+	private array $headers = [];
+
+	/**
+	 * @var array<string, string>
+	 */
+	private array $headerNames = [];
+
+	private ?StreamInterface $body = null;
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getProtocolVersion(): string
+	{
+		return $this->protocolVersion;
+	}
+
+	/**
+	 * @inheritDoc
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function withProtocolVersion($version): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->setProtocolVersion($version);
+
+		return $clone;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getHeaders(): array
+	{
+		return $this->headers;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function hasHeader($name): bool
+	{
+		$key = strtolower($name);
+
+		return isset($this->headerNames[$key]);
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getHeader($name): array
+	{
+		$key = strtolower($name);
+
+		if (!isset($this->headerNames[$key])) {
+			return [];
+		}
+
+		return $this->headers[$this->headerNames[$key]];
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getHeaderLine($name): string
+	{
+		$key = strtolower($name);
+
+		if (!isset($this->headerNames[$key])) {
+			return '';
+		}
+
+		return implode(',', $this->headers[$this->headerNames[$key]]);
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function withHeader($name, $value): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->setHeader($name, $value, true);
+
+		return $clone;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function withAddedHeader($name, $value): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->setHeader($name, $value, false);
+
+		return $clone;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function withoutHeader($name): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->deleteHeader($name);
+
+		return $clone;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getBody(): StreamInterface
+	{
+		return $this->body ??= new PhpTempStream();
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function withBody(StreamInterface $body): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->setBody($body);
+
+		return $clone;
+	}
+
+	/**
+	 * Sets the given HTTP version to the message
+	 *
+	 * @param string $protocolVersion
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	final protected function setProtocolVersion($protocolVersion): void
+	{
+		$this->validateProtocolVersion($protocolVersion);
+
+		$this->protocolVersion = $protocolVersion;
+	}
+
+	/**
+	 * Sets a new header to the message with the given name and value(s)
+	 *
+	 * @param string $name
+	 * @param string|string[] $value
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	final protected function setHeader($name, $value, bool $replace = true): void
+	{
+		if (!is_array($value)) {
+			$value = [$value];
+		}
+
+		$this->validateHeaderName($name);
+		$this->validateHeaderValue($name, $value);
+
+		$replace and $this->deleteHeader($name);
+
+		$key = strtolower($name);
+
+		$this->headerNames[$key] ??= $name;
+		$this->headers[$this->headerNames[$key]] ??= [];
+
+		foreach ($value as $item) {
+			$this->headers[$this->headerNames[$key]][] = $item;
+		}
+	}
+
+	/**
+	 * Sets the given headers to the message
+	 *
+	 * @param array<string, string|string[]> $headers
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	final protected function setHeaders(array $headers): void
+	{
+		foreach ($headers as $name => $value) {
+			$this->setHeader($name, $value, false);
+		}
+	}
+
+	/**
+	 * Deletes a header from the message by the given name
+	 *
+	 * @param string $name
+	 */
+	final protected function deleteHeader($name): void
+	{
+		$key = strtolower($name);
+
+		if (isset($this->headerNames[$key])) {
+			unset($this->headers[$this->headerNames[$key]]);
+			unset($this->headerNames[$key]);
+		}
+	}
+
+	/**
+	 * Sets the given body to the message
+	 */
+	final protected function setBody(StreamInterface $body): void
+	{
+		$this->body = $body;
+	}
+
+	/**
+	 * Validates the given HTTP version
+	 *
+	 * @param mixed $protocolVersion
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private function validateProtocolVersion($protocolVersion): void
+	{
+		if ($protocolVersion === '') {
+			throw new InvalidArgumentException('HTTP version cannot be an empty');
+		}
+
+		if (!is_string($protocolVersion)) {
+			throw new InvalidArgumentException('HTTP version must be a string');
+		}
+
+		if (!preg_match(self::HTTP_VERSION_REGEX, $protocolVersion)) {
+			throw new InvalidArgumentException('HTTP version is invalid');
+		}
+	}
+
+	/**
+	 * Validates the given header name
+	 *
+	 * @param mixed $name
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private function validateHeaderName($name): void
+	{
+		if ($name === '') {
+			throw new InvalidArgumentException('HTTP header name cannot be an empty');
+		}
+
+		if (!is_string($name)) {
+			throw new InvalidArgumentException('HTTP header name must be a string');
+		}
+
+		if (!preg_match(HeaderInterface::RFC7230_TOKEN_REGEX, $name)) {
+			throw new InvalidArgumentException('HTTP header name is invalid');
+		}
+	}
+
+	/**
+	 * Validates the given header value
+	 *
+	 * @param array<array-key, mixed> $value
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private function validateHeaderValue(string $name, array $value): void
+	{
+		if ($value === []) {
+			throw new InvalidArgumentException("The value of the HTTP header $name cannot be an empty array");
+		}
+
+		foreach ($value as $key => $item) {
+			if ($item === '') {
+				continue;
+			}
+
+			if (!is_string($item)) {
+				throw new InvalidArgumentException("The value of the HTTP header $name:$key must be a string");
+			}
+
+			if (!preg_match(HeaderInterface::RFC7230_FIELD_VALUE_REGEX, $item)) {
+				throw new InvalidArgumentException("The value of the HTTP header $name:$key is invalid");
+			}
+		}
+	}
 }

src/ServerRequest.php

Indentation +313 added lines, -313 removed lines

@@ -23,317 +23,317 @@
 
 class ServerRequest extends Request implements ServerRequestInterface
 {
-    /**
-     * @var array<array-key, mixed>
-     */
-    private array $serverParams;
-
-    /**
-     * @var array<array-key, mixed>
-     */
-    private array $queryParams;
-
-    /**
-     * @var array<array-key, mixed>
-     */
-    private array $cookieParams;
-
-    /**
-     * @var array<array-key, mixed>
-     */
-    private array $uploadedFiles = [];
-
-    /**
-     * @var array<array-key, mixed>|object|null
-     */
-    private $parsedBody = null;
-
-    /**
-     * @var array<array-key, mixed>
-     */
-    private array $attributes;
-
-    /**
-     * Constructor of the class
-     *
-     * @param mixed $uri
-     * @param array<string, string|string[]>|null $headers
-     *
-     * @param array<array-key, mixed> $serverParams
-     * @param array<array-key, mixed> $queryParams
-     * @param array<array-key, mixed> $cookieParams
-     * @param array<array-key, mixed> $uploadedFiles
-     * @param array<array-key, mixed>|object|null $parsedBody
-     * @param array<array-key, mixed> $attributes
-     *
-     * @throws InvalidArgumentException
-     */
-    public function __construct(
-        ?string $protocolVersion = null,
-        ?string $method = null,
-        $uri = null,
-        ?array $headers = null,
-        ?StreamInterface $body = null,
-        array $serverParams = [],
-        array $queryParams = [],
-        array $cookieParams = [],
-        array $uploadedFiles = [],
-        $parsedBody = null,
-        array $attributes = []
-    ) {
-        parent::__construct($method, $uri, $headers, $body);
-
-        if ($protocolVersion !== null) {
-            $this->setProtocolVersion($protocolVersion);
-        }
-
-        if ($uploadedFiles !== []) {
-            $this->setUploadedFiles($uploadedFiles);
-        }
-
-        if ($parsedBody !== null) {
-            $this->setParsedBody($parsedBody);
-        }
-
-        $this->serverParams = $serverParams;
-        $this->queryParams = $queryParams;
-        $this->cookieParams = $cookieParams;
-        $this->attributes = $attributes;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @return array<array-key, mixed>
-     */
-    public function getServerParams(): array
-    {
-        return $this->serverParams;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @return array<array-key, mixed>
-     */
-    public function getQueryParams(): array
-    {
-        return $this->queryParams;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @param array<array-key, mixed> $query
-     *
-     * @return static
-     */
-    public function withQueryParams(array $query): ServerRequestInterface
-    {
-        $clone = clone $this;
-        $clone->queryParams = $query;
-
-        return $clone;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @return array<array-key, mixed>
-     */
-    public function getCookieParams(): array
-    {
-        return $this->cookieParams;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @param array<array-key, mixed> $cookies
-     *
-     * @return static
-     */
-    public function withCookieParams(array $cookies): ServerRequestInterface
-    {
-        $clone = clone $this;
-        $clone->cookieParams = $cookies;
-
-        return $clone;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @return array<array-key, mixed>
-     */
-    public function getUploadedFiles(): array
-    {
-        return $this->uploadedFiles;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @param array<array-key, mixed> $uploadedFiles
-     *
-     * @return static
-     *
-     * @throws InvalidArgumentException
-     */
-    public function withUploadedFiles(array $uploadedFiles): ServerRequestInterface
-    {
-        $clone = clone $this;
-        $clone->setUploadedFiles($uploadedFiles);
-
-        return $clone;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @return array<array-key, mixed>|object|null
-     */
-    public function getParsedBody()
-    {
-        return $this->parsedBody;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @param array<array-key, mixed>|object|null $data
-     *
-     * @return static
-     *
-     * @throws InvalidArgumentException
-     */
-    public function withParsedBody($data): ServerRequestInterface
-    {
-        $clone = clone $this;
-        $clone->setParsedBody($data);
-
-        return $clone;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @return array<array-key, mixed>
-     */
-    public function getAttributes(): array
-    {
-        return $this->attributes;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @param array-key $name
-     * @param mixed $default
-     *
-     * @return mixed
-     */
-    public function getAttribute($name, $default = null)
-    {
-        if (!array_key_exists($name, $this->attributes)) {
-            return $default;
-        }
-
-        return $this->attributes[$name];
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @param array-key $name
-     * @param mixed $value
-     *
-     * @return static
-     */
-    public function withAttribute($name, $value): ServerRequestInterface
-    {
-        $clone = clone $this;
-        $clone->attributes[$name] = $value;
-
-        return $clone;
-    }
-
-    /**
-     * {@inheritDoc}
-     *
-     * @param array-key $name
-     *
-     * @return static
-     */
-    public function withoutAttribute($name): ServerRequestInterface
-    {
-        $clone = clone $this;
-        unset($clone->attributes[$name]);
-
-        return $clone;
-    }
-
-    /**
-     * Sets the given uploaded files to the request
-     *
-     * @param array<array-key, mixed> $files
-     *
-     * @throws InvalidArgumentException
-     */
-    final protected function setUploadedFiles(array $files): void
-    {
-        $this->validateUploadedFiles($files);
-
-        $this->uploadedFiles = $files;
-    }
-
-    /**
-     * Sets the given parsed body to the request
-     *
-     * @param array<array-key, mixed>|object|null $data
-     *
-     * @throws InvalidArgumentException
-     */
-    final protected function setParsedBody($data): void
-    {
-        $this->validateParsedBody($data);
-
-        $this->parsedBody = $data;
-    }
-
-    /**
-     * Validates the given uploaded files
-     *
-     * @param array<array-key, mixed> $files
-     *
-     * @throws InvalidArgumentException
-     */
-    private function validateUploadedFiles(array $files): void
-    {
-        if ($files === []) {
-            return;
-        }
-
-        array_walk_recursive($files, /** @param mixed $file */ static function ($file): void {
-            if (!($file instanceof UploadedFileInterface)) {
-                throw new InvalidArgumentException('Invalid uploaded file');
-            }
-        });
-    }
-
-    /**
-     * Validates the given parsed body
-     *
-     * @param mixed $data
-     *
-     * @throws InvalidArgumentException
-     */
-    private function validateParsedBody($data): void
-    {
-        if ($data === null || is_array($data) || is_object($data)) {
-            return;
-        }
-
-        throw new InvalidArgumentException('Invalid parsed body');
-    }
+	/**
+	 * @var array<array-key, mixed>
+	 */
+	private array $serverParams;
+
+	/**
+	 * @var array<array-key, mixed>
+	 */
+	private array $queryParams;
+
+	/**
+	 * @var array<array-key, mixed>
+	 */
+	private array $cookieParams;
+
+	/**
+	 * @var array<array-key, mixed>
+	 */
+	private array $uploadedFiles = [];
+
+	/**
+	 * @var array<array-key, mixed>|object|null
+	 */
+	private $parsedBody = null;
+
+	/**
+	 * @var array<array-key, mixed>
+	 */
+	private array $attributes;
+
+	/**
+	 * Constructor of the class
+	 *
+	 * @param mixed $uri
+	 * @param array<string, string|string[]>|null $headers
+	 *
+	 * @param array<array-key, mixed> $serverParams
+	 * @param array<array-key, mixed> $queryParams
+	 * @param array<array-key, mixed> $cookieParams
+	 * @param array<array-key, mixed> $uploadedFiles
+	 * @param array<array-key, mixed>|object|null $parsedBody
+	 * @param array<array-key, mixed> $attributes
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function __construct(
+		?string $protocolVersion = null,
+		?string $method = null,
+		$uri = null,
+		?array $headers = null,
+		?StreamInterface $body = null,
+		array $serverParams = [],
+		array $queryParams = [],
+		array $cookieParams = [],
+		array $uploadedFiles = [],
+		$parsedBody = null,
+		array $attributes = []
+	) {
+		parent::__construct($method, $uri, $headers, $body);
+
+		if ($protocolVersion !== null) {
+			$this->setProtocolVersion($protocolVersion);
+		}
+
+		if ($uploadedFiles !== []) {
+			$this->setUploadedFiles($uploadedFiles);
+		}
+
+		if ($parsedBody !== null) {
+			$this->setParsedBody($parsedBody);
+		}
+
+		$this->serverParams = $serverParams;
+		$this->queryParams = $queryParams;
+		$this->cookieParams = $cookieParams;
+		$this->attributes = $attributes;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @return array<array-key, mixed>
+	 */
+	public function getServerParams(): array
+	{
+		return $this->serverParams;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @return array<array-key, mixed>
+	 */
+	public function getQueryParams(): array
+	{
+		return $this->queryParams;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @param array<array-key, mixed> $query
+	 *
+	 * @return static
+	 */
+	public function withQueryParams(array $query): ServerRequestInterface
+	{
+		$clone = clone $this;
+		$clone->queryParams = $query;
+
+		return $clone;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @return array<array-key, mixed>
+	 */
+	public function getCookieParams(): array
+	{
+		return $this->cookieParams;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @param array<array-key, mixed> $cookies
+	 *
+	 * @return static
+	 */
+	public function withCookieParams(array $cookies): ServerRequestInterface
+	{
+		$clone = clone $this;
+		$clone->cookieParams = $cookies;
+
+		return $clone;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @return array<array-key, mixed>
+	 */
+	public function getUploadedFiles(): array
+	{
+		return $this->uploadedFiles;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @param array<array-key, mixed> $uploadedFiles
+	 *
+	 * @return static
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function withUploadedFiles(array $uploadedFiles): ServerRequestInterface
+	{
+		$clone = clone $this;
+		$clone->setUploadedFiles($uploadedFiles);
+
+		return $clone;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @return array<array-key, mixed>|object|null
+	 */
+	public function getParsedBody()
+	{
+		return $this->parsedBody;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @param array<array-key, mixed>|object|null $data
+	 *
+	 * @return static
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function withParsedBody($data): ServerRequestInterface
+	{
+		$clone = clone $this;
+		$clone->setParsedBody($data);
+
+		return $clone;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @return array<array-key, mixed>
+	 */
+	public function getAttributes(): array
+	{
+		return $this->attributes;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @param array-key $name
+	 * @param mixed $default
+	 *
+	 * @return mixed
+	 */
+	public function getAttribute($name, $default = null)
+	{
+		if (!array_key_exists($name, $this->attributes)) {
+			return $default;
+		}
+
+		return $this->attributes[$name];
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @param array-key $name
+	 * @param mixed $value
+	 *
+	 * @return static
+	 */
+	public function withAttribute($name, $value): ServerRequestInterface
+	{
+		$clone = clone $this;
+		$clone->attributes[$name] = $value;
+
+		return $clone;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @param array-key $name
+	 *
+	 * @return static
+	 */
+	public function withoutAttribute($name): ServerRequestInterface
+	{
+		$clone = clone $this;
+		unset($clone->attributes[$name]);
+
+		return $clone;
+	}
+
+	/**
+	 * Sets the given uploaded files to the request
+	 *
+	 * @param array<array-key, mixed> $files
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	final protected function setUploadedFiles(array $files): void
+	{
+		$this->validateUploadedFiles($files);
+
+		$this->uploadedFiles = $files;
+	}
+
+	/**
+	 * Sets the given parsed body to the request
+	 *
+	 * @param array<array-key, mixed>|object|null $data
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	final protected function setParsedBody($data): void
+	{
+		$this->validateParsedBody($data);
+
+		$this->parsedBody = $data;
+	}
+
+	/**
+	 * Validates the given uploaded files
+	 *
+	 * @param array<array-key, mixed> $files
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private function validateUploadedFiles(array $files): void
+	{
+		if ($files === []) {
+			return;
+		}
+
+		array_walk_recursive($files, /** @param mixed $file */ static function ($file): void {
+			if (!($file instanceof UploadedFileInterface)) {
+				throw new InvalidArgumentException('Invalid uploaded file');
+			}
+		});
+	}
+
+	/**
+	 * Validates the given parsed body
+	 *
+	 * @param mixed $data
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private function validateParsedBody($data): void
+	{
+		if ($data === null || is_array($data) || is_object($data)) {
+			return;
+		}
+
+		throw new InvalidArgumentException('Invalid parsed body');
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -314,7 +314,7 @@
             return;
         }
 
-        array_walk_recursive($files, /** @param mixed $file */ static function ($file): void {
+        array_walk_recursive($files, /** @param mixed $file */ static function($file): void {
             if (!($file instanceof UploadedFileInterface)) {
                 throw new InvalidArgumentException('Invalid uploaded file');
             }

resources/definitions/psr17.php

Indentation +6 added lines, -6 removed lines

@@ -18,10 +18,10 @@
 use function DI\create;
 
 return [
-    RequestFactoryInterface::class => create(RequestFactory::class),
-    ResponseFactoryInterface::class => create(ResponseFactory::class),
-    ServerRequestFactoryInterface::class => create(ServerRequestFactory::class),
-    StreamFactoryInterface::class => create(StreamFactory::class),
-    UploadedFileFactoryInterface::class => create(UploadedFileFactory::class),
-    UriFactoryInterface::class => create(UriFactory::class),
+	RequestFactoryInterface::class => create(RequestFactory::class),
+	ResponseFactoryInterface::class => create(ResponseFactory::class),
+	ServerRequestFactoryInterface::class => create(ServerRequestFactory::class),
+	StreamFactoryInterface::class => create(StreamFactory::class),
+	UploadedFileFactoryInterface::class => create(UploadedFileFactory::class),
+	UriFactoryInterface::class => create(UriFactory::class),
 ];

src/UploadedFile.php

Indentation +136 added lines, -136 removed lines

@@ -40,140 +40,140 @@
 
 class UploadedFile implements UploadedFileInterface
 {
-    /**
-     * @link https://www.php.net/manual/en/features.file-upload.errors.php
-     *
-     * @var array<int, non-empty-string>
-     */
-    public const UPLOAD_ERRORS = [
-        UPLOAD_ERR_OK         => 'No error',
-        UPLOAD_ERR_INI_SIZE   => 'Uploaded file exceeds the upload_max_filesize directive in the php.ini',
-        UPLOAD_ERR_FORM_SIZE  => 'Uploaded file exceeds the MAX_FILE_SIZE directive in the HTML form',
-        UPLOAD_ERR_PARTIAL    => 'Uploaded file was only partially uploaded',
-        UPLOAD_ERR_NO_FILE    => 'No file was uploaded',
-        UPLOAD_ERR_NO_TMP_DIR => 'Missing temporary directory',
-        UPLOAD_ERR_CANT_WRITE => 'Failed to write file to disk',
-        UPLOAD_ERR_EXTENSION  => 'File upload was stopped by a PHP extension',
-    ];
-
-    private ?StreamInterface $stream;
-    private ?int $size;
-    private int $errorCode;
-    private string $errorMessage;
-    private ?string $clientFilename;
-    private ?string $clientMediaType;
-    private bool $isMoved = false;
-
-    public function __construct(
-        ?StreamInterface $stream,
-        ?int $size = null,
-        int $error = UPLOAD_ERR_OK,
-        ?string $clientFilename = null,
-        ?string $clientMediaType = null
-    ) {
-        $this->stream = $stream;
-        $this->size = $size;
-        $this->errorCode = $error;
-        $this->errorMessage = self::UPLOAD_ERRORS[$error] ?? 'Unknown file upload error';
-        $this->clientFilename = $clientFilename;
-        $this->clientMediaType = $clientMediaType;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getStream(): StreamInterface
-    {
-        if ($this->isMoved) {
-            throw new RuntimeException('Uploaded file was moved');
-        }
-
-        if ($this->errorCode !== UPLOAD_ERR_OK) {
-            throw new RuntimeException($this->errorMessage, $this->errorCode);
-        }
-
-        if ($this->stream === null) {
-            throw new RuntimeException('Uploaded file has no stream');
-        }
-
-        return $this->stream;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function moveTo($targetPath): void
-    {
-        /** @psalm-suppress TypeDoesNotContainType */
-        // @phpstan-ignore function.alreadyNarrowedType
-        if (!is_string($targetPath)) {
-            throw new TypeError(sprintf(
-                'Argument #1 ($targetPath) must be of type string, %s given',
-                gettype($targetPath),
-            ));
-        }
-
-        $sourceStream = $this->getStream();
-
-        $sourcePath = $sourceStream->getMetadata('uri');
-        if (!is_string($sourcePath) || !is_file($sourcePath) || !is_readable($sourcePath)) {
-            throw new RuntimeException('Uploaded file does not exist or is not readable');
-        }
-
-        $sourceDirname = dirname($sourcePath);
-        if (!is_writable($sourceDirname)) {
-            throw new RuntimeException('To move the uploaded file, the source directory must be writable');
-        }
-
-        $targetDirname = dirname($targetPath);
-        if (!is_dir($targetDirname) || !is_writable($targetDirname)) {
-            throw new RuntimeException('To move the uploaded file, the target directory must exist and be writable');
-        }
-
-        try {
-            $this->isMoved = is_uploaded_file($sourcePath)
-                ? move_uploaded_file($sourcePath, $targetPath)
-                : rename($sourcePath, $targetPath);
-        } catch (Throwable $e) {
-        }
-
-        if (!$this->isMoved) {
-            throw new RuntimeException('Failed to move the uploaded file');
-        }
-
-        $sourceStream->close();
-        $this->stream = null;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getSize(): ?int
-    {
-        return $this->size;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getError(): int
-    {
-        return $this->errorCode;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getClientFilename(): ?string
-    {
-        return $this->clientFilename;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getClientMediaType(): ?string
-    {
-        return $this->clientMediaType;
-    }
+	/**
+	 * @link https://www.php.net/manual/en/features.file-upload.errors.php
+	 *
+	 * @var array<int, non-empty-string>
+	 */
+	public const UPLOAD_ERRORS = [
+		UPLOAD_ERR_OK         => 'No error',
+		UPLOAD_ERR_INI_SIZE   => 'Uploaded file exceeds the upload_max_filesize directive in the php.ini',
+		UPLOAD_ERR_FORM_SIZE  => 'Uploaded file exceeds the MAX_FILE_SIZE directive in the HTML form',
+		UPLOAD_ERR_PARTIAL    => 'Uploaded file was only partially uploaded',
+		UPLOAD_ERR_NO_FILE    => 'No file was uploaded',
+		UPLOAD_ERR_NO_TMP_DIR => 'Missing temporary directory',
+		UPLOAD_ERR_CANT_WRITE => 'Failed to write file to disk',
+		UPLOAD_ERR_EXTENSION  => 'File upload was stopped by a PHP extension',
+	];
+
+	private ?StreamInterface $stream;
+	private ?int $size;
+	private int $errorCode;
+	private string $errorMessage;
+	private ?string $clientFilename;
+	private ?string $clientMediaType;
+	private bool $isMoved = false;
+
+	public function __construct(
+		?StreamInterface $stream,
+		?int $size = null,
+		int $error = UPLOAD_ERR_OK,
+		?string $clientFilename = null,
+		?string $clientMediaType = null
+	) {
+		$this->stream = $stream;
+		$this->size = $size;
+		$this->errorCode = $error;
+		$this->errorMessage = self::UPLOAD_ERRORS[$error] ?? 'Unknown file upload error';
+		$this->clientFilename = $clientFilename;
+		$this->clientMediaType = $clientMediaType;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getStream(): StreamInterface
+	{
+		if ($this->isMoved) {
+			throw new RuntimeException('Uploaded file was moved');
+		}
+
+		if ($this->errorCode !== UPLOAD_ERR_OK) {
+			throw new RuntimeException($this->errorMessage, $this->errorCode);
+		}
+
+		if ($this->stream === null) {
+			throw new RuntimeException('Uploaded file has no stream');
+		}
+
+		return $this->stream;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function moveTo($targetPath): void
+	{
+		/** @psalm-suppress TypeDoesNotContainType */
+		// @phpstan-ignore function.alreadyNarrowedType
+		if (!is_string($targetPath)) {
+			throw new TypeError(sprintf(
+				'Argument #1 ($targetPath) must be of type string, %s given',
+				gettype($targetPath),
+			));
+		}
+
+		$sourceStream = $this->getStream();
+
+		$sourcePath = $sourceStream->getMetadata('uri');
+		if (!is_string($sourcePath) || !is_file($sourcePath) || !is_readable($sourcePath)) {
+			throw new RuntimeException('Uploaded file does not exist or is not readable');
+		}
+
+		$sourceDirname = dirname($sourcePath);
+		if (!is_writable($sourceDirname)) {
+			throw new RuntimeException('To move the uploaded file, the source directory must be writable');
+		}
+
+		$targetDirname = dirname($targetPath);
+		if (!is_dir($targetDirname) || !is_writable($targetDirname)) {
+			throw new RuntimeException('To move the uploaded file, the target directory must exist and be writable');
+		}
+
+		try {
+			$this->isMoved = is_uploaded_file($sourcePath)
+				? move_uploaded_file($sourcePath, $targetPath)
+				: rename($sourcePath, $targetPath);
+		} catch (Throwable $e) {
+		}
+
+		if (!$this->isMoved) {
+			throw new RuntimeException('Failed to move the uploaded file');
+		}
+
+		$sourceStream->close();
+		$this->stream = null;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getSize(): ?int
+	{
+		return $this->size;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getError(): int
+	{
+		return $this->errorCode;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getClientFilename(): ?string
+	{
+		return $this->clientFilename;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getClientMediaType(): ?string
+	{
+		return $this->clientMediaType;
+	}
 }

src/Response/JsonResponse.php

Indentation +39 added lines, -39 removed lines

@@ -24,48 +24,48 @@
 
 final class JsonResponse extends Response
 {
-    /**
-     * @param mixed $data
-     * @param int<1, max> $depth
-     * @psalm-param int<1, 2147483647> $depth
-     *
-     * @throws InvalidArgumentException
-     */
-    public function __construct(int $statusCode, $data, int $flags = 0, int $depth = 512)
-    {
-        parent::__construct($statusCode);
+	/**
+	 * @param mixed $data
+	 * @param int<1, max> $depth
+	 * @psalm-param int<1, 2147483647> $depth
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function __construct(int $statusCode, $data, int $flags = 0, int $depth = 512)
+	{
+		parent::__construct($statusCode);
 
-        $this->setBody(self::createBody($data, $flags, $depth));
-        $this->setHeader('Content-Type', 'application/json; charset=utf-8');
-    }
+		$this->setBody(self::createBody($data, $flags, $depth));
+		$this->setHeader('Content-Type', 'application/json; charset=utf-8');
+	}
 
-    /**
-     * @param mixed $data
-     * @param int<1, max> $depth
-     * @psalm-param int<1, 2147483647> $depth
-     *
-     * @throws InvalidArgumentException
-     */
-    private static function createBody($data, int $flags, int $depth): StreamInterface
-    {
-        if ($data instanceof StreamInterface) {
-            return $data;
-        }
+	/**
+	 * @param mixed $data
+	 * @param int<1, max> $depth
+	 * @psalm-param int<1, 2147483647> $depth
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private static function createBody($data, int $flags, int $depth): StreamInterface
+	{
+		if ($data instanceof StreamInterface) {
+			return $data;
+		}
 
-        try {
-            /** @var non-empty-string $json */
-            $json = json_encode($data, $flags | JSON_THROW_ON_ERROR, $depth);
-        } catch (JsonException $e) {
-            throw new InvalidArgumentException(sprintf(
-                'Unable to create the JSON response due to an invalid data: %s',
-                $e->getMessage()
-            ), 0, $e);
-        }
+		try {
+			/** @var non-empty-string $json */
+			$json = json_encode($data, $flags | JSON_THROW_ON_ERROR, $depth);
+		} catch (JsonException $e) {
+			throw new InvalidArgumentException(sprintf(
+				'Unable to create the JSON response due to an invalid data: %s',
+				$e->getMessage()
+			), 0, $e);
+		}
 
-        $stream = new PhpTempStream('r+b');
-        $stream->write($json);
-        $stream->rewind();
+		$stream = new PhpTempStream('r+b');
+		$stream->write($json);
+		$stream->rewind();
 
-        return $stream;
-    }
+		return $stream;
+	}
 }

src/Stream.php

Indentation +285 added lines, -285 removed lines

@@ -32,289 +32,289 @@
 
 class Stream implements StreamInterface
 {
-    /**
-     * @var resource|null
-     */
-    private $resource;
-
-    private bool $autoClose;
-
-    /**
-     * @param mixed $resource
-     *
-     * @throws InvalidArgumentException
-     */
-    public function __construct($resource, bool $autoClose = true)
-    {
-        if (!is_resource($resource)) {
-            throw new InvalidArgumentException('Unexpected stream resource');
-        }
-
-        $this->resource = $resource;
-        $this->autoClose = $autoClose;
-    }
-
-    /**
-     * @param mixed $resource
-     *
-     * @throws InvalidArgumentException
-     */
-    public static function create($resource): StreamInterface
-    {
-        if ($resource instanceof StreamInterface) {
-            return $resource;
-        }
-
-        return new self($resource);
-    }
-
-    public function __destruct()
-    {
-        if ($this->autoClose) {
-            $this->close();
-        }
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function detach()
-    {
-        $resource = $this->resource;
-        $this->resource = null;
-
-        return $resource;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function close(): void
-    {
-        $resource = $this->detach();
-        if (!is_resource($resource)) {
-            return;
-        }
-
-        fclose($resource);
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function eof(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return true;
-        }
-
-        return feof($this->resource);
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function tell(): int
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('Stream has no resource');
-        }
-
-        $result = ftell($this->resource);
-        if ($result === false) {
-            throw new RuntimeException('Unable to get the stream pointer position');
-        }
-
-        return $result;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function isSeekable(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return false;
-        }
-
-        $metadata = stream_get_meta_data($this->resource);
-
-        return $metadata['seekable'];
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function rewind(): void
-    {
-        $this->seek(0);
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function seek($offset, $whence = SEEK_SET): void
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('Stream has no resource');
-        }
-
-        if (!$this->isSeekable()) {
-            throw new RuntimeException('Stream is not seekable');
-        }
-
-        $result = fseek($this->resource, $offset, $whence);
-        if ($result !== 0) {
-            throw new RuntimeException('Unable to move the stream pointer position');
-        }
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function isWritable(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return false;
-        }
-
-        $metadata = stream_get_meta_data($this->resource);
-
-        return strpbrk($metadata['mode'], '+acwx') !== false;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function write($string): int
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('Stream has no resource');
-        }
-
-        if (!$this->isWritable()) {
-            throw new RuntimeException('Stream is not writable');
-        }
-
-        $result = fwrite($this->resource, $string);
-        if ($result === false) {
-            throw new RuntimeException('Unable to write to the stream');
-        }
-
-        return $result;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function isReadable(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return false;
-        }
-
-        $metadata = stream_get_meta_data($this->resource);
-
-        return strpbrk($metadata['mode'], '+r') !== false;
-    }
-
-    /**
-     * @inheritDoc
-     *
-     * @psalm-param int $length
-     * @phpstan-param int<1, max> $length
-     */
-    public function read($length): string
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('Stream has no resource');
-        }
-
-        if (!$this->isReadable()) {
-            throw new RuntimeException('Stream is not readable');
-        }
-
-        $result = fread($this->resource, $length);
-        if ($result === false) {
-            throw new RuntimeException('Unable to read from the stream');
-        }
-
-        return $result;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getContents(): string
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('Stream has no resource');
-        }
-
-        if (!$this->isReadable()) {
-            throw new RuntimeException('Stream is not readable');
-        }
-
-        $result = stream_get_contents($this->resource);
-        if ($result === false) {
-            throw new RuntimeException('Unable to read the remainder of the stream');
-        }
-
-        return $result;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getMetadata($key = null)
-    {
-        if (!is_resource($this->resource)) {
-            return null;
-        }
-
-        $metadata = stream_get_meta_data($this->resource);
-        if ($key === null) {
-            return $metadata;
-        }
-
-        return $metadata[$key] ?? null;
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function getSize(): ?int
-    {
-        if (!is_resource($this->resource)) {
-            return null;
-        }
-
-        /** @var array{size: int}|false */
-        $stats = fstat($this->resource);
-        if ($stats === false) {
-            return null;
-        }
-
-        return $stats['size'];
-    }
-
-    /**
-     * @inheritDoc
-     */
-    public function __toString(): string
-    {
-        if (!$this->isReadable()) {
-            return '';
-        }
-
-        try {
-            if ($this->isSeekable()) {
-                $this->rewind();
-            }
-
-            return $this->getContents();
-        } catch (Throwable $e) {
-            return '';
-        }
-    }
+	/**
+	 * @var resource|null
+	 */
+	private $resource;
+
+	private bool $autoClose;
+
+	/**
+	 * @param mixed $resource
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public function __construct($resource, bool $autoClose = true)
+	{
+		if (!is_resource($resource)) {
+			throw new InvalidArgumentException('Unexpected stream resource');
+		}
+
+		$this->resource = $resource;
+		$this->autoClose = $autoClose;
+	}
+
+	/**
+	 * @param mixed $resource
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public static function create($resource): StreamInterface
+	{
+		if ($resource instanceof StreamInterface) {
+			return $resource;
+		}
+
+		return new self($resource);
+	}
+
+	public function __destruct()
+	{
+		if ($this->autoClose) {
+			$this->close();
+		}
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function detach()
+	{
+		$resource = $this->resource;
+		$this->resource = null;
+
+		return $resource;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function close(): void
+	{
+		$resource = $this->detach();
+		if (!is_resource($resource)) {
+			return;
+		}
+
+		fclose($resource);
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function eof(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return true;
+		}
+
+		return feof($this->resource);
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function tell(): int
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('Stream has no resource');
+		}
+
+		$result = ftell($this->resource);
+		if ($result === false) {
+			throw new RuntimeException('Unable to get the stream pointer position');
+		}
+
+		return $result;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function isSeekable(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return false;
+		}
+
+		$metadata = stream_get_meta_data($this->resource);
+
+		return $metadata['seekable'];
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function rewind(): void
+	{
+		$this->seek(0);
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function seek($offset, $whence = SEEK_SET): void
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('Stream has no resource');
+		}
+
+		if (!$this->isSeekable()) {
+			throw new RuntimeException('Stream is not seekable');
+		}
+
+		$result = fseek($this->resource, $offset, $whence);
+		if ($result !== 0) {
+			throw new RuntimeException('Unable to move the stream pointer position');
+		}
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function isWritable(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return false;
+		}
+
+		$metadata = stream_get_meta_data($this->resource);
+
+		return strpbrk($metadata['mode'], '+acwx') !== false;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function write($string): int
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('Stream has no resource');
+		}
+
+		if (!$this->isWritable()) {
+			throw new RuntimeException('Stream is not writable');
+		}
+
+		$result = fwrite($this->resource, $string);
+		if ($result === false) {
+			throw new RuntimeException('Unable to write to the stream');
+		}
+
+		return $result;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function isReadable(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return false;
+		}
+
+		$metadata = stream_get_meta_data($this->resource);
+
+		return strpbrk($metadata['mode'], '+r') !== false;
+	}
+
+	/**
+	 * @inheritDoc
+	 *
+	 * @psalm-param int $length
+	 * @phpstan-param int<1, max> $length
+	 */
+	public function read($length): string
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('Stream has no resource');
+		}
+
+		if (!$this->isReadable()) {
+			throw new RuntimeException('Stream is not readable');
+		}
+
+		$result = fread($this->resource, $length);
+		if ($result === false) {
+			throw new RuntimeException('Unable to read from the stream');
+		}
+
+		return $result;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getContents(): string
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('Stream has no resource');
+		}
+
+		if (!$this->isReadable()) {
+			throw new RuntimeException('Stream is not readable');
+		}
+
+		$result = stream_get_contents($this->resource);
+		if ($result === false) {
+			throw new RuntimeException('Unable to read the remainder of the stream');
+		}
+
+		return $result;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getMetadata($key = null)
+	{
+		if (!is_resource($this->resource)) {
+			return null;
+		}
+
+		$metadata = stream_get_meta_data($this->resource);
+		if ($key === null) {
+			return $metadata;
+		}
+
+		return $metadata[$key] ?? null;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getSize(): ?int
+	{
+		if (!is_resource($this->resource)) {
+			return null;
+		}
+
+		/** @var array{size: int}|false */
+		$stats = fstat($this->resource);
+		if ($stats === false) {
+			return null;
+		}
+
+		return $stats['size'];
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function __toString(): string
+	{
+		if (!$this->isReadable()) {
+			return '';
+		}
+
+		try {
+			if ($this->isSeekable()) {
+				$this->rewind();
+			}
+
+			return $this->getContents();
+		} catch (Throwable $e) {
+			return '';
+		}
+	}
 }