sunrise-php / http-message

src/Stream/TempFileStream.php

Indentation +28 added lines, -28 removed lines

@@ -32,32 +32,32 @@
 final class TempFileStream extends Stream
 {
 
-    /**
-     * Constructor of the class
-     *
-     * @param string|null $prefix
-     *
-     * @throws RuntimeException
-     */
-    public function __construct(?string $prefix = null)
-    {
-        $prefix ??= 'sunrisephp';
-
-        $dirname = sys_get_temp_dir();
-        if (!is_writable($dirname)) {
-            throw new RuntimeException('Temporary files directory is not writable');
-        }
-
-        $filename = tempnam($dirname, $prefix);
-        if ($filename === false) {
-            throw new RuntimeException('Temporary file name cannot be generated');
-        }
-
-        $resource = fopen($filename, 'w+b');
-        if (!is_resource($resource)) {
-            throw new RuntimeException('Temporary file cannot be created or opened');
-        }
-
-        parent::__construct($resource);
-    }
+	/**
+	 * Constructor of the class
+	 *
+	 * @param string|null $prefix
+	 *
+	 * @throws RuntimeException
+	 */
+	public function __construct(?string $prefix = null)
+	{
+		$prefix ??= 'sunrisephp';
+
+		$dirname = sys_get_temp_dir();
+		if (!is_writable($dirname)) {
+			throw new RuntimeException('Temporary files directory is not writable');
+		}
+
+		$filename = tempnam($dirname, $prefix);
+		if ($filename === false) {
+			throw new RuntimeException('Temporary file name cannot be generated');
+		}
+
+		$resource = fopen($filename, 'w+b');
+		if (!is_resource($resource)) {
+			throw new RuntimeException('Temporary file cannot be created or opened');
+		}
+
+		parent::__construct($resource);
+	}
 }

src/Stream/TmpfileStream.php

Indentation +19 added lines, -19 removed lines

@@ -35,23 +35,23 @@
 final class TmpfileStream extends Stream
 {
 
-    /**
-     * Constructor of the class
-     *
-     * @throws RuntimeException
-     */
-    public function __construct()
-    {
-        $dirname = sys_get_temp_dir();
-        if (!is_writable($dirname)) {
-            throw new RuntimeException('Temporary files directory is not writable');
-        }
-
-        $resource = tmpfile();
-        if (!is_resource($resource)) {
-            throw new RuntimeException('Temporary file cannot be created or opened');
-        }
-
-        parent::__construct($resource);
-    }
+	/**
+	 * Constructor of the class
+	 *
+	 * @throws RuntimeException
+	 */
+	public function __construct()
+	{
+		$dirname = sys_get_temp_dir();
+		if (!is_writable($dirname)) {
+			throw new RuntimeException('Temporary files directory is not writable');
+		}
+
+		$resource = tmpfile();
+		if (!is_resource($resource)) {
+			throw new RuntimeException('Temporary file cannot be created or opened');
+		}
+
+		parent::__construct($resource);
+	}
 }

src/Enum/CookieSameSite.php

Indentation +27 added lines, -27 removed lines

@@ -19,33 +19,33 @@
 final class CookieSameSite
 {
 
-    /**
-     * Cookies are not sent on normal cross-site subrequests, but are
-     * sent when a user is navigating to the origin site.
-     *
-     * This is the default cookie value if SameSite has not been
-     * explicitly specified in recent browser versions.
-     *
-     * @link https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Set-Cookie/SameSite#lax
-     */
-    public const LAX = 'Lax';
+	/**
+	 * Cookies are not sent on normal cross-site subrequests, but are
+	 * sent when a user is navigating to the origin site.
+	 *
+	 * This is the default cookie value if SameSite has not been
+	 * explicitly specified in recent browser versions.
+	 *
+	 * @link https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Set-Cookie/SameSite#lax
+	 */
+	public const LAX = 'Lax';
 
-    /**
-     * Cookies will only be sent in a first-party context and not be
-     * sent along with requests initiated by third party websites.
-     *
-     * @link https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Set-Cookie/SameSite#strict
-     */
-    public const STRICT = 'Strict';
+	/**
+	 * Cookies will only be sent in a first-party context and not be
+	 * sent along with requests initiated by third party websites.
+	 *
+	 * @link https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Set-Cookie/SameSite#strict
+	 */
+	public const STRICT = 'Strict';
 
-    /**
-     * Cookies will be sent in all contexts, i.e. in responses to both
-     * first-party and cross-site requests.
-     *
-     * If SameSite=None is set, the cookie Secure attribute must also
-     * be set (or the cookie will be blocked).
-     *
-     * @link https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Set-Cookie/SameSite#none
-     */
-    public const NONE = 'None';
+	/**
+	 * Cookies will be sent in all contexts, i.e. in responses to both
+	 * first-party and cross-site requests.
+	 *
+	 * If SameSite=None is set, the cookie Secure attribute must also
+	 * be set (or the cookie will be blocked).
+	 *
+	 * @link https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Set-Cookie/SameSite#none
+	 */
+	public const NONE = 'None';
 }

src/Enum/Encoding.php

Indentation +5 added lines, -5 removed lines

@@ -16,9 +16,9 @@
  */
 final class Encoding
 {
-    public const BR = 'br';
-    public const CHUNKED = 'chunked';
-    public const COMPRESS = 'compress';
-    public const DEFLATE = 'deflate';
-    public const GZIP = 'gzip';
+	public const BR = 'br';
+	public const CHUNKED = 'chunked';
+	public const COMPRESS = 'compress';
+	public const DEFLATE = 'deflate';
+	public const GZIP = 'gzip';
 }

src/Enum/WarningCode.php

Indentation +7 added lines, -7 removed lines

@@ -18,11 +18,11 @@
  */
 final class WarningCode
 {
-    public const RESPONSE_IS_STALE = 110;
-    public const REVALIDATION_FAILED = 111;
-    public const DISCONNECTED_OPERATION = 112;
-    public const HEURISTIC_EXPIRATION = 113;
-    public const MISCELLANEOUS_WARNING = 199;
-    public const TRANSFORMATION_APPLIED = 214;
-    public const MISCELLANEOUS_PERSISTENT_WARNING = 299;
+	public const RESPONSE_IS_STALE = 110;
+	public const REVALIDATION_FAILED = 111;
+	public const DISCONNECTED_OPERATION = 112;
+	public const HEURISTIC_EXPIRATION = 113;
+	public const MISCELLANEOUS_WARNING = 199;
+	public const TRANSFORMATION_APPLIED = 214;
+	public const MISCELLANEOUS_PERSISTENT_WARNING = 299;
 }

src/Enum/AuthenticationScheme.php

Indentation +10 added lines, -10 removed lines

@@ -18,14 +18,14 @@
  */
 final class AuthenticationScheme
 {
-    public const BASIC         = 'Basic';
-    public const BEARER        = 'Bearer';
-    public const DIGEST        = 'Digest';
-    public const HOBA          = 'HOBA';
-    public const MUTUAL        = 'Mutual';
-    public const NEGOTIATE     = 'Negotiate';
-    public const OAUTH         = 'OAuth';
-    public const SCRAM_SHA_1   = 'SCRAM-SHA-1';
-    public const SCRAM_SHA_256 = 'SCRAM-SHA-256';
-    public const VAPID         = 'vapid';
+	public const BASIC         = 'Basic';
+	public const BEARER        = 'Bearer';
+	public const DIGEST        = 'Digest';
+	public const HOBA          = 'HOBA';
+	public const MUTUAL        = 'Mutual';
+	public const NEGOTIATE     = 'Negotiate';
+	public const OAUTH         = 'OAuth';
+	public const SCRAM_SHA_1   = 'SCRAM-SHA-1';
+	public const SCRAM_SHA_256 = 'SCRAM-SHA-256';
+	public const VAPID         = 'vapid';
 }

src/Message.php

Indentation +391 added lines, -391 removed lines

@@ -39,395 +39,395 @@
 abstract class Message implements MessageInterface
 {
 
-    /**
-     * Default HTTP version
-     *
-     * @var string
-     */
-    public const DEFAULT_HTTP_VERSION = '1.1';
-
-    /**
-     * Supported HTTP versions
-     *
-     * @var list<string>
-     */
-    public const SUPPORTED_HTTP_VERSIONS = ['1.0', '1.1', '2.0', '2'];
-
-    /**
-     * The message HTTP version
-     *
-     * @var string
-     */
-    private string $protocolVersion = self::DEFAULT_HTTP_VERSION;
-
-    /**
-     * The message headers
-     *
-     * @var array<string, list<string>>
-     */
-    private array $headers = [];
-
-    /**
-     * Original header names (see $headers)
-     *
-     * @var array<string, string>
-     */
-    private array $headerNames = [];
-
-    /**
-     * The message body
-     *
-     * @var StreamInterface|null
-     */
-    private ?StreamInterface $body = null;
-
-    /**
-     * Gets the message HTTP version
-     *
-     * @return string
-     */
-    public function getProtocolVersion(): string
-    {
-        return $this->protocolVersion;
-    }
-
-    /**
-     * Creates a new instance of the message with the given HTTP version
-     *
-     * @param string $version
-     *
-     * @return static
-     *
-     * @throws InvalidArgumentException
-     *         If the HTTP version isn't valid.
-     */
-    public function withProtocolVersion($version): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->setProtocolVersion($version);
-
-        return $clone;
-    }
-
-    /**
-     * Gets the message headers
-     *
-     * @return array<string, list<string>>
-     */
-    public function getHeaders(): array
-    {
-        return $this->headers;
-    }
-
-    /**
-     * Checks if a header exists in the message by the given name
-     *
-     * @param string $name
-     *
-     * @return bool
-     */
-    public function hasHeader($name): bool
-    {
-        $key = strtolower($name);
-
-        return isset($this->headerNames[$key]);
-    }
-
-    /**
-     * Gets a header value from the message by the given name
-     *
-     * @param string $name
-     *
-     * @return list<string>
-     */
-    public function getHeader($name): array
-    {
-        if (!$this->hasHeader($name)) {
-            return [];
-        }
-
-        $key = strtolower($name);
-        $originalName = $this->headerNames[$key];
-        $value = $this->headers[$originalName];
-
-        return $value;
-    }
-
-    /**
-     * Gets a header value as a string from the message by the given name
-     *
-     * @param string $name
-     *
-     * @return string
-     */
-    public function getHeaderLine($name): string
-    {
-        $value = $this->getHeader($name);
-        if ([] === $value) {
-            return '';
-        }
-
-        return implode(',', $value);
-    }
-
-    /**
-     * Creates a new instance of the message with the given header overwriting the old header
-     *
-     * @param string $name
-     * @param string|string[] $value
-     *
-     * @return static
-     *
-     * @throws InvalidArgumentException
-     *         If the header isn't valid.
-     */
-    public function withHeader($name, $value): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->setHeader($name, $value, true);
-
-        return $clone;
-    }
-
-    /**
-     * Creates a new instance of the message with the given header NOT overwriting the old header
-     *
-     * @param string $name
-     * @param string|string[] $value
-     *
-     * @return static
-     *
-     * @throws InvalidArgumentException
-     *         If the header isn't valid.
-     */
-    public function withAddedHeader($name, $value): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->setHeader($name, $value, false);
-
-        return $clone;
-    }
-
-    /**
-     * Creates a new instance of the message without a header by the given name
-     *
-     * @param string $name
-     *
-     * @return static
-     */
-    public function withoutHeader($name): MessageInterface
-    {
-        $clone = clone $this;
-        $clone->deleteHeader($name);
-
-        return $clone;
-    }
-
-    /**
-     * Gets the message body
-     *
-     * @return StreamInterface
-     */
-    public function getBody(): StreamInterface
-    {
-        return $this->body ??= new PhpTempStream();
-    }
-
-    /**
-     * Creates a new instance of the message with the given body
-     *
-     * @param StreamInterface $body
-     *
-     * @return static
-     */
-    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
-     *
-     * @return void
-     *
-     * @throws InvalidArgumentException
-     *         If the HTTP version isn't valid.
-     */
-    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
-     * @param bool $replace
-     *
-     * @return void
-     *
-     * @throws InvalidArgumentException
-     *         If the header isn't valid.
-     */
-    final protected function setHeader($name, $value, bool $replace = true): void
-    {
-        if (!is_array($value)) {
-            $value = [$value];
-        }
-
-        $this->validateHeaderName($name);
-        $this->validateHeaderValue($name, $value);
-
-        if ($replace) {
-            $this->deleteHeader($name);
-        }
-
-        $key = strtolower($name);
-
-        $this->headerNames[$key] ??= $name;
-        $this->headers[$this->headerNames[$key]] ??= [];
-
-        foreach ($value as $subvalue) {
-            $this->headers[$this->headerNames[$key]][] = $subvalue;
-        }
-    }
-
-    /**
-     * Sets the given headers to the message
-     *
-     * @param array<string, string|string[]> $headers
-     *
-     * @return void
-     *
-     * @throws InvalidArgumentException
-     *         If one of the headers isn't valid.
-     */
-    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
-     *
-     * @return void
-     */
-    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
-     *
-     * @param StreamInterface $body
-     *
-     * @return void
-     */
-    final protected function setBody(StreamInterface $body): void
-    {
-        $this->body = $body;
-    }
-
-    /**
-     * Validates the given HTTP version
-     *
-     * @param mixed $protocolVersion
-     *
-     * @return void
-     *
-     * @throws InvalidArgumentException
-     *         If the HTTP version isn't valid.
-     */
-    private function validateProtocolVersion($protocolVersion): void
-    {
-        if (!in_array($protocolVersion, self::SUPPORTED_HTTP_VERSIONS, true)) {
-            throw new InvalidArgumentException('Invalid or unsupported HTTP version');
-        }
-    }
-
-    /**
-     * Validates the given header name
-     *
-     * @param mixed $name
-     *
-     * @return void
-     *
-     * @throws InvalidArgumentException
-     *         If the header name isn't valid.
-     */
-    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(Header::RFC7230_VALID_TOKEN, $name)) {
-            throw new InvalidArgumentException('HTTP header name is invalid');
-        }
-    }
-
-    /**
-     * Validates the given header value
-     *
-     * @param string $validName
-     * @param array $value
-     *
-     * @return void
-     *
-     * @throws InvalidArgumentException
-     *         If the header value isn't valid.
-     */
-    private function validateHeaderValue(string $validName, array $value): void
-    {
-        if ([] === $value) {
-            throw new InvalidArgumentException(sprintf(
-                'The "%s" HTTP header value cannot be an empty array',
-                $validName,
-            ));
-        }
-
-        foreach ($value as $key => $item) {
-            if ('' === $item) {
-                continue;
-            }
-
-            if (!is_string($item)) {
-                throw new InvalidArgumentException(sprintf(
-                    'The "%s[%s]" HTTP header value must be a string',
-                    $validName,
-                    $key
-                ));
-            }
-
-            if (!preg_match(Header::RFC7230_VALID_FIELD_VALUE, $item)) {
-                throw new InvalidArgumentException(sprintf(
-                    'The "%s[%s]" HTTP header value is invalid',
-                    $validName,
-                    $key
-                ));
-            }
-        }
-    }
+	/**
+	 * Default HTTP version
+	 *
+	 * @var string
+	 */
+	public const DEFAULT_HTTP_VERSION = '1.1';
+
+	/**
+	 * Supported HTTP versions
+	 *
+	 * @var list<string>
+	 */
+	public const SUPPORTED_HTTP_VERSIONS = ['1.0', '1.1', '2.0', '2'];
+
+	/**
+	 * The message HTTP version
+	 *
+	 * @var string
+	 */
+	private string $protocolVersion = self::DEFAULT_HTTP_VERSION;
+
+	/**
+	 * The message headers
+	 *
+	 * @var array<string, list<string>>
+	 */
+	private array $headers = [];
+
+	/**
+	 * Original header names (see $headers)
+	 *
+	 * @var array<string, string>
+	 */
+	private array $headerNames = [];
+
+	/**
+	 * The message body
+	 *
+	 * @var StreamInterface|null
+	 */
+	private ?StreamInterface $body = null;
+
+	/**
+	 * Gets the message HTTP version
+	 *
+	 * @return string
+	 */
+	public function getProtocolVersion(): string
+	{
+		return $this->protocolVersion;
+	}
+
+	/**
+	 * Creates a new instance of the message with the given HTTP version
+	 *
+	 * @param string $version
+	 *
+	 * @return static
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the HTTP version isn't valid.
+	 */
+	public function withProtocolVersion($version): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->setProtocolVersion($version);
+
+		return $clone;
+	}
+
+	/**
+	 * Gets the message headers
+	 *
+	 * @return array<string, list<string>>
+	 */
+	public function getHeaders(): array
+	{
+		return $this->headers;
+	}
+
+	/**
+	 * Checks if a header exists in the message by the given name
+	 *
+	 * @param string $name
+	 *
+	 * @return bool
+	 */
+	public function hasHeader($name): bool
+	{
+		$key = strtolower($name);
+
+		return isset($this->headerNames[$key]);
+	}
+
+	/**
+	 * Gets a header value from the message by the given name
+	 *
+	 * @param string $name
+	 *
+	 * @return list<string>
+	 */
+	public function getHeader($name): array
+	{
+		if (!$this->hasHeader($name)) {
+			return [];
+		}
+
+		$key = strtolower($name);
+		$originalName = $this->headerNames[$key];
+		$value = $this->headers[$originalName];
+
+		return $value;
+	}
+
+	/**
+	 * Gets a header value as a string from the message by the given name
+	 *
+	 * @param string $name
+	 *
+	 * @return string
+	 */
+	public function getHeaderLine($name): string
+	{
+		$value = $this->getHeader($name);
+		if ([] === $value) {
+			return '';
+		}
+
+		return implode(',', $value);
+	}
+
+	/**
+	 * Creates a new instance of the message with the given header overwriting the old header
+	 *
+	 * @param string $name
+	 * @param string|string[] $value
+	 *
+	 * @return static
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the header isn't valid.
+	 */
+	public function withHeader($name, $value): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->setHeader($name, $value, true);
+
+		return $clone;
+	}
+
+	/**
+	 * Creates a new instance of the message with the given header NOT overwriting the old header
+	 *
+	 * @param string $name
+	 * @param string|string[] $value
+	 *
+	 * @return static
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the header isn't valid.
+	 */
+	public function withAddedHeader($name, $value): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->setHeader($name, $value, false);
+
+		return $clone;
+	}
+
+	/**
+	 * Creates a new instance of the message without a header by the given name
+	 *
+	 * @param string $name
+	 *
+	 * @return static
+	 */
+	public function withoutHeader($name): MessageInterface
+	{
+		$clone = clone $this;
+		$clone->deleteHeader($name);
+
+		return $clone;
+	}
+
+	/**
+	 * Gets the message body
+	 *
+	 * @return StreamInterface
+	 */
+	public function getBody(): StreamInterface
+	{
+		return $this->body ??= new PhpTempStream();
+	}
+
+	/**
+	 * Creates a new instance of the message with the given body
+	 *
+	 * @param StreamInterface $body
+	 *
+	 * @return static
+	 */
+	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
+	 *
+	 * @return void
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the HTTP version isn't valid.
+	 */
+	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
+	 * @param bool $replace
+	 *
+	 * @return void
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the header isn't valid.
+	 */
+	final protected function setHeader($name, $value, bool $replace = true): void
+	{
+		if (!is_array($value)) {
+			$value = [$value];
+		}
+
+		$this->validateHeaderName($name);
+		$this->validateHeaderValue($name, $value);
+
+		if ($replace) {
+			$this->deleteHeader($name);
+		}
+
+		$key = strtolower($name);
+
+		$this->headerNames[$key] ??= $name;
+		$this->headers[$this->headerNames[$key]] ??= [];
+
+		foreach ($value as $subvalue) {
+			$this->headers[$this->headerNames[$key]][] = $subvalue;
+		}
+	}
+
+	/**
+	 * Sets the given headers to the message
+	 *
+	 * @param array<string, string|string[]> $headers
+	 *
+	 * @return void
+	 *
+	 * @throws InvalidArgumentException
+	 *         If one of the headers isn't valid.
+	 */
+	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
+	 *
+	 * @return void
+	 */
+	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
+	 *
+	 * @param StreamInterface $body
+	 *
+	 * @return void
+	 */
+	final protected function setBody(StreamInterface $body): void
+	{
+		$this->body = $body;
+	}
+
+	/**
+	 * Validates the given HTTP version
+	 *
+	 * @param mixed $protocolVersion
+	 *
+	 * @return void
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the HTTP version isn't valid.
+	 */
+	private function validateProtocolVersion($protocolVersion): void
+	{
+		if (!in_array($protocolVersion, self::SUPPORTED_HTTP_VERSIONS, true)) {
+			throw new InvalidArgumentException('Invalid or unsupported HTTP version');
+		}
+	}
+
+	/**
+	 * Validates the given header name
+	 *
+	 * @param mixed $name
+	 *
+	 * @return void
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the header name isn't valid.
+	 */
+	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(Header::RFC7230_VALID_TOKEN, $name)) {
+			throw new InvalidArgumentException('HTTP header name is invalid');
+		}
+	}
+
+	/**
+	 * Validates the given header value
+	 *
+	 * @param string $validName
+	 * @param array $value
+	 *
+	 * @return void
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the header value isn't valid.
+	 */
+	private function validateHeaderValue(string $validName, array $value): void
+	{
+		if ([] === $value) {
+			throw new InvalidArgumentException(sprintf(
+				'The "%s" HTTP header value cannot be an empty array',
+				$validName,
+			));
+		}
+
+		foreach ($value as $key => $item) {
+			if ('' === $item) {
+				continue;
+			}
+
+			if (!is_string($item)) {
+				throw new InvalidArgumentException(sprintf(
+					'The "%s[%s]" HTTP header value must be a string',
+					$validName,
+					$key
+				));
+			}
+
+			if (!preg_match(Header::RFC7230_VALID_FIELD_VALUE, $item)) {
+				throw new InvalidArgumentException(sprintf(
+					'The "%s[%s]" HTTP header value is invalid',
+					$validName,
+					$key
+				));
+			}
+		}
+	}
 }

src/Stream.php

Indentation +382 added lines, -382 removed lines

@@ -47,386 +47,386 @@
 class Stream implements StreamInterface
 {
 
-    /**
-     * The stream resource
-     *
-     * @var resource|null
-     */
-    private $resource;
-
-    /**
-     * Signals to close the stream on destruction
-     *
-     * @var bool
-     */
-    private $autoClose;
-
-    /**
-     * Constructor of the class
-     *
-     * @param mixed $resource
-     * @param bool $autoClose
-     *
-     * @throws InvalidArgumentException
-     *         If the stream cannot be initialized with the resource.
-     */
-    public function __construct($resource, bool $autoClose = true)
-    {
-        if (!is_resource($resource)) {
-            throw new InvalidArgumentException('Unexpected stream resource');
-        }
-
-        $this->resource = $resource;
-        $this->autoClose = $autoClose;
-    }
-
-    /**
-     * Creates a stream
-     *
-     * @param mixed $resource
-     *
-     * @return StreamInterface
-     *
-     * @throws InvalidArgumentException
-     *         If the stream cannot be initialized with the resource.
-     */
-    public static function create($resource): StreamInterface
-    {
-        if ($resource instanceof StreamInterface) {
-            return $resource;
-        }
-
-        return new self($resource);
-    }
-
-    /**
-     * Destructor of the class
-     */
-    public function __destruct()
-    {
-        if ($this->autoClose) {
-            $this->close();
-        }
-    }
-
-    /**
-     * Detaches a resource from the stream
-     *
-     * Returns NULL if the stream already without a resource.
-     *
-     * @return resource|null
-     */
-    public function detach()
-    {
-        $resource = $this->resource;
-        $this->resource = null;
-
-        return $resource;
-    }
-
-    /**
-     * Closes the stream
-     *
-     * @link http://php.net/manual/en/function.fclose.php
-     *
-     * @return void
-     */
-    public function close(): void
-    {
-        $resource = $this->detach();
-        if (!is_resource($resource)) {
-            return;
-        }
-
-        fclose($resource);
-    }
-
-    /**
-     * Checks if the end of the stream is reached
-     *
-     * @link http://php.net/manual/en/function.feof.php
-     *
-     * @return bool
-     */
-    public function eof(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return true;
-        }
-
-        return feof($this->resource);
-    }
-
-    /**
-     * Gets the stream pointer position
-     *
-     * @link http://php.net/manual/en/function.ftell.php
-     *
-     * @return int
-     *
-     * @throws RuntimeException
-     */
-    public function tell(): int
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('The stream without a resource so the operation is not possible');
-        }
-
-        $result = ftell($this->resource);
-        if ($result === false) {
-            throw new RuntimeException('Unable to get the stream pointer position');
-        }
-
-        return $result;
-    }
-
-    /**
-     * Checks if the stream is seekable
-     *
-     * @return bool
-     */
-    public function isSeekable(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return false;
-        }
-
-        /** @var array{seekable: bool} */
-        $metadata = stream_get_meta_data($this->resource);
-
-        return $metadata['seekable'];
-    }
-
-    /**
-     * Moves the stream pointer to the beginning
-     *
-     * @return void
-     *
-     * @throws RuntimeException
-     */
-    public function rewind(): void
-    {
-        $this->seek(0);
-    }
-
-    /**
-     * Moves the stream pointer to the given position
-     *
-     * @link http://php.net/manual/en/function.fseek.php
-     *
-     * @param int $offset
-     * @param int $whence
-     *
-     * @return void
-     *
-     * @throws RuntimeException
-     */
-    public function seek($offset, $whence = SEEK_SET): void
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('The stream without a resource so the operation is not possible');
-        }
-
-        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');
-        }
-    }
-
-    /**
-     * Checks if the stream is writable
-     *
-     * @return bool
-     */
-    public function isWritable(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return false;
-        }
-
-        /** @var array{mode: string} */
-        $metadata = stream_get_meta_data($this->resource);
-
-        return strpbrk($metadata['mode'], '+acwx') !== false;
-    }
-
-    /**
-     * Writes the given string to the stream
-     *
-     * Returns the number of bytes written to the stream.
-     *
-     * @link http://php.net/manual/en/function.fwrite.php
-     *
-     * @param string $string
-     *
-     * @return int
-     *
-     * @throws RuntimeException
-     */
-    public function write($string): int
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('The stream without a resource so the operation is not possible');
-        }
-
-        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;
-    }
-
-    /**
-     * Checks if the stream is readable
-     *
-     * @return bool
-     */
-    public function isReadable(): bool
-    {
-        if (!is_resource($this->resource)) {
-            return false;
-        }
-
-        /** @var array{mode: string} */
-        $metadata = stream_get_meta_data($this->resource);
-
-        return strpbrk($metadata['mode'], '+r') !== false;
-    }
-
-    /**
-     * Reads the given number of bytes from the stream
-     *
-     * @link http://php.net/manual/en/function.fread.php
-     *
-     * @param int $length
-     *
-     * @return string
-     *
-     * @throws RuntimeException
-     */
-    public function read($length): string
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('The stream without a resource so the operation is not possible');
-        }
-
-        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;
-    }
-
-    /**
-     * Reads the remainder of the stream
-     *
-     * @link http://php.net/manual/en/function.stream-get-contents.php
-     *
-     * @return string
-     *
-     * @throws RuntimeException
-     */
-    public function getContents(): string
-    {
-        if (!is_resource($this->resource)) {
-            throw new RuntimeException('The stream without a resource so the operation is not possible');
-        }
-
-        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;
-    }
-
-    /**
-     * Gets the stream metadata
-     *
-     * @link http://php.net/manual/en/function.stream-get-meta-data.php
-     *
-     * @param string|null $key
-     *
-     * @return mixed
-     */
-    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;
-    }
-
-    /**
-     * Gets the stream size
-     *
-     * Returns NULL if the stream without a resource,
-     * or if the stream size cannot be determined.
-     *
-     * @link http://php.net/manual/en/function.fstat.php
-     *
-     * @return int|null
-     */
-    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'];
-    }
-
-    /**
-     * Converts the stream to a string
-     *
-     * @link http://php.net/manual/en/language.oop5.magic.php#object.tostring
-     *
-     * @return string
-     */
-    public function __toString(): string
-    {
-        if (!$this->isReadable()) {
-            return '';
-        }
-
-        try {
-            if ($this->isSeekable()) {
-                $this->rewind();
-            }
-
-            return $this->getContents();
-        } catch (Throwable $e) {
-            return '';
-        }
-    }
+	/**
+	 * The stream resource
+	 *
+	 * @var resource|null
+	 */
+	private $resource;
+
+	/**
+	 * Signals to close the stream on destruction
+	 *
+	 * @var bool
+	 */
+	private $autoClose;
+
+	/**
+	 * Constructor of the class
+	 *
+	 * @param mixed $resource
+	 * @param bool $autoClose
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the stream cannot be initialized with the resource.
+	 */
+	public function __construct($resource, bool $autoClose = true)
+	{
+		if (!is_resource($resource)) {
+			throw new InvalidArgumentException('Unexpected stream resource');
+		}
+
+		$this->resource = $resource;
+		$this->autoClose = $autoClose;
+	}
+
+	/**
+	 * Creates a stream
+	 *
+	 * @param mixed $resource
+	 *
+	 * @return StreamInterface
+	 *
+	 * @throws InvalidArgumentException
+	 *         If the stream cannot be initialized with the resource.
+	 */
+	public static function create($resource): StreamInterface
+	{
+		if ($resource instanceof StreamInterface) {
+			return $resource;
+		}
+
+		return new self($resource);
+	}
+
+	/**
+	 * Destructor of the class
+	 */
+	public function __destruct()
+	{
+		if ($this->autoClose) {
+			$this->close();
+		}
+	}
+
+	/**
+	 * Detaches a resource from the stream
+	 *
+	 * Returns NULL if the stream already without a resource.
+	 *
+	 * @return resource|null
+	 */
+	public function detach()
+	{
+		$resource = $this->resource;
+		$this->resource = null;
+
+		return $resource;
+	}
+
+	/**
+	 * Closes the stream
+	 *
+	 * @link http://php.net/manual/en/function.fclose.php
+	 *
+	 * @return void
+	 */
+	public function close(): void
+	{
+		$resource = $this->detach();
+		if (!is_resource($resource)) {
+			return;
+		}
+
+		fclose($resource);
+	}
+
+	/**
+	 * Checks if the end of the stream is reached
+	 *
+	 * @link http://php.net/manual/en/function.feof.php
+	 *
+	 * @return bool
+	 */
+	public function eof(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return true;
+		}
+
+		return feof($this->resource);
+	}
+
+	/**
+	 * Gets the stream pointer position
+	 *
+	 * @link http://php.net/manual/en/function.ftell.php
+	 *
+	 * @return int
+	 *
+	 * @throws RuntimeException
+	 */
+	public function tell(): int
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('The stream without a resource so the operation is not possible');
+		}
+
+		$result = ftell($this->resource);
+		if ($result === false) {
+			throw new RuntimeException('Unable to get the stream pointer position');
+		}
+
+		return $result;
+	}
+
+	/**
+	 * Checks if the stream is seekable
+	 *
+	 * @return bool
+	 */
+	public function isSeekable(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return false;
+		}
+
+		/** @var array{seekable: bool} */
+		$metadata = stream_get_meta_data($this->resource);
+
+		return $metadata['seekable'];
+	}
+
+	/**
+	 * Moves the stream pointer to the beginning
+	 *
+	 * @return void
+	 *
+	 * @throws RuntimeException
+	 */
+	public function rewind(): void
+	{
+		$this->seek(0);
+	}
+
+	/**
+	 * Moves the stream pointer to the given position
+	 *
+	 * @link http://php.net/manual/en/function.fseek.php
+	 *
+	 * @param int $offset
+	 * @param int $whence
+	 *
+	 * @return void
+	 *
+	 * @throws RuntimeException
+	 */
+	public function seek($offset, $whence = SEEK_SET): void
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('The stream without a resource so the operation is not possible');
+		}
+
+		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');
+		}
+	}
+
+	/**
+	 * Checks if the stream is writable
+	 *
+	 * @return bool
+	 */
+	public function isWritable(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return false;
+		}
+
+		/** @var array{mode: string} */
+		$metadata = stream_get_meta_data($this->resource);
+
+		return strpbrk($metadata['mode'], '+acwx') !== false;
+	}
+
+	/**
+	 * Writes the given string to the stream
+	 *
+	 * Returns the number of bytes written to the stream.
+	 *
+	 * @link http://php.net/manual/en/function.fwrite.php
+	 *
+	 * @param string $string
+	 *
+	 * @return int
+	 *
+	 * @throws RuntimeException
+	 */
+	public function write($string): int
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('The stream without a resource so the operation is not possible');
+		}
+
+		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;
+	}
+
+	/**
+	 * Checks if the stream is readable
+	 *
+	 * @return bool
+	 */
+	public function isReadable(): bool
+	{
+		if (!is_resource($this->resource)) {
+			return false;
+		}
+
+		/** @var array{mode: string} */
+		$metadata = stream_get_meta_data($this->resource);
+
+		return strpbrk($metadata['mode'], '+r') !== false;
+	}
+
+	/**
+	 * Reads the given number of bytes from the stream
+	 *
+	 * @link http://php.net/manual/en/function.fread.php
+	 *
+	 * @param int $length
+	 *
+	 * @return string
+	 *
+	 * @throws RuntimeException
+	 */
+	public function read($length): string
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('The stream without a resource so the operation is not possible');
+		}
+
+		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;
+	}
+
+	/**
+	 * Reads the remainder of the stream
+	 *
+	 * @link http://php.net/manual/en/function.stream-get-contents.php
+	 *
+	 * @return string
+	 *
+	 * @throws RuntimeException
+	 */
+	public function getContents(): string
+	{
+		if (!is_resource($this->resource)) {
+			throw new RuntimeException('The stream without a resource so the operation is not possible');
+		}
+
+		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;
+	}
+
+	/**
+	 * Gets the stream metadata
+	 *
+	 * @link http://php.net/manual/en/function.stream-get-meta-data.php
+	 *
+	 * @param string|null $key
+	 *
+	 * @return mixed
+	 */
+	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;
+	}
+
+	/**
+	 * Gets the stream size
+	 *
+	 * Returns NULL if the stream without a resource,
+	 * or if the stream size cannot be determined.
+	 *
+	 * @link http://php.net/manual/en/function.fstat.php
+	 *
+	 * @return int|null
+	 */
+	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'];
+	}
+
+	/**
+	 * Converts the stream to a string
+	 *
+	 * @link http://php.net/manual/en/language.oop5.magic.php#object.tostring
+	 *
+	 * @return string
+	 */
+	public function __toString(): string
+	{
+		if (!$this->isReadable()) {
+			return '';
+		}
+
+		try {
+			if ($this->isSeekable()) {
+				$this->rewind();
+			}
+
+			return $this->getContents();
+		} catch (Throwable $e) {
+			return '';
+		}
+	}
 }

src/Header/ContentEncodingHeader.php

Indentation +49 added lines, -49 removed lines

@@ -29,61 +29,61 @@
 class ContentEncodingHeader extends Header
 {
 
-    /**
-     * @deprecated Use the {@see Encoding} enum.
-     */
-    public const BR = Encoding::BR;
+	/**
+	 * @deprecated Use the {@see Encoding} enum.
+	 */
+	public const BR = Encoding::BR;
 
-    /**
-     * @deprecated Use the {@see Encoding} enum.
-     */
-    public const COMPRESS = Encoding::COMPRESS;
+	/**
+	 * @deprecated Use the {@see Encoding} enum.
+	 */
+	public const COMPRESS = Encoding::COMPRESS;
 
-    /**
-     * @deprecated Use the {@see Encoding} enum.
-     */
-    public const DEFLATE = Encoding::DEFLATE;
+	/**
+	 * @deprecated Use the {@see Encoding} enum.
+	 */
+	public const DEFLATE = Encoding::DEFLATE;
 
-    /**
-     * @deprecated Use the {@see Encoding} enum.
-     */
-    public const GZIP = Encoding::GZIP;
+	/**
+	 * @deprecated Use the {@see Encoding} enum.
+	 */
+	public const GZIP = Encoding::GZIP;
 
-    /**
-     * @var list<string>
-     */
-    private array $directives = [];
+	/**
+	 * @var list<string>
+	 */
+	private array $directives = [];
 
-    /**
-     * Constructor of the class
-     *
-     * @param string ...$directives
-     *
-     * @throws InvalidHeaderException
-     *         If one of the directives isn't valid.
-     */
-    public function __construct(string ...$directives)
-    {
-        $this->validateToken(...$directives);
+	/**
+	 * Constructor of the class
+	 *
+	 * @param string ...$directives
+	 *
+	 * @throws InvalidHeaderException
+	 *         If one of the directives isn't valid.
+	 */
+	public function __construct(string ...$directives)
+	{
+		$this->validateToken(...$directives);
 
-        foreach ($directives as $directive) {
-            $this->directives[] = $directive;
-        }
-    }
+		foreach ($directives as $directive) {
+			$this->directives[] = $directive;
+		}
+	}
 
-    /**
-     * {@inheritdoc}
-     */
-    public function getFieldName(): string
-    {
-        return 'Content-Encoding';
-    }
+	/**
+	 * {@inheritdoc}
+	 */
+	public function getFieldName(): string
+	{
+		return 'Content-Encoding';
+	}
 
-    /**
-     * {@inheritdoc}
-     */
-    public function getFieldValue(): string
-    {
-        return implode(', ', $this->directives);
-    }
+	/**
+	 * {@inheritdoc}
+	 */
+	public function getFieldValue(): string
+	{
+		return implode(', ', $this->directives);
+	}
 }