nextcloud / fulltextsearch_elasticsearch

lib/Vendor/GuzzleHttp/BodySummarizerInterface.php

Indentation +4 added lines, -4 removed lines

@@ -5,8 +5,8 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\MessageInterface;
 interface BodySummarizerInterface
 {
-    /**
-     * Returns a summarized message body.
-     */
-    public function summarize(MessageInterface $message) : ?string;
+	/**
+	 * Returns a summarized message body.
+	 */
+	public function summarize(MessageInterface $message) : ?string;
 }

Braces +1 added lines, -2 removed lines

@@ -3,8 +3,7 @@
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\MessageInterface;
-interface BodySummarizerInterface
-{
+interface BodySummarizerInterface {
     /**
      * Returns a summarized message body.
      */

lib/Vendor/GuzzleHttp/Psr7/Header.php

Indentation +109 added lines, -109 removed lines

@@ -5,113 +5,113 @@
 
 final class Header
 {
-    /**
-     * Parse an array of header values containing ";" separated data into an
-     * array of associative arrays representing the header key value pair data
-     * of the header. When a parameter does not contain a value, but just
-     * contains a key, this function will inject a key with a '' string value.
-     *
-     * @param string|array $header Header to parse into components.
-     */
-    public static function parse($header) : array
-    {
-        static $trimmed = "\"'  \n\t\r";
-        $params = $matches = [];
-        foreach ((array) $header as $value) {
-            foreach (self::splitList($value) as $val) {
-                $part = [];
-                foreach (\preg_split('/;(?=([^"]*"[^"]*")*[^"]*$)/', $val) ?: [] as $kvp) {
-                    if (\preg_match_all('/<[^>]+>|[^=]+/', $kvp, $matches)) {
-                        $m = $matches[0];
-                        if (isset($m[1])) {
-                            $part[\trim($m[0], $trimmed)] = \trim($m[1], $trimmed);
-                        } else {
-                            $part[] = \trim($m[0], $trimmed);
-                        }
-                    }
-                }
-                if ($part) {
-                    $params[] = $part;
-                }
-            }
-        }
-        return $params;
-    }
-    /**
-     * Converts an array of header values that may contain comma separated
-     * headers into an array of headers with no comma separated values.
-     *
-     * @param string|array $header Header to normalize.
-     *
-     * @deprecated Use self::splitList() instead.
-     */
-    public static function normalize($header) : array
-    {
-        $result = [];
-        foreach ((array) $header as $value) {
-            foreach (self::splitList($value) as $parsed) {
-                $result[] = $parsed;
-            }
-        }
-        return $result;
-    }
-    /**
-     * Splits a HTTP header defined to contain a comma-separated list into
-     * each individual value. Empty values will be removed.
-     *
-     * Example headers include 'accept', 'cache-control' and 'if-none-match'.
-     *
-     * This method must not be used to parse headers that are not defined as
-     * a list, such as 'user-agent' or 'set-cookie'.
-     *
-     * @param string|string[] $values Header value as returned by MessageInterface::getHeader()
-     *
-     * @return string[]
-     */
-    public static function splitList($values) : array
-    {
-        if (!\is_array($values)) {
-            $values = [$values];
-        }
-        $result = [];
-        foreach ($values as $value) {
-            if (!\is_string($value)) {
-                throw new \TypeError('$header must either be a string or an array containing strings.');
-            }
-            $v = '';
-            $isQuoted = \false;
-            $isEscaped = \false;
-            for ($i = 0, $max = \strlen($value); $i < $max; ++$i) {
-                if ($isEscaped) {
-                    $v .= $value[$i];
-                    $isEscaped = \false;
-                    continue;
-                }
-                if (!$isQuoted && $value[$i] === ',') {
-                    $v = \trim($v);
-                    if ($v !== '') {
-                        $result[] = $v;
-                    }
-                    $v = '';
-                    continue;
-                }
-                if ($isQuoted && $value[$i] === '\\') {
-                    $isEscaped = \true;
-                    $v .= $value[$i];
-                    continue;
-                }
-                if ($value[$i] === '"') {
-                    $isQuoted = !$isQuoted;
-                    $v .= $value[$i];
-                    continue;
-                }
-                $v .= $value[$i];
-            }
-            $v = \trim($v);
-            if ($v !== '') {
-                $result[] = $v;
-            }
-        }
-        return $result;
-    }
+	/**
+	 * Parse an array of header values containing ";" separated data into an
+	 * array of associative arrays representing the header key value pair data
+	 * of the header. When a parameter does not contain a value, but just
+	 * contains a key, this function will inject a key with a '' string value.
+	 *
+	 * @param string|array $header Header to parse into components.
+	 */
+	public static function parse($header) : array
+	{
+		static $trimmed = "\"'  \n\t\r";
+		$params = $matches = [];
+		foreach ((array) $header as $value) {
+			foreach (self::splitList($value) as $val) {
+				$part = [];
+				foreach (\preg_split('/;(?=([^"]*"[^"]*")*[^"]*$)/', $val) ?: [] as $kvp) {
+					if (\preg_match_all('/<[^>]+>|[^=]+/', $kvp, $matches)) {
+						$m = $matches[0];
+						if (isset($m[1])) {
+							$part[\trim($m[0], $trimmed)] = \trim($m[1], $trimmed);
+						} else {
+							$part[] = \trim($m[0], $trimmed);
+						}
+					}
+				}
+				if ($part) {
+					$params[] = $part;
+				}
+			}
+		}
+		return $params;
+	}
+	/**
+	 * Converts an array of header values that may contain comma separated
+	 * headers into an array of headers with no comma separated values.
+	 *
+	 * @param string|array $header Header to normalize.
+	 *
+	 * @deprecated Use self::splitList() instead.
+	 */
+	public static function normalize($header) : array
+	{
+		$result = [];
+		foreach ((array) $header as $value) {
+			foreach (self::splitList($value) as $parsed) {
+				$result[] = $parsed;
+			}
+		}
+		return $result;
+	}
+	/**
+	 * Splits a HTTP header defined to contain a comma-separated list into
+	 * each individual value. Empty values will be removed.
+	 *
+	 * Example headers include 'accept', 'cache-control' and 'if-none-match'.
+	 *
+	 * This method must not be used to parse headers that are not defined as
+	 * a list, such as 'user-agent' or 'set-cookie'.
+	 *
+	 * @param string|string[] $values Header value as returned by MessageInterface::getHeader()
+	 *
+	 * @return string[]
+	 */
+	public static function splitList($values) : array
+	{
+		if (!\is_array($values)) {
+			$values = [$values];
+		}
+		$result = [];
+		foreach ($values as $value) {
+			if (!\is_string($value)) {
+				throw new \TypeError('$header must either be a string or an array containing strings.');
+			}
+			$v = '';
+			$isQuoted = \false;
+			$isEscaped = \false;
+			for ($i = 0, $max = \strlen($value); $i < $max; ++$i) {
+				if ($isEscaped) {
+					$v .= $value[$i];
+					$isEscaped = \false;
+					continue;
+				}
+				if (!$isQuoted && $value[$i] === ',') {
+					$v = \trim($v);
+					if ($v !== '') {
+						$result[] = $v;
+					}
+					$v = '';
+					continue;
+				}
+				if ($isQuoted && $value[$i] === '\\') {
+					$isEscaped = \true;
+					$v .= $value[$i];
+					continue;
+				}
+				if ($value[$i] === '"') {
+					$isQuoted = !$isQuoted;
+					$v .= $value[$i];
+					continue;
+				}
+				$v .= $value[$i];
+			}
+			$v = \trim($v);
+			if ($v !== '') {
+				$result[] = $v;
+			}
+		}
+		return $result;
+	}
 }

Spacing +3 added lines, -3 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 final class Header
@@ -17,7 +17,7 @@ 
     {
         static $trimmed = "\"'  \n\t\r";
         $params = $matches = [];
-        foreach ((array) $header as $value) {
+        foreach ((array)$header as $value) {
             foreach (self::splitList($value) as $val) {
                 $part = [];
                 foreach (\preg_split('/;(?=([^"]*"[^"]*")*[^"]*$)/', $val) ?: [] as $kvp) {
@@ -48,7 +48,7 @@ 
     public static function normalize($header) : array
     {
         $result = [];
-        foreach ((array) $header as $value) {
+        foreach ((array)$header as $value) {
             foreach (self::splitList($value) as $parsed) {
                 $result[] = $parsed;
             }

Braces +1 added lines, -2 removed lines

@@ -3,8 +3,7 @@
 declare (strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
-final class Header
-{
+final class Header {
     /**
      * Parse an array of header values containing ";" separated data into an
      * array of associative arrays representing the header key value pair data

lib/Vendor/GuzzleHttp/Psr7/HttpFactory.php

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\RequestFactoryInterface;

Indentation +50 added lines, -50 removed lines

@@ -23,54 +23,54 @@
  */
 final class HttpFactory implements RequestFactoryInterface, ResponseFactoryInterface, ServerRequestFactoryInterface, StreamFactoryInterface, UploadedFileFactoryInterface, UriFactoryInterface
 {
-    public function createUploadedFile(StreamInterface $stream, ?int $size = null, int $error = \UPLOAD_ERR_OK, ?string $clientFilename = null, ?string $clientMediaType = null) : UploadedFileInterface
-    {
-        if ($size === null) {
-            $size = $stream->getSize();
-        }
-        return new UploadedFile($stream, $size, $error, $clientFilename, $clientMediaType);
-    }
-    public function createStream(string $content = '') : StreamInterface
-    {
-        return Utils::streamFor($content);
-    }
-    public function createStreamFromFile(string $file, string $mode = 'r') : StreamInterface
-    {
-        try {
-            $resource = Utils::tryFopen($file, $mode);
-        } catch (\RuntimeException $e) {
-            if ('' === $mode || \false === \in_array($mode[0], ['r', 'w', 'a', 'x', 'c'], \true)) {
-                throw new \InvalidArgumentException(\sprintf('Invalid file opening mode "%s"', $mode), 0, $e);
-            }
-            throw $e;
-        }
-        return Utils::streamFor($resource);
-    }
-    public function createStreamFromResource($resource) : StreamInterface
-    {
-        return Utils::streamFor($resource);
-    }
-    public function createServerRequest(string $method, $uri, array $serverParams = []) : ServerRequestInterface
-    {
-        if (empty($method)) {
-            if (!empty($serverParams['REQUEST_METHOD'])) {
-                $method = $serverParams['REQUEST_METHOD'];
-            } else {
-                throw new \InvalidArgumentException('Cannot determine HTTP method');
-            }
-        }
-        return new ServerRequest($method, $uri, [], null, '1.1', $serverParams);
-    }
-    public function createResponse(int $code = 200, string $reasonPhrase = '') : ResponseInterface
-    {
-        return new Response($code, [], null, '1.1', $reasonPhrase);
-    }
-    public function createRequest(string $method, $uri) : RequestInterface
-    {
-        return new Request($method, $uri);
-    }
-    public function createUri(string $uri = '') : UriInterface
-    {
-        return new Uri($uri);
-    }
+	public function createUploadedFile(StreamInterface $stream, ?int $size = null, int $error = \UPLOAD_ERR_OK, ?string $clientFilename = null, ?string $clientMediaType = null) : UploadedFileInterface
+	{
+		if ($size === null) {
+			$size = $stream->getSize();
+		}
+		return new UploadedFile($stream, $size, $error, $clientFilename, $clientMediaType);
+	}
+	public function createStream(string $content = '') : StreamInterface
+	{
+		return Utils::streamFor($content);
+	}
+	public function createStreamFromFile(string $file, string $mode = 'r') : StreamInterface
+	{
+		try {
+			$resource = Utils::tryFopen($file, $mode);
+		} catch (\RuntimeException $e) {
+			if ('' === $mode || \false === \in_array($mode[0], ['r', 'w', 'a', 'x', 'c'], \true)) {
+				throw new \InvalidArgumentException(\sprintf('Invalid file opening mode "%s"', $mode), 0, $e);
+			}
+			throw $e;
+		}
+		return Utils::streamFor($resource);
+	}
+	public function createStreamFromResource($resource) : StreamInterface
+	{
+		return Utils::streamFor($resource);
+	}
+	public function createServerRequest(string $method, $uri, array $serverParams = []) : ServerRequestInterface
+	{
+		if (empty($method)) {
+			if (!empty($serverParams['REQUEST_METHOD'])) {
+				$method = $serverParams['REQUEST_METHOD'];
+			} else {
+				throw new \InvalidArgumentException('Cannot determine HTTP method');
+			}
+		}
+		return new ServerRequest($method, $uri, [], null, '1.1', $serverParams);
+	}
+	public function createResponse(int $code = 200, string $reasonPhrase = '') : ResponseInterface
+	{
+		return new Response($code, [], null, '1.1', $reasonPhrase);
+	}
+	public function createRequest(string $method, $uri) : RequestInterface
+	{
+		return new Request($method, $uri);
+	}
+	public function createUri(string $uri = '') : UriInterface
+	{
+		return new Uri($uri);
+	}
 }

lib/Vendor/GuzzleHttp/Psr7/PumpStream.php

Indentation +130 added lines, -130 removed lines

@@ -16,134 +16,134 @@
  */
 final class PumpStream implements StreamInterface
 {
-    /** @var callable(int): (string|false|null)|null */
-    private $source;
-    /** @var int|null */
-    private $size;
-    /** @var int */
-    private $tellPos = 0;
-    /** @var array */
-    private $metadata;
-    /** @var BufferStream */
-    private $buffer;
-    /**
-     * @param callable(int): (string|false|null)  $source  Source of the stream data. The callable MAY
-     *                                                     accept an integer argument used to control the
-     *                                                     amount of data to return. The callable MUST
-     *                                                     return a string when called, or false|null on error
-     *                                                     or EOF.
-     * @param array{size?: int, metadata?: array} $options Stream options:
-     *                                                     - metadata: Hash of metadata to use with stream.
-     *                                                     - size: Size of the stream, if known.
-     */
-    public function __construct(callable $source, array $options = [])
-    {
-        $this->source = $source;
-        $this->size = $options['size'] ?? null;
-        $this->metadata = $options['metadata'] ?? [];
-        $this->buffer = new BufferStream();
-    }
-    public function __toString() : string
-    {
-        try {
-            return Utils::copyToString($this);
-        } catch (\Throwable $e) {
-            if (\PHP_VERSION_ID >= 70400) {
-                throw $e;
-            }
-            \trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string) $e), \E_USER_ERROR);
-            return '';
-        }
-    }
-    public function close() : void
-    {
-        $this->detach();
-    }
-    public function detach()
-    {
-        $this->tellPos = 0;
-        $this->source = null;
-        return null;
-    }
-    public function getSize() : ?int
-    {
-        return $this->size;
-    }
-    public function tell() : int
-    {
-        return $this->tellPos;
-    }
-    public function eof() : bool
-    {
-        return $this->source === null;
-    }
-    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 PumpStream');
-    }
-    public function isWritable() : bool
-    {
-        return \false;
-    }
-    public function write($string) : int
-    {
-        throw new \RuntimeException('Cannot write to a PumpStream');
-    }
-    public function isReadable() : bool
-    {
-        return \true;
-    }
-    public function read($length) : string
-    {
-        $data = $this->buffer->read($length);
-        $readLen = \strlen($data);
-        $this->tellPos += $readLen;
-        $remaining = $length - $readLen;
-        if ($remaining) {
-            $this->pump($remaining);
-            $data .= $this->buffer->read($remaining);
-            $this->tellPos += \strlen($data) - $readLen;
-        }
-        return $data;
-    }
-    public function getContents() : string
-    {
-        $result = '';
-        while (!$this->eof()) {
-            $result .= $this->read(1000000);
-        }
-        return $result;
-    }
-    /**
-     * @return mixed
-     */
-    public function getMetadata($key = null)
-    {
-        if (!$key) {
-            return $this->metadata;
-        }
-        return $this->metadata[$key] ?? null;
-    }
-    private function pump(int $length) : void
-    {
-        if ($this->source !== null) {
-            do {
-                $data = ($this->source)($length);
-                if ($data === \false || $data === null) {
-                    $this->source = null;
-                    return;
-                }
-                $this->buffer->write($data);
-                $length -= \strlen($data);
-            } while ($length > 0);
-        }
-    }
+	/** @var callable(int): (string|false|null)|null */
+	private $source;
+	/** @var int|null */
+	private $size;
+	/** @var int */
+	private $tellPos = 0;
+	/** @var array */
+	private $metadata;
+	/** @var BufferStream */
+	private $buffer;
+	/**
+	 * @param callable(int): (string|false|null)  $source  Source of the stream data. The callable MAY
+	 *                                                     accept an integer argument used to control the
+	 *                                                     amount of data to return. The callable MUST
+	 *                                                     return a string when called, or false|null on error
+	 *                                                     or EOF.
+	 * @param array{size?: int, metadata?: array} $options Stream options:
+	 *                                                     - metadata: Hash of metadata to use with stream.
+	 *                                                     - size: Size of the stream, if known.
+	 */
+	public function __construct(callable $source, array $options = [])
+	{
+		$this->source = $source;
+		$this->size = $options['size'] ?? null;
+		$this->metadata = $options['metadata'] ?? [];
+		$this->buffer = new BufferStream();
+	}
+	public function __toString() : string
+	{
+		try {
+			return Utils::copyToString($this);
+		} catch (\Throwable $e) {
+			if (\PHP_VERSION_ID >= 70400) {
+				throw $e;
+			}
+			\trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string) $e), \E_USER_ERROR);
+			return '';
+		}
+	}
+	public function close() : void
+	{
+		$this->detach();
+	}
+	public function detach()
+	{
+		$this->tellPos = 0;
+		$this->source = null;
+		return null;
+	}
+	public function getSize() : ?int
+	{
+		return $this->size;
+	}
+	public function tell() : int
+	{
+		return $this->tellPos;
+	}
+	public function eof() : bool
+	{
+		return $this->source === null;
+	}
+	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 PumpStream');
+	}
+	public function isWritable() : bool
+	{
+		return \false;
+	}
+	public function write($string) : int
+	{
+		throw new \RuntimeException('Cannot write to a PumpStream');
+	}
+	public function isReadable() : bool
+	{
+		return \true;
+	}
+	public function read($length) : string
+	{
+		$data = $this->buffer->read($length);
+		$readLen = \strlen($data);
+		$this->tellPos += $readLen;
+		$remaining = $length - $readLen;
+		if ($remaining) {
+			$this->pump($remaining);
+			$data .= $this->buffer->read($remaining);
+			$this->tellPos += \strlen($data) - $readLen;
+		}
+		return $data;
+	}
+	public function getContents() : string
+	{
+		$result = '';
+		while (!$this->eof()) {
+			$result .= $this->read(1000000);
+		}
+		return $result;
+	}
+	/**
+	 * @return mixed
+	 */
+	public function getMetadata($key = null)
+	{
+		if (!$key) {
+			return $this->metadata;
+		}
+		return $this->metadata[$key] ?? null;
+	}
+	private function pump(int $length) : void
+	{
+		if ($this->source !== null) {
+			do {
+				$data = ($this->source)($length);
+				if ($data === \false || $data === null) {
+					$this->source = null;
+					return;
+				}
+				$this->buffer->write($data);
+				$length -= \strlen($data);
+			} while ($length > 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;
@@ -51,7 +51,7 @@ 
             if (\PHP_VERSION_ID >= 70400) {
                 throw $e;
             }
-            \trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string) $e), \E_USER_ERROR);
+            \trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string)$e), \E_USER_ERROR);
             return '';
         }
     }

Braces +1 added lines, -2 removed lines

@@ -14,8 +14,7 @@
  * the read() function of the PumpStream. The provided callable MUST return
  * false when there is no more data to read.
  */
-final class PumpStream implements StreamInterface
-{
+final class PumpStream implements StreamInterface {
     /** @var callable(int): (string|false|null)|null */
     private $source;
     /** @var int|null */

lib/Vendor/GuzzleHttp/Psr7/MultipartStream.php

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\StreamInterface;
@@ -51,7 +51,7 @@ 
         foreach ($headers as $key => $value) {
             $str .= "{$key}: {$value}\r\n";
         }
-        return "--{$this->boundary}\r\n" . \trim($str) . "\r\n\r\n";
+        return "--{$this->boundary}\r\n".\trim($str)."\r\n\r\n";
     }
     /**
      * Create the aggregate stream that will be used to upload the POST data
@@ -104,7 +104,7 @@ 
         $length = self::getHeader($headers, 'content-length');
         if (!$length) {
             if ($length = $stream->getSize()) {
-                $headers['Content-Length'] = (string) $length;
+                $headers['Content-Length'] = (string)$length;
             }
         }
         // Set a default Content-Type if one was not supplied
@@ -121,7 +121,7 @@ 
     {
         $lowercaseHeader = \strtolower($key);
         foreach ($headers as $k => $v) {
-            if (\strtolower((string) $k) === $lowercaseHeader) {
+            if (\strtolower((string)$k) === $lowercaseHeader) {
                 return $v;
             }
         }

Braces +1 added lines, -2 removed lines

@@ -8,8 +8,7 @@
  * Stream that when read returns bytes for a streaming multipart or
  * multipart/form-data stream.
  */
-final class MultipartStream implements StreamInterface
-{
+final class MultipartStream implements StreamInterface {
     use StreamDecoratorTrait;
     /** @var string */
     private $boundary;

Indentation +117 added lines, -117 removed lines

@@ -10,121 +10,121 @@
  */
 final class MultipartStream implements StreamInterface
 {
-    use StreamDecoratorTrait;
-    /** @var string */
-    private $boundary;
-    /** @var StreamInterface */
-    private $stream;
-    /**
-     * @param array  $elements Array of associative arrays, each containing a
-     *                         required "name" key mapping to the form field,
-     *                         name, a required "contents" key mapping to a
-     *                         StreamInterface/resource/string, an optional
-     *                         "headers" associative array of custom headers,
-     *                         and an optional "filename" key mapping to a
-     *                         string to send as the filename in the part.
-     * @param string $boundary You can optionally provide a specific boundary
-     *
-     * @throws \InvalidArgumentException
-     */
-    public function __construct(array $elements = [], ?string $boundary = null)
-    {
-        $this->boundary = $boundary ?: \bin2hex(\random_bytes(20));
-        $this->stream = $this->createStream($elements);
-    }
-    public function getBoundary() : string
-    {
-        return $this->boundary;
-    }
-    public function isWritable() : bool
-    {
-        return \false;
-    }
-    /**
-     * Get the headers needed before transferring the content of a POST file
-     *
-     * @param string[] $headers
-     */
-    private function getHeaders(array $headers) : string
-    {
-        $str = '';
-        foreach ($headers as $key => $value) {
-            $str .= "{$key}: {$value}\r\n";
-        }
-        return "--{$this->boundary}\r\n" . \trim($str) . "\r\n\r\n";
-    }
-    /**
-     * Create the aggregate stream that will be used to upload the POST data
-     */
-    protected function createStream(array $elements = []) : StreamInterface
-    {
-        $stream = new AppendStream();
-        foreach ($elements as $element) {
-            if (!\is_array($element)) {
-                throw new \UnexpectedValueException('An array is expected');
-            }
-            $this->addElement($stream, $element);
-        }
-        // Add the trailing boundary with CRLF
-        $stream->addStream(Utils::streamFor("--{$this->boundary}--\r\n"));
-        return $stream;
-    }
-    private function addElement(AppendStream $stream, array $element) : void
-    {
-        foreach (['contents', 'name'] as $key) {
-            if (!\array_key_exists($key, $element)) {
-                throw new \InvalidArgumentException("A '{$key}' key is required");
-            }
-        }
-        $element['contents'] = Utils::streamFor($element['contents']);
-        if (empty($element['filename'])) {
-            $uri = $element['contents']->getMetadata('uri');
-            if ($uri && \is_string($uri) && \substr($uri, 0, 6) !== 'php://' && \substr($uri, 0, 7) !== 'data://') {
-                $element['filename'] = $uri;
-            }
-        }
-        [$body, $headers] = $this->createElement($element['name'], $element['contents'], $element['filename'] ?? null, $element['headers'] ?? []);
-        $stream->addStream(Utils::streamFor($this->getHeaders($headers)));
-        $stream->addStream($body);
-        $stream->addStream(Utils::streamFor("\r\n"));
-    }
-    /**
-     * @param string[] $headers
-     *
-     * @return array{0: StreamInterface, 1: string[]}
-     */
-    private function createElement(string $name, StreamInterface $stream, ?string $filename, array $headers) : array
-    {
-        // Set a default content-disposition header if one was no provided
-        $disposition = self::getHeader($headers, 'content-disposition');
-        if (!$disposition) {
-            $headers['Content-Disposition'] = $filename === '0' || $filename ? \sprintf('form-data; name="%s"; filename="%s"', $name, \basename($filename)) : "form-data; name=\"{$name}\"";
-        }
-        // Set a default content-length header if one was no provided
-        $length = self::getHeader($headers, 'content-length');
-        if (!$length) {
-            if ($length = $stream->getSize()) {
-                $headers['Content-Length'] = (string) $length;
-            }
-        }
-        // Set a default Content-Type if one was not supplied
-        $type = self::getHeader($headers, 'content-type');
-        if (!$type && ($filename === '0' || $filename)) {
-            $headers['Content-Type'] = MimeType::fromFilename($filename) ?? 'application/octet-stream';
-        }
-        return [$stream, $headers];
-    }
-    /**
-     * @param string[] $headers
-     */
-    private static function getHeader(array $headers, string $key) : ?string
-    {
-        $lowercaseHeader = \strtolower($key);
-        foreach ($headers as $k => $v) {
-            if (\strtolower((string) $k) === $lowercaseHeader) {
-                return $v;
-            }
-        }
-        return null;
-    }
+	use StreamDecoratorTrait;
+	/** @var string */
+	private $boundary;
+	/** @var StreamInterface */
+	private $stream;
+	/**
+	 * @param array  $elements Array of associative arrays, each containing a
+	 *                         required "name" key mapping to the form field,
+	 *                         name, a required "contents" key mapping to a
+	 *                         StreamInterface/resource/string, an optional
+	 *                         "headers" associative array of custom headers,
+	 *                         and an optional "filename" key mapping to a
+	 *                         string to send as the filename in the part.
+	 * @param string $boundary You can optionally provide a specific boundary
+	 *
+	 * @throws \InvalidArgumentException
+	 */
+	public function __construct(array $elements = [], ?string $boundary = null)
+	{
+		$this->boundary = $boundary ?: \bin2hex(\random_bytes(20));
+		$this->stream = $this->createStream($elements);
+	}
+	public function getBoundary() : string
+	{
+		return $this->boundary;
+	}
+	public function isWritable() : bool
+	{
+		return \false;
+	}
+	/**
+	 * Get the headers needed before transferring the content of a POST file
+	 *
+	 * @param string[] $headers
+	 */
+	private function getHeaders(array $headers) : string
+	{
+		$str = '';
+		foreach ($headers as $key => $value) {
+			$str .= "{$key}: {$value}\r\n";
+		}
+		return "--{$this->boundary}\r\n" . \trim($str) . "\r\n\r\n";
+	}
+	/**
+	 * Create the aggregate stream that will be used to upload the POST data
+	 */
+	protected function createStream(array $elements = []) : StreamInterface
+	{
+		$stream = new AppendStream();
+		foreach ($elements as $element) {
+			if (!\is_array($element)) {
+				throw new \UnexpectedValueException('An array is expected');
+			}
+			$this->addElement($stream, $element);
+		}
+		// Add the trailing boundary with CRLF
+		$stream->addStream(Utils::streamFor("--{$this->boundary}--\r\n"));
+		return $stream;
+	}
+	private function addElement(AppendStream $stream, array $element) : void
+	{
+		foreach (['contents', 'name'] as $key) {
+			if (!\array_key_exists($key, $element)) {
+				throw new \InvalidArgumentException("A '{$key}' key is required");
+			}
+		}
+		$element['contents'] = Utils::streamFor($element['contents']);
+		if (empty($element['filename'])) {
+			$uri = $element['contents']->getMetadata('uri');
+			if ($uri && \is_string($uri) && \substr($uri, 0, 6) !== 'php://' && \substr($uri, 0, 7) !== 'data://') {
+				$element['filename'] = $uri;
+			}
+		}
+		[$body, $headers] = $this->createElement($element['name'], $element['contents'], $element['filename'] ?? null, $element['headers'] ?? []);
+		$stream->addStream(Utils::streamFor($this->getHeaders($headers)));
+		$stream->addStream($body);
+		$stream->addStream(Utils::streamFor("\r\n"));
+	}
+	/**
+	 * @param string[] $headers
+	 *
+	 * @return array{0: StreamInterface, 1: string[]}
+	 */
+	private function createElement(string $name, StreamInterface $stream, ?string $filename, array $headers) : array
+	{
+		// Set a default content-disposition header if one was no provided
+		$disposition = self::getHeader($headers, 'content-disposition');
+		if (!$disposition) {
+			$headers['Content-Disposition'] = $filename === '0' || $filename ? \sprintf('form-data; name="%s"; filename="%s"', $name, \basename($filename)) : "form-data; name=\"{$name}\"";
+		}
+		// Set a default content-length header if one was no provided
+		$length = self::getHeader($headers, 'content-length');
+		if (!$length) {
+			if ($length = $stream->getSize()) {
+				$headers['Content-Length'] = (string) $length;
+			}
+		}
+		// Set a default Content-Type if one was not supplied
+		$type = self::getHeader($headers, 'content-type');
+		if (!$type && ($filename === '0' || $filename)) {
+			$headers['Content-Type'] = MimeType::fromFilename($filename) ?? 'application/octet-stream';
+		}
+		return [$stream, $headers];
+	}
+	/**
+	 * @param string[] $headers
+	 */
+	private static function getHeader(array $headers, string $key) : ?string
+	{
+		$lowercaseHeader = \strtolower($key);
+		foreach ($headers as $k => $v) {
+			if (\strtolower((string) $k) === $lowercaseHeader) {
+				return $v;
+			}
+		}
+		return null;
+	}
 }

lib/Vendor/GuzzleHttp/Psr7/FnStream.php

Indentation +133 added lines, -133 removed lines

@@ -13,137 +13,137 @@
 #[\AllowDynamicProperties]
 final class FnStream implements StreamInterface
 {
-    private const SLOTS = ['__toString', 'close', 'detach', 'rewind', 'getSize', 'tell', 'eof', 'isSeekable', 'seek', 'isWritable', 'write', 'isReadable', 'read', 'getContents', 'getMetadata'];
-    /** @var array<string, callable> */
-    private $methods;
-    /**
-     * @param array<string, callable> $methods Hash of method name to a callable.
-     */
-    public function __construct(array $methods)
-    {
-        $this->methods = $methods;
-        // Create the functions on the class
-        foreach ($methods as $name => $fn) {
-            $this->{'_fn_' . $name} = $fn;
-        }
-    }
-    /**
-     * Lazily determine which methods are not implemented.
-     *
-     * @throws \BadMethodCallException
-     */
-    public function __get(string $name) : void
-    {
-        throw new \BadMethodCallException(\str_replace('_fn_', '', $name) . '() is not implemented in the FnStream');
-    }
-    /**
-     * The close method is called on the underlying stream only if possible.
-     */
-    public function __destruct()
-    {
-        if (isset($this->_fn_close)) {
-            ($this->_fn_close)();
-        }
-    }
-    /**
-     * An unserialize would allow the __destruct to run when the unserialized value goes out of scope.
-     *
-     * @throws \LogicException
-     */
-    public function __wakeup() : void
-    {
-        throw new \LogicException('FnStream should never be unserialized');
-    }
-    /**
-     * Adds custom functionality to an underlying stream by intercepting
-     * specific method calls.
-     *
-     * @param StreamInterface         $stream  Stream to decorate
-     * @param array<string, callable> $methods Hash of method name to a closure
-     *
-     * @return FnStream
-     */
-    public static function decorate(StreamInterface $stream, array $methods)
-    {
-        // If any of the required methods were not provided, then simply
-        // proxy to the decorated stream.
-        foreach (\array_diff(self::SLOTS, \array_keys($methods)) as $diff) {
-            /** @var callable $callable */
-            $callable = [$stream, $diff];
-            $methods[$diff] = $callable;
-        }
-        return new self($methods);
-    }
-    public function __toString() : string
-    {
-        try {
-            /** @var string */
-            return ($this->_fn___toString)();
-        } catch (\Throwable $e) {
-            if (\PHP_VERSION_ID >= 70400) {
-                throw $e;
-            }
-            \trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string) $e), \E_USER_ERROR);
-            return '';
-        }
-    }
-    public function close() : void
-    {
-        ($this->_fn_close)();
-    }
-    public function detach()
-    {
-        return ($this->_fn_detach)();
-    }
-    public function getSize() : ?int
-    {
-        return ($this->_fn_getSize)();
-    }
-    public function tell() : int
-    {
-        return ($this->_fn_tell)();
-    }
-    public function eof() : bool
-    {
-        return ($this->_fn_eof)();
-    }
-    public function isSeekable() : bool
-    {
-        return ($this->_fn_isSeekable)();
-    }
-    public function rewind() : void
-    {
-        ($this->_fn_rewind)();
-    }
-    public function seek($offset, $whence = \SEEK_SET) : void
-    {
-        ($this->_fn_seek)($offset, $whence);
-    }
-    public function isWritable() : bool
-    {
-        return ($this->_fn_isWritable)();
-    }
-    public function write($string) : int
-    {
-        return ($this->_fn_write)($string);
-    }
-    public function isReadable() : bool
-    {
-        return ($this->_fn_isReadable)();
-    }
-    public function read($length) : string
-    {
-        return ($this->_fn_read)($length);
-    }
-    public function getContents() : string
-    {
-        return ($this->_fn_getContents)();
-    }
-    /**
-     * @return mixed
-     */
-    public function getMetadata($key = null)
-    {
-        return ($this->_fn_getMetadata)($key);
-    }
+	private const SLOTS = ['__toString', 'close', 'detach', 'rewind', 'getSize', 'tell', 'eof', 'isSeekable', 'seek', 'isWritable', 'write', 'isReadable', 'read', 'getContents', 'getMetadata'];
+	/** @var array<string, callable> */
+	private $methods;
+	/**
+	 * @param array<string, callable> $methods Hash of method name to a callable.
+	 */
+	public function __construct(array $methods)
+	{
+		$this->methods = $methods;
+		// Create the functions on the class
+		foreach ($methods as $name => $fn) {
+			$this->{'_fn_' . $name} = $fn;
+		}
+	}
+	/**
+	 * Lazily determine which methods are not implemented.
+	 *
+	 * @throws \BadMethodCallException
+	 */
+	public function __get(string $name) : void
+	{
+		throw new \BadMethodCallException(\str_replace('_fn_', '', $name) . '() is not implemented in the FnStream');
+	}
+	/**
+	 * The close method is called on the underlying stream only if possible.
+	 */
+	public function __destruct()
+	{
+		if (isset($this->_fn_close)) {
+			($this->_fn_close)();
+		}
+	}
+	/**
+	 * An unserialize would allow the __destruct to run when the unserialized value goes out of scope.
+	 *
+	 * @throws \LogicException
+	 */
+	public function __wakeup() : void
+	{
+		throw new \LogicException('FnStream should never be unserialized');
+	}
+	/**
+	 * Adds custom functionality to an underlying stream by intercepting
+	 * specific method calls.
+	 *
+	 * @param StreamInterface         $stream  Stream to decorate
+	 * @param array<string, callable> $methods Hash of method name to a closure
+	 *
+	 * @return FnStream
+	 */
+	public static function decorate(StreamInterface $stream, array $methods)
+	{
+		// If any of the required methods were not provided, then simply
+		// proxy to the decorated stream.
+		foreach (\array_diff(self::SLOTS, \array_keys($methods)) as $diff) {
+			/** @var callable $callable */
+			$callable = [$stream, $diff];
+			$methods[$diff] = $callable;
+		}
+		return new self($methods);
+	}
+	public function __toString() : string
+	{
+		try {
+			/** @var string */
+			return ($this->_fn___toString)();
+		} catch (\Throwable $e) {
+			if (\PHP_VERSION_ID >= 70400) {
+				throw $e;
+			}
+			\trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string) $e), \E_USER_ERROR);
+			return '';
+		}
+	}
+	public function close() : void
+	{
+		($this->_fn_close)();
+	}
+	public function detach()
+	{
+		return ($this->_fn_detach)();
+	}
+	public function getSize() : ?int
+	{
+		return ($this->_fn_getSize)();
+	}
+	public function tell() : int
+	{
+		return ($this->_fn_tell)();
+	}
+	public function eof() : bool
+	{
+		return ($this->_fn_eof)();
+	}
+	public function isSeekable() : bool
+	{
+		return ($this->_fn_isSeekable)();
+	}
+	public function rewind() : void
+	{
+		($this->_fn_rewind)();
+	}
+	public function seek($offset, $whence = \SEEK_SET) : void
+	{
+		($this->_fn_seek)($offset, $whence);
+	}
+	public function isWritable() : bool
+	{
+		return ($this->_fn_isWritable)();
+	}
+	public function write($string) : int
+	{
+		return ($this->_fn_write)($string);
+	}
+	public function isReadable() : bool
+	{
+		return ($this->_fn_isReadable)();
+	}
+	public function read($length) : string
+	{
+		return ($this->_fn_read)($length);
+	}
+	public function getContents() : string
+	{
+		return ($this->_fn_getContents)();
+	}
+	/**
+	 * @return mixed
+	 */
+	public function getMetadata($key = null)
+	{
+		return ($this->_fn_getMetadata)($key);
+	}
 }

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\StreamInterface;
@@ -24,7 +24,7 @@ 
         $this->methods = $methods;
         // Create the functions on the class
         foreach ($methods as $name => $fn) {
-            $this->{'_fn_' . $name} = $fn;
+            $this->{'_fn_'.$name} = $fn;
         }
     }
     /**
@@ -34,7 +34,7 @@ 
      */
     public function __get(string $name) : void
     {
-        throw new \BadMethodCallException(\str_replace('_fn_', '', $name) . '() is not implemented in the FnStream');
+        throw new \BadMethodCallException(\str_replace('_fn_', '', $name).'() is not implemented in the FnStream');
     }
     /**
      * The close method is called on the underlying stream only if possible.
@@ -83,7 +83,7 @@ 
             if (\PHP_VERSION_ID >= 70400) {
                 throw $e;
             }
-            \trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string) $e), \E_USER_ERROR);
+            \trigger_error(\sprintf('%s::__toString exception: %s', self::class, (string)$e), \E_USER_ERROR);
             return '';
         }
     }

Braces +1 added lines, -2 removed lines

@@ -11,8 +11,7 @@
  * to create a concrete class for a simple extension point.
  */
 #[\AllowDynamicProperties]
-final class FnStream implements StreamInterface
-{
+final class FnStream implements StreamInterface {
     private const SLOTS = ['__toString', 'close', 'detach', 'rewind', 'getSize', 'tell', 'eof', 'isSeekable', 'seek', 'isWritable', 'write', 'isReadable', 'read', 'getContents', 'getMetadata'];
     /** @var array<string, callable> */
     private $methods;

lib/Vendor/GuzzleHttp/Psr7/NoSeekStream.php

Indentation +11 added lines, -11 removed lines

@@ -9,15 +9,15 @@
  */
 final class NoSeekStream implements StreamInterface
 {
-    use StreamDecoratorTrait;
-    /** @var StreamInterface */
-    private $stream;
-    public function seek($offset, $whence = \SEEK_SET) : void
-    {
-        throw new \RuntimeException('Cannot seek a NoSeekStream');
-    }
-    public function isSeekable() : bool
-    {
-        return \false;
-    }
+	use StreamDecoratorTrait;
+	/** @var StreamInterface */
+	private $stream;
+	public function seek($offset, $whence = \SEEK_SET) : void
+	{
+		throw new \RuntimeException('Cannot seek a NoSeekStream');
+	}
+	public function isSeekable() : bool
+	{
+		return \false;
+	}
 }

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;

Braces +1 added lines, -2 removed lines

@@ -7,8 +7,7 @@
 /**
  * Stream decorator that prevents a stream from being seeked.
  */
-final class NoSeekStream implements StreamInterface
-{
+final class NoSeekStream implements StreamInterface {
     use StreamDecoratorTrait;
     /** @var StreamInterface */
     private $stream;

lib/Vendor/GuzzleHttp/Psr7/Response.php

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\ResponseInterface;
@@ -35,7 +35,7 @@ 
         if ($reason == '' && isset(self::PHRASES[$this->statusCode])) {
             $this->reasonPhrase = self::PHRASES[$this->statusCode];
         } else {
-            $this->reasonPhrase = (string) $reason;
+            $this->reasonPhrase = (string)$reason;
         }
         $this->protocol = $version;
     }
@@ -50,14 +50,14 @@ 
     public function withStatus($code, $reasonPhrase = '') : ResponseInterface
     {
         $this->assertStatusCodeIsInteger($code);
-        $code = (int) $code;
+        $code = (int)$code;
         $this->assertStatusCodeRange($code);
         $new = clone $this;
         $new->statusCode = $code;
         if ($reasonPhrase == '' && isset(self::PHRASES[$new->statusCode])) {
             $reasonPhrase = self::PHRASES[$new->statusCode];
         }
-        $new->reasonPhrase = (string) $reasonPhrase;
+        $new->reasonPhrase = (string)$reasonPhrase;
         return $new;
     }
     /**

Braces +1 added lines, -2 removed lines

@@ -8,8 +8,7 @@
 /**
  * PSR-7 response implementation.
  */
-class Response implements ResponseInterface
-{
+class Response implements ResponseInterface {
     use MessageTrait;
     /** Map of standard HTTP status code/reason phrases */
     private const PHRASES = [100 => 'Continue', 101 => 'Switching Protocols', 102 => 'Processing', 200 => 'OK', 201 => 'Created', 202 => 'Accepted', 203 => 'Non-Authoritative Information', 204 => 'No Content', 205 => 'Reset Content', 206 => 'Partial Content', 207 => 'Multi-status', 208 => 'Already Reported', 300 => 'Multiple Choices', 301 => 'Moved Permanently', 302 => 'Found', 303 => 'See Other', 304 => 'Not Modified', 305 => 'Use Proxy', 306 => 'Switch Proxy', 307 => 'Temporary Redirect', 308 => 'Permanent Redirect', 400 => 'Bad Request', 401 => 'Unauthorized', 402 => 'Payment Required', 403 => 'Forbidden', 404 => 'Not Found', 405 => 'Method Not Allowed', 406 => 'Not Acceptable', 407 => 'Proxy Authentication Required', 408 => 'Request Time-out', 409 => 'Conflict', 410 => 'Gone', 411 => 'Length Required', 412 => 'Precondition Failed', 413 => 'Request Entity Too Large', 414 => 'Request-URI Too Large', 415 => 'Unsupported Media Type', 416 => 'Requested range not satisfiable', 417 => 'Expectation Failed', 418 => 'I\'m a teapot', 422 => 'Unprocessable Entity', 423 => 'Locked', 424 => 'Failed Dependency', 425 => 'Unordered Collection', 426 => 'Upgrade Required', 428 => 'Precondition Required', 429 => 'Too Many Requests', 431 => 'Request Header Fields Too Large', 451 => 'Unavailable For Legal Reasons', 500 => 'Internal Server Error', 501 => 'Not Implemented', 502 => 'Bad Gateway', 503 => 'Service Unavailable', 504 => 'Gateway Time-out', 505 => 'HTTP Version not supported', 506 => 'Variant Also Negotiates', 507 => 'Insufficient Storage', 508 => 'Loop Detected', 510 => 'Not Extended', 511 => 'Network Authentication Required'];

Indentation +65 added lines, -65 removed lines

@@ -10,69 +10,69 @@
  */
 class Response implements ResponseInterface
 {
-    use MessageTrait;
-    /** Map of standard HTTP status code/reason phrases */
-    private const PHRASES = [100 => 'Continue', 101 => 'Switching Protocols', 102 => 'Processing', 200 => 'OK', 201 => 'Created', 202 => 'Accepted', 203 => 'Non-Authoritative Information', 204 => 'No Content', 205 => 'Reset Content', 206 => 'Partial Content', 207 => 'Multi-status', 208 => 'Already Reported', 300 => 'Multiple Choices', 301 => 'Moved Permanently', 302 => 'Found', 303 => 'See Other', 304 => 'Not Modified', 305 => 'Use Proxy', 306 => 'Switch Proxy', 307 => 'Temporary Redirect', 308 => 'Permanent Redirect', 400 => 'Bad Request', 401 => 'Unauthorized', 402 => 'Payment Required', 403 => 'Forbidden', 404 => 'Not Found', 405 => 'Method Not Allowed', 406 => 'Not Acceptable', 407 => 'Proxy Authentication Required', 408 => 'Request Time-out', 409 => 'Conflict', 410 => 'Gone', 411 => 'Length Required', 412 => 'Precondition Failed', 413 => 'Request Entity Too Large', 414 => 'Request-URI Too Large', 415 => 'Unsupported Media Type', 416 => 'Requested range not satisfiable', 417 => 'Expectation Failed', 418 => 'I\'m a teapot', 422 => 'Unprocessable Entity', 423 => 'Locked', 424 => 'Failed Dependency', 425 => 'Unordered Collection', 426 => 'Upgrade Required', 428 => 'Precondition Required', 429 => 'Too Many Requests', 431 => 'Request Header Fields Too Large', 451 => 'Unavailable For Legal Reasons', 500 => 'Internal Server Error', 501 => 'Not Implemented', 502 => 'Bad Gateway', 503 => 'Service Unavailable', 504 => 'Gateway Time-out', 505 => 'HTTP Version not supported', 506 => 'Variant Also Negotiates', 507 => 'Insufficient Storage', 508 => 'Loop Detected', 510 => 'Not Extended', 511 => 'Network Authentication Required'];
-    /** @var string */
-    private $reasonPhrase;
-    /** @var int */
-    private $statusCode;
-    /**
-     * @param int                                  $status  Status code
-     * @param (string|string[])[]                  $headers Response headers
-     * @param string|resource|StreamInterface|null $body    Response body
-     * @param string                               $version Protocol version
-     * @param string|null                          $reason  Reason phrase (when empty a default will be used based on the status code)
-     */
-    public function __construct(int $status = 200, array $headers = [], $body = null, string $version = '1.1', ?string $reason = null)
-    {
-        $this->assertStatusCodeRange($status);
-        $this->statusCode = $status;
-        if ($body !== '' && $body !== null) {
-            $this->stream = Utils::streamFor($body);
-        }
-        $this->setHeaders($headers);
-        if ($reason == '' && isset(self::PHRASES[$this->statusCode])) {
-            $this->reasonPhrase = self::PHRASES[$this->statusCode];
-        } else {
-            $this->reasonPhrase = (string) $reason;
-        }
-        $this->protocol = $version;
-    }
-    public function getStatusCode() : int
-    {
-        return $this->statusCode;
-    }
-    public function getReasonPhrase() : string
-    {
-        return $this->reasonPhrase;
-    }
-    public function withStatus($code, $reasonPhrase = '') : ResponseInterface
-    {
-        $this->assertStatusCodeIsInteger($code);
-        $code = (int) $code;
-        $this->assertStatusCodeRange($code);
-        $new = clone $this;
-        $new->statusCode = $code;
-        if ($reasonPhrase == '' && isset(self::PHRASES[$new->statusCode])) {
-            $reasonPhrase = self::PHRASES[$new->statusCode];
-        }
-        $new->reasonPhrase = (string) $reasonPhrase;
-        return $new;
-    }
-    /**
-     * @param mixed $statusCode
-     */
-    private function assertStatusCodeIsInteger($statusCode) : void
-    {
-        if (\filter_var($statusCode, \FILTER_VALIDATE_INT) === \false) {
-            throw new \InvalidArgumentException('Status code must be an integer value.');
-        }
-    }
-    private function assertStatusCodeRange(int $statusCode) : void
-    {
-        if ($statusCode < 100 || $statusCode >= 600) {
-            throw new \InvalidArgumentException('Status code must be an integer value between 1xx and 5xx.');
-        }
-    }
+	use MessageTrait;
+	/** Map of standard HTTP status code/reason phrases */
+	private const PHRASES = [100 => 'Continue', 101 => 'Switching Protocols', 102 => 'Processing', 200 => 'OK', 201 => 'Created', 202 => 'Accepted', 203 => 'Non-Authoritative Information', 204 => 'No Content', 205 => 'Reset Content', 206 => 'Partial Content', 207 => 'Multi-status', 208 => 'Already Reported', 300 => 'Multiple Choices', 301 => 'Moved Permanently', 302 => 'Found', 303 => 'See Other', 304 => 'Not Modified', 305 => 'Use Proxy', 306 => 'Switch Proxy', 307 => 'Temporary Redirect', 308 => 'Permanent Redirect', 400 => 'Bad Request', 401 => 'Unauthorized', 402 => 'Payment Required', 403 => 'Forbidden', 404 => 'Not Found', 405 => 'Method Not Allowed', 406 => 'Not Acceptable', 407 => 'Proxy Authentication Required', 408 => 'Request Time-out', 409 => 'Conflict', 410 => 'Gone', 411 => 'Length Required', 412 => 'Precondition Failed', 413 => 'Request Entity Too Large', 414 => 'Request-URI Too Large', 415 => 'Unsupported Media Type', 416 => 'Requested range not satisfiable', 417 => 'Expectation Failed', 418 => 'I\'m a teapot', 422 => 'Unprocessable Entity', 423 => 'Locked', 424 => 'Failed Dependency', 425 => 'Unordered Collection', 426 => 'Upgrade Required', 428 => 'Precondition Required', 429 => 'Too Many Requests', 431 => 'Request Header Fields Too Large', 451 => 'Unavailable For Legal Reasons', 500 => 'Internal Server Error', 501 => 'Not Implemented', 502 => 'Bad Gateway', 503 => 'Service Unavailable', 504 => 'Gateway Time-out', 505 => 'HTTP Version not supported', 506 => 'Variant Also Negotiates', 507 => 'Insufficient Storage', 508 => 'Loop Detected', 510 => 'Not Extended', 511 => 'Network Authentication Required'];
+	/** @var string */
+	private $reasonPhrase;
+	/** @var int */
+	private $statusCode;
+	/**
+	 * @param int                                  $status  Status code
+	 * @param (string|string[])[]                  $headers Response headers
+	 * @param string|resource|StreamInterface|null $body    Response body
+	 * @param string                               $version Protocol version
+	 * @param string|null                          $reason  Reason phrase (when empty a default will be used based on the status code)
+	 */
+	public function __construct(int $status = 200, array $headers = [], $body = null, string $version = '1.1', ?string $reason = null)
+	{
+		$this->assertStatusCodeRange($status);
+		$this->statusCode = $status;
+		if ($body !== '' && $body !== null) {
+			$this->stream = Utils::streamFor($body);
+		}
+		$this->setHeaders($headers);
+		if ($reason == '' && isset(self::PHRASES[$this->statusCode])) {
+			$this->reasonPhrase = self::PHRASES[$this->statusCode];
+		} else {
+			$this->reasonPhrase = (string) $reason;
+		}
+		$this->protocol = $version;
+	}
+	public function getStatusCode() : int
+	{
+		return $this->statusCode;
+	}
+	public function getReasonPhrase() : string
+	{
+		return $this->reasonPhrase;
+	}
+	public function withStatus($code, $reasonPhrase = '') : ResponseInterface
+	{
+		$this->assertStatusCodeIsInteger($code);
+		$code = (int) $code;
+		$this->assertStatusCodeRange($code);
+		$new = clone $this;
+		$new->statusCode = $code;
+		if ($reasonPhrase == '' && isset(self::PHRASES[$new->statusCode])) {
+			$reasonPhrase = self::PHRASES[$new->statusCode];
+		}
+		$new->reasonPhrase = (string) $reasonPhrase;
+		return $new;
+	}
+	/**
+	 * @param mixed $statusCode
+	 */
+	private function assertStatusCodeIsInteger($statusCode) : void
+	{
+		if (\filter_var($statusCode, \FILTER_VALIDATE_INT) === \false) {
+			throw new \InvalidArgumentException('Status code must be an integer value.');
+		}
+	}
+	private function assertStatusCodeRange(int $statusCode) : void
+	{
+		if ($statusCode < 100 || $statusCode >= 600) {
+			throw new \InvalidArgumentException('Status code must be an integer value between 1xx and 5xx.');
+		}
+	}
 }

lib/Vendor/GuzzleHttp/Psr7/StreamWrapper.php

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 */

Indentation +131 added lines, -131 removed lines

@@ -11,135 +11,135 @@
  */
 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
-     * }|false
-     */
-    public function stream_stat()
-    {
-        if ($this->stream->getSize() === null) {
-            return \false;
-        }
-        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
+	 * }|false
+	 */
+	public function stream_stat()
+	{
+		if ($this->stream->getSize() === null) {
+			return \false;
+		}
+		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];
+	}
 }