nextcloud / fulltextsearch_elasticsearch

lib/Vendor/GuzzleHttp/Psr7/StreamWrapper.php

Indentation +128 added lines, -128 removed lines

@@ -11,132 +11,132 @@
  */
 final class StreamWrapper
 {
-    /** @var resource */
-    public $context;
-    /** @var StreamInterface */
-    private $stream;
-    /** @var string r, r+, or w */
-    private $mode;
-    /**
-     * Returns a resource representing the stream.
-     *
-     * @param StreamInterface $stream The stream to get a resource for
-     *
-     * @return resource
-     *
-     * @throws \InvalidArgumentException if stream is not readable or writable
-     */
-    public static function getResource(StreamInterface $stream)
-    {
-        self::register();
-        if ($stream->isReadable()) {
-            $mode = $stream->isWritable() ? 'r+' : 'r';
-        } elseif ($stream->isWritable()) {
-            $mode = 'w';
-        } else {
-            throw new \InvalidArgumentException('The stream must be readable, ' . 'writable, or both.');
-        }
-        return \fopen('guzzle://stream', $mode, \false, self::createStreamContext($stream));
-    }
-    /**
-     * Creates a stream context that can be used to open a stream as a php stream resource.
-     *
-     * @return resource
-     */
-    public static function createStreamContext(StreamInterface $stream)
-    {
-        return \stream_context_create(['guzzle' => ['stream' => $stream]]);
-    }
-    /**
-     * Registers the stream wrapper if needed
-     */
-    public static function register() : void
-    {
-        if (!\in_array('guzzle', \stream_get_wrappers())) {
-            \stream_wrapper_register('guzzle', __CLASS__);
-        }
-    }
-    public function stream_open(string $path, string $mode, int $options, string &$opened_path = null) : bool
-    {
-        $options = \stream_context_get_options($this->context);
-        if (!isset($options['guzzle']['stream'])) {
-            return \false;
-        }
-        $this->mode = $mode;
-        $this->stream = $options['guzzle']['stream'];
-        return \true;
-    }
-    public function stream_read(int $count) : string
-    {
-        return $this->stream->read($count);
-    }
-    public function stream_write(string $data) : int
-    {
-        return $this->stream->write($data);
-    }
-    public function stream_tell() : int
-    {
-        return $this->stream->tell();
-    }
-    public function stream_eof() : bool
-    {
-        return $this->stream->eof();
-    }
-    public function stream_seek(int $offset, int $whence) : bool
-    {
-        $this->stream->seek($offset, $whence);
-        return \true;
-    }
-    /**
-     * @return resource|false
-     */
-    public function stream_cast(int $cast_as)
-    {
-        $stream = clone $this->stream;
-        $resource = $stream->detach();
-        return $resource ?? \false;
-    }
-    /**
-     * @return array{
-     *   dev: int,
-     *   ino: int,
-     *   mode: int,
-     *   nlink: int,
-     *   uid: int,
-     *   gid: int,
-     *   rdev: int,
-     *   size: int,
-     *   atime: int,
-     *   mtime: int,
-     *   ctime: int,
-     *   blksize: int,
-     *   blocks: int
-     * }
-     */
-    public function stream_stat() : array
-    {
-        static $modeMap = ['r' => 33060, 'rb' => 33060, 'r+' => 33206, 'w' => 33188, 'wb' => 33188];
-        return ['dev' => 0, 'ino' => 0, 'mode' => $modeMap[$this->mode], 'nlink' => 0, 'uid' => 0, 'gid' => 0, 'rdev' => 0, 'size' => $this->stream->getSize() ?: 0, 'atime' => 0, 'mtime' => 0, 'ctime' => 0, 'blksize' => 0, 'blocks' => 0];
-    }
-    /**
-     * @return array{
-     *   dev: int,
-     *   ino: int,
-     *   mode: int,
-     *   nlink: int,
-     *   uid: int,
-     *   gid: int,
-     *   rdev: int,
-     *   size: int,
-     *   atime: int,
-     *   mtime: int,
-     *   ctime: int,
-     *   blksize: int,
-     *   blocks: int
-     * }
-     */
-    public function url_stat(string $path, int $flags) : array
-    {
-        return ['dev' => 0, 'ino' => 0, 'mode' => 0, 'nlink' => 0, 'uid' => 0, 'gid' => 0, 'rdev' => 0, 'size' => 0, 'atime' => 0, 'mtime' => 0, 'ctime' => 0, 'blksize' => 0, 'blocks' => 0];
-    }
+	/** @var resource */
+	public $context;
+	/** @var StreamInterface */
+	private $stream;
+	/** @var string r, r+, or w */
+	private $mode;
+	/**
+	 * Returns a resource representing the stream.
+	 *
+	 * @param StreamInterface $stream The stream to get a resource for
+	 *
+	 * @return resource
+	 *
+	 * @throws \InvalidArgumentException if stream is not readable or writable
+	 */
+	public static function getResource(StreamInterface $stream)
+	{
+		self::register();
+		if ($stream->isReadable()) {
+			$mode = $stream->isWritable() ? 'r+' : 'r';
+		} elseif ($stream->isWritable()) {
+			$mode = 'w';
+		} else {
+			throw new \InvalidArgumentException('The stream must be readable, ' . 'writable, or both.');
+		}
+		return \fopen('guzzle://stream', $mode, \false, self::createStreamContext($stream));
+	}
+	/**
+	 * Creates a stream context that can be used to open a stream as a php stream resource.
+	 *
+	 * @return resource
+	 */
+	public static function createStreamContext(StreamInterface $stream)
+	{
+		return \stream_context_create(['guzzle' => ['stream' => $stream]]);
+	}
+	/**
+	 * Registers the stream wrapper if needed
+	 */
+	public static function register() : void
+	{
+		if (!\in_array('guzzle', \stream_get_wrappers())) {
+			\stream_wrapper_register('guzzle', __CLASS__);
+		}
+	}
+	public function stream_open(string $path, string $mode, int $options, string &$opened_path = null) : bool
+	{
+		$options = \stream_context_get_options($this->context);
+		if (!isset($options['guzzle']['stream'])) {
+			return \false;
+		}
+		$this->mode = $mode;
+		$this->stream = $options['guzzle']['stream'];
+		return \true;
+	}
+	public function stream_read(int $count) : string
+	{
+		return $this->stream->read($count);
+	}
+	public function stream_write(string $data) : int
+	{
+		return $this->stream->write($data);
+	}
+	public function stream_tell() : int
+	{
+		return $this->stream->tell();
+	}
+	public function stream_eof() : bool
+	{
+		return $this->stream->eof();
+	}
+	public function stream_seek(int $offset, int $whence) : bool
+	{
+		$this->stream->seek($offset, $whence);
+		return \true;
+	}
+	/**
+	 * @return resource|false
+	 */
+	public function stream_cast(int $cast_as)
+	{
+		$stream = clone $this->stream;
+		$resource = $stream->detach();
+		return $resource ?? \false;
+	}
+	/**
+	 * @return array{
+	 *   dev: int,
+	 *   ino: int,
+	 *   mode: int,
+	 *   nlink: int,
+	 *   uid: int,
+	 *   gid: int,
+	 *   rdev: int,
+	 *   size: int,
+	 *   atime: int,
+	 *   mtime: int,
+	 *   ctime: int,
+	 *   blksize: int,
+	 *   blocks: int
+	 * }
+	 */
+	public function stream_stat() : array
+	{
+		static $modeMap = ['r' => 33060, 'rb' => 33060, 'r+' => 33206, 'w' => 33188, 'wb' => 33188];
+		return ['dev' => 0, 'ino' => 0, 'mode' => $modeMap[$this->mode], 'nlink' => 0, 'uid' => 0, 'gid' => 0, 'rdev' => 0, 'size' => $this->stream->getSize() ?: 0, 'atime' => 0, 'mtime' => 0, 'ctime' => 0, 'blksize' => 0, 'blocks' => 0];
+	}
+	/**
+	 * @return array{
+	 *   dev: int,
+	 *   ino: int,
+	 *   mode: int,
+	 *   nlink: int,
+	 *   uid: int,
+	 *   gid: int,
+	 *   rdev: int,
+	 *   size: int,
+	 *   atime: int,
+	 *   mtime: int,
+	 *   ctime: int,
+	 *   blksize: int,
+	 *   blocks: int
+	 * }
+	 */
+	public function url_stat(string $path, int $flags) : array
+	{
+		return ['dev' => 0, 'ino' => 0, 'mode' => 0, 'nlink' => 0, 'uid' => 0, 'gid' => 0, 'rdev' => 0, 'size' => 0, 'atime' => 0, 'mtime' => 0, 'ctime' => 0, 'blksize' => 0, 'blocks' => 0];
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;
@@ -34,7 +34,7 @@ 
         } elseif ($stream->isWritable()) {
             $mode = 'w';
         } else {
-            throw new \InvalidArgumentException('The stream must be readable, ' . 'writable, or both.');
+            throw new \InvalidArgumentException('The stream must be readable, '.'writable, or both.');
         }
         return \fopen('guzzle://stream', $mode, \false, self::createStreamContext($stream));
     }

Braces +1 added lines, -2 removed lines

@@ -9,8 +9,7 @@
  *
  * @see https://www.php.net/streamwrapper
  */
-final class StreamWrapper
-{
+final class StreamWrapper {
     /** @var resource */
     public $context;
     /** @var StreamInterface */

lib/Vendor/GuzzleHttp/Psr7/Message.php

Indentation +178 added lines, -178 removed lines

@@ -8,182 +8,182 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface;
 final class Message
 {
-    /**
-     * Returns the string representation of an HTTP message.
-     *
-     * @param MessageInterface $message Message to convert to a string.
-     */
-    public static function toString(MessageInterface $message) : string
-    {
-        if ($message instanceof RequestInterface) {
-            $msg = \trim($message->getMethod() . ' ' . $message->getRequestTarget()) . ' HTTP/' . $message->getProtocolVersion();
-            if (!$message->hasHeader('host')) {
-                $msg .= "\r\nHost: " . $message->getUri()->getHost();
-            }
-        } elseif ($message instanceof ResponseInterface) {
-            $msg = 'HTTP/' . $message->getProtocolVersion() . ' ' . $message->getStatusCode() . ' ' . $message->getReasonPhrase();
-        } else {
-            throw new \InvalidArgumentException('Unknown message type');
-        }
-        foreach ($message->getHeaders() as $name => $values) {
-            if (\is_string($name) && \strtolower($name) === 'set-cookie') {
-                foreach ($values as $value) {
-                    $msg .= "\r\n{$name}: " . $value;
-                }
-            } else {
-                $msg .= "\r\n{$name}: " . \implode(', ', $values);
-            }
-        }
-        return "{$msg}\r\n\r\n" . $message->getBody();
-    }
-    /**
-     * Get a short summary of the message body.
-     *
-     * Will return `null` if the response is not printable.
-     *
-     * @param MessageInterface $message    The message to get the body summary
-     * @param int              $truncateAt The maximum allowed size of the summary
-     */
-    public static function bodySummary(MessageInterface $message, int $truncateAt = 120) : ?string
-    {
-        $body = $message->getBody();
-        if (!$body->isSeekable() || !$body->isReadable()) {
-            return null;
-        }
-        $size = $body->getSize();
-        if ($size === 0) {
-            return null;
-        }
-        $body->rewind();
-        $summary = $body->read($truncateAt);
-        $body->rewind();
-        if ($size > $truncateAt) {
-            $summary .= ' (truncated...)';
-        }
-        // Matches any printable character, including unicode characters:
-        // letters, marks, numbers, punctuation, spacing, and separators.
-        if (\preg_match('/[^\\pL\\pM\\pN\\pP\\pS\\pZ\\n\\r\\t]/u', $summary) !== 0) {
-            return null;
-        }
-        return $summary;
-    }
-    /**
-     * Attempts to rewind a message body and throws an exception on failure.
-     *
-     * The body of the message will only be rewound if a call to `tell()`
-     * returns a value other than `0`.
-     *
-     * @param MessageInterface $message Message to rewind
-     *
-     * @throws \RuntimeException
-     */
-    public static function rewindBody(MessageInterface $message) : void
-    {
-        $body = $message->getBody();
-        if ($body->tell()) {
-            $body->rewind();
-        }
-    }
-    /**
-     * Parses an HTTP message into an associative array.
-     *
-     * The array contains the "start-line" key containing the start line of
-     * the message, "headers" key containing an associative array of header
-     * array values, and a "body" key containing the body of the message.
-     *
-     * @param string $message HTTP request or response to parse.
-     */
-    public static function parseMessage(string $message) : array
-    {
-        if (!$message) {
-            throw new \InvalidArgumentException('Invalid message');
-        }
-        $message = \ltrim($message, "\r\n");
-        $messageParts = \preg_split("/\r?\n\r?\n/", $message, 2);
-        if ($messageParts === \false || \count($messageParts) !== 2) {
-            throw new \InvalidArgumentException('Invalid message: Missing header delimiter');
-        }
-        [$rawHeaders, $body] = $messageParts;
-        $rawHeaders .= "\r\n";
-        // Put back the delimiter we split previously
-        $headerParts = \preg_split("/\r?\n/", $rawHeaders, 2);
-        if ($headerParts === \false || \count($headerParts) !== 2) {
-            throw new \InvalidArgumentException('Invalid message: Missing status line');
-        }
-        [$startLine, $rawHeaders] = $headerParts;
-        if (\preg_match("/(?:^HTTP\\/|^[A-Z]+ \\S+ HTTP\\/)(\\d+(?:\\.\\d+)?)/i", $startLine, $matches) && $matches[1] === '1.0') {
-            // Header folding is deprecated for HTTP/1.1, but allowed in HTTP/1.0
-            $rawHeaders = \preg_replace(Rfc7230::HEADER_FOLD_REGEX, ' ', $rawHeaders);
-        }
-        /** @var array[] $headerLines */
-        $count = \preg_match_all(Rfc7230::HEADER_REGEX, $rawHeaders, $headerLines, \PREG_SET_ORDER);
-        // If these aren't the same, then one line didn't match and there's an invalid header.
-        if ($count !== \substr_count($rawHeaders, "\n")) {
-            // Folding is deprecated, see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2.4
-            if (\preg_match(Rfc7230::HEADER_FOLD_REGEX, $rawHeaders)) {
-                throw new \InvalidArgumentException('Invalid header syntax: Obsolete line folding');
-            }
-            throw new \InvalidArgumentException('Invalid header syntax');
-        }
-        $headers = [];
-        foreach ($headerLines as $headerLine) {
-            $headers[$headerLine[1]][] = $headerLine[2];
-        }
-        return ['start-line' => $startLine, 'headers' => $headers, 'body' => $body];
-    }
-    /**
-     * Constructs a URI for an HTTP request message.
-     *
-     * @param string $path    Path from the start-line
-     * @param array  $headers Array of headers (each value an array).
-     */
-    public static function parseRequestUri(string $path, array $headers) : string
-    {
-        $hostKey = \array_filter(\array_keys($headers), function ($k) {
-            // Numeric array keys are converted to int by PHP.
-            $k = (string) $k;
-            return \strtolower($k) === 'host';
-        });
-        // If no host is found, then a full URI cannot be constructed.
-        if (!$hostKey) {
-            return $path;
-        }
-        $host = $headers[\reset($hostKey)][0];
-        $scheme = \substr($host, -4) === ':443' ? 'https' : 'http';
-        return $scheme . '://' . $host . '/' . \ltrim($path, '/');
-    }
-    /**
-     * Parses a request message string into a request object.
-     *
-     * @param string $message Request message string.
-     */
-    public static function parseRequest(string $message) : RequestInterface
-    {
-        $data = self::parseMessage($message);
-        $matches = [];
-        if (!\preg_match('/^[\\S]+\\s+([a-zA-Z]+:\\/\\/|\\/).*/', $data['start-line'], $matches)) {
-            throw new \InvalidArgumentException('Invalid request string');
-        }
-        $parts = \explode(' ', $data['start-line'], 3);
-        $version = isset($parts[2]) ? \explode('/', $parts[2])[1] : '1.1';
-        $request = new Request($parts[0], $matches[1] === '/' ? self::parseRequestUri($parts[1], $data['headers']) : $parts[1], $data['headers'], $data['body'], $version);
-        return $matches[1] === '/' ? $request : $request->withRequestTarget($parts[1]);
-    }
-    /**
-     * Parses a response message string into a response object.
-     *
-     * @param string $message Response message string.
-     */
-    public static function parseResponse(string $message) : ResponseInterface
-    {
-        $data = self::parseMessage($message);
-        // According to https://datatracker.ietf.org/doc/html/rfc7230#section-3.1.2
-        // the space between status-code and reason-phrase is required. But
-        // browsers accept responses without space and reason as well.
-        if (!\preg_match('/^HTTP\\/.* [0-9]{3}( .*|$)/', $data['start-line'])) {
-            throw new \InvalidArgumentException('Invalid response string: ' . $data['start-line']);
-        }
-        $parts = \explode(' ', $data['start-line'], 3);
-        return new Response((int) $parts[1], $data['headers'], $data['body'], \explode('/', $parts[0])[1], $parts[2] ?? null);
-    }
+	/**
+	 * Returns the string representation of an HTTP message.
+	 *
+	 * @param MessageInterface $message Message to convert to a string.
+	 */
+	public static function toString(MessageInterface $message) : string
+	{
+		if ($message instanceof RequestInterface) {
+			$msg = \trim($message->getMethod() . ' ' . $message->getRequestTarget()) . ' HTTP/' . $message->getProtocolVersion();
+			if (!$message->hasHeader('host')) {
+				$msg .= "\r\nHost: " . $message->getUri()->getHost();
+			}
+		} elseif ($message instanceof ResponseInterface) {
+			$msg = 'HTTP/' . $message->getProtocolVersion() . ' ' . $message->getStatusCode() . ' ' . $message->getReasonPhrase();
+		} else {
+			throw new \InvalidArgumentException('Unknown message type');
+		}
+		foreach ($message->getHeaders() as $name => $values) {
+			if (\is_string($name) && \strtolower($name) === 'set-cookie') {
+				foreach ($values as $value) {
+					$msg .= "\r\n{$name}: " . $value;
+				}
+			} else {
+				$msg .= "\r\n{$name}: " . \implode(', ', $values);
+			}
+		}
+		return "{$msg}\r\n\r\n" . $message->getBody();
+	}
+	/**
+	 * Get a short summary of the message body.
+	 *
+	 * Will return `null` if the response is not printable.
+	 *
+	 * @param MessageInterface $message    The message to get the body summary
+	 * @param int              $truncateAt The maximum allowed size of the summary
+	 */
+	public static function bodySummary(MessageInterface $message, int $truncateAt = 120) : ?string
+	{
+		$body = $message->getBody();
+		if (!$body->isSeekable() || !$body->isReadable()) {
+			return null;
+		}
+		$size = $body->getSize();
+		if ($size === 0) {
+			return null;
+		}
+		$body->rewind();
+		$summary = $body->read($truncateAt);
+		$body->rewind();
+		if ($size > $truncateAt) {
+			$summary .= ' (truncated...)';
+		}
+		// Matches any printable character, including unicode characters:
+		// letters, marks, numbers, punctuation, spacing, and separators.
+		if (\preg_match('/[^\\pL\\pM\\pN\\pP\\pS\\pZ\\n\\r\\t]/u', $summary) !== 0) {
+			return null;
+		}
+		return $summary;
+	}
+	/**
+	 * Attempts to rewind a message body and throws an exception on failure.
+	 *
+	 * The body of the message will only be rewound if a call to `tell()`
+	 * returns a value other than `0`.
+	 *
+	 * @param MessageInterface $message Message to rewind
+	 *
+	 * @throws \RuntimeException
+	 */
+	public static function rewindBody(MessageInterface $message) : void
+	{
+		$body = $message->getBody();
+		if ($body->tell()) {
+			$body->rewind();
+		}
+	}
+	/**
+	 * Parses an HTTP message into an associative array.
+	 *
+	 * The array contains the "start-line" key containing the start line of
+	 * the message, "headers" key containing an associative array of header
+	 * array values, and a "body" key containing the body of the message.
+	 *
+	 * @param string $message HTTP request or response to parse.
+	 */
+	public static function parseMessage(string $message) : array
+	{
+		if (!$message) {
+			throw new \InvalidArgumentException('Invalid message');
+		}
+		$message = \ltrim($message, "\r\n");
+		$messageParts = \preg_split("/\r?\n\r?\n/", $message, 2);
+		if ($messageParts === \false || \count($messageParts) !== 2) {
+			throw new \InvalidArgumentException('Invalid message: Missing header delimiter');
+		}
+		[$rawHeaders, $body] = $messageParts;
+		$rawHeaders .= "\r\n";
+		// Put back the delimiter we split previously
+		$headerParts = \preg_split("/\r?\n/", $rawHeaders, 2);
+		if ($headerParts === \false || \count($headerParts) !== 2) {
+			throw new \InvalidArgumentException('Invalid message: Missing status line');
+		}
+		[$startLine, $rawHeaders] = $headerParts;
+		if (\preg_match("/(?:^HTTP\\/|^[A-Z]+ \\S+ HTTP\\/)(\\d+(?:\\.\\d+)?)/i", $startLine, $matches) && $matches[1] === '1.0') {
+			// Header folding is deprecated for HTTP/1.1, but allowed in HTTP/1.0
+			$rawHeaders = \preg_replace(Rfc7230::HEADER_FOLD_REGEX, ' ', $rawHeaders);
+		}
+		/** @var array[] $headerLines */
+		$count = \preg_match_all(Rfc7230::HEADER_REGEX, $rawHeaders, $headerLines, \PREG_SET_ORDER);
+		// If these aren't the same, then one line didn't match and there's an invalid header.
+		if ($count !== \substr_count($rawHeaders, "\n")) {
+			// Folding is deprecated, see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2.4
+			if (\preg_match(Rfc7230::HEADER_FOLD_REGEX, $rawHeaders)) {
+				throw new \InvalidArgumentException('Invalid header syntax: Obsolete line folding');
+			}
+			throw new \InvalidArgumentException('Invalid header syntax');
+		}
+		$headers = [];
+		foreach ($headerLines as $headerLine) {
+			$headers[$headerLine[1]][] = $headerLine[2];
+		}
+		return ['start-line' => $startLine, 'headers' => $headers, 'body' => $body];
+	}
+	/**
+	 * Constructs a URI for an HTTP request message.
+	 *
+	 * @param string $path    Path from the start-line
+	 * @param array  $headers Array of headers (each value an array).
+	 */
+	public static function parseRequestUri(string $path, array $headers) : string
+	{
+		$hostKey = \array_filter(\array_keys($headers), function ($k) {
+			// Numeric array keys are converted to int by PHP.
+			$k = (string) $k;
+			return \strtolower($k) === 'host';
+		});
+		// If no host is found, then a full URI cannot be constructed.
+		if (!$hostKey) {
+			return $path;
+		}
+		$host = $headers[\reset($hostKey)][0];
+		$scheme = \substr($host, -4) === ':443' ? 'https' : 'http';
+		return $scheme . '://' . $host . '/' . \ltrim($path, '/');
+	}
+	/**
+	 * Parses a request message string into a request object.
+	 *
+	 * @param string $message Request message string.
+	 */
+	public static function parseRequest(string $message) : RequestInterface
+	{
+		$data = self::parseMessage($message);
+		$matches = [];
+		if (!\preg_match('/^[\\S]+\\s+([a-zA-Z]+:\\/\\/|\\/).*/', $data['start-line'], $matches)) {
+			throw new \InvalidArgumentException('Invalid request string');
+		}
+		$parts = \explode(' ', $data['start-line'], 3);
+		$version = isset($parts[2]) ? \explode('/', $parts[2])[1] : '1.1';
+		$request = new Request($parts[0], $matches[1] === '/' ? self::parseRequestUri($parts[1], $data['headers']) : $parts[1], $data['headers'], $data['body'], $version);
+		return $matches[1] === '/' ? $request : $request->withRequestTarget($parts[1]);
+	}
+	/**
+	 * Parses a response message string into a response object.
+	 *
+	 * @param string $message Response message string.
+	 */
+	public static function parseResponse(string $message) : ResponseInterface
+	{
+		$data = self::parseMessage($message);
+		// According to https://datatracker.ietf.org/doc/html/rfc7230#section-3.1.2
+		// the space between status-code and reason-phrase is required. But
+		// browsers accept responses without space and reason as well.
+		if (!\preg_match('/^HTTP\\/.* [0-9]{3}( .*|$)/', $data['start-line'])) {
+			throw new \InvalidArgumentException('Invalid response string: ' . $data['start-line']);
+		}
+		$parts = \explode(' ', $data['start-line'], 3);
+		return new Response((int) $parts[1], $data['headers'], $data['body'], \explode('/', $parts[0])[1], $parts[2] ?? null);
+	}
 }

Spacing +12 added lines, -12 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\MessageInterface;
@@ -16,25 +16,25 @@ 
     public static function toString(MessageInterface $message) : string
     {
         if ($message instanceof RequestInterface) {
-            $msg = \trim($message->getMethod() . ' ' . $message->getRequestTarget()) . ' HTTP/' . $message->getProtocolVersion();
+            $msg = \trim($message->getMethod().' '.$message->getRequestTarget()).' HTTP/'.$message->getProtocolVersion();
             if (!$message->hasHeader('host')) {
-                $msg .= "\r\nHost: " . $message->getUri()->getHost();
+                $msg .= "\r\nHost: ".$message->getUri()->getHost();
             }
         } elseif ($message instanceof ResponseInterface) {
-            $msg = 'HTTP/' . $message->getProtocolVersion() . ' ' . $message->getStatusCode() . ' ' . $message->getReasonPhrase();
+            $msg = 'HTTP/'.$message->getProtocolVersion().' '.$message->getStatusCode().' '.$message->getReasonPhrase();
         } else {
             throw new \InvalidArgumentException('Unknown message type');
         }
         foreach ($message->getHeaders() as $name => $values) {
             if (\is_string($name) && \strtolower($name) === 'set-cookie') {
                 foreach ($values as $value) {
-                    $msg .= "\r\n{$name}: " . $value;
+                    $msg .= "\r\n{$name}: ".$value;
                 }
             } else {
-                $msg .= "\r\n{$name}: " . \implode(', ', $values);
+                $msg .= "\r\n{$name}: ".\implode(', ', $values);
             }
         }
-        return "{$msg}\r\n\r\n" . $message->getBody();
+        return "{$msg}\r\n\r\n".$message->getBody();
     }
     /**
      * Get a short summary of the message body.
@@ -139,9 +139,9 @@ 
      */
     public static function parseRequestUri(string $path, array $headers) : string
     {
-        $hostKey = \array_filter(\array_keys($headers), function ($k) {
+        $hostKey = \array_filter(\array_keys($headers), function($k) {
             // Numeric array keys are converted to int by PHP.
-            $k = (string) $k;
+            $k = (string)$k;
             return \strtolower($k) === 'host';
         });
         // If no host is found, then a full URI cannot be constructed.
@@ -150,7 +150,7 @@ 
         }
         $host = $headers[\reset($hostKey)][0];
         $scheme = \substr($host, -4) === ':443' ? 'https' : 'http';
-        return $scheme . '://' . $host . '/' . \ltrim($path, '/');
+        return $scheme.'://'.$host.'/'.\ltrim($path, '/');
     }
     /**
      * Parses a request message string into a request object.
@@ -181,9 +181,9 @@ 
         // the space between status-code and reason-phrase is required. But
         // browsers accept responses without space and reason as well.
         if (!\preg_match('/^HTTP\\/.* [0-9]{3}( .*|$)/', $data['start-line'])) {
-            throw new \InvalidArgumentException('Invalid response string: ' . $data['start-line']);
+            throw new \InvalidArgumentException('Invalid response string: '.$data['start-line']);
         }
         $parts = \explode(' ', $data['start-line'], 3);
-        return new Response((int) $parts[1], $data['headers'], $data['body'], \explode('/', $parts[0])[1], $parts[2] ?? null);
+        return new Response((int)$parts[1], $data['headers'], $data['body'], \explode('/', $parts[0])[1], $parts[2] ?? null);
     }
 }

Braces +1 added lines, -2 removed lines

@@ -6,8 +6,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\MessageInterface;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\RequestInterface;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface;
-final class Message
-{
+final class Message {
     /**
      * Returns the string representation of an HTTP message.
      *

lib/Vendor/GuzzleHttp/Psr7/InflateStream.php

Indentation +13 added lines, -13 removed lines

@@ -17,17 +17,17 @@
  */
 final class InflateStream implements StreamInterface
 {
-    use StreamDecoratorTrait;
-    /** @var StreamInterface */
-    private $stream;
-    public function __construct(StreamInterface $stream)
-    {
-        $resource = StreamWrapper::getResource($stream);
-        // Specify window=15+32, so zlib will use header detection to both gzip (with header) and zlib data
-        // See https://www.zlib.net/manual.html#Advanced definition of inflateInit2
-        // "Add 32 to windowBits to enable zlib and gzip decoding with automatic header detection"
-        // Default window size is 15.
-        \stream_filter_append($resource, 'zlib.inflate', \STREAM_FILTER_READ, ['window' => 15 + 32]);
-        $this->stream = $stream->isSeekable() ? new Stream($resource) : new NoSeekStream(new Stream($resource));
-    }
+	use StreamDecoratorTrait;
+	/** @var StreamInterface */
+	private $stream;
+	public function __construct(StreamInterface $stream)
+	{
+		$resource = StreamWrapper::getResource($stream);
+		// Specify window=15+32, so zlib will use header detection to both gzip (with header) and zlib data
+		// See https://www.zlib.net/manual.html#Advanced definition of inflateInit2
+		// "Add 32 to windowBits to enable zlib and gzip decoding with automatic header detection"
+		// Default window size is 15.
+		\stream_filter_append($resource, 'zlib.inflate', \STREAM_FILTER_READ, ['window' => 15 + 32]);
+		$this->stream = $stream->isSeekable() ? new Stream($resource) : new NoSeekStream(new Stream($resource));
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -15,8 +15,7 @@
  * @see https://datatracker.ietf.org/doc/html/rfc1952
  * @see https://www.php.net/manual/en/filters.compression.php
  */
-final class InflateStream implements StreamInterface
-{
+final class InflateStream implements StreamInterface {
     use StreamDecoratorTrait;
     /** @var StreamInterface */
     private $stream;

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;

lib/Vendor/GuzzleHttp/Psr7/LimitStream.php

Indentation +116 added lines, -116 removed lines

@@ -9,120 +9,120 @@
  */
 final class LimitStream implements StreamInterface
 {
-    use StreamDecoratorTrait;
-    /** @var int Offset to start reading from */
-    private $offset;
-    /** @var int Limit the number of bytes that can be read */
-    private $limit;
-    /** @var StreamInterface */
-    private $stream;
-    /**
-     * @param StreamInterface $stream Stream to wrap
-     * @param int             $limit  Total number of bytes to allow to be read
-     *                                from the stream. Pass -1 for no limit.
-     * @param int             $offset Position to seek to before reading (only
-     *                                works on seekable streams).
-     */
-    public function __construct(StreamInterface $stream, int $limit = -1, int $offset = 0)
-    {
-        $this->stream = $stream;
-        $this->setLimit($limit);
-        $this->setOffset($offset);
-    }
-    public function eof() : bool
-    {
-        // Always return true if the underlying stream is EOF
-        if ($this->stream->eof()) {
-            return \true;
-        }
-        // No limit and the underlying stream is not at EOF
-        if ($this->limit === -1) {
-            return \false;
-        }
-        return $this->stream->tell() >= $this->offset + $this->limit;
-    }
-    /**
-     * Returns the size of the limited subset of data
-     */
-    public function getSize() : ?int
-    {
-        if (null === ($length = $this->stream->getSize())) {
-            return null;
-        } elseif ($this->limit === -1) {
-            return $length - $this->offset;
-        } else {
-            return \min($this->limit, $length - $this->offset);
-        }
-    }
-    /**
-     * Allow for a bounded seek on the read limited stream
-     */
-    public function seek($offset, $whence = \SEEK_SET) : void
-    {
-        if ($whence !== \SEEK_SET || $offset < 0) {
-            throw new \RuntimeException(\sprintf('Cannot seek to offset %s with whence %s', $offset, $whence));
-        }
-        $offset += $this->offset;
-        if ($this->limit !== -1) {
-            if ($offset > $this->offset + $this->limit) {
-                $offset = $this->offset + $this->limit;
-            }
-        }
-        $this->stream->seek($offset);
-    }
-    /**
-     * Give a relative tell()
-     */
-    public function tell() : int
-    {
-        return $this->stream->tell() - $this->offset;
-    }
-    /**
-     * Set the offset to start limiting from
-     *
-     * @param int $offset Offset to seek to and begin byte limiting from
-     *
-     * @throws \RuntimeException if the stream cannot be seeked.
-     */
-    public function setOffset(int $offset) : void
-    {
-        $current = $this->stream->tell();
-        if ($current !== $offset) {
-            // If the stream cannot seek to the offset position, then read to it
-            if ($this->stream->isSeekable()) {
-                $this->stream->seek($offset);
-            } elseif ($current > $offset) {
-                throw new \RuntimeException("Could not seek to stream offset {$offset}");
-            } else {
-                $this->stream->read($offset - $current);
-            }
-        }
-        $this->offset = $offset;
-    }
-    /**
-     * Set the limit of bytes that the decorator allows to be read from the
-     * stream.
-     *
-     * @param int $limit Number of bytes to allow to be read from the stream.
-     *                   Use -1 for no limit.
-     */
-    public function setLimit(int $limit) : void
-    {
-        $this->limit = $limit;
-    }
-    public function read($length) : string
-    {
-        if ($this->limit === -1) {
-            return $this->stream->read($length);
-        }
-        // Check if the current position is less than the total allowed
-        // bytes + original offset
-        $remaining = $this->offset + $this->limit - $this->stream->tell();
-        if ($remaining > 0) {
-            // Only return the amount of requested data, ensuring that the byte
-            // limit is not exceeded
-            return $this->stream->read(\min($remaining, $length));
-        }
-        return '';
-    }
+	use StreamDecoratorTrait;
+	/** @var int Offset to start reading from */
+	private $offset;
+	/** @var int Limit the number of bytes that can be read */
+	private $limit;
+	/** @var StreamInterface */
+	private $stream;
+	/**
+	 * @param StreamInterface $stream Stream to wrap
+	 * @param int             $limit  Total number of bytes to allow to be read
+	 *                                from the stream. Pass -1 for no limit.
+	 * @param int             $offset Position to seek to before reading (only
+	 *                                works on seekable streams).
+	 */
+	public function __construct(StreamInterface $stream, int $limit = -1, int $offset = 0)
+	{
+		$this->stream = $stream;
+		$this->setLimit($limit);
+		$this->setOffset($offset);
+	}
+	public function eof() : bool
+	{
+		// Always return true if the underlying stream is EOF
+		if ($this->stream->eof()) {
+			return \true;
+		}
+		// No limit and the underlying stream is not at EOF
+		if ($this->limit === -1) {
+			return \false;
+		}
+		return $this->stream->tell() >= $this->offset + $this->limit;
+	}
+	/**
+	 * Returns the size of the limited subset of data
+	 */
+	public function getSize() : ?int
+	{
+		if (null === ($length = $this->stream->getSize())) {
+			return null;
+		} elseif ($this->limit === -1) {
+			return $length - $this->offset;
+		} else {
+			return \min($this->limit, $length - $this->offset);
+		}
+	}
+	/**
+	 * Allow for a bounded seek on the read limited stream
+	 */
+	public function seek($offset, $whence = \SEEK_SET) : void
+	{
+		if ($whence !== \SEEK_SET || $offset < 0) {
+			throw new \RuntimeException(\sprintf('Cannot seek to offset %s with whence %s', $offset, $whence));
+		}
+		$offset += $this->offset;
+		if ($this->limit !== -1) {
+			if ($offset > $this->offset + $this->limit) {
+				$offset = $this->offset + $this->limit;
+			}
+		}
+		$this->stream->seek($offset);
+	}
+	/**
+	 * Give a relative tell()
+	 */
+	public function tell() : int
+	{
+		return $this->stream->tell() - $this->offset;
+	}
+	/**
+	 * Set the offset to start limiting from
+	 *
+	 * @param int $offset Offset to seek to and begin byte limiting from
+	 *
+	 * @throws \RuntimeException if the stream cannot be seeked.
+	 */
+	public function setOffset(int $offset) : void
+	{
+		$current = $this->stream->tell();
+		if ($current !== $offset) {
+			// If the stream cannot seek to the offset position, then read to it
+			if ($this->stream->isSeekable()) {
+				$this->stream->seek($offset);
+			} elseif ($current > $offset) {
+				throw new \RuntimeException("Could not seek to stream offset {$offset}");
+			} else {
+				$this->stream->read($offset - $current);
+			}
+		}
+		$this->offset = $offset;
+	}
+	/**
+	 * Set the limit of bytes that the decorator allows to be read from the
+	 * stream.
+	 *
+	 * @param int $limit Number of bytes to allow to be read from the stream.
+	 *                   Use -1 for no limit.
+	 */
+	public function setLimit(int $limit) : void
+	{
+		$this->limit = $limit;
+	}
+	public function read($length) : string
+	{
+		if ($this->limit === -1) {
+			return $this->stream->read($length);
+		}
+		// Check if the current position is less than the total allowed
+		// bytes + original offset
+		$remaining = $this->offset + $this->limit - $this->stream->tell();
+		if ($remaining > 0) {
+			// Only return the amount of requested data, ensuring that the byte
+			// limit is not exceeded
+			return $this->stream->read(\min($remaining, $length));
+		}
+		return '';
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -7,8 +7,7 @@
 /**
  * Decorator used to return only a subset of a stream.
  */
-final class LimitStream implements StreamInterface
-{
+final class LimitStream implements StreamInterface {
     use StreamDecoratorTrait;
     /** @var int Offset to start reading from */
     private $offset;

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;

lib/Vendor/GuzzleHttp/Psr7/CachingStream.php

Indentation +112 added lines, -112 removed lines

@@ -10,116 +10,116 @@
  */
 final class CachingStream implements StreamInterface
 {
-    use StreamDecoratorTrait;
-    /** @var StreamInterface Stream being wrapped */
-    private $remoteStream;
-    /** @var int Number of bytes to skip reading due to a write on the buffer */
-    private $skipReadBytes = 0;
-    /**
-     * @var StreamInterface
-     */
-    private $stream;
-    /**
-     * We will treat the buffer object as the body of the stream
-     *
-     * @param StreamInterface $stream Stream to cache. The cursor is assumed to be at the beginning of the stream.
-     * @param StreamInterface $target Optionally specify where data is cached
-     */
-    public function __construct(StreamInterface $stream, StreamInterface $target = null)
-    {
-        $this->remoteStream = $stream;
-        $this->stream = $target ?: new Stream(Utils::tryFopen('php://temp', 'r+'));
-    }
-    public function getSize() : ?int
-    {
-        $remoteSize = $this->remoteStream->getSize();
-        if (null === $remoteSize) {
-            return null;
-        }
-        return \max($this->stream->getSize(), $remoteSize);
-    }
-    public function rewind() : void
-    {
-        $this->seek(0);
-    }
-    public function seek($offset, $whence = \SEEK_SET) : void
-    {
-        if ($whence === \SEEK_SET) {
-            $byte = $offset;
-        } elseif ($whence === \SEEK_CUR) {
-            $byte = $offset + $this->tell();
-        } elseif ($whence === \SEEK_END) {
-            $size = $this->remoteStream->getSize();
-            if ($size === null) {
-                $size = $this->cacheEntireStream();
-            }
-            $byte = $size + $offset;
-        } else {
-            throw new \InvalidArgumentException('Invalid whence');
-        }
-        $diff = $byte - $this->stream->getSize();
-        if ($diff > 0) {
-            // Read the remoteStream until we have read in at least the amount
-            // of bytes requested, or we reach the end of the file.
-            while ($diff > 0 && !$this->remoteStream->eof()) {
-                $this->read($diff);
-                $diff = $byte - $this->stream->getSize();
-            }
-        } else {
-            // We can just do a normal seek since we've already seen this byte.
-            $this->stream->seek($byte);
-        }
-    }
-    public function read($length) : string
-    {
-        // Perform a regular read on any previously read data from the buffer
-        $data = $this->stream->read($length);
-        $remaining = $length - \strlen($data);
-        // More data was requested so read from the remote stream
-        if ($remaining) {
-            // If data was written to the buffer in a position that would have
-            // been filled from the remote stream, then we must skip bytes on
-            // the remote stream to emulate overwriting bytes from that
-            // position. This mimics the behavior of other PHP stream wrappers.
-            $remoteData = $this->remoteStream->read($remaining + $this->skipReadBytes);
-            if ($this->skipReadBytes) {
-                $len = \strlen($remoteData);
-                $remoteData = \substr($remoteData, $this->skipReadBytes);
-                $this->skipReadBytes = \max(0, $this->skipReadBytes - $len);
-            }
-            $data .= $remoteData;
-            $this->stream->write($remoteData);
-        }
-        return $data;
-    }
-    public function write($string) : int
-    {
-        // When appending to the end of the currently read stream, you'll want
-        // to skip bytes from being read from the remote stream to emulate
-        // other stream wrappers. Basically replacing bytes of data of a fixed
-        // length.
-        $overflow = \strlen($string) + $this->tell() - $this->remoteStream->tell();
-        if ($overflow > 0) {
-            $this->skipReadBytes += $overflow;
-        }
-        return $this->stream->write($string);
-    }
-    public function eof() : bool
-    {
-        return $this->stream->eof() && $this->remoteStream->eof();
-    }
-    /**
-     * Close both the remote stream and buffer stream
-     */
-    public function close() : void
-    {
-        $this->remoteStream->close();
-        $this->stream->close();
-    }
-    private function cacheEntireStream() : int
-    {
-        $target = new FnStream(['write' => 'strlen']);
-        Utils::copyToStream($this, $target);
-        return $this->tell();
-    }
+	use StreamDecoratorTrait;
+	/** @var StreamInterface Stream being wrapped */
+	private $remoteStream;
+	/** @var int Number of bytes to skip reading due to a write on the buffer */
+	private $skipReadBytes = 0;
+	/**
+	 * @var StreamInterface
+	 */
+	private $stream;
+	/**
+	 * We will treat the buffer object as the body of the stream
+	 *
+	 * @param StreamInterface $stream Stream to cache. The cursor is assumed to be at the beginning of the stream.
+	 * @param StreamInterface $target Optionally specify where data is cached
+	 */
+	public function __construct(StreamInterface $stream, StreamInterface $target = null)
+	{
+		$this->remoteStream = $stream;
+		$this->stream = $target ?: new Stream(Utils::tryFopen('php://temp', 'r+'));
+	}
+	public function getSize() : ?int
+	{
+		$remoteSize = $this->remoteStream->getSize();
+		if (null === $remoteSize) {
+			return null;
+		}
+		return \max($this->stream->getSize(), $remoteSize);
+	}
+	public function rewind() : void
+	{
+		$this->seek(0);
+	}
+	public function seek($offset, $whence = \SEEK_SET) : void
+	{
+		if ($whence === \SEEK_SET) {
+			$byte = $offset;
+		} elseif ($whence === \SEEK_CUR) {
+			$byte = $offset + $this->tell();
+		} elseif ($whence === \SEEK_END) {
+			$size = $this->remoteStream->getSize();
+			if ($size === null) {
+				$size = $this->cacheEntireStream();
+			}
+			$byte = $size + $offset;
+		} else {
+			throw new \InvalidArgumentException('Invalid whence');
+		}
+		$diff = $byte - $this->stream->getSize();
+		if ($diff > 0) {
+			// Read the remoteStream until we have read in at least the amount
+			// of bytes requested, or we reach the end of the file.
+			while ($diff > 0 && !$this->remoteStream->eof()) {
+				$this->read($diff);
+				$diff = $byte - $this->stream->getSize();
+			}
+		} else {
+			// We can just do a normal seek since we've already seen this byte.
+			$this->stream->seek($byte);
+		}
+	}
+	public function read($length) : string
+	{
+		// Perform a regular read on any previously read data from the buffer
+		$data = $this->stream->read($length);
+		$remaining = $length - \strlen($data);
+		// More data was requested so read from the remote stream
+		if ($remaining) {
+			// If data was written to the buffer in a position that would have
+			// been filled from the remote stream, then we must skip bytes on
+			// the remote stream to emulate overwriting bytes from that
+			// position. This mimics the behavior of other PHP stream wrappers.
+			$remoteData = $this->remoteStream->read($remaining + $this->skipReadBytes);
+			if ($this->skipReadBytes) {
+				$len = \strlen($remoteData);
+				$remoteData = \substr($remoteData, $this->skipReadBytes);
+				$this->skipReadBytes = \max(0, $this->skipReadBytes - $len);
+			}
+			$data .= $remoteData;
+			$this->stream->write($remoteData);
+		}
+		return $data;
+	}
+	public function write($string) : int
+	{
+		// When appending to the end of the currently read stream, you'll want
+		// to skip bytes from being read from the remote stream to emulate
+		// other stream wrappers. Basically replacing bytes of data of a fixed
+		// length.
+		$overflow = \strlen($string) + $this->tell() - $this->remoteStream->tell();
+		if ($overflow > 0) {
+			$this->skipReadBytes += $overflow;
+		}
+		return $this->stream->write($string);
+	}
+	public function eof() : bool
+	{
+		return $this->stream->eof() && $this->remoteStream->eof();
+	}
+	/**
+	 * Close both the remote stream and buffer stream
+	 */
+	public function close() : void
+	{
+		$this->remoteStream->close();
+		$this->stream->close();
+	}
+	private function cacheEntireStream() : int
+	{
+		$target = new FnStream(['write' => 'strlen']);
+		Utils::copyToStream($this, $target);
+		return $this->tell();
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -8,8 +8,7 @@
  * Stream decorator that can cache previously read bytes from a sequentially
  * read stream.
  */
-final class CachingStream implements StreamInterface
-{
+final class CachingStream implements StreamInterface {
     use StreamDecoratorTrait;
     /** @var StreamInterface Stream being wrapped */
     private $remoteStream;

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;

lib/Vendor/GuzzleHttp/Psr7/Uri.php

Indentation +555 added lines, -555 removed lines

@@ -14,559 +14,559 @@
  */
 class Uri implements UriInterface, \JsonSerializable
 {
-    /**
-     * Absolute http and https URIs require a host per RFC 7230 Section 2.7
-     * but in generic URIs the host can be empty. So for http(s) URIs
-     * we apply this default host when no host is given yet to form a
-     * valid URI.
-     */
-    private const HTTP_DEFAULT_HOST = 'localhost';
-    private const DEFAULT_PORTS = ['http' => 80, 'https' => 443, 'ftp' => 21, 'gopher' => 70, 'nntp' => 119, 'news' => 119, 'telnet' => 23, 'tn3270' => 23, 'imap' => 143, 'pop' => 110, 'ldap' => 389];
-    /**
-     * Unreserved characters for use in a regex.
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-2.3
-     */
-    private const CHAR_UNRESERVED = 'a-zA-Z0-9_\\-\\.~';
-    /**
-     * Sub-delims for use in a regex.
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-2.2
-     */
-    private const CHAR_SUB_DELIMS = '!\\$&\'\\(\\)\\*\\+,;=';
-    private const QUERY_SEPARATORS_REPLACEMENT = ['=' => '%3D', '&' => '%26'];
-    /** @var string Uri scheme. */
-    private $scheme = '';
-    /** @var string Uri user info. */
-    private $userInfo = '';
-    /** @var string Uri host. */
-    private $host = '';
-    /** @var int|null Uri port. */
-    private $port;
-    /** @var string Uri path. */
-    private $path = '';
-    /** @var string Uri query string. */
-    private $query = '';
-    /** @var string Uri fragment. */
-    private $fragment = '';
-    /** @var string|null String representation */
-    private $composedComponents;
-    public function __construct(string $uri = '')
-    {
-        if ($uri !== '') {
-            $parts = self::parse($uri);
-            if ($parts === \false) {
-                throw new MalformedUriException("Unable to parse URI: {$uri}");
-            }
-            $this->applyParts($parts);
-        }
-    }
-    /**
-     * UTF-8 aware \parse_url() replacement.
-     *
-     * The internal function produces broken output for non ASCII domain names
-     * (IDN) when used with locales other than "C".
-     *
-     * On the other hand, cURL understands IDN correctly only when UTF-8 locale
-     * is configured ("C.UTF-8", "en_US.UTF-8", etc.).
-     *
-     * @see https://bugs.php.net/bug.php?id=52923
-     * @see https://www.php.net/manual/en/function.parse-url.php#114817
-     * @see https://curl.haxx.se/libcurl/c/CURLOPT_URL.html#ENCODING
-     *
-     * @return array|false
-     */
-    private static function parse(string $url)
-    {
-        // If IPv6
-        $prefix = '';
-        if (\preg_match('%^(.*://\\[[0-9:a-f]+\\])(.*?)$%', $url, $matches)) {
-            /** @var array{0:string, 1:string, 2:string} $matches */
-            $prefix = $matches[1];
-            $url = $matches[2];
-        }
-        /** @var string */
-        $encodedUrl = \preg_replace_callback('%[^:/@?&=#]+%usD', static function ($matches) {
-            return \urlencode($matches[0]);
-        }, $url);
-        $result = \parse_url($prefix . $encodedUrl);
-        if ($result === \false) {
-            return \false;
-        }
-        return \array_map('urldecode', $result);
-    }
-    public function __toString() : string
-    {
-        if ($this->composedComponents === null) {
-            $this->composedComponents = self::composeComponents($this->scheme, $this->getAuthority(), $this->path, $this->query, $this->fragment);
-        }
-        return $this->composedComponents;
-    }
-    /**
-     * Composes a URI reference string from its various components.
-     *
-     * Usually this method does not need to be called manually but instead is used indirectly via
-     * `Psr\Http\Message\UriInterface::__toString`.
-     *
-     * PSR-7 UriInterface treats an empty component the same as a missing component as
-     * getQuery(), getFragment() etc. always return a string. This explains the slight
-     * difference to RFC 3986 Section 5.3.
-     *
-     * Another adjustment is that the authority separator is added even when the authority is missing/empty
-     * for the "file" scheme. This is because PHP stream functions like `file_get_contents` only work with
-     * `file:///myfile` but not with `file:/myfile` although they are equivalent according to RFC 3986. But
-     * `file:///` is the more common syntax for the file scheme anyway (Chrome for example redirects to
-     * that format).
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-5.3
-     */
-    public static function composeComponents(?string $scheme, ?string $authority, string $path, ?string $query, ?string $fragment) : string
-    {
-        $uri = '';
-        // weak type checks to also accept null until we can add scalar type hints
-        if ($scheme != '') {
-            $uri .= $scheme . ':';
-        }
-        if ($authority != '' || $scheme === 'file') {
-            $uri .= '//' . $authority;
-        }
-        if ($authority != '' && $path != '' && $path[0] != '/') {
-            $path = '/' . $path;
-        }
-        $uri .= $path;
-        if ($query != '') {
-            $uri .= '?' . $query;
-        }
-        if ($fragment != '') {
-            $uri .= '#' . $fragment;
-        }
-        return $uri;
-    }
-    /**
-     * Whether the URI has the default port of the current scheme.
-     *
-     * `Psr\Http\Message\UriInterface::getPort` may return null or the standard port. This method can be used
-     * independently of the implementation.
-     */
-    public static function isDefaultPort(UriInterface $uri) : bool
-    {
-        return $uri->getPort() === null || isset(self::DEFAULT_PORTS[$uri->getScheme()]) && $uri->getPort() === self::DEFAULT_PORTS[$uri->getScheme()];
-    }
-    /**
-     * Whether the URI is absolute, i.e. it has a scheme.
-     *
-     * An instance of UriInterface can either be an absolute URI or a relative reference. This method returns true
-     * if it is the former. An absolute URI has a scheme. A relative reference is used to express a URI relative
-     * to another URI, the base URI. Relative references can be divided into several forms:
-     * - network-path references, e.g. '//example.com/path'
-     * - absolute-path references, e.g. '/path'
-     * - relative-path references, e.g. 'subpath'
-     *
-     * @see Uri::isNetworkPathReference
-     * @see Uri::isAbsolutePathReference
-     * @see Uri::isRelativePathReference
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4
-     */
-    public static function isAbsolute(UriInterface $uri) : bool
-    {
-        return $uri->getScheme() !== '';
-    }
-    /**
-     * Whether the URI is a network-path reference.
-     *
-     * A relative reference that begins with two slash characters is termed an network-path reference.
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.2
-     */
-    public static function isNetworkPathReference(UriInterface $uri) : bool
-    {
-        return $uri->getScheme() === '' && $uri->getAuthority() !== '';
-    }
-    /**
-     * Whether the URI is a absolute-path reference.
-     *
-     * A relative reference that begins with a single slash character is termed an absolute-path reference.
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.2
-     */
-    public static function isAbsolutePathReference(UriInterface $uri) : bool
-    {
-        return $uri->getScheme() === '' && $uri->getAuthority() === '' && isset($uri->getPath()[0]) && $uri->getPath()[0] === '/';
-    }
-    /**
-     * Whether the URI is a relative-path reference.
-     *
-     * A relative reference that does not begin with a slash character is termed a relative-path reference.
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.2
-     */
-    public static function isRelativePathReference(UriInterface $uri) : bool
-    {
-        return $uri->getScheme() === '' && $uri->getAuthority() === '' && (!isset($uri->getPath()[0]) || $uri->getPath()[0] !== '/');
-    }
-    /**
-     * Whether the URI is a same-document reference.
-     *
-     * A same-document reference refers to a URI that is, aside from its fragment
-     * component, identical to the base URI. When no base URI is given, only an empty
-     * URI reference (apart from its fragment) is considered a same-document reference.
-     *
-     * @param UriInterface      $uri  The URI to check
-     * @param UriInterface|null $base An optional base URI to compare against
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.4
-     */
-    public static function isSameDocumentReference(UriInterface $uri, UriInterface $base = null) : bool
-    {
-        if ($base !== null) {
-            $uri = UriResolver::resolve($base, $uri);
-            return $uri->getScheme() === $base->getScheme() && $uri->getAuthority() === $base->getAuthority() && $uri->getPath() === $base->getPath() && $uri->getQuery() === $base->getQuery();
-        }
-        return $uri->getScheme() === '' && $uri->getAuthority() === '' && $uri->getPath() === '' && $uri->getQuery() === '';
-    }
-    /**
-     * Creates a new URI with a specific query string value removed.
-     *
-     * Any existing query string values that exactly match the provided key are
-     * removed.
-     *
-     * @param UriInterface $uri URI to use as a base.
-     * @param string       $key Query string key to remove.
-     */
-    public static function withoutQueryValue(UriInterface $uri, string $key) : UriInterface
-    {
-        $result = self::getFilteredQueryString($uri, [$key]);
-        return $uri->withQuery(\implode('&', $result));
-    }
-    /**
-     * Creates a new URI with a specific query string value.
-     *
-     * Any existing query string values that exactly match the provided key are
-     * removed and replaced with the given key value pair.
-     *
-     * A value of null will set the query string key without a value, e.g. "key"
-     * instead of "key=value".
-     *
-     * @param UriInterface $uri   URI to use as a base.
-     * @param string       $key   Key to set.
-     * @param string|null  $value Value to set
-     */
-    public static function withQueryValue(UriInterface $uri, string $key, ?string $value) : UriInterface
-    {
-        $result = self::getFilteredQueryString($uri, [$key]);
-        $result[] = self::generateQueryString($key, $value);
-        return $uri->withQuery(\implode('&', $result));
-    }
-    /**
-     * Creates a new URI with multiple specific query string values.
-     *
-     * It has the same behavior as withQueryValue() but for an associative array of key => value.
-     *
-     * @param UriInterface    $uri           URI to use as a base.
-     * @param (string|null)[] $keyValueArray Associative array of key and values
-     */
-    public static function withQueryValues(UriInterface $uri, array $keyValueArray) : UriInterface
-    {
-        $result = self::getFilteredQueryString($uri, \array_keys($keyValueArray));
-        foreach ($keyValueArray as $key => $value) {
-            $result[] = self::generateQueryString((string) $key, $value !== null ? (string) $value : null);
-        }
-        return $uri->withQuery(\implode('&', $result));
-    }
-    /**
-     * Creates a URI from a hash of `parse_url` components.
-     *
-     * @see https://www.php.net/manual/en/function.parse-url.php
-     *
-     * @throws MalformedUriException If the components do not form a valid URI.
-     */
-    public static function fromParts(array $parts) : UriInterface
-    {
-        $uri = new self();
-        $uri->applyParts($parts);
-        $uri->validateState();
-        return $uri;
-    }
-    public function getScheme() : string
-    {
-        return $this->scheme;
-    }
-    public function getAuthority() : string
-    {
-        $authority = $this->host;
-        if ($this->userInfo !== '') {
-            $authority = $this->userInfo . '@' . $authority;
-        }
-        if ($this->port !== null) {
-            $authority .= ':' . $this->port;
-        }
-        return $authority;
-    }
-    public function getUserInfo() : string
-    {
-        return $this->userInfo;
-    }
-    public function getHost() : string
-    {
-        return $this->host;
-    }
-    public function getPort() : ?int
-    {
-        return $this->port;
-    }
-    public function getPath() : string
-    {
-        return $this->path;
-    }
-    public function getQuery() : string
-    {
-        return $this->query;
-    }
-    public function getFragment() : string
-    {
-        return $this->fragment;
-    }
-    public function withScheme($scheme) : UriInterface
-    {
-        $scheme = $this->filterScheme($scheme);
-        if ($this->scheme === $scheme) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->scheme = $scheme;
-        $new->composedComponents = null;
-        $new->removeDefaultPort();
-        $new->validateState();
-        return $new;
-    }
-    public function withUserInfo($user, $password = null) : UriInterface
-    {
-        $info = $this->filterUserInfoComponent($user);
-        if ($password !== null) {
-            $info .= ':' . $this->filterUserInfoComponent($password);
-        }
-        if ($this->userInfo === $info) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->userInfo = $info;
-        $new->composedComponents = null;
-        $new->validateState();
-        return $new;
-    }
-    public function withHost($host) : UriInterface
-    {
-        $host = $this->filterHost($host);
-        if ($this->host === $host) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->host = $host;
-        $new->composedComponents = null;
-        $new->validateState();
-        return $new;
-    }
-    public function withPort($port) : UriInterface
-    {
-        $port = $this->filterPort($port);
-        if ($this->port === $port) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->port = $port;
-        $new->composedComponents = null;
-        $new->removeDefaultPort();
-        $new->validateState();
-        return $new;
-    }
-    public function withPath($path) : UriInterface
-    {
-        $path = $this->filterPath($path);
-        if ($this->path === $path) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->path = $path;
-        $new->composedComponents = null;
-        $new->validateState();
-        return $new;
-    }
-    public function withQuery($query) : UriInterface
-    {
-        $query = $this->filterQueryAndFragment($query);
-        if ($this->query === $query) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->query = $query;
-        $new->composedComponents = null;
-        return $new;
-    }
-    public function withFragment($fragment) : UriInterface
-    {
-        $fragment = $this->filterQueryAndFragment($fragment);
-        if ($this->fragment === $fragment) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->fragment = $fragment;
-        $new->composedComponents = null;
-        return $new;
-    }
-    public function jsonSerialize() : string
-    {
-        return $this->__toString();
-    }
-    /**
-     * Apply parse_url parts to a URI.
-     *
-     * @param array $parts Array of parse_url parts to apply.
-     */
-    private function applyParts(array $parts) : void
-    {
-        $this->scheme = isset($parts['scheme']) ? $this->filterScheme($parts['scheme']) : '';
-        $this->userInfo = isset($parts['user']) ? $this->filterUserInfoComponent($parts['user']) : '';
-        $this->host = isset($parts['host']) ? $this->filterHost($parts['host']) : '';
-        $this->port = isset($parts['port']) ? $this->filterPort($parts['port']) : null;
-        $this->path = isset($parts['path']) ? $this->filterPath($parts['path']) : '';
-        $this->query = isset($parts['query']) ? $this->filterQueryAndFragment($parts['query']) : '';
-        $this->fragment = isset($parts['fragment']) ? $this->filterQueryAndFragment($parts['fragment']) : '';
-        if (isset($parts['pass'])) {
-            $this->userInfo .= ':' . $this->filterUserInfoComponent($parts['pass']);
-        }
-        $this->removeDefaultPort();
-    }
-    /**
-     * @param mixed $scheme
-     *
-     * @throws \InvalidArgumentException If the scheme is invalid.
-     */
-    private function filterScheme($scheme) : string
-    {
-        if (!\is_string($scheme)) {
-            throw new \InvalidArgumentException('Scheme must be a string');
-        }
-        return \strtr($scheme, 'ABCDEFGHIJKLMNOPQRSTUVWXYZ', 'abcdefghijklmnopqrstuvwxyz');
-    }
-    /**
-     * @param mixed $component
-     *
-     * @throws \InvalidArgumentException If the user info is invalid.
-     */
-    private function filterUserInfoComponent($component) : string
-    {
-        if (!\is_string($component)) {
-            throw new \InvalidArgumentException('User info must be a string');
-        }
-        return \preg_replace_callback('/(?:[^%' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . ']+|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $component);
-    }
-    /**
-     * @param mixed $host
-     *
-     * @throws \InvalidArgumentException If the host is invalid.
-     */
-    private function filterHost($host) : string
-    {
-        if (!\is_string($host)) {
-            throw new \InvalidArgumentException('Host must be a string');
-        }
-        return \strtr($host, 'ABCDEFGHIJKLMNOPQRSTUVWXYZ', 'abcdefghijklmnopqrstuvwxyz');
-    }
-    /**
-     * @param mixed $port
-     *
-     * @throws \InvalidArgumentException If the port is invalid.
-     */
-    private function filterPort($port) : ?int
-    {
-        if ($port === null) {
-            return null;
-        }
-        $port = (int) $port;
-        if (0 > $port || 0xffff < $port) {
-            throw new \InvalidArgumentException(\sprintf('Invalid port: %d. Must be between 0 and 65535', $port));
-        }
-        return $port;
-    }
-    /**
-     * @param (string|int)[] $keys
-     *
-     * @return string[]
-     */
-    private static function getFilteredQueryString(UriInterface $uri, array $keys) : array
-    {
-        $current = $uri->getQuery();
-        if ($current === '') {
-            return [];
-        }
-        $decodedKeys = \array_map(function ($k) : string {
-            return \rawurldecode((string) $k);
-        }, $keys);
-        return \array_filter(\explode('&', $current), function ($part) use($decodedKeys) {
-            return !\in_array(\rawurldecode(\explode('=', $part)[0]), $decodedKeys, \true);
-        });
-    }
-    private static function generateQueryString(string $key, ?string $value) : string
-    {
-        // Query string separators ("=", "&") within the key or value need to be encoded
-        // (while preventing double-encoding) before setting the query string. All other
-        // chars that need percent-encoding will be encoded by withQuery().
-        $queryString = \strtr($key, self::QUERY_SEPARATORS_REPLACEMENT);
-        if ($value !== null) {
-            $queryString .= '=' . \strtr($value, self::QUERY_SEPARATORS_REPLACEMENT);
-        }
-        return $queryString;
-    }
-    private function removeDefaultPort() : void
-    {
-        if ($this->port !== null && self::isDefaultPort($this)) {
-            $this->port = null;
-        }
-    }
-    /**
-     * Filters the path of a URI
-     *
-     * @param mixed $path
-     *
-     * @throws \InvalidArgumentException If the path is invalid.
-     */
-    private function filterPath($path) : string
-    {
-        if (!\is_string($path)) {
-            throw new \InvalidArgumentException('Path must be a string');
-        }
-        return \preg_replace_callback('/(?:[^' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . '%:@\\/]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $path);
-    }
-    /**
-     * Filters the query string or fragment of a URI.
-     *
-     * @param mixed $str
-     *
-     * @throws \InvalidArgumentException If the query or fragment is invalid.
-     */
-    private function filterQueryAndFragment($str) : string
-    {
-        if (!\is_string($str)) {
-            throw new \InvalidArgumentException('Query and fragment must be a string');
-        }
-        return \preg_replace_callback('/(?:[^' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . '%:@\\/\\?]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $str);
-    }
-    private function rawurlencodeMatchZero(array $match) : string
-    {
-        return \rawurlencode($match[0]);
-    }
-    private function validateState() : void
-    {
-        if ($this->host === '' && ($this->scheme === 'http' || $this->scheme === 'https')) {
-            $this->host = self::HTTP_DEFAULT_HOST;
-        }
-        if ($this->getAuthority() === '') {
-            if (0 === \strpos($this->path, '//')) {
-                throw new MalformedUriException('The path of a URI without an authority must not start with two slashes "//"');
-            }
-            if ($this->scheme === '' && \false !== \strpos(\explode('/', $this->path, 2)[0], ':')) {
-                throw new MalformedUriException('A relative URI must not have a path beginning with a segment containing a colon');
-            }
-        }
-    }
+	/**
+	 * Absolute http and https URIs require a host per RFC 7230 Section 2.7
+	 * but in generic URIs the host can be empty. So for http(s) URIs
+	 * we apply this default host when no host is given yet to form a
+	 * valid URI.
+	 */
+	private const HTTP_DEFAULT_HOST = 'localhost';
+	private const DEFAULT_PORTS = ['http' => 80, 'https' => 443, 'ftp' => 21, 'gopher' => 70, 'nntp' => 119, 'news' => 119, 'telnet' => 23, 'tn3270' => 23, 'imap' => 143, 'pop' => 110, 'ldap' => 389];
+	/**
+	 * Unreserved characters for use in a regex.
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-2.3
+	 */
+	private const CHAR_UNRESERVED = 'a-zA-Z0-9_\\-\\.~';
+	/**
+	 * Sub-delims for use in a regex.
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-2.2
+	 */
+	private const CHAR_SUB_DELIMS = '!\\$&\'\\(\\)\\*\\+,;=';
+	private const QUERY_SEPARATORS_REPLACEMENT = ['=' => '%3D', '&' => '%26'];
+	/** @var string Uri scheme. */
+	private $scheme = '';
+	/** @var string Uri user info. */
+	private $userInfo = '';
+	/** @var string Uri host. */
+	private $host = '';
+	/** @var int|null Uri port. */
+	private $port;
+	/** @var string Uri path. */
+	private $path = '';
+	/** @var string Uri query string. */
+	private $query = '';
+	/** @var string Uri fragment. */
+	private $fragment = '';
+	/** @var string|null String representation */
+	private $composedComponents;
+	public function __construct(string $uri = '')
+	{
+		if ($uri !== '') {
+			$parts = self::parse($uri);
+			if ($parts === \false) {
+				throw new MalformedUriException("Unable to parse URI: {$uri}");
+			}
+			$this->applyParts($parts);
+		}
+	}
+	/**
+	 * UTF-8 aware \parse_url() replacement.
+	 *
+	 * The internal function produces broken output for non ASCII domain names
+	 * (IDN) when used with locales other than "C".
+	 *
+	 * On the other hand, cURL understands IDN correctly only when UTF-8 locale
+	 * is configured ("C.UTF-8", "en_US.UTF-8", etc.).
+	 *
+	 * @see https://bugs.php.net/bug.php?id=52923
+	 * @see https://www.php.net/manual/en/function.parse-url.php#114817
+	 * @see https://curl.haxx.se/libcurl/c/CURLOPT_URL.html#ENCODING
+	 *
+	 * @return array|false
+	 */
+	private static function parse(string $url)
+	{
+		// If IPv6
+		$prefix = '';
+		if (\preg_match('%^(.*://\\[[0-9:a-f]+\\])(.*?)$%', $url, $matches)) {
+			/** @var array{0:string, 1:string, 2:string} $matches */
+			$prefix = $matches[1];
+			$url = $matches[2];
+		}
+		/** @var string */
+		$encodedUrl = \preg_replace_callback('%[^:/@?&=#]+%usD', static function ($matches) {
+			return \urlencode($matches[0]);
+		}, $url);
+		$result = \parse_url($prefix . $encodedUrl);
+		if ($result === \false) {
+			return \false;
+		}
+		return \array_map('urldecode', $result);
+	}
+	public function __toString() : string
+	{
+		if ($this->composedComponents === null) {
+			$this->composedComponents = self::composeComponents($this->scheme, $this->getAuthority(), $this->path, $this->query, $this->fragment);
+		}
+		return $this->composedComponents;
+	}
+	/**
+	 * Composes a URI reference string from its various components.
+	 *
+	 * Usually this method does not need to be called manually but instead is used indirectly via
+	 * `Psr\Http\Message\UriInterface::__toString`.
+	 *
+	 * PSR-7 UriInterface treats an empty component the same as a missing component as
+	 * getQuery(), getFragment() etc. always return a string. This explains the slight
+	 * difference to RFC 3986 Section 5.3.
+	 *
+	 * Another adjustment is that the authority separator is added even when the authority is missing/empty
+	 * for the "file" scheme. This is because PHP stream functions like `file_get_contents` only work with
+	 * `file:///myfile` but not with `file:/myfile` although they are equivalent according to RFC 3986. But
+	 * `file:///` is the more common syntax for the file scheme anyway (Chrome for example redirects to
+	 * that format).
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-5.3
+	 */
+	public static function composeComponents(?string $scheme, ?string $authority, string $path, ?string $query, ?string $fragment) : string
+	{
+		$uri = '';
+		// weak type checks to also accept null until we can add scalar type hints
+		if ($scheme != '') {
+			$uri .= $scheme . ':';
+		}
+		if ($authority != '' || $scheme === 'file') {
+			$uri .= '//' . $authority;
+		}
+		if ($authority != '' && $path != '' && $path[0] != '/') {
+			$path = '/' . $path;
+		}
+		$uri .= $path;
+		if ($query != '') {
+			$uri .= '?' . $query;
+		}
+		if ($fragment != '') {
+			$uri .= '#' . $fragment;
+		}
+		return $uri;
+	}
+	/**
+	 * Whether the URI has the default port of the current scheme.
+	 *
+	 * `Psr\Http\Message\UriInterface::getPort` may return null or the standard port. This method can be used
+	 * independently of the implementation.
+	 */
+	public static function isDefaultPort(UriInterface $uri) : bool
+	{
+		return $uri->getPort() === null || isset(self::DEFAULT_PORTS[$uri->getScheme()]) && $uri->getPort() === self::DEFAULT_PORTS[$uri->getScheme()];
+	}
+	/**
+	 * Whether the URI is absolute, i.e. it has a scheme.
+	 *
+	 * An instance of UriInterface can either be an absolute URI or a relative reference. This method returns true
+	 * if it is the former. An absolute URI has a scheme. A relative reference is used to express a URI relative
+	 * to another URI, the base URI. Relative references can be divided into several forms:
+	 * - network-path references, e.g. '//example.com/path'
+	 * - absolute-path references, e.g. '/path'
+	 * - relative-path references, e.g. 'subpath'
+	 *
+	 * @see Uri::isNetworkPathReference
+	 * @see Uri::isAbsolutePathReference
+	 * @see Uri::isRelativePathReference
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4
+	 */
+	public static function isAbsolute(UriInterface $uri) : bool
+	{
+		return $uri->getScheme() !== '';
+	}
+	/**
+	 * Whether the URI is a network-path reference.
+	 *
+	 * A relative reference that begins with two slash characters is termed an network-path reference.
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.2
+	 */
+	public static function isNetworkPathReference(UriInterface $uri) : bool
+	{
+		return $uri->getScheme() === '' && $uri->getAuthority() !== '';
+	}
+	/**
+	 * Whether the URI is a absolute-path reference.
+	 *
+	 * A relative reference that begins with a single slash character is termed an absolute-path reference.
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.2
+	 */
+	public static function isAbsolutePathReference(UriInterface $uri) : bool
+	{
+		return $uri->getScheme() === '' && $uri->getAuthority() === '' && isset($uri->getPath()[0]) && $uri->getPath()[0] === '/';
+	}
+	/**
+	 * Whether the URI is a relative-path reference.
+	 *
+	 * A relative reference that does not begin with a slash character is termed a relative-path reference.
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.2
+	 */
+	public static function isRelativePathReference(UriInterface $uri) : bool
+	{
+		return $uri->getScheme() === '' && $uri->getAuthority() === '' && (!isset($uri->getPath()[0]) || $uri->getPath()[0] !== '/');
+	}
+	/**
+	 * Whether the URI is a same-document reference.
+	 *
+	 * A same-document reference refers to a URI that is, aside from its fragment
+	 * component, identical to the base URI. When no base URI is given, only an empty
+	 * URI reference (apart from its fragment) is considered a same-document reference.
+	 *
+	 * @param UriInterface      $uri  The URI to check
+	 * @param UriInterface|null $base An optional base URI to compare against
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc3986#section-4.4
+	 */
+	public static function isSameDocumentReference(UriInterface $uri, UriInterface $base = null) : bool
+	{
+		if ($base !== null) {
+			$uri = UriResolver::resolve($base, $uri);
+			return $uri->getScheme() === $base->getScheme() && $uri->getAuthority() === $base->getAuthority() && $uri->getPath() === $base->getPath() && $uri->getQuery() === $base->getQuery();
+		}
+		return $uri->getScheme() === '' && $uri->getAuthority() === '' && $uri->getPath() === '' && $uri->getQuery() === '';
+	}
+	/**
+	 * Creates a new URI with a specific query string value removed.
+	 *
+	 * Any existing query string values that exactly match the provided key are
+	 * removed.
+	 *
+	 * @param UriInterface $uri URI to use as a base.
+	 * @param string       $key Query string key to remove.
+	 */
+	public static function withoutQueryValue(UriInterface $uri, string $key) : UriInterface
+	{
+		$result = self::getFilteredQueryString($uri, [$key]);
+		return $uri->withQuery(\implode('&', $result));
+	}
+	/**
+	 * Creates a new URI with a specific query string value.
+	 *
+	 * Any existing query string values that exactly match the provided key are
+	 * removed and replaced with the given key value pair.
+	 *
+	 * A value of null will set the query string key without a value, e.g. "key"
+	 * instead of "key=value".
+	 *
+	 * @param UriInterface $uri   URI to use as a base.
+	 * @param string       $key   Key to set.
+	 * @param string|null  $value Value to set
+	 */
+	public static function withQueryValue(UriInterface $uri, string $key, ?string $value) : UriInterface
+	{
+		$result = self::getFilteredQueryString($uri, [$key]);
+		$result[] = self::generateQueryString($key, $value);
+		return $uri->withQuery(\implode('&', $result));
+	}
+	/**
+	 * Creates a new URI with multiple specific query string values.
+	 *
+	 * It has the same behavior as withQueryValue() but for an associative array of key => value.
+	 *
+	 * @param UriInterface    $uri           URI to use as a base.
+	 * @param (string|null)[] $keyValueArray Associative array of key and values
+	 */
+	public static function withQueryValues(UriInterface $uri, array $keyValueArray) : UriInterface
+	{
+		$result = self::getFilteredQueryString($uri, \array_keys($keyValueArray));
+		foreach ($keyValueArray as $key => $value) {
+			$result[] = self::generateQueryString((string) $key, $value !== null ? (string) $value : null);
+		}
+		return $uri->withQuery(\implode('&', $result));
+	}
+	/**
+	 * Creates a URI from a hash of `parse_url` components.
+	 *
+	 * @see https://www.php.net/manual/en/function.parse-url.php
+	 *
+	 * @throws MalformedUriException If the components do not form a valid URI.
+	 */
+	public static function fromParts(array $parts) : UriInterface
+	{
+		$uri = new self();
+		$uri->applyParts($parts);
+		$uri->validateState();
+		return $uri;
+	}
+	public function getScheme() : string
+	{
+		return $this->scheme;
+	}
+	public function getAuthority() : string
+	{
+		$authority = $this->host;
+		if ($this->userInfo !== '') {
+			$authority = $this->userInfo . '@' . $authority;
+		}
+		if ($this->port !== null) {
+			$authority .= ':' . $this->port;
+		}
+		return $authority;
+	}
+	public function getUserInfo() : string
+	{
+		return $this->userInfo;
+	}
+	public function getHost() : string
+	{
+		return $this->host;
+	}
+	public function getPort() : ?int
+	{
+		return $this->port;
+	}
+	public function getPath() : string
+	{
+		return $this->path;
+	}
+	public function getQuery() : string
+	{
+		return $this->query;
+	}
+	public function getFragment() : string
+	{
+		return $this->fragment;
+	}
+	public function withScheme($scheme) : UriInterface
+	{
+		$scheme = $this->filterScheme($scheme);
+		if ($this->scheme === $scheme) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->scheme = $scheme;
+		$new->composedComponents = null;
+		$new->removeDefaultPort();
+		$new->validateState();
+		return $new;
+	}
+	public function withUserInfo($user, $password = null) : UriInterface
+	{
+		$info = $this->filterUserInfoComponent($user);
+		if ($password !== null) {
+			$info .= ':' . $this->filterUserInfoComponent($password);
+		}
+		if ($this->userInfo === $info) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->userInfo = $info;
+		$new->composedComponents = null;
+		$new->validateState();
+		return $new;
+	}
+	public function withHost($host) : UriInterface
+	{
+		$host = $this->filterHost($host);
+		if ($this->host === $host) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->host = $host;
+		$new->composedComponents = null;
+		$new->validateState();
+		return $new;
+	}
+	public function withPort($port) : UriInterface
+	{
+		$port = $this->filterPort($port);
+		if ($this->port === $port) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->port = $port;
+		$new->composedComponents = null;
+		$new->removeDefaultPort();
+		$new->validateState();
+		return $new;
+	}
+	public function withPath($path) : UriInterface
+	{
+		$path = $this->filterPath($path);
+		if ($this->path === $path) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->path = $path;
+		$new->composedComponents = null;
+		$new->validateState();
+		return $new;
+	}
+	public function withQuery($query) : UriInterface
+	{
+		$query = $this->filterQueryAndFragment($query);
+		if ($this->query === $query) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->query = $query;
+		$new->composedComponents = null;
+		return $new;
+	}
+	public function withFragment($fragment) : UriInterface
+	{
+		$fragment = $this->filterQueryAndFragment($fragment);
+		if ($this->fragment === $fragment) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->fragment = $fragment;
+		$new->composedComponents = null;
+		return $new;
+	}
+	public function jsonSerialize() : string
+	{
+		return $this->__toString();
+	}
+	/**
+	 * Apply parse_url parts to a URI.
+	 *
+	 * @param array $parts Array of parse_url parts to apply.
+	 */
+	private function applyParts(array $parts) : void
+	{
+		$this->scheme = isset($parts['scheme']) ? $this->filterScheme($parts['scheme']) : '';
+		$this->userInfo = isset($parts['user']) ? $this->filterUserInfoComponent($parts['user']) : '';
+		$this->host = isset($parts['host']) ? $this->filterHost($parts['host']) : '';
+		$this->port = isset($parts['port']) ? $this->filterPort($parts['port']) : null;
+		$this->path = isset($parts['path']) ? $this->filterPath($parts['path']) : '';
+		$this->query = isset($parts['query']) ? $this->filterQueryAndFragment($parts['query']) : '';
+		$this->fragment = isset($parts['fragment']) ? $this->filterQueryAndFragment($parts['fragment']) : '';
+		if (isset($parts['pass'])) {
+			$this->userInfo .= ':' . $this->filterUserInfoComponent($parts['pass']);
+		}
+		$this->removeDefaultPort();
+	}
+	/**
+	 * @param mixed $scheme
+	 *
+	 * @throws \InvalidArgumentException If the scheme is invalid.
+	 */
+	private function filterScheme($scheme) : string
+	{
+		if (!\is_string($scheme)) {
+			throw new \InvalidArgumentException('Scheme must be a string');
+		}
+		return \strtr($scheme, 'ABCDEFGHIJKLMNOPQRSTUVWXYZ', 'abcdefghijklmnopqrstuvwxyz');
+	}
+	/**
+	 * @param mixed $component
+	 *
+	 * @throws \InvalidArgumentException If the user info is invalid.
+	 */
+	private function filterUserInfoComponent($component) : string
+	{
+		if (!\is_string($component)) {
+			throw new \InvalidArgumentException('User info must be a string');
+		}
+		return \preg_replace_callback('/(?:[^%' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . ']+|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $component);
+	}
+	/**
+	 * @param mixed $host
+	 *
+	 * @throws \InvalidArgumentException If the host is invalid.
+	 */
+	private function filterHost($host) : string
+	{
+		if (!\is_string($host)) {
+			throw new \InvalidArgumentException('Host must be a string');
+		}
+		return \strtr($host, 'ABCDEFGHIJKLMNOPQRSTUVWXYZ', 'abcdefghijklmnopqrstuvwxyz');
+	}
+	/**
+	 * @param mixed $port
+	 *
+	 * @throws \InvalidArgumentException If the port is invalid.
+	 */
+	private function filterPort($port) : ?int
+	{
+		if ($port === null) {
+			return null;
+		}
+		$port = (int) $port;
+		if (0 > $port || 0xffff < $port) {
+			throw new \InvalidArgumentException(\sprintf('Invalid port: %d. Must be between 0 and 65535', $port));
+		}
+		return $port;
+	}
+	/**
+	 * @param (string|int)[] $keys
+	 *
+	 * @return string[]
+	 */
+	private static function getFilteredQueryString(UriInterface $uri, array $keys) : array
+	{
+		$current = $uri->getQuery();
+		if ($current === '') {
+			return [];
+		}
+		$decodedKeys = \array_map(function ($k) : string {
+			return \rawurldecode((string) $k);
+		}, $keys);
+		return \array_filter(\explode('&', $current), function ($part) use($decodedKeys) {
+			return !\in_array(\rawurldecode(\explode('=', $part)[0]), $decodedKeys, \true);
+		});
+	}
+	private static function generateQueryString(string $key, ?string $value) : string
+	{
+		// Query string separators ("=", "&") within the key or value need to be encoded
+		// (while preventing double-encoding) before setting the query string. All other
+		// chars that need percent-encoding will be encoded by withQuery().
+		$queryString = \strtr($key, self::QUERY_SEPARATORS_REPLACEMENT);
+		if ($value !== null) {
+			$queryString .= '=' . \strtr($value, self::QUERY_SEPARATORS_REPLACEMENT);
+		}
+		return $queryString;
+	}
+	private function removeDefaultPort() : void
+	{
+		if ($this->port !== null && self::isDefaultPort($this)) {
+			$this->port = null;
+		}
+	}
+	/**
+	 * Filters the path of a URI
+	 *
+	 * @param mixed $path
+	 *
+	 * @throws \InvalidArgumentException If the path is invalid.
+	 */
+	private function filterPath($path) : string
+	{
+		if (!\is_string($path)) {
+			throw new \InvalidArgumentException('Path must be a string');
+		}
+		return \preg_replace_callback('/(?:[^' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . '%:@\\/]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $path);
+	}
+	/**
+	 * Filters the query string or fragment of a URI.
+	 *
+	 * @param mixed $str
+	 *
+	 * @throws \InvalidArgumentException If the query or fragment is invalid.
+	 */
+	private function filterQueryAndFragment($str) : string
+	{
+		if (!\is_string($str)) {
+			throw new \InvalidArgumentException('Query and fragment must be a string');
+		}
+		return \preg_replace_callback('/(?:[^' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . '%:@\\/\\?]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $str);
+	}
+	private function rawurlencodeMatchZero(array $match) : string
+	{
+		return \rawurlencode($match[0]);
+	}
+	private function validateState() : void
+	{
+		if ($this->host === '' && ($this->scheme === 'http' || $this->scheme === 'https')) {
+			$this->host = self::HTTP_DEFAULT_HOST;
+		}
+		if ($this->getAuthority() === '') {
+			if (0 === \strpos($this->path, '//')) {
+				throw new MalformedUriException('The path of a URI without an authority must not start with two slashes "//"');
+			}
+			if ($this->scheme === '' && \false !== \strpos(\explode('/', $this->path, 2)[0], ':')) {
+				throw new MalformedUriException('A relative URI must not have a path beginning with a segment containing a colon');
+			}
+		}
+	}
 }

Spacing +21 added lines, -21 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Exception\MalformedUriException;
@@ -86,10 +86,10 @@ 
             $url = $matches[2];
         }
         /** @var string */
-        $encodedUrl = \preg_replace_callback('%[^:/@?&=#]+%usD', static function ($matches) {
+        $encodedUrl = \preg_replace_callback('%[^:/@?&=#]+%usD', static function($matches) {
             return \urlencode($matches[0]);
         }, $url);
-        $result = \parse_url($prefix . $encodedUrl);
+        $result = \parse_url($prefix.$encodedUrl);
         if ($result === \false) {
             return \false;
         }
@@ -125,20 +125,20 @@ 
         $uri = '';
         // weak type checks to also accept null until we can add scalar type hints
         if ($scheme != '') {
-            $uri .= $scheme . ':';
+            $uri .= $scheme.':';
         }
         if ($authority != '' || $scheme === 'file') {
-            $uri .= '//' . $authority;
+            $uri .= '//'.$authority;
         }
         if ($authority != '' && $path != '' && $path[0] != '/') {
-            $path = '/' . $path;
+            $path = '/'.$path;
         }
         $uri .= $path;
         if ($query != '') {
-            $uri .= '?' . $query;
+            $uri .= '?'.$query;
         }
         if ($fragment != '') {
-            $uri .= '#' . $fragment;
+            $uri .= '#'.$fragment;
         }
         return $uri;
     }
@@ -269,7 +269,7 @@ 
     {
         $result = self::getFilteredQueryString($uri, \array_keys($keyValueArray));
         foreach ($keyValueArray as $key => $value) {
-            $result[] = self::generateQueryString((string) $key, $value !== null ? (string) $value : null);
+            $result[] = self::generateQueryString((string)$key, $value !== null ? (string)$value : null);
         }
         return $uri->withQuery(\implode('&', $result));
     }
@@ -295,10 +295,10 @@ 
     {
         $authority = $this->host;
         if ($this->userInfo !== '') {
-            $authority = $this->userInfo . '@' . $authority;
+            $authority = $this->userInfo.'@'.$authority;
         }
         if ($this->port !== null) {
-            $authority .= ':' . $this->port;
+            $authority .= ':'.$this->port;
         }
         return $authority;
     }
@@ -343,7 +343,7 @@ 
     {
         $info = $this->filterUserInfoComponent($user);
         if ($password !== null) {
-            $info .= ':' . $this->filterUserInfoComponent($password);
+            $info .= ':'.$this->filterUserInfoComponent($password);
         }
         if ($this->userInfo === $info) {
             return $this;
@@ -432,7 +432,7 @@ 
         $this->query = isset($parts['query']) ? $this->filterQueryAndFragment($parts['query']) : '';
         $this->fragment = isset($parts['fragment']) ? $this->filterQueryAndFragment($parts['fragment']) : '';
         if (isset($parts['pass'])) {
-            $this->userInfo .= ':' . $this->filterUserInfoComponent($parts['pass']);
+            $this->userInfo .= ':'.$this->filterUserInfoComponent($parts['pass']);
         }
         $this->removeDefaultPort();
     }
@@ -458,7 +458,7 @@ 
         if (!\is_string($component)) {
             throw new \InvalidArgumentException('User info must be a string');
         }
-        return \preg_replace_callback('/(?:[^%' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . ']+|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $component);
+        return \preg_replace_callback('/(?:[^%'.self::CHAR_UNRESERVED.self::CHAR_SUB_DELIMS.']+|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $component);
     }
     /**
      * @param mixed $host
@@ -482,7 +482,7 @@ 
         if ($port === null) {
             return null;
         }
-        $port = (int) $port;
+        $port = (int)$port;
         if (0 > $port || 0xffff < $port) {
             throw new \InvalidArgumentException(\sprintf('Invalid port: %d. Must be between 0 and 65535', $port));
         }
@@ -499,10 +499,10 @@ 
         if ($current === '') {
             return [];
         }
-        $decodedKeys = \array_map(function ($k) : string {
-            return \rawurldecode((string) $k);
+        $decodedKeys = \array_map(function($k) : string {
+            return \rawurldecode((string)$k);
         }, $keys);
-        return \array_filter(\explode('&', $current), function ($part) use($decodedKeys) {
+        return \array_filter(\explode('&', $current), function($part) use($decodedKeys) {
             return !\in_array(\rawurldecode(\explode('=', $part)[0]), $decodedKeys, \true);
         });
     }
@@ -513,7 +513,7 @@ 
         // chars that need percent-encoding will be encoded by withQuery().
         $queryString = \strtr($key, self::QUERY_SEPARATORS_REPLACEMENT);
         if ($value !== null) {
-            $queryString .= '=' . \strtr($value, self::QUERY_SEPARATORS_REPLACEMENT);
+            $queryString .= '='.\strtr($value, self::QUERY_SEPARATORS_REPLACEMENT);
         }
         return $queryString;
     }
@@ -535,7 +535,7 @@ 
         if (!\is_string($path)) {
             throw new \InvalidArgumentException('Path must be a string');
         }
-        return \preg_replace_callback('/(?:[^' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . '%:@\\/]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $path);
+        return \preg_replace_callback('/(?:[^'.self::CHAR_UNRESERVED.self::CHAR_SUB_DELIMS.'%:@\\/]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $path);
     }
     /**
      * Filters the query string or fragment of a URI.
@@ -549,7 +549,7 @@ 
         if (!\is_string($str)) {
             throw new \InvalidArgumentException('Query and fragment must be a string');
         }
-        return \preg_replace_callback('/(?:[^' . self::CHAR_UNRESERVED . self::CHAR_SUB_DELIMS . '%:@\\/\\?]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $str);
+        return \preg_replace_callback('/(?:[^'.self::CHAR_UNRESERVED.self::CHAR_SUB_DELIMS.'%:@\\/\\?]++|%(?![A-Fa-f0-9]{2}))/', [$this, 'rawurlencodeMatchZero'], $str);
     }
     private function rawurlencodeMatchZero(array $match) : string
     {

lib/Vendor/GuzzleHttp/Psr7/BufferStream.php

Indentation +104 added lines, -104 removed lines

@@ -14,108 +14,108 @@
  */
 final class BufferStream implements StreamInterface
 {
-    /** @var int */
-    private $hwm;
-    /** @var string */
-    private $buffer = '';
-    /**
-     * @param int $hwm High water mark, representing the preferred maximum
-     *                 buffer size. If the size of the buffer exceeds the high
-     *                 water mark, then calls to write will continue to succeed
-     *                 but will return 0 to inform writers to slow down
-     *                 until the buffer has been drained by reading from it.
-     */
-    public function __construct(int $hwm = 16384)
-    {
-        $this->hwm = $hwm;
-    }
-    public function __toString() : string
-    {
-        return $this->getContents();
-    }
-    public function getContents() : string
-    {
-        $buffer = $this->buffer;
-        $this->buffer = '';
-        return $buffer;
-    }
-    public function close() : void
-    {
-        $this->buffer = '';
-    }
-    public function detach()
-    {
-        $this->close();
-        return null;
-    }
-    public function getSize() : ?int
-    {
-        return \strlen($this->buffer);
-    }
-    public function isReadable() : bool
-    {
-        return \true;
-    }
-    public function isWritable() : bool
-    {
-        return \true;
-    }
-    public function isSeekable() : bool
-    {
-        return \false;
-    }
-    public function rewind() : void
-    {
-        $this->seek(0);
-    }
-    public function seek($offset, $whence = \SEEK_SET) : void
-    {
-        throw new \RuntimeException('Cannot seek a BufferStream');
-    }
-    public function eof() : bool
-    {
-        return \strlen($this->buffer) === 0;
-    }
-    public function tell() : int
-    {
-        throw new \RuntimeException('Cannot determine the position of a BufferStream');
-    }
-    /**
-     * Reads data from the buffer.
-     */
-    public function read($length) : string
-    {
-        $currentLength = \strlen($this->buffer);
-        if ($length >= $currentLength) {
-            // No need to slice the buffer because we don't have enough data.
-            $result = $this->buffer;
-            $this->buffer = '';
-        } else {
-            // Slice up the result to provide a subset of the buffer.
-            $result = \substr($this->buffer, 0, $length);
-            $this->buffer = \substr($this->buffer, $length);
-        }
-        return $result;
-    }
-    /**
-     * Writes data to the buffer.
-     */
-    public function write($string) : int
-    {
-        $this->buffer .= $string;
-        if (\strlen($this->buffer) >= $this->hwm) {
-            return 0;
-        }
-        return \strlen($string);
-    }
-    /**
-     * @return mixed
-     */
-    public function getMetadata($key = null)
-    {
-        if ($key === 'hwm') {
-            return $this->hwm;
-        }
-        return $key ? null : [];
-    }
+	/** @var int */
+	private $hwm;
+	/** @var string */
+	private $buffer = '';
+	/**
+	 * @param int $hwm High water mark, representing the preferred maximum
+	 *                 buffer size. If the size of the buffer exceeds the high
+	 *                 water mark, then calls to write will continue to succeed
+	 *                 but will return 0 to inform writers to slow down
+	 *                 until the buffer has been drained by reading from it.
+	 */
+	public function __construct(int $hwm = 16384)
+	{
+		$this->hwm = $hwm;
+	}
+	public function __toString() : string
+	{
+		return $this->getContents();
+	}
+	public function getContents() : string
+	{
+		$buffer = $this->buffer;
+		$this->buffer = '';
+		return $buffer;
+	}
+	public function close() : void
+	{
+		$this->buffer = '';
+	}
+	public function detach()
+	{
+		$this->close();
+		return null;
+	}
+	public function getSize() : ?int
+	{
+		return \strlen($this->buffer);
+	}
+	public function isReadable() : bool
+	{
+		return \true;
+	}
+	public function isWritable() : bool
+	{
+		return \true;
+	}
+	public function isSeekable() : bool
+	{
+		return \false;
+	}
+	public function rewind() : void
+	{
+		$this->seek(0);
+	}
+	public function seek($offset, $whence = \SEEK_SET) : void
+	{
+		throw new \RuntimeException('Cannot seek a BufferStream');
+	}
+	public function eof() : bool
+	{
+		return \strlen($this->buffer) === 0;
+	}
+	public function tell() : int
+	{
+		throw new \RuntimeException('Cannot determine the position of a BufferStream');
+	}
+	/**
+	 * Reads data from the buffer.
+	 */
+	public function read($length) : string
+	{
+		$currentLength = \strlen($this->buffer);
+		if ($length >= $currentLength) {
+			// No need to slice the buffer because we don't have enough data.
+			$result = $this->buffer;
+			$this->buffer = '';
+		} else {
+			// Slice up the result to provide a subset of the buffer.
+			$result = \substr($this->buffer, 0, $length);
+			$this->buffer = \substr($this->buffer, $length);
+		}
+		return $result;
+	}
+	/**
+	 * Writes data to the buffer.
+	 */
+	public function write($string) : int
+	{
+		$this->buffer .= $string;
+		if (\strlen($this->buffer) >= $this->hwm) {
+			return 0;
+		}
+		return \strlen($string);
+	}
+	/**
+	 * @return mixed
+	 */
+	public function getMetadata($key = null)
+	{
+		if ($key === 'hwm') {
+			return $this->hwm;
+		}
+		return $key ? null : [];
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -12,8 +12,7 @@
  * what the configured high water mark of the stream is, or the maximum
  * preferred size of the buffer.
  */
-final class BufferStream implements StreamInterface
-{
+final class BufferStream implements StreamInterface {
     /** @var int */
     private $hwm;
     /** @var string */

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;

lib/Vendor/GuzzleHttp/Psr7/UploadedFile.php

Indentation +140 added lines, -140 removed lines

@@ -9,144 +9,144 @@
 use RuntimeException;
 class UploadedFile implements UploadedFileInterface
 {
-    private const ERRORS = [\UPLOAD_ERR_OK, \UPLOAD_ERR_INI_SIZE, \UPLOAD_ERR_FORM_SIZE, \UPLOAD_ERR_PARTIAL, \UPLOAD_ERR_NO_FILE, \UPLOAD_ERR_NO_TMP_DIR, \UPLOAD_ERR_CANT_WRITE, \UPLOAD_ERR_EXTENSION];
-    /**
-     * @var string|null
-     */
-    private $clientFilename;
-    /**
-     * @var string|null
-     */
-    private $clientMediaType;
-    /**
-     * @var int
-     */
-    private $error;
-    /**
-     * @var string|null
-     */
-    private $file;
-    /**
-     * @var bool
-     */
-    private $moved = \false;
-    /**
-     * @var int|null
-     */
-    private $size;
-    /**
-     * @var StreamInterface|null
-     */
-    private $stream;
-    /**
-     * @param StreamInterface|string|resource $streamOrFile
-     */
-    public function __construct($streamOrFile, ?int $size, int $errorStatus, string $clientFilename = null, string $clientMediaType = null)
-    {
-        $this->setError($errorStatus);
-        $this->size = $size;
-        $this->clientFilename = $clientFilename;
-        $this->clientMediaType = $clientMediaType;
-        if ($this->isOk()) {
-            $this->setStreamOrFile($streamOrFile);
-        }
-    }
-    /**
-     * Depending on the value set file or stream variable
-     *
-     * @param StreamInterface|string|resource $streamOrFile
-     *
-     * @throws InvalidArgumentException
-     */
-    private function setStreamOrFile($streamOrFile) : void
-    {
-        if (\is_string($streamOrFile)) {
-            $this->file = $streamOrFile;
-        } elseif (\is_resource($streamOrFile)) {
-            $this->stream = new Stream($streamOrFile);
-        } elseif ($streamOrFile instanceof StreamInterface) {
-            $this->stream = $streamOrFile;
-        } else {
-            throw new InvalidArgumentException('Invalid stream or file provided for UploadedFile');
-        }
-    }
-    /**
-     * @throws InvalidArgumentException
-     */
-    private function setError(int $error) : void
-    {
-        if (\false === \in_array($error, UploadedFile::ERRORS, \true)) {
-            throw new InvalidArgumentException('Invalid error status for UploadedFile');
-        }
-        $this->error = $error;
-    }
-    private static function isStringNotEmpty($param) : bool
-    {
-        return \is_string($param) && \false === empty($param);
-    }
-    /**
-     * Return true if there is no upload error
-     */
-    private function isOk() : bool
-    {
-        return $this->error === \UPLOAD_ERR_OK;
-    }
-    public function isMoved() : bool
-    {
-        return $this->moved;
-    }
-    /**
-     * @throws RuntimeException if is moved or not ok
-     */
-    private function validateActive() : void
-    {
-        if (\false === $this->isOk()) {
-            throw new RuntimeException('Cannot retrieve stream due to upload error');
-        }
-        if ($this->isMoved()) {
-            throw new RuntimeException('Cannot retrieve stream after it has already been moved');
-        }
-    }
-    public function getStream() : StreamInterface
-    {
-        $this->validateActive();
-        if ($this->stream instanceof StreamInterface) {
-            return $this->stream;
-        }
-        /** @var string $file */
-        $file = $this->file;
-        return new LazyOpenStream($file, 'r+');
-    }
-    public function moveTo($targetPath) : void
-    {
-        $this->validateActive();
-        if (\false === self::isStringNotEmpty($targetPath)) {
-            throw new InvalidArgumentException('Invalid path provided for move operation; must be a non-empty string');
-        }
-        if ($this->file) {
-            $this->moved = \PHP_SAPI === 'cli' ? \rename($this->file, $targetPath) : \move_uploaded_file($this->file, $targetPath);
-        } else {
-            Utils::copyToStream($this->getStream(), new LazyOpenStream($targetPath, 'w'));
-            $this->moved = \true;
-        }
-        if (\false === $this->moved) {
-            throw new RuntimeException(\sprintf('Uploaded file could not be moved to %s', $targetPath));
-        }
-    }
-    public function getSize() : ?int
-    {
-        return $this->size;
-    }
-    public function getError() : int
-    {
-        return $this->error;
-    }
-    public function getClientFilename() : ?string
-    {
-        return $this->clientFilename;
-    }
-    public function getClientMediaType() : ?string
-    {
-        return $this->clientMediaType;
-    }
+	private const ERRORS = [\UPLOAD_ERR_OK, \UPLOAD_ERR_INI_SIZE, \UPLOAD_ERR_FORM_SIZE, \UPLOAD_ERR_PARTIAL, \UPLOAD_ERR_NO_FILE, \UPLOAD_ERR_NO_TMP_DIR, \UPLOAD_ERR_CANT_WRITE, \UPLOAD_ERR_EXTENSION];
+	/**
+	 * @var string|null
+	 */
+	private $clientFilename;
+	/**
+	 * @var string|null
+	 */
+	private $clientMediaType;
+	/**
+	 * @var int
+	 */
+	private $error;
+	/**
+	 * @var string|null
+	 */
+	private $file;
+	/**
+	 * @var bool
+	 */
+	private $moved = \false;
+	/**
+	 * @var int|null
+	 */
+	private $size;
+	/**
+	 * @var StreamInterface|null
+	 */
+	private $stream;
+	/**
+	 * @param StreamInterface|string|resource $streamOrFile
+	 */
+	public function __construct($streamOrFile, ?int $size, int $errorStatus, string $clientFilename = null, string $clientMediaType = null)
+	{
+		$this->setError($errorStatus);
+		$this->size = $size;
+		$this->clientFilename = $clientFilename;
+		$this->clientMediaType = $clientMediaType;
+		if ($this->isOk()) {
+			$this->setStreamOrFile($streamOrFile);
+		}
+	}
+	/**
+	 * Depending on the value set file or stream variable
+	 *
+	 * @param StreamInterface|string|resource $streamOrFile
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	private function setStreamOrFile($streamOrFile) : void
+	{
+		if (\is_string($streamOrFile)) {
+			$this->file = $streamOrFile;
+		} elseif (\is_resource($streamOrFile)) {
+			$this->stream = new Stream($streamOrFile);
+		} elseif ($streamOrFile instanceof StreamInterface) {
+			$this->stream = $streamOrFile;
+		} else {
+			throw new InvalidArgumentException('Invalid stream or file provided for UploadedFile');
+		}
+	}
+	/**
+	 * @throws InvalidArgumentException
+	 */
+	private function setError(int $error) : void
+	{
+		if (\false === \in_array($error, UploadedFile::ERRORS, \true)) {
+			throw new InvalidArgumentException('Invalid error status for UploadedFile');
+		}
+		$this->error = $error;
+	}
+	private static function isStringNotEmpty($param) : bool
+	{
+		return \is_string($param) && \false === empty($param);
+	}
+	/**
+	 * Return true if there is no upload error
+	 */
+	private function isOk() : bool
+	{
+		return $this->error === \UPLOAD_ERR_OK;
+	}
+	public function isMoved() : bool
+	{
+		return $this->moved;
+	}
+	/**
+	 * @throws RuntimeException if is moved or not ok
+	 */
+	private function validateActive() : void
+	{
+		if (\false === $this->isOk()) {
+			throw new RuntimeException('Cannot retrieve stream due to upload error');
+		}
+		if ($this->isMoved()) {
+			throw new RuntimeException('Cannot retrieve stream after it has already been moved');
+		}
+	}
+	public function getStream() : StreamInterface
+	{
+		$this->validateActive();
+		if ($this->stream instanceof StreamInterface) {
+			return $this->stream;
+		}
+		/** @var string $file */
+		$file = $this->file;
+		return new LazyOpenStream($file, 'r+');
+	}
+	public function moveTo($targetPath) : void
+	{
+		$this->validateActive();
+		if (\false === self::isStringNotEmpty($targetPath)) {
+			throw new InvalidArgumentException('Invalid path provided for move operation; must be a non-empty string');
+		}
+		if ($this->file) {
+			$this->moved = \PHP_SAPI === 'cli' ? \rename($this->file, $targetPath) : \move_uploaded_file($this->file, $targetPath);
+		} else {
+			Utils::copyToStream($this->getStream(), new LazyOpenStream($targetPath, 'w'));
+			$this->moved = \true;
+		}
+		if (\false === $this->moved) {
+			throw new RuntimeException(\sprintf('Uploaded file could not be moved to %s', $targetPath));
+		}
+	}
+	public function getSize() : ?int
+	{
+		return $this->size;
+	}
+	public function getError() : int
+	{
+		return $this->error;
+	}
+	public function getClientFilename() : ?string
+	{
+		return $this->clientFilename;
+	}
+	public function getClientMediaType() : ?string
+	{
+		return $this->clientMediaType;
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use InvalidArgumentException;

Braces +1 added lines, -2 removed lines

@@ -7,8 +7,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\UploadedFileInterface;
 use RuntimeException;
-class UploadedFile implements UploadedFileInterface
-{
+class UploadedFile implements UploadedFileInterface {
     private const ERRORS = [\UPLOAD_ERR_OK, \UPLOAD_ERR_INI_SIZE, \UPLOAD_ERR_FORM_SIZE, \UPLOAD_ERR_PARTIAL, \UPLOAD_ERR_NO_FILE, \UPLOAD_ERR_NO_TMP_DIR, \UPLOAD_ERR_CANT_WRITE, \UPLOAD_ERR_EXTENSION];
     /**
      * @var string|null

lib/Vendor/GuzzleHttp/Psr7/MessageTrait.php

Indentation +199 added lines, -199 removed lines

@@ -10,203 +10,203 @@
  */
 trait MessageTrait
 {
-    /** @var string[][] Map of all registered headers, as original name => array of values */
-    private $headers = [];
-    /** @var string[] Map of lowercase header name => original name at registration */
-    private $headerNames = [];
-    /** @var string */
-    private $protocol = '1.1';
-    /** @var StreamInterface|null */
-    private $stream;
-    public function getProtocolVersion() : string
-    {
-        return $this->protocol;
-    }
-    public function withProtocolVersion($version) : MessageInterface
-    {
-        if ($this->protocol === $version) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->protocol = $version;
-        return $new;
-    }
-    public function getHeaders() : array
-    {
-        return $this->headers;
-    }
-    public function hasHeader($header) : bool
-    {
-        return isset($this->headerNames[\strtolower($header)]);
-    }
-    public function getHeader($header) : array
-    {
-        $header = \strtolower($header);
-        if (!isset($this->headerNames[$header])) {
-            return [];
-        }
-        $header = $this->headerNames[$header];
-        return $this->headers[$header];
-    }
-    public function getHeaderLine($header) : string
-    {
-        return \implode(', ', $this->getHeader($header));
-    }
-    public function withHeader($header, $value) : MessageInterface
-    {
-        $this->assertHeader($header);
-        $value = $this->normalizeHeaderValue($value);
-        $normalized = \strtolower($header);
-        $new = clone $this;
-        if (isset($new->headerNames[$normalized])) {
-            unset($new->headers[$new->headerNames[$normalized]]);
-        }
-        $new->headerNames[$normalized] = $header;
-        $new->headers[$header] = $value;
-        return $new;
-    }
-    public function withAddedHeader($header, $value) : MessageInterface
-    {
-        $this->assertHeader($header);
-        $value = $this->normalizeHeaderValue($value);
-        $normalized = \strtolower($header);
-        $new = clone $this;
-        if (isset($new->headerNames[$normalized])) {
-            $header = $this->headerNames[$normalized];
-            $new->headers[$header] = \array_merge($this->headers[$header], $value);
-        } else {
-            $new->headerNames[$normalized] = $header;
-            $new->headers[$header] = $value;
-        }
-        return $new;
-    }
-    public function withoutHeader($header) : MessageInterface
-    {
-        $normalized = \strtolower($header);
-        if (!isset($this->headerNames[$normalized])) {
-            return $this;
-        }
-        $header = $this->headerNames[$normalized];
-        $new = clone $this;
-        unset($new->headers[$header], $new->headerNames[$normalized]);
-        return $new;
-    }
-    public function getBody() : StreamInterface
-    {
-        if (!$this->stream) {
-            $this->stream = Utils::streamFor('');
-        }
-        return $this->stream;
-    }
-    public function withBody(StreamInterface $body) : MessageInterface
-    {
-        if ($body === $this->stream) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->stream = $body;
-        return $new;
-    }
-    /**
-     * @param (string|string[])[] $headers
-     */
-    private function setHeaders(array $headers) : void
-    {
-        $this->headerNames = $this->headers = [];
-        foreach ($headers as $header => $value) {
-            // Numeric array keys are converted to int by PHP.
-            $header = (string) $header;
-            $this->assertHeader($header);
-            $value = $this->normalizeHeaderValue($value);
-            $normalized = \strtolower($header);
-            if (isset($this->headerNames[$normalized])) {
-                $header = $this->headerNames[$normalized];
-                $this->headers[$header] = \array_merge($this->headers[$header], $value);
-            } else {
-                $this->headerNames[$normalized] = $header;
-                $this->headers[$header] = $value;
-            }
-        }
-    }
-    /**
-     * @param mixed $value
-     *
-     * @return string[]
-     */
-    private function normalizeHeaderValue($value) : array
-    {
-        if (!\is_array($value)) {
-            return $this->trimAndValidateHeaderValues([$value]);
-        }
-        if (\count($value) === 0) {
-            throw new \InvalidArgumentException('Header value can not be an empty array.');
-        }
-        return $this->trimAndValidateHeaderValues($value);
-    }
-    /**
-     * Trims whitespace from the header values.
-     *
-     * Spaces and tabs ought to be excluded by parsers when extracting the field value from a header field.
-     *
-     * header-field = field-name ":" OWS field-value OWS
-     * OWS          = *( SP / HTAB )
-     *
-     * @param mixed[] $values Header values
-     *
-     * @return string[] Trimmed header values
-     *
-     * @see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2.4
-     */
-    private function trimAndValidateHeaderValues(array $values) : array
-    {
-        return \array_map(function ($value) {
-            if (!\is_scalar($value) && null !== $value) {
-                throw new \InvalidArgumentException(\sprintf('Header value must be scalar or null but %s provided.', \is_object($value) ? \get_class($value) : \gettype($value)));
-            }
-            $trimmed = \trim((string) $value, " \t");
-            $this->assertValue($trimmed);
-            return $trimmed;
-        }, \array_values($values));
-    }
-    /**
-     * @see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2
-     *
-     * @param mixed $header
-     */
-    private function assertHeader($header) : void
-    {
-        if (!\is_string($header)) {
-            throw new \InvalidArgumentException(\sprintf('Header name must be a string but %s provided.', \is_object($header) ? \get_class($header) : \gettype($header)));
-        }
-        if (!\preg_match('/^[a-zA-Z0-9\'`#$%&*+.^_|~!-]+$/D', $header)) {
-            throw new \InvalidArgumentException(\sprintf('"%s" is not valid header name.', $header));
-        }
-    }
-    /**
-     * @see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2
-     *
-     * field-value    = *( field-content / obs-fold )
-     * field-content  = field-vchar [ 1*( SP / HTAB ) field-vchar ]
-     * field-vchar    = VCHAR / obs-text
-     * VCHAR          = %x21-7E
-     * obs-text       = %x80-FF
-     * obs-fold       = CRLF 1*( SP / HTAB )
-     */
-    private function assertValue(string $value) : void
-    {
-        // The regular expression intentionally does not support the obs-fold production, because as
-        // per RFC 7230#3.2.4:
-        //
-        // A sender MUST NOT generate a message that includes
-        // line folding (i.e., that has any field-value that contains a match to
-        // the obs-fold rule) unless the message is intended for packaging
-        // within the message/http media type.
-        //
-        // Clients must not send a request with line folding and a server sending folded headers is
-        // likely very rare. Line folding is a fairly obscure feature of HTTP/1.1 and thus not accepting
-        // folding is not likely to break any legitimate use case.
-        if (!\preg_match('/^[\\x20\\x09\\x21-\\x7E\\x80-\\xFF]*$/D', $value)) {
-            throw new \InvalidArgumentException(\sprintf('"%s" is not valid header value.', $value));
-        }
-    }
+	/** @var string[][] Map of all registered headers, as original name => array of values */
+	private $headers = [];
+	/** @var string[] Map of lowercase header name => original name at registration */
+	private $headerNames = [];
+	/** @var string */
+	private $protocol = '1.1';
+	/** @var StreamInterface|null */
+	private $stream;
+	public function getProtocolVersion() : string
+	{
+		return $this->protocol;
+	}
+	public function withProtocolVersion($version) : MessageInterface
+	{
+		if ($this->protocol === $version) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->protocol = $version;
+		return $new;
+	}
+	public function getHeaders() : array
+	{
+		return $this->headers;
+	}
+	public function hasHeader($header) : bool
+	{
+		return isset($this->headerNames[\strtolower($header)]);
+	}
+	public function getHeader($header) : array
+	{
+		$header = \strtolower($header);
+		if (!isset($this->headerNames[$header])) {
+			return [];
+		}
+		$header = $this->headerNames[$header];
+		return $this->headers[$header];
+	}
+	public function getHeaderLine($header) : string
+	{
+		return \implode(', ', $this->getHeader($header));
+	}
+	public function withHeader($header, $value) : MessageInterface
+	{
+		$this->assertHeader($header);
+		$value = $this->normalizeHeaderValue($value);
+		$normalized = \strtolower($header);
+		$new = clone $this;
+		if (isset($new->headerNames[$normalized])) {
+			unset($new->headers[$new->headerNames[$normalized]]);
+		}
+		$new->headerNames[$normalized] = $header;
+		$new->headers[$header] = $value;
+		return $new;
+	}
+	public function withAddedHeader($header, $value) : MessageInterface
+	{
+		$this->assertHeader($header);
+		$value = $this->normalizeHeaderValue($value);
+		$normalized = \strtolower($header);
+		$new = clone $this;
+		if (isset($new->headerNames[$normalized])) {
+			$header = $this->headerNames[$normalized];
+			$new->headers[$header] = \array_merge($this->headers[$header], $value);
+		} else {
+			$new->headerNames[$normalized] = $header;
+			$new->headers[$header] = $value;
+		}
+		return $new;
+	}
+	public function withoutHeader($header) : MessageInterface
+	{
+		$normalized = \strtolower($header);
+		if (!isset($this->headerNames[$normalized])) {
+			return $this;
+		}
+		$header = $this->headerNames[$normalized];
+		$new = clone $this;
+		unset($new->headers[$header], $new->headerNames[$normalized]);
+		return $new;
+	}
+	public function getBody() : StreamInterface
+	{
+		if (!$this->stream) {
+			$this->stream = Utils::streamFor('');
+		}
+		return $this->stream;
+	}
+	public function withBody(StreamInterface $body) : MessageInterface
+	{
+		if ($body === $this->stream) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->stream = $body;
+		return $new;
+	}
+	/**
+	 * @param (string|string[])[] $headers
+	 */
+	private function setHeaders(array $headers) : void
+	{
+		$this->headerNames = $this->headers = [];
+		foreach ($headers as $header => $value) {
+			// Numeric array keys are converted to int by PHP.
+			$header = (string) $header;
+			$this->assertHeader($header);
+			$value = $this->normalizeHeaderValue($value);
+			$normalized = \strtolower($header);
+			if (isset($this->headerNames[$normalized])) {
+				$header = $this->headerNames[$normalized];
+				$this->headers[$header] = \array_merge($this->headers[$header], $value);
+			} else {
+				$this->headerNames[$normalized] = $header;
+				$this->headers[$header] = $value;
+			}
+		}
+	}
+	/**
+	 * @param mixed $value
+	 *
+	 * @return string[]
+	 */
+	private function normalizeHeaderValue($value) : array
+	{
+		if (!\is_array($value)) {
+			return $this->trimAndValidateHeaderValues([$value]);
+		}
+		if (\count($value) === 0) {
+			throw new \InvalidArgumentException('Header value can not be an empty array.');
+		}
+		return $this->trimAndValidateHeaderValues($value);
+	}
+	/**
+	 * Trims whitespace from the header values.
+	 *
+	 * Spaces and tabs ought to be excluded by parsers when extracting the field value from a header field.
+	 *
+	 * header-field = field-name ":" OWS field-value OWS
+	 * OWS          = *( SP / HTAB )
+	 *
+	 * @param mixed[] $values Header values
+	 *
+	 * @return string[] Trimmed header values
+	 *
+	 * @see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2.4
+	 */
+	private function trimAndValidateHeaderValues(array $values) : array
+	{
+		return \array_map(function ($value) {
+			if (!\is_scalar($value) && null !== $value) {
+				throw new \InvalidArgumentException(\sprintf('Header value must be scalar or null but %s provided.', \is_object($value) ? \get_class($value) : \gettype($value)));
+			}
+			$trimmed = \trim((string) $value, " \t");
+			$this->assertValue($trimmed);
+			return $trimmed;
+		}, \array_values($values));
+	}
+	/**
+	 * @see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2
+	 *
+	 * @param mixed $header
+	 */
+	private function assertHeader($header) : void
+	{
+		if (!\is_string($header)) {
+			throw new \InvalidArgumentException(\sprintf('Header name must be a string but %s provided.', \is_object($header) ? \get_class($header) : \gettype($header)));
+		}
+		if (!\preg_match('/^[a-zA-Z0-9\'`#$%&*+.^_|~!-]+$/D', $header)) {
+			throw new \InvalidArgumentException(\sprintf('"%s" is not valid header name.', $header));
+		}
+	}
+	/**
+	 * @see https://datatracker.ietf.org/doc/html/rfc7230#section-3.2
+	 *
+	 * field-value    = *( field-content / obs-fold )
+	 * field-content  = field-vchar [ 1*( SP / HTAB ) field-vchar ]
+	 * field-vchar    = VCHAR / obs-text
+	 * VCHAR          = %x21-7E
+	 * obs-text       = %x80-FF
+	 * obs-fold       = CRLF 1*( SP / HTAB )
+	 */
+	private function assertValue(string $value) : void
+	{
+		// The regular expression intentionally does not support the obs-fold production, because as
+		// per RFC 7230#3.2.4:
+		//
+		// A sender MUST NOT generate a message that includes
+		// line folding (i.e., that has any field-value that contains a match to
+		// the obs-fold rule) unless the message is intended for packaging
+		// within the message/http media type.
+		//
+		// Clients must not send a request with line folding and a server sending folded headers is
+		// likely very rare. Line folding is a fairly obscure feature of HTTP/1.1 and thus not accepting
+		// folding is not likely to break any legitimate use case.
+		if (!\preg_match('/^[\\x20\\x09\\x21-\\x7E\\x80-\\xFF]*$/D', $value)) {
+			throw new \InvalidArgumentException(\sprintf('"%s" is not valid header value.', $value));
+		}
+	}
 }

Spacing +4 added lines, -4 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\MessageInterface;
@@ -115,7 +115,7 @@ 
         $this->headerNames = $this->headers = [];
         foreach ($headers as $header => $value) {
             // Numeric array keys are converted to int by PHP.
-            $header = (string) $header;
+            $header = (string)$header;
             $this->assertHeader($header);
             $value = $this->normalizeHeaderValue($value);
             $normalized = \strtolower($header);
@@ -159,11 +159,11 @@ 
      */
     private function trimAndValidateHeaderValues(array $values) : array
     {
-        return \array_map(function ($value) {
+        return \array_map(function($value) {
             if (!\is_scalar($value) && null !== $value) {
                 throw new \InvalidArgumentException(\sprintf('Header value must be scalar or null but %s provided.', \is_object($value) ? \get_class($value) : \gettype($value)));
             }
-            $trimmed = \trim((string) $value, " \t");
+            $trimmed = \trim((string)$value, " \t");
             $this->assertValue($trimmed);
             return $trimmed;
         }, \array_values($values));

Braces +1 added lines, -2 removed lines

@@ -8,8 +8,7 @@
 /**
  * Trait implementing functionality common to requests and responses.
  */
-trait MessageTrait
-{
+trait MessageTrait {
     /** @var string[][] Map of all registered headers, as original name => array of values */
     private $headers = [];
     /** @var string[] Map of lowercase header name => original name at registration */