nextcloud / fulltextsearch_elasticsearch

lib/Vendor/GuzzleHttp/Psr7/AppendStream.php

Indentation +189 added lines, -189 removed lines

@@ -11,193 +11,193 @@
  */
 final class AppendStream implements StreamInterface
 {
-    /** @var StreamInterface[] Streams being decorated */
-    private $streams = [];
-    /** @var bool */
-    private $seekable = \true;
-    /** @var int */
-    private $current = 0;
-    /** @var int */
-    private $pos = 0;
-    /**
-     * @param StreamInterface[] $streams Streams to decorate. Each stream must
-     *                                   be readable.
-     */
-    public function __construct(array $streams = [])
-    {
-        foreach ($streams as $stream) {
-            $this->addStream($stream);
-        }
-    }
-    public function __toString() : string
-    {
-        try {
-            $this->rewind();
-            return $this->getContents();
-        } 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 '';
-        }
-    }
-    /**
-     * Add a stream to the AppendStream
-     *
-     * @param StreamInterface $stream Stream to append. Must be readable.
-     *
-     * @throws \InvalidArgumentException if the stream is not readable
-     */
-    public function addStream(StreamInterface $stream) : void
-    {
-        if (!$stream->isReadable()) {
-            throw new \InvalidArgumentException('Each stream must be readable');
-        }
-        // The stream is only seekable if all streams are seekable
-        if (!$stream->isSeekable()) {
-            $this->seekable = \false;
-        }
-        $this->streams[] = $stream;
-    }
-    public function getContents() : string
-    {
-        return Utils::copyToString($this);
-    }
-    /**
-     * Closes each attached stream.
-     */
-    public function close() : void
-    {
-        $this->pos = $this->current = 0;
-        $this->seekable = \true;
-        foreach ($this->streams as $stream) {
-            $stream->close();
-        }
-        $this->streams = [];
-    }
-    /**
-     * Detaches each attached stream.
-     *
-     * Returns null as it's not clear which underlying stream resource to return.
-     */
-    public function detach()
-    {
-        $this->pos = $this->current = 0;
-        $this->seekable = \true;
-        foreach ($this->streams as $stream) {
-            $stream->detach();
-        }
-        $this->streams = [];
-        return null;
-    }
-    public function tell() : int
-    {
-        return $this->pos;
-    }
-    /**
-     * Tries to calculate the size by adding the size of each stream.
-     *
-     * If any of the streams do not return a valid number, then the size of the
-     * append stream cannot be determined and null is returned.
-     */
-    public function getSize() : ?int
-    {
-        $size = 0;
-        foreach ($this->streams as $stream) {
-            $s = $stream->getSize();
-            if ($s === null) {
-                return null;
-            }
-            $size += $s;
-        }
-        return $size;
-    }
-    public function eof() : bool
-    {
-        return !$this->streams || $this->current >= \count($this->streams) - 1 && $this->streams[$this->current]->eof();
-    }
-    public function rewind() : void
-    {
-        $this->seek(0);
-    }
-    /**
-     * Attempts to seek to the given position. Only supports SEEK_SET.
-     */
-    public function seek($offset, $whence = \SEEK_SET) : void
-    {
-        if (!$this->seekable) {
-            throw new \RuntimeException('This AppendStream is not seekable');
-        } elseif ($whence !== \SEEK_SET) {
-            throw new \RuntimeException('The AppendStream can only seek with SEEK_SET');
-        }
-        $this->pos = $this->current = 0;
-        // Rewind each stream
-        foreach ($this->streams as $i => $stream) {
-            try {
-                $stream->rewind();
-            } catch (\Exception $e) {
-                throw new \RuntimeException('Unable to seek stream ' . $i . ' of the AppendStream', 0, $e);
-            }
-        }
-        // Seek to the actual position by reading from each stream
-        while ($this->pos < $offset && !$this->eof()) {
-            $result = $this->read(\min(8096, $offset - $this->pos));
-            if ($result === '') {
-                break;
-            }
-        }
-    }
-    /**
-     * Reads from all of the appended streams until the length is met or EOF.
-     */
-    public function read($length) : string
-    {
-        $buffer = '';
-        $total = \count($this->streams) - 1;
-        $remaining = $length;
-        $progressToNext = \false;
-        while ($remaining > 0) {
-            // Progress to the next stream if needed.
-            if ($progressToNext || $this->streams[$this->current]->eof()) {
-                $progressToNext = \false;
-                if ($this->current === $total) {
-                    break;
-                }
-                ++$this->current;
-            }
-            $result = $this->streams[$this->current]->read($remaining);
-            if ($result === '') {
-                $progressToNext = \true;
-                continue;
-            }
-            $buffer .= $result;
-            $remaining = $length - \strlen($buffer);
-        }
-        $this->pos += \strlen($buffer);
-        return $buffer;
-    }
-    public function isReadable() : bool
-    {
-        return \true;
-    }
-    public function isWritable() : bool
-    {
-        return \false;
-    }
-    public function isSeekable() : bool
-    {
-        return $this->seekable;
-    }
-    public function write($string) : int
-    {
-        throw new \RuntimeException('Cannot write to an AppendStream');
-    }
-    /**
-     * @return mixed
-     */
-    public function getMetadata($key = null)
-    {
-        return $key ? null : [];
-    }
+	/** @var StreamInterface[] Streams being decorated */
+	private $streams = [];
+	/** @var bool */
+	private $seekable = \true;
+	/** @var int */
+	private $current = 0;
+	/** @var int */
+	private $pos = 0;
+	/**
+	 * @param StreamInterface[] $streams Streams to decorate. Each stream must
+	 *                                   be readable.
+	 */
+	public function __construct(array $streams = [])
+	{
+		foreach ($streams as $stream) {
+			$this->addStream($stream);
+		}
+	}
+	public function __toString() : string
+	{
+		try {
+			$this->rewind();
+			return $this->getContents();
+		} 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 '';
+		}
+	}
+	/**
+	 * Add a stream to the AppendStream
+	 *
+	 * @param StreamInterface $stream Stream to append. Must be readable.
+	 *
+	 * @throws \InvalidArgumentException if the stream is not readable
+	 */
+	public function addStream(StreamInterface $stream) : void
+	{
+		if (!$stream->isReadable()) {
+			throw new \InvalidArgumentException('Each stream must be readable');
+		}
+		// The stream is only seekable if all streams are seekable
+		if (!$stream->isSeekable()) {
+			$this->seekable = \false;
+		}
+		$this->streams[] = $stream;
+	}
+	public function getContents() : string
+	{
+		return Utils::copyToString($this);
+	}
+	/**
+	 * Closes each attached stream.
+	 */
+	public function close() : void
+	{
+		$this->pos = $this->current = 0;
+		$this->seekable = \true;
+		foreach ($this->streams as $stream) {
+			$stream->close();
+		}
+		$this->streams = [];
+	}
+	/**
+	 * Detaches each attached stream.
+	 *
+	 * Returns null as it's not clear which underlying stream resource to return.
+	 */
+	public function detach()
+	{
+		$this->pos = $this->current = 0;
+		$this->seekable = \true;
+		foreach ($this->streams as $stream) {
+			$stream->detach();
+		}
+		$this->streams = [];
+		return null;
+	}
+	public function tell() : int
+	{
+		return $this->pos;
+	}
+	/**
+	 * Tries to calculate the size by adding the size of each stream.
+	 *
+	 * If any of the streams do not return a valid number, then the size of the
+	 * append stream cannot be determined and null is returned.
+	 */
+	public function getSize() : ?int
+	{
+		$size = 0;
+		foreach ($this->streams as $stream) {
+			$s = $stream->getSize();
+			if ($s === null) {
+				return null;
+			}
+			$size += $s;
+		}
+		return $size;
+	}
+	public function eof() : bool
+	{
+		return !$this->streams || $this->current >= \count($this->streams) - 1 && $this->streams[$this->current]->eof();
+	}
+	public function rewind() : void
+	{
+		$this->seek(0);
+	}
+	/**
+	 * Attempts to seek to the given position. Only supports SEEK_SET.
+	 */
+	public function seek($offset, $whence = \SEEK_SET) : void
+	{
+		if (!$this->seekable) {
+			throw new \RuntimeException('This AppendStream is not seekable');
+		} elseif ($whence !== \SEEK_SET) {
+			throw new \RuntimeException('The AppendStream can only seek with SEEK_SET');
+		}
+		$this->pos = $this->current = 0;
+		// Rewind each stream
+		foreach ($this->streams as $i => $stream) {
+			try {
+				$stream->rewind();
+			} catch (\Exception $e) {
+				throw new \RuntimeException('Unable to seek stream ' . $i . ' of the AppendStream', 0, $e);
+			}
+		}
+		// Seek to the actual position by reading from each stream
+		while ($this->pos < $offset && !$this->eof()) {
+			$result = $this->read(\min(8096, $offset - $this->pos));
+			if ($result === '') {
+				break;
+			}
+		}
+	}
+	/**
+	 * Reads from all of the appended streams until the length is met or EOF.
+	 */
+	public function read($length) : string
+	{
+		$buffer = '';
+		$total = \count($this->streams) - 1;
+		$remaining = $length;
+		$progressToNext = \false;
+		while ($remaining > 0) {
+			// Progress to the next stream if needed.
+			if ($progressToNext || $this->streams[$this->current]->eof()) {
+				$progressToNext = \false;
+				if ($this->current === $total) {
+					break;
+				}
+				++$this->current;
+			}
+			$result = $this->streams[$this->current]->read($remaining);
+			if ($result === '') {
+				$progressToNext = \true;
+				continue;
+			}
+			$buffer .= $result;
+			$remaining = $length - \strlen($buffer);
+		}
+		$this->pos += \strlen($buffer);
+		return $buffer;
+	}
+	public function isReadable() : bool
+	{
+		return \true;
+	}
+	public function isWritable() : bool
+	{
+		return \false;
+	}
+	public function isSeekable() : bool
+	{
+		return $this->seekable;
+	}
+	public function write($string) : int
+	{
+		throw new \RuntimeException('Cannot write to an AppendStream');
+	}
+	/**
+	 * @return mixed
+	 */
+	public function getMetadata($key = null)
+	{
+		return $key ? null : [];
+	}
 }

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;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;
@@ -38,7 +38,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 '';
         }
     }
@@ -137,7 +137,7 @@ 
             try {
                 $stream->rewind();
             } catch (\Exception $e) {
-                throw new \RuntimeException('Unable to seek stream ' . $i . ' of the AppendStream', 0, $e);
+                throw new \RuntimeException('Unable to seek stream '.$i.' of the AppendStream', 0, $e);
             }
         }
         // Seek to the actual position by reading from each stream

Braces +1 added lines, -2 removed lines

@@ -9,8 +9,7 @@
  *
  * This is a read-only stream decorator.
  */
-final class AppendStream implements StreamInterface
-{
+final class AppendStream implements StreamInterface {
     /** @var StreamInterface[] Streams being decorated */
     private $streams = [];
     /** @var bool */

lib/Vendor/GuzzleHttp/Psr7/Request.php

Indentation +109 added lines, -109 removed lines

@@ -12,113 +12,113 @@
  */
 class Request implements RequestInterface
 {
-    use MessageTrait;
-    /** @var string */
-    private $method;
-    /** @var string|null */
-    private $requestTarget;
-    /** @var UriInterface */
-    private $uri;
-    /**
-     * @param string                               $method  HTTP method
-     * @param string|UriInterface                  $uri     URI
-     * @param (string|string[])[]                  $headers Request headers
-     * @param string|resource|StreamInterface|null $body    Request body
-     * @param string                               $version Protocol version
-     */
-    public function __construct(string $method, $uri, array $headers = [], $body = null, string $version = '1.1')
-    {
-        $this->assertMethod($method);
-        if (!$uri instanceof UriInterface) {
-            $uri = new Uri($uri);
-        }
-        $this->method = \strtoupper($method);
-        $this->uri = $uri;
-        $this->setHeaders($headers);
-        $this->protocol = $version;
-        if (!isset($this->headerNames['host'])) {
-            $this->updateHostFromUri();
-        }
-        if ($body !== '' && $body !== null) {
-            $this->stream = Utils::streamFor($body);
-        }
-    }
-    public function getRequestTarget() : string
-    {
-        if ($this->requestTarget !== null) {
-            return $this->requestTarget;
-        }
-        $target = $this->uri->getPath();
-        if ($target === '') {
-            $target = '/';
-        }
-        if ($this->uri->getQuery() != '') {
-            $target .= '?' . $this->uri->getQuery();
-        }
-        return $target;
-    }
-    public function withRequestTarget($requestTarget) : RequestInterface
-    {
-        if (\preg_match('#\\s#', $requestTarget)) {
-            throw new InvalidArgumentException('Invalid request target provided; cannot contain whitespace');
-        }
-        $new = clone $this;
-        $new->requestTarget = $requestTarget;
-        return $new;
-    }
-    public function getMethod() : string
-    {
-        return $this->method;
-    }
-    public function withMethod($method) : RequestInterface
-    {
-        $this->assertMethod($method);
-        $new = clone $this;
-        $new->method = \strtoupper($method);
-        return $new;
-    }
-    public function getUri() : UriInterface
-    {
-        return $this->uri;
-    }
-    public function withUri(UriInterface $uri, $preserveHost = \false) : RequestInterface
-    {
-        if ($uri === $this->uri) {
-            return $this;
-        }
-        $new = clone $this;
-        $new->uri = $uri;
-        if (!$preserveHost || !isset($this->headerNames['host'])) {
-            $new->updateHostFromUri();
-        }
-        return $new;
-    }
-    private function updateHostFromUri() : void
-    {
-        $host = $this->uri->getHost();
-        if ($host == '') {
-            return;
-        }
-        if (($port = $this->uri->getPort()) !== null) {
-            $host .= ':' . $port;
-        }
-        if (isset($this->headerNames['host'])) {
-            $header = $this->headerNames['host'];
-        } else {
-            $header = 'Host';
-            $this->headerNames['host'] = 'Host';
-        }
-        // Ensure Host is the first header.
-        // See: https://datatracker.ietf.org/doc/html/rfc7230#section-5.4
-        $this->headers = [$header => [$host]] + $this->headers;
-    }
-    /**
-     * @param mixed $method
-     */
-    private function assertMethod($method) : void
-    {
-        if (!\is_string($method) || $method === '') {
-            throw new InvalidArgumentException('Method must be a non-empty string.');
-        }
-    }
+	use MessageTrait;
+	/** @var string */
+	private $method;
+	/** @var string|null */
+	private $requestTarget;
+	/** @var UriInterface */
+	private $uri;
+	/**
+	 * @param string                               $method  HTTP method
+	 * @param string|UriInterface                  $uri     URI
+	 * @param (string|string[])[]                  $headers Request headers
+	 * @param string|resource|StreamInterface|null $body    Request body
+	 * @param string                               $version Protocol version
+	 */
+	public function __construct(string $method, $uri, array $headers = [], $body = null, string $version = '1.1')
+	{
+		$this->assertMethod($method);
+		if (!$uri instanceof UriInterface) {
+			$uri = new Uri($uri);
+		}
+		$this->method = \strtoupper($method);
+		$this->uri = $uri;
+		$this->setHeaders($headers);
+		$this->protocol = $version;
+		if (!isset($this->headerNames['host'])) {
+			$this->updateHostFromUri();
+		}
+		if ($body !== '' && $body !== null) {
+			$this->stream = Utils::streamFor($body);
+		}
+	}
+	public function getRequestTarget() : string
+	{
+		if ($this->requestTarget !== null) {
+			return $this->requestTarget;
+		}
+		$target = $this->uri->getPath();
+		if ($target === '') {
+			$target = '/';
+		}
+		if ($this->uri->getQuery() != '') {
+			$target .= '?' . $this->uri->getQuery();
+		}
+		return $target;
+	}
+	public function withRequestTarget($requestTarget) : RequestInterface
+	{
+		if (\preg_match('#\\s#', $requestTarget)) {
+			throw new InvalidArgumentException('Invalid request target provided; cannot contain whitespace');
+		}
+		$new = clone $this;
+		$new->requestTarget = $requestTarget;
+		return $new;
+	}
+	public function getMethod() : string
+	{
+		return $this->method;
+	}
+	public function withMethod($method) : RequestInterface
+	{
+		$this->assertMethod($method);
+		$new = clone $this;
+		$new->method = \strtoupper($method);
+		return $new;
+	}
+	public function getUri() : UriInterface
+	{
+		return $this->uri;
+	}
+	public function withUri(UriInterface $uri, $preserveHost = \false) : RequestInterface
+	{
+		if ($uri === $this->uri) {
+			return $this;
+		}
+		$new = clone $this;
+		$new->uri = $uri;
+		if (!$preserveHost || !isset($this->headerNames['host'])) {
+			$new->updateHostFromUri();
+		}
+		return $new;
+	}
+	private function updateHostFromUri() : void
+	{
+		$host = $this->uri->getHost();
+		if ($host == '') {
+			return;
+		}
+		if (($port = $this->uri->getPort()) !== null) {
+			$host .= ':' . $port;
+		}
+		if (isset($this->headerNames['host'])) {
+			$header = $this->headerNames['host'];
+		} else {
+			$header = 'Host';
+			$this->headerNames['host'] = 'Host';
+		}
+		// Ensure Host is the first header.
+		// See: https://datatracker.ietf.org/doc/html/rfc7230#section-5.4
+		$this->headers = [$header => [$host]] + $this->headers;
+	}
+	/**
+	 * @param mixed $method
+	 */
+	private function assertMethod($method) : void
+	{
+		if (!\is_string($method) || $method === '') {
+			throw new InvalidArgumentException('Method must be a non-empty string.');
+		}
+	}
 }

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;
 
 use InvalidArgumentException;
@@ -53,7 +53,7 @@ 
             $target = '/';
         }
         if ($this->uri->getQuery() != '') {
-            $target .= '?' . $this->uri->getQuery();
+            $target .= '?'.$this->uri->getQuery();
         }
         return $target;
     }
@@ -100,7 +100,7 @@ 
             return;
         }
         if (($port = $this->uri->getPort()) !== null) {
-            $host .= ':' . $port;
+            $host .= ':'.$port;
         }
         if (isset($this->headerNames['host'])) {
             $header = $this->headerNames['host'];

Braces +1 added lines, -2 removed lines

@@ -10,8 +10,7 @@
 /**
  * PSR-7 request implementation.
  */
-class Request implements RequestInterface
-{
+class Request implements RequestInterface {
     use MessageTrait;
     /** @var string */
     private $method;

lib/Vendor/GuzzleHttp/Psr7/Query.php

Indentation +96 added lines, -96 removed lines

@@ -5,100 +5,100 @@
 
 final class Query
 {
-    /**
-     * Parse a query string into an associative array.
-     *
-     * If multiple values are found for the same key, the value of that key
-     * value pair will become an array. This function does not parse nested
-     * PHP style arrays into an associative array (e.g., `foo[a]=1&foo[b]=2`
-     * will be parsed into `['foo[a]' => '1', 'foo[b]' => '2'])`.
-     *
-     * @param string   $str         Query string to parse
-     * @param int|bool $urlEncoding How the query string is encoded
-     */
-    public static function parse(string $str, $urlEncoding = \true) : array
-    {
-        $result = [];
-        if ($str === '') {
-            return $result;
-        }
-        if ($urlEncoding === \true) {
-            $decoder = function ($value) {
-                return \rawurldecode(\str_replace('+', ' ', (string) $value));
-            };
-        } elseif ($urlEncoding === \PHP_QUERY_RFC3986) {
-            $decoder = 'rawurldecode';
-        } elseif ($urlEncoding === \PHP_QUERY_RFC1738) {
-            $decoder = 'urldecode';
-        } else {
-            $decoder = function ($str) {
-                return $str;
-            };
-        }
-        foreach (\explode('&', $str) as $kvp) {
-            $parts = \explode('=', $kvp, 2);
-            $key = $decoder($parts[0]);
-            $value = isset($parts[1]) ? $decoder($parts[1]) : null;
-            if (!\array_key_exists($key, $result)) {
-                $result[$key] = $value;
-            } else {
-                if (!\is_array($result[$key])) {
-                    $result[$key] = [$result[$key]];
-                }
-                $result[$key][] = $value;
-            }
-        }
-        return $result;
-    }
-    /**
-     * Build a query string from an array of key value pairs.
-     *
-     * This function can use the return value of `parse()` to build a query
-     * string. This function does not modify the provided keys when an array is
-     * encountered (like `http_build_query()` would).
-     *
-     * @param array     $params   Query string parameters.
-     * @param int|false $encoding Set to false to not encode, PHP_QUERY_RFC3986
-     *                            to encode using RFC3986, or PHP_QUERY_RFC1738
-     *                            to encode using RFC1738.
-     */
-    public static function build(array $params, $encoding = \PHP_QUERY_RFC3986) : string
-    {
-        if (!$params) {
-            return '';
-        }
-        if ($encoding === \false) {
-            $encoder = function (string $str) : string {
-                return $str;
-            };
-        } elseif ($encoding === \PHP_QUERY_RFC3986) {
-            $encoder = 'rawurlencode';
-        } elseif ($encoding === \PHP_QUERY_RFC1738) {
-            $encoder = 'urlencode';
-        } else {
-            throw new \InvalidArgumentException('Invalid type');
-        }
-        $qs = '';
-        foreach ($params as $k => $v) {
-            $k = $encoder((string) $k);
-            if (!\is_array($v)) {
-                $qs .= $k;
-                $v = \is_bool($v) ? (int) $v : $v;
-                if ($v !== null) {
-                    $qs .= '=' . $encoder((string) $v);
-                }
-                $qs .= '&';
-            } else {
-                foreach ($v as $vv) {
-                    $qs .= $k;
-                    $vv = \is_bool($vv) ? (int) $vv : $vv;
-                    if ($vv !== null) {
-                        $qs .= '=' . $encoder((string) $vv);
-                    }
-                    $qs .= '&';
-                }
-            }
-        }
-        return $qs ? (string) \substr($qs, 0, -1) : '';
-    }
+	/**
+	 * Parse a query string into an associative array.
+	 *
+	 * If multiple values are found for the same key, the value of that key
+	 * value pair will become an array. This function does not parse nested
+	 * PHP style arrays into an associative array (e.g., `foo[a]=1&foo[b]=2`
+	 * will be parsed into `['foo[a]' => '1', 'foo[b]' => '2'])`.
+	 *
+	 * @param string   $str         Query string to parse
+	 * @param int|bool $urlEncoding How the query string is encoded
+	 */
+	public static function parse(string $str, $urlEncoding = \true) : array
+	{
+		$result = [];
+		if ($str === '') {
+			return $result;
+		}
+		if ($urlEncoding === \true) {
+			$decoder = function ($value) {
+				return \rawurldecode(\str_replace('+', ' ', (string) $value));
+			};
+		} elseif ($urlEncoding === \PHP_QUERY_RFC3986) {
+			$decoder = 'rawurldecode';
+		} elseif ($urlEncoding === \PHP_QUERY_RFC1738) {
+			$decoder = 'urldecode';
+		} else {
+			$decoder = function ($str) {
+				return $str;
+			};
+		}
+		foreach (\explode('&', $str) as $kvp) {
+			$parts = \explode('=', $kvp, 2);
+			$key = $decoder($parts[0]);
+			$value = isset($parts[1]) ? $decoder($parts[1]) : null;
+			if (!\array_key_exists($key, $result)) {
+				$result[$key] = $value;
+			} else {
+				if (!\is_array($result[$key])) {
+					$result[$key] = [$result[$key]];
+				}
+				$result[$key][] = $value;
+			}
+		}
+		return $result;
+	}
+	/**
+	 * Build a query string from an array of key value pairs.
+	 *
+	 * This function can use the return value of `parse()` to build a query
+	 * string. This function does not modify the provided keys when an array is
+	 * encountered (like `http_build_query()` would).
+	 *
+	 * @param array     $params   Query string parameters.
+	 * @param int|false $encoding Set to false to not encode, PHP_QUERY_RFC3986
+	 *                            to encode using RFC3986, or PHP_QUERY_RFC1738
+	 *                            to encode using RFC1738.
+	 */
+	public static function build(array $params, $encoding = \PHP_QUERY_RFC3986) : string
+	{
+		if (!$params) {
+			return '';
+		}
+		if ($encoding === \false) {
+			$encoder = function (string $str) : string {
+				return $str;
+			};
+		} elseif ($encoding === \PHP_QUERY_RFC3986) {
+			$encoder = 'rawurlencode';
+		} elseif ($encoding === \PHP_QUERY_RFC1738) {
+			$encoder = 'urlencode';
+		} else {
+			throw new \InvalidArgumentException('Invalid type');
+		}
+		$qs = '';
+		foreach ($params as $k => $v) {
+			$k = $encoder((string) $k);
+			if (!\is_array($v)) {
+				$qs .= $k;
+				$v = \is_bool($v) ? (int) $v : $v;
+				if ($v !== null) {
+					$qs .= '=' . $encoder((string) $v);
+				}
+				$qs .= '&';
+			} else {
+				foreach ($v as $vv) {
+					$qs .= $k;
+					$vv = \is_bool($vv) ? (int) $vv : $vv;
+					if ($vv !== null) {
+						$qs .= '=' . $encoder((string) $vv);
+					}
+					$qs .= '&';
+				}
+			}
+		}
+		return $qs ? (string) \substr($qs, 0, -1) : '';
+	}
 }

Spacing +11 added lines, -11 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 final class Query
@@ -23,15 +23,15 @@ 
             return $result;
         }
         if ($urlEncoding === \true) {
-            $decoder = function ($value) {
-                return \rawurldecode(\str_replace('+', ' ', (string) $value));
+            $decoder = function($value) {
+                return \rawurldecode(\str_replace('+', ' ', (string)$value));
             };
         } elseif ($urlEncoding === \PHP_QUERY_RFC3986) {
             $decoder = 'rawurldecode';
         } elseif ($urlEncoding === \PHP_QUERY_RFC1738) {
             $decoder = 'urldecode';
         } else {
-            $decoder = function ($str) {
+            $decoder = function($str) {
                 return $str;
             };
         }
@@ -68,7 +68,7 @@ 
             return '';
         }
         if ($encoding === \false) {
-            $encoder = function (string $str) : string {
+            $encoder = function(string $str) : string {
                 return $str;
             };
         } elseif ($encoding === \PHP_QUERY_RFC3986) {
@@ -80,25 +80,25 @@ 
         }
         $qs = '';
         foreach ($params as $k => $v) {
-            $k = $encoder((string) $k);
+            $k = $encoder((string)$k);
             if (!\is_array($v)) {
                 $qs .= $k;
-                $v = \is_bool($v) ? (int) $v : $v;
+                $v = \is_bool($v) ? (int)$v : $v;
                 if ($v !== null) {
-                    $qs .= '=' . $encoder((string) $v);
+                    $qs .= '='.$encoder((string)$v);
                 }
                 $qs .= '&';
             } else {
                 foreach ($v as $vv) {
                     $qs .= $k;
-                    $vv = \is_bool($vv) ? (int) $vv : $vv;
+                    $vv = \is_bool($vv) ? (int)$vv : $vv;
                     if ($vv !== null) {
-                        $qs .= '=' . $encoder((string) $vv);
+                        $qs .= '='.$encoder((string)$vv);
                     }
                     $qs .= '&';
                 }
             }
         }
-        return $qs ? (string) \substr($qs, 0, -1) : '';
+        return $qs ? (string)\substr($qs, 0, -1) : '';
     }
 }

Braces +1 added lines, -2 removed lines

@@ -3,8 +3,7 @@
 declare (strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
-final class Query
-{
+final class Query {
     /**
      * Parse a query string into an associative array.
      *

lib/Vendor/GuzzleHttp/Psr7/LazyOpenStream.php

Indentation +28 added lines, -28 removed lines

@@ -10,32 +10,32 @@
  */
 final class LazyOpenStream implements StreamInterface
 {
-    use StreamDecoratorTrait;
-    /** @var string */
-    private $filename;
-    /** @var string */
-    private $mode;
-    /**
-     * @var StreamInterface
-     */
-    private $stream;
-    /**
-     * @param string $filename File to lazily open
-     * @param string $mode     fopen mode to use when opening the stream
-     */
-    public function __construct(string $filename, string $mode)
-    {
-        $this->filename = $filename;
-        $this->mode = $mode;
-        // unsetting the property forces the first access to go through
-        // __get().
-        unset($this->stream);
-    }
-    /**
-     * Creates the underlying stream lazily when required.
-     */
-    protected function createStream() : StreamInterface
-    {
-        return Utils::streamFor(Utils::tryFopen($this->filename, $this->mode));
-    }
+	use StreamDecoratorTrait;
+	/** @var string */
+	private $filename;
+	/** @var string */
+	private $mode;
+	/**
+	 * @var StreamInterface
+	 */
+	private $stream;
+	/**
+	 * @param string $filename File to lazily open
+	 * @param string $mode     fopen mode to use when opening the stream
+	 */
+	public function __construct(string $filename, string $mode)
+	{
+		$this->filename = $filename;
+		$this->mode = $mode;
+		// unsetting the property forces the first access to go through
+		// __get().
+		unset($this->stream);
+	}
+	/**
+	 * Creates the underlying stream lazily when required.
+	 */
+	protected function createStream() : StreamInterface
+	{
+		return Utils::streamFor(Utils::tryFopen($this->filename, $this->mode));
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -8,8 +8,7 @@
  * Lazily reads or writes to a file that is opened only after an IO operation
  * take place on the stream.
  */
-final class LazyOpenStream implements StreamInterface
-{
+final class LazyOpenStream implements StreamInterface {
     use StreamDecoratorTrait;
     /** @var string */
     private $filename;

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/DroppingStream.php

Indentation +27 added lines, -27 removed lines

@@ -10,31 +10,31 @@
  */
 final class DroppingStream implements StreamInterface
 {
-    use StreamDecoratorTrait;
-    /** @var int */
-    private $maxLength;
-    /** @var StreamInterface */
-    private $stream;
-    /**
-     * @param StreamInterface $stream    Underlying stream to decorate.
-     * @param int             $maxLength Maximum size before dropping data.
-     */
-    public function __construct(StreamInterface $stream, int $maxLength)
-    {
-        $this->stream = $stream;
-        $this->maxLength = $maxLength;
-    }
-    public function write($string) : int
-    {
-        $diff = $this->maxLength - $this->stream->getSize();
-        // Begin returning 0 when the underlying stream is too large.
-        if ($diff <= 0) {
-            return 0;
-        }
-        // Write the stream or a subset of the stream if needed.
-        if (\strlen($string) < $diff) {
-            return $this->stream->write($string);
-        }
-        return $this->stream->write(\substr($string, 0, $diff));
-    }
+	use StreamDecoratorTrait;
+	/** @var int */
+	private $maxLength;
+	/** @var StreamInterface */
+	private $stream;
+	/**
+	 * @param StreamInterface $stream    Underlying stream to decorate.
+	 * @param int             $maxLength Maximum size before dropping data.
+	 */
+	public function __construct(StreamInterface $stream, int $maxLength)
+	{
+		$this->stream = $stream;
+		$this->maxLength = $maxLength;
+	}
+	public function write($string) : int
+	{
+		$diff = $this->maxLength - $this->stream->getSize();
+		// Begin returning 0 when the underlying stream is too large.
+		if ($diff <= 0) {
+			return 0;
+		}
+		// Write the stream or a subset of the stream if needed.
+		if (\strlen($string) < $diff) {
+			return $this->stream->write($string);
+		}
+		return $this->stream->write(\substr($string, 0, $diff));
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -8,8 +8,7 @@
  * Stream decorator that begins dropping data once the size of the underlying
  * stream becomes too full.
  */
-final class DroppingStream implements StreamInterface
-{
+final class DroppingStream implements StreamInterface {
     use StreamDecoratorTrait;
     /** @var int */
     private $maxLength;

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/Utils.php

Indentation +360 added lines, -360 removed lines

@@ -9,367 +9,367 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\UriInterface;
 final class Utils
 {
-    /**
-     * Remove the items given by the keys, case insensitively from the data.
-     *
-     * @param (string|int)[] $keys
-     */
-    public static function caselessRemove(array $keys, array $data) : array
-    {
-        $result = [];
-        foreach ($keys as &$key) {
-            $key = \strtolower((string) $key);
-        }
-        foreach ($data as $k => $v) {
-            if (!\in_array(\strtolower((string) $k), $keys)) {
-                $result[$k] = $v;
-            }
-        }
-        return $result;
-    }
-    /**
-     * Copy the contents of a stream into another stream until the given number
-     * of bytes have been read.
-     *
-     * @param StreamInterface $source Stream to read from
-     * @param StreamInterface $dest   Stream to write to
-     * @param int             $maxLen Maximum number of bytes to read. Pass -1
-     *                                to read the entire stream.
-     *
-     * @throws \RuntimeException on error.
-     */
-    public static function copyToStream(StreamInterface $source, StreamInterface $dest, int $maxLen = -1) : void
-    {
-        $bufferSize = 8192;
-        if ($maxLen === -1) {
-            while (!$source->eof()) {
-                if (!$dest->write($source->read($bufferSize))) {
-                    break;
-                }
-            }
-        } else {
-            $remaining = $maxLen;
-            while ($remaining > 0 && !$source->eof()) {
-                $buf = $source->read(\min($bufferSize, $remaining));
-                $len = \strlen($buf);
-                if (!$len) {
-                    break;
-                }
-                $remaining -= $len;
-                $dest->write($buf);
-            }
-        }
-    }
-    /**
-     * Copy the contents of a stream into a string until the given number of
-     * bytes have been read.
-     *
-     * @param StreamInterface $stream Stream to read
-     * @param int             $maxLen Maximum number of bytes to read. Pass -1
-     *                                to read the entire stream.
-     *
-     * @throws \RuntimeException on error.
-     */
-    public static function copyToString(StreamInterface $stream, int $maxLen = -1) : string
-    {
-        $buffer = '';
-        if ($maxLen === -1) {
-            while (!$stream->eof()) {
-                $buf = $stream->read(1048576);
-                if ($buf === '') {
-                    break;
-                }
-                $buffer .= $buf;
-            }
-            return $buffer;
-        }
-        $len = 0;
-        while (!$stream->eof() && $len < $maxLen) {
-            $buf = $stream->read($maxLen - $len);
-            if ($buf === '') {
-                break;
-            }
-            $buffer .= $buf;
-            $len = \strlen($buffer);
-        }
-        return $buffer;
-    }
-    /**
-     * Calculate a hash of a stream.
-     *
-     * This method reads the entire stream to calculate a rolling hash, based
-     * on PHP's `hash_init` functions.
-     *
-     * @param StreamInterface $stream    Stream to calculate the hash for
-     * @param string          $algo      Hash algorithm (e.g. md5, crc32, etc)
-     * @param bool            $rawOutput Whether or not to use raw output
-     *
-     * @throws \RuntimeException on error.
-     */
-    public static function hash(StreamInterface $stream, string $algo, bool $rawOutput = \false) : string
-    {
-        $pos = $stream->tell();
-        if ($pos > 0) {
-            $stream->rewind();
-        }
-        $ctx = \hash_init($algo);
-        while (!$stream->eof()) {
-            \hash_update($ctx, $stream->read(1048576));
-        }
-        $out = \hash_final($ctx, $rawOutput);
-        $stream->seek($pos);
-        return $out;
-    }
-    /**
-     * Clone and modify a request with the given changes.
-     *
-     * This method is useful for reducing the number of clones needed to mutate
-     * a message.
-     *
-     * The changes can be one of:
-     * - method: (string) Changes the HTTP method.
-     * - set_headers: (array) Sets the given headers.
-     * - remove_headers: (array) Remove the given headers.
-     * - body: (mixed) Sets the given body.
-     * - uri: (UriInterface) Set the URI.
-     * - query: (string) Set the query string value of the URI.
-     * - version: (string) Set the protocol version.
-     *
-     * @param RequestInterface $request Request to clone and modify.
-     * @param array            $changes Changes to apply.
-     */
-    public static function modifyRequest(RequestInterface $request, array $changes) : RequestInterface
-    {
-        if (!$changes) {
-            return $request;
-        }
-        $headers = $request->getHeaders();
-        if (!isset($changes['uri'])) {
-            $uri = $request->getUri();
-        } else {
-            // Remove the host header if one is on the URI
-            if ($host = $changes['uri']->getHost()) {
-                $changes['set_headers']['Host'] = $host;
-                if ($port = $changes['uri']->getPort()) {
-                    $standardPorts = ['http' => 80, 'https' => 443];
-                    $scheme = $changes['uri']->getScheme();
-                    if (isset($standardPorts[$scheme]) && $port != $standardPorts[$scheme]) {
-                        $changes['set_headers']['Host'] .= ':' . $port;
-                    }
-                }
-            }
-            $uri = $changes['uri'];
-        }
-        if (!empty($changes['remove_headers'])) {
-            $headers = self::caselessRemove($changes['remove_headers'], $headers);
-        }
-        if (!empty($changes['set_headers'])) {
-            $headers = self::caselessRemove(\array_keys($changes['set_headers']), $headers);
-            $headers = $changes['set_headers'] + $headers;
-        }
-        if (isset($changes['query'])) {
-            $uri = $uri->withQuery($changes['query']);
-        }
-        if ($request instanceof ServerRequestInterface) {
-            $new = (new ServerRequest($changes['method'] ?? $request->getMethod(), $uri, $headers, $changes['body'] ?? $request->getBody(), $changes['version'] ?? $request->getProtocolVersion(), $request->getServerParams()))->withParsedBody($request->getParsedBody())->withQueryParams($request->getQueryParams())->withCookieParams($request->getCookieParams())->withUploadedFiles($request->getUploadedFiles());
-            foreach ($request->getAttributes() as $key => $value) {
-                $new = $new->withAttribute($key, $value);
-            }
-            return $new;
-        }
-        return new Request($changes['method'] ?? $request->getMethod(), $uri, $headers, $changes['body'] ?? $request->getBody(), $changes['version'] ?? $request->getProtocolVersion());
-    }
-    /**
-     * Read a line from the stream up to the maximum allowed buffer length.
-     *
-     * @param StreamInterface $stream    Stream to read from
-     * @param int|null        $maxLength Maximum buffer length
-     */
-    public static function readLine(StreamInterface $stream, int $maxLength = null) : string
-    {
-        $buffer = '';
-        $size = 0;
-        while (!$stream->eof()) {
-            if ('' === ($byte = $stream->read(1))) {
-                return $buffer;
-            }
-            $buffer .= $byte;
-            // Break when a new line is found or the max length - 1 is reached
-            if ($byte === "\n" || ++$size === $maxLength - 1) {
-                break;
-            }
-        }
-        return $buffer;
-    }
-    /**
-     * Create a new stream based on the input type.
-     *
-     * Options is an associative array that can contain the following keys:
-     * - metadata: Array of custom metadata.
-     * - size: Size of the stream.
-     *
-     * This method accepts the following `$resource` types:
-     * - `Psr\Http\Message\StreamInterface`: Returns the value as-is.
-     * - `string`: Creates a stream object that uses the given string as the contents.
-     * - `resource`: Creates a stream object that wraps the given PHP stream resource.
-     * - `Iterator`: If the provided value implements `Iterator`, then a read-only
-     *   stream object will be created that wraps the given iterable. Each time the
-     *   stream is read from, data from the iterator will fill a buffer and will be
-     *   continuously called until the buffer is equal to the requested read size.
-     *   Subsequent read calls will first read from the buffer and then call `next`
-     *   on the underlying iterator until it is exhausted.
-     * - `object` with `__toString()`: If the object has the `__toString()` method,
-     *   the object will be cast to a string and then a stream will be returned that
-     *   uses the string value.
-     * - `NULL`: When `null` is passed, an empty stream object is returned.
-     * - `callable` When a callable is passed, a read-only stream object will be
-     *   created that invokes the given callable. The callable is invoked with the
-     *   number of suggested bytes to read. The callable can return any number of
-     *   bytes, but MUST return `false` when there is no more data to return. The
-     *   stream object that wraps the callable will invoke the callable until the
-     *   number of requested bytes are available. Any additional bytes will be
-     *   buffered and used in subsequent reads.
-     *
-     * @param resource|string|int|float|bool|StreamInterface|callable|\Iterator|null $resource Entity body data
-     * @param array{size?: int, metadata?: array}                                    $options  Additional options
-     *
-     * @throws \InvalidArgumentException if the $resource arg is not valid.
-     */
-    public static function streamFor($resource = '', array $options = []) : StreamInterface
-    {
-        if (\is_scalar($resource)) {
-            $stream = self::tryFopen('php://temp', 'r+');
-            if ($resource !== '') {
-                \fwrite($stream, (string) $resource);
-                \fseek($stream, 0);
-            }
-            return new Stream($stream, $options);
-        }
-        switch (\gettype($resource)) {
-            case 'resource':
-                /*
+	/**
+	 * Remove the items given by the keys, case insensitively from the data.
+	 *
+	 * @param (string|int)[] $keys
+	 */
+	public static function caselessRemove(array $keys, array $data) : array
+	{
+		$result = [];
+		foreach ($keys as &$key) {
+			$key = \strtolower((string) $key);
+		}
+		foreach ($data as $k => $v) {
+			if (!\in_array(\strtolower((string) $k), $keys)) {
+				$result[$k] = $v;
+			}
+		}
+		return $result;
+	}
+	/**
+	 * Copy the contents of a stream into another stream until the given number
+	 * of bytes have been read.
+	 *
+	 * @param StreamInterface $source Stream to read from
+	 * @param StreamInterface $dest   Stream to write to
+	 * @param int             $maxLen Maximum number of bytes to read. Pass -1
+	 *                                to read the entire stream.
+	 *
+	 * @throws \RuntimeException on error.
+	 */
+	public static function copyToStream(StreamInterface $source, StreamInterface $dest, int $maxLen = -1) : void
+	{
+		$bufferSize = 8192;
+		if ($maxLen === -1) {
+			while (!$source->eof()) {
+				if (!$dest->write($source->read($bufferSize))) {
+					break;
+				}
+			}
+		} else {
+			$remaining = $maxLen;
+			while ($remaining > 0 && !$source->eof()) {
+				$buf = $source->read(\min($bufferSize, $remaining));
+				$len = \strlen($buf);
+				if (!$len) {
+					break;
+				}
+				$remaining -= $len;
+				$dest->write($buf);
+			}
+		}
+	}
+	/**
+	 * Copy the contents of a stream into a string until the given number of
+	 * bytes have been read.
+	 *
+	 * @param StreamInterface $stream Stream to read
+	 * @param int             $maxLen Maximum number of bytes to read. Pass -1
+	 *                                to read the entire stream.
+	 *
+	 * @throws \RuntimeException on error.
+	 */
+	public static function copyToString(StreamInterface $stream, int $maxLen = -1) : string
+	{
+		$buffer = '';
+		if ($maxLen === -1) {
+			while (!$stream->eof()) {
+				$buf = $stream->read(1048576);
+				if ($buf === '') {
+					break;
+				}
+				$buffer .= $buf;
+			}
+			return $buffer;
+		}
+		$len = 0;
+		while (!$stream->eof() && $len < $maxLen) {
+			$buf = $stream->read($maxLen - $len);
+			if ($buf === '') {
+				break;
+			}
+			$buffer .= $buf;
+			$len = \strlen($buffer);
+		}
+		return $buffer;
+	}
+	/**
+	 * Calculate a hash of a stream.
+	 *
+	 * This method reads the entire stream to calculate a rolling hash, based
+	 * on PHP's `hash_init` functions.
+	 *
+	 * @param StreamInterface $stream    Stream to calculate the hash for
+	 * @param string          $algo      Hash algorithm (e.g. md5, crc32, etc)
+	 * @param bool            $rawOutput Whether or not to use raw output
+	 *
+	 * @throws \RuntimeException on error.
+	 */
+	public static function hash(StreamInterface $stream, string $algo, bool $rawOutput = \false) : string
+	{
+		$pos = $stream->tell();
+		if ($pos > 0) {
+			$stream->rewind();
+		}
+		$ctx = \hash_init($algo);
+		while (!$stream->eof()) {
+			\hash_update($ctx, $stream->read(1048576));
+		}
+		$out = \hash_final($ctx, $rawOutput);
+		$stream->seek($pos);
+		return $out;
+	}
+	/**
+	 * Clone and modify a request with the given changes.
+	 *
+	 * This method is useful for reducing the number of clones needed to mutate
+	 * a message.
+	 *
+	 * The changes can be one of:
+	 * - method: (string) Changes the HTTP method.
+	 * - set_headers: (array) Sets the given headers.
+	 * - remove_headers: (array) Remove the given headers.
+	 * - body: (mixed) Sets the given body.
+	 * - uri: (UriInterface) Set the URI.
+	 * - query: (string) Set the query string value of the URI.
+	 * - version: (string) Set the protocol version.
+	 *
+	 * @param RequestInterface $request Request to clone and modify.
+	 * @param array            $changes Changes to apply.
+	 */
+	public static function modifyRequest(RequestInterface $request, array $changes) : RequestInterface
+	{
+		if (!$changes) {
+			return $request;
+		}
+		$headers = $request->getHeaders();
+		if (!isset($changes['uri'])) {
+			$uri = $request->getUri();
+		} else {
+			// Remove the host header if one is on the URI
+			if ($host = $changes['uri']->getHost()) {
+				$changes['set_headers']['Host'] = $host;
+				if ($port = $changes['uri']->getPort()) {
+					$standardPorts = ['http' => 80, 'https' => 443];
+					$scheme = $changes['uri']->getScheme();
+					if (isset($standardPorts[$scheme]) && $port != $standardPorts[$scheme]) {
+						$changes['set_headers']['Host'] .= ':' . $port;
+					}
+				}
+			}
+			$uri = $changes['uri'];
+		}
+		if (!empty($changes['remove_headers'])) {
+			$headers = self::caselessRemove($changes['remove_headers'], $headers);
+		}
+		if (!empty($changes['set_headers'])) {
+			$headers = self::caselessRemove(\array_keys($changes['set_headers']), $headers);
+			$headers = $changes['set_headers'] + $headers;
+		}
+		if (isset($changes['query'])) {
+			$uri = $uri->withQuery($changes['query']);
+		}
+		if ($request instanceof ServerRequestInterface) {
+			$new = (new ServerRequest($changes['method'] ?? $request->getMethod(), $uri, $headers, $changes['body'] ?? $request->getBody(), $changes['version'] ?? $request->getProtocolVersion(), $request->getServerParams()))->withParsedBody($request->getParsedBody())->withQueryParams($request->getQueryParams())->withCookieParams($request->getCookieParams())->withUploadedFiles($request->getUploadedFiles());
+			foreach ($request->getAttributes() as $key => $value) {
+				$new = $new->withAttribute($key, $value);
+			}
+			return $new;
+		}
+		return new Request($changes['method'] ?? $request->getMethod(), $uri, $headers, $changes['body'] ?? $request->getBody(), $changes['version'] ?? $request->getProtocolVersion());
+	}
+	/**
+	 * Read a line from the stream up to the maximum allowed buffer length.
+	 *
+	 * @param StreamInterface $stream    Stream to read from
+	 * @param int|null        $maxLength Maximum buffer length
+	 */
+	public static function readLine(StreamInterface $stream, int $maxLength = null) : string
+	{
+		$buffer = '';
+		$size = 0;
+		while (!$stream->eof()) {
+			if ('' === ($byte = $stream->read(1))) {
+				return $buffer;
+			}
+			$buffer .= $byte;
+			// Break when a new line is found or the max length - 1 is reached
+			if ($byte === "\n" || ++$size === $maxLength - 1) {
+				break;
+			}
+		}
+		return $buffer;
+	}
+	/**
+	 * Create a new stream based on the input type.
+	 *
+	 * Options is an associative array that can contain the following keys:
+	 * - metadata: Array of custom metadata.
+	 * - size: Size of the stream.
+	 *
+	 * This method accepts the following `$resource` types:
+	 * - `Psr\Http\Message\StreamInterface`: Returns the value as-is.
+	 * - `string`: Creates a stream object that uses the given string as the contents.
+	 * - `resource`: Creates a stream object that wraps the given PHP stream resource.
+	 * - `Iterator`: If the provided value implements `Iterator`, then a read-only
+	 *   stream object will be created that wraps the given iterable. Each time the
+	 *   stream is read from, data from the iterator will fill a buffer and will be
+	 *   continuously called until the buffer is equal to the requested read size.
+	 *   Subsequent read calls will first read from the buffer and then call `next`
+	 *   on the underlying iterator until it is exhausted.
+	 * - `object` with `__toString()`: If the object has the `__toString()` method,
+	 *   the object will be cast to a string and then a stream will be returned that
+	 *   uses the string value.
+	 * - `NULL`: When `null` is passed, an empty stream object is returned.
+	 * - `callable` When a callable is passed, a read-only stream object will be
+	 *   created that invokes the given callable. The callable is invoked with the
+	 *   number of suggested bytes to read. The callable can return any number of
+	 *   bytes, but MUST return `false` when there is no more data to return. The
+	 *   stream object that wraps the callable will invoke the callable until the
+	 *   number of requested bytes are available. Any additional bytes will be
+	 *   buffered and used in subsequent reads.
+	 *
+	 * @param resource|string|int|float|bool|StreamInterface|callable|\Iterator|null $resource Entity body data
+	 * @param array{size?: int, metadata?: array}                                    $options  Additional options
+	 *
+	 * @throws \InvalidArgumentException if the $resource arg is not valid.
+	 */
+	public static function streamFor($resource = '', array $options = []) : StreamInterface
+	{
+		if (\is_scalar($resource)) {
+			$stream = self::tryFopen('php://temp', 'r+');
+			if ($resource !== '') {
+				\fwrite($stream, (string) $resource);
+				\fseek($stream, 0);
+			}
+			return new Stream($stream, $options);
+		}
+		switch (\gettype($resource)) {
+			case 'resource':
+				/*
                  * The 'php://input' is a special stream with quirks and inconsistencies.
                  * We avoid using that stream by reading it into php://temp
                  */
-                /** @var resource $resource */
-                if ((\stream_get_meta_data($resource)['uri'] ?? '') === 'php://input') {
-                    $stream = self::tryFopen('php://temp', 'w+');
-                    \stream_copy_to_stream($resource, $stream);
-                    \fseek($stream, 0);
-                    $resource = $stream;
-                }
-                return new Stream($resource, $options);
-            case 'object':
-                /** @var object $resource */
-                if ($resource instanceof StreamInterface) {
-                    return $resource;
-                } elseif ($resource instanceof \Iterator) {
-                    return new PumpStream(function () use($resource) {
-                        if (!$resource->valid()) {
-                            return \false;
-                        }
-                        $result = $resource->current();
-                        $resource->next();
-                        return $result;
-                    }, $options);
-                } elseif (\method_exists($resource, '__toString')) {
-                    return self::streamFor((string) $resource, $options);
-                }
-                break;
-            case 'NULL':
-                return new Stream(self::tryFopen('php://temp', 'r+'), $options);
-        }
-        if (\is_callable($resource)) {
-            return new PumpStream($resource, $options);
-        }
-        throw new \InvalidArgumentException('Invalid resource type: ' . \gettype($resource));
-    }
-    /**
-     * Safely opens a PHP stream resource using a filename.
-     *
-     * When fopen fails, PHP normally raises a warning. This function adds an
-     * error handler that checks for errors and throws an exception instead.
-     *
-     * @param string $filename File to open
-     * @param string $mode     Mode used to open the file
-     *
-     * @return resource
-     *
-     * @throws \RuntimeException if the file cannot be opened
-     */
-    public static function tryFopen(string $filename, string $mode)
-    {
-        $ex = null;
-        \set_error_handler(static function (int $errno, string $errstr) use($filename, $mode, &$ex) : bool {
-            $ex = new \RuntimeException(\sprintf('Unable to open "%s" using mode "%s": %s', $filename, $mode, $errstr));
-            return \true;
-        });
-        try {
-            /** @var resource $handle */
-            $handle = \fopen($filename, $mode);
-        } catch (\Throwable $e) {
-            $ex = new \RuntimeException(\sprintf('Unable to open "%s" using mode "%s": %s', $filename, $mode, $e->getMessage()), 0, $e);
-        }
-        \restore_error_handler();
-        if ($ex) {
-            /** @var $ex \RuntimeException */
-            throw $ex;
-        }
-        return $handle;
-    }
-    /**
-     * Safely gets the contents of a given stream.
-     *
-     * When stream_get_contents fails, PHP normally raises a warning. This
-     * function adds an error handler that checks for errors and throws an
-     * exception instead.
-     *
-     * @param resource $stream
-     *
-     * @throws \RuntimeException if the stream cannot be read
-     */
-    public static function tryGetContents($stream) : string
-    {
-        $ex = null;
-        \set_error_handler(static function (int $errno, string $errstr) use(&$ex) : bool {
-            $ex = new \RuntimeException(\sprintf('Unable to read stream contents: %s', $errstr));
-            return \true;
-        });
-        try {
-            /** @var string|false $contents */
-            $contents = \stream_get_contents($stream);
-            if ($contents === \false) {
-                $ex = new \RuntimeException('Unable to read stream contents');
-            }
-        } catch (\Throwable $e) {
-            $ex = new \RuntimeException(\sprintf('Unable to read stream contents: %s', $e->getMessage()), 0, $e);
-        }
-        \restore_error_handler();
-        if ($ex) {
-            /** @var $ex \RuntimeException */
-            throw $ex;
-        }
-        return $contents;
-    }
-    /**
-     * Returns a UriInterface for the given value.
-     *
-     * This function accepts a string or UriInterface and returns a
-     * UriInterface for the given value. If the value is already a
-     * UriInterface, it is returned as-is.
-     *
-     * @param string|UriInterface $uri
-     *
-     * @throws \InvalidArgumentException
-     */
-    public static function uriFor($uri) : UriInterface
-    {
-        if ($uri instanceof UriInterface) {
-            return $uri;
-        }
-        if (\is_string($uri)) {
-            return new Uri($uri);
-        }
-        throw new \InvalidArgumentException('URI must be a string or UriInterface');
-    }
+				/** @var resource $resource */
+				if ((\stream_get_meta_data($resource)['uri'] ?? '') === 'php://input') {
+					$stream = self::tryFopen('php://temp', 'w+');
+					\stream_copy_to_stream($resource, $stream);
+					\fseek($stream, 0);
+					$resource = $stream;
+				}
+				return new Stream($resource, $options);
+			case 'object':
+				/** @var object $resource */
+				if ($resource instanceof StreamInterface) {
+					return $resource;
+				} elseif ($resource instanceof \Iterator) {
+					return new PumpStream(function () use($resource) {
+						if (!$resource->valid()) {
+							return \false;
+						}
+						$result = $resource->current();
+						$resource->next();
+						return $result;
+					}, $options);
+				} elseif (\method_exists($resource, '__toString')) {
+					return self::streamFor((string) $resource, $options);
+				}
+				break;
+			case 'NULL':
+				return new Stream(self::tryFopen('php://temp', 'r+'), $options);
+		}
+		if (\is_callable($resource)) {
+			return new PumpStream($resource, $options);
+		}
+		throw new \InvalidArgumentException('Invalid resource type: ' . \gettype($resource));
+	}
+	/**
+	 * Safely opens a PHP stream resource using a filename.
+	 *
+	 * When fopen fails, PHP normally raises a warning. This function adds an
+	 * error handler that checks for errors and throws an exception instead.
+	 *
+	 * @param string $filename File to open
+	 * @param string $mode     Mode used to open the file
+	 *
+	 * @return resource
+	 *
+	 * @throws \RuntimeException if the file cannot be opened
+	 */
+	public static function tryFopen(string $filename, string $mode)
+	{
+		$ex = null;
+		\set_error_handler(static function (int $errno, string $errstr) use($filename, $mode, &$ex) : bool {
+			$ex = new \RuntimeException(\sprintf('Unable to open "%s" using mode "%s": %s', $filename, $mode, $errstr));
+			return \true;
+		});
+		try {
+			/** @var resource $handle */
+			$handle = \fopen($filename, $mode);
+		} catch (\Throwable $e) {
+			$ex = new \RuntimeException(\sprintf('Unable to open "%s" using mode "%s": %s', $filename, $mode, $e->getMessage()), 0, $e);
+		}
+		\restore_error_handler();
+		if ($ex) {
+			/** @var $ex \RuntimeException */
+			throw $ex;
+		}
+		return $handle;
+	}
+	/**
+	 * Safely gets the contents of a given stream.
+	 *
+	 * When stream_get_contents fails, PHP normally raises a warning. This
+	 * function adds an error handler that checks for errors and throws an
+	 * exception instead.
+	 *
+	 * @param resource $stream
+	 *
+	 * @throws \RuntimeException if the stream cannot be read
+	 */
+	public static function tryGetContents($stream) : string
+	{
+		$ex = null;
+		\set_error_handler(static function (int $errno, string $errstr) use(&$ex) : bool {
+			$ex = new \RuntimeException(\sprintf('Unable to read stream contents: %s', $errstr));
+			return \true;
+		});
+		try {
+			/** @var string|false $contents */
+			$contents = \stream_get_contents($stream);
+			if ($contents === \false) {
+				$ex = new \RuntimeException('Unable to read stream contents');
+			}
+		} catch (\Throwable $e) {
+			$ex = new \RuntimeException(\sprintf('Unable to read stream contents: %s', $e->getMessage()), 0, $e);
+		}
+		\restore_error_handler();
+		if ($ex) {
+			/** @var $ex \RuntimeException */
+			throw $ex;
+		}
+		return $contents;
+	}
+	/**
+	 * Returns a UriInterface for the given value.
+	 *
+	 * This function accepts a string or UriInterface and returns a
+	 * UriInterface for the given value. If the value is already a
+	 * UriInterface, it is returned as-is.
+	 *
+	 * @param string|UriInterface $uri
+	 *
+	 * @throws \InvalidArgumentException
+	 */
+	public static function uriFor($uri) : UriInterface
+	{
+		if ($uri instanceof UriInterface) {
+			return $uri;
+		}
+		if (\is_string($uri)) {
+			return new Uri($uri);
+		}
+		throw new \InvalidArgumentException('URI must be a string or UriInterface');
+	}
 }

Spacing +10 added lines, -10 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\RequestInterface;
@@ -18,10 +18,10 @@ 
     {
         $result = [];
         foreach ($keys as &$key) {
-            $key = \strtolower((string) $key);
+            $key = \strtolower((string)$key);
         }
         foreach ($data as $k => $v) {
-            if (!\in_array(\strtolower((string) $k), $keys)) {
+            if (!\in_array(\strtolower((string)$k), $keys)) {
                 $result[$k] = $v;
             }
         }
@@ -154,7 +154,7 @@ 
                     $standardPorts = ['http' => 80, 'https' => 443];
                     $scheme = $changes['uri']->getScheme();
                     if (isset($standardPorts[$scheme]) && $port != $standardPorts[$scheme]) {
-                        $changes['set_headers']['Host'] .= ':' . $port;
+                        $changes['set_headers']['Host'] .= ':'.$port;
                     }
                 }
             }
@@ -240,7 +240,7 @@ 
         if (\is_scalar($resource)) {
             $stream = self::tryFopen('php://temp', 'r+');
             if ($resource !== '') {
-                \fwrite($stream, (string) $resource);
+                \fwrite($stream, (string)$resource);
                 \fseek($stream, 0);
             }
             return new Stream($stream, $options);
@@ -264,7 +264,7 @@ 
                 if ($resource instanceof StreamInterface) {
                     return $resource;
                 } elseif ($resource instanceof \Iterator) {
-                    return new PumpStream(function () use($resource) {
+                    return new PumpStream(function() use($resource) {
                         if (!$resource->valid()) {
                             return \false;
                         }
@@ -273,7 +273,7 @@ 
                         return $result;
                     }, $options);
                 } elseif (\method_exists($resource, '__toString')) {
-                    return self::streamFor((string) $resource, $options);
+                    return self::streamFor((string)$resource, $options);
                 }
                 break;
             case 'NULL':
@@ -282,7 +282,7 @@ 
         if (\is_callable($resource)) {
             return new PumpStream($resource, $options);
         }
-        throw new \InvalidArgumentException('Invalid resource type: ' . \gettype($resource));
+        throw new \InvalidArgumentException('Invalid resource type: '.\gettype($resource));
     }
     /**
      * Safely opens a PHP stream resource using a filename.
@@ -300,7 +300,7 @@ 
     public static function tryFopen(string $filename, string $mode)
     {
         $ex = null;
-        \set_error_handler(static function (int $errno, string $errstr) use($filename, $mode, &$ex) : bool {
+        \set_error_handler(static function(int $errno, string $errstr) use($filename, $mode, &$ex) : bool {
             $ex = new \RuntimeException(\sprintf('Unable to open "%s" using mode "%s": %s', $filename, $mode, $errstr));
             return \true;
         });
@@ -331,7 +331,7 @@ 
     public static function tryGetContents($stream) : string
     {
         $ex = null;
-        \set_error_handler(static function (int $errno, string $errstr) use(&$ex) : bool {
+        \set_error_handler(static function(int $errno, string $errstr) use(&$ex) : bool {
             $ex = new \RuntimeException(\sprintf('Unable to read stream contents: %s', $errstr));
             return \true;
         });

Braces +1 added lines, -2 removed lines

@@ -7,8 +7,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ServerRequestInterface;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\StreamInterface;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\UriInterface;
-final class Utils
-{
+final class Utils {
     /**
      * Remove the items given by the keys, case insensitively from the data.
      *

lib/Vendor/GuzzleHttp/Exception/BadResponseException.php

Indentation +19 added lines, -19 removed lines

@@ -9,23 +9,23 @@
  */
 class BadResponseException extends RequestException
 {
-    public function __construct(string $message, RequestInterface $request, ResponseInterface $response, \Throwable $previous = null, array $handlerContext = [])
-    {
-        parent::__construct($message, $request, $response, $previous, $handlerContext);
-    }
-    /**
-     * Current exception and the ones that extend it will always have a response.
-     */
-    public function hasResponse() : bool
-    {
-        return \true;
-    }
-    /**
-     * This function narrows the return type from the parent class and does not allow it to be nullable.
-     */
-    public function getResponse() : ResponseInterface
-    {
-        /** @var ResponseInterface */
-        return parent::getResponse();
-    }
+	public function __construct(string $message, RequestInterface $request, ResponseInterface $response, \Throwable $previous = null, array $handlerContext = [])
+	{
+		parent::__construct($message, $request, $response, $previous, $handlerContext);
+	}
+	/**
+	 * Current exception and the ones that extend it will always have a response.
+	 */
+	public function hasResponse() : bool
+	{
+		return \true;
+	}
+	/**
+	 * This function narrows the return type from the parent class and does not allow it to be nullable.
+	 */
+	public function getResponse() : ResponseInterface
+	{
+		/** @var ResponseInterface */
+		return parent::getResponse();
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -7,8 +7,7 @@
 /**
  * Exception when an HTTP error occurs (4xx or 5xx error)
  */
-class BadResponseException extends RequestException
-{
+class BadResponseException extends RequestException {
     public function __construct(string $message, RequestInterface $request, ResponseInterface $response, \Throwable $previous = null, array $handlerContext = [])
     {
         parent::__construct($message, $request, $response, $previous, $handlerContext);

lib/Vendor/GuzzleHttp/Exception/GuzzleException.php

Braces +1 added lines, -2 removed lines

@@ -3,6 +3,5 @@
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Exception;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Client\ClientExceptionInterface;
-interface GuzzleException extends ClientExceptionInterface
-{
+interface GuzzleException extends ClientExceptionInterface {
 }

lib/Vendor/GuzzleHttp/Handler/CurlFactory.php

Indentation +475 added lines, -475 removed lines

@@ -18,479 +18,479 @@
  */
 class CurlFactory implements CurlFactoryInterface
 {
-    public const CURL_VERSION_STR = 'curl_version';
-    /**
-     * @deprecated
-     */
-    public const LOW_CURL_VERSION_NUMBER = '7.21.2';
-    /**
-     * @var resource[]|\CurlHandle[]
-     */
-    private $handles = [];
-    /**
-     * @var int Total number of idle handles to keep in cache
-     */
-    private $maxHandles;
-    /**
-     * @param int $maxHandles Maximum number of idle handles.
-     */
-    public function __construct(int $maxHandles)
-    {
-        $this->maxHandles = $maxHandles;
-    }
-    public function create(RequestInterface $request, array $options) : EasyHandle
-    {
-        if (isset($options['curl']['body_as_string'])) {
-            $options['_body_as_string'] = $options['curl']['body_as_string'];
-            unset($options['curl']['body_as_string']);
-        }
-        $easy = new EasyHandle();
-        $easy->request = $request;
-        $easy->options = $options;
-        $conf = $this->getDefaultConf($easy);
-        $this->applyMethod($easy, $conf);
-        $this->applyHandlerOptions($easy, $conf);
-        $this->applyHeaders($easy, $conf);
-        unset($conf['_headers']);
-        // Add handler options from the request configuration options
-        if (isset($options['curl'])) {
-            $conf = \array_replace($conf, $options['curl']);
-        }
-        $conf[\CURLOPT_HEADERFUNCTION] = $this->createHeaderFn($easy);
-        $easy->handle = $this->handles ? \array_pop($this->handles) : \curl_init();
-        \curl_setopt_array($easy->handle, $conf);
-        return $easy;
-    }
-    public function release(EasyHandle $easy) : void
-    {
-        $resource = $easy->handle;
-        unset($easy->handle);
-        if (\count($this->handles) >= $this->maxHandles) {
-            \curl_close($resource);
-        } else {
-            // Remove all callback functions as they can hold onto references
-            // and are not cleaned up by curl_reset. Using curl_setopt_array
-            // does not work for some reason, so removing each one
-            // individually.
-            \curl_setopt($resource, \CURLOPT_HEADERFUNCTION, null);
-            \curl_setopt($resource, \CURLOPT_READFUNCTION, null);
-            \curl_setopt($resource, \CURLOPT_WRITEFUNCTION, null);
-            \curl_setopt($resource, \CURLOPT_PROGRESSFUNCTION, null);
-            \curl_reset($resource);
-            $this->handles[] = $resource;
-        }
-    }
-    /**
-     * Completes a cURL transaction, either returning a response promise or a
-     * rejected promise.
-     *
-     * @param callable(RequestInterface, array): PromiseInterface $handler
-     * @param CurlFactoryInterface                                $factory Dictates how the handle is released
-     */
-    public static function finish(callable $handler, EasyHandle $easy, CurlFactoryInterface $factory) : PromiseInterface
-    {
-        if (isset($easy->options['on_stats'])) {
-            self::invokeStats($easy);
-        }
-        if (!$easy->response || $easy->errno) {
-            return self::finishError($handler, $easy, $factory);
-        }
-        // Return the response if it is present and there is no error.
-        $factory->release($easy);
-        // Rewind the body of the response if possible.
-        $body = $easy->response->getBody();
-        if ($body->isSeekable()) {
-            $body->rewind();
-        }
-        return new FulfilledPromise($easy->response);
-    }
-    private static function invokeStats(EasyHandle $easy) : void
-    {
-        $curlStats = \curl_getinfo($easy->handle);
-        $curlStats['appconnect_time'] = \curl_getinfo($easy->handle, \CURLINFO_APPCONNECT_TIME);
-        $stats = new TransferStats($easy->request, $easy->response, $curlStats['total_time'], $easy->errno, $curlStats);
-        $easy->options['on_stats']($stats);
-    }
-    /**
-     * @param callable(RequestInterface, array): PromiseInterface $handler
-     */
-    private static function finishError(callable $handler, EasyHandle $easy, CurlFactoryInterface $factory) : PromiseInterface
-    {
-        // Get error information and release the handle to the factory.
-        $ctx = ['errno' => $easy->errno, 'error' => \curl_error($easy->handle), 'appconnect_time' => \curl_getinfo($easy->handle, \CURLINFO_APPCONNECT_TIME)] + \curl_getinfo($easy->handle);
-        $ctx[self::CURL_VERSION_STR] = \curl_version()['version'];
-        $factory->release($easy);
-        // Retry when nothing is present or when curl failed to rewind.
-        if (empty($easy->options['_err_message']) && (!$easy->errno || $easy->errno == 65)) {
-            return self::retryFailedRewind($handler, $easy, $ctx);
-        }
-        return self::createRejection($easy, $ctx);
-    }
-    private static function createRejection(EasyHandle $easy, array $ctx) : PromiseInterface
-    {
-        static $connectionErrors = [\CURLE_OPERATION_TIMEOUTED => \true, \CURLE_COULDNT_RESOLVE_HOST => \true, \CURLE_COULDNT_CONNECT => \true, \CURLE_SSL_CONNECT_ERROR => \true, \CURLE_GOT_NOTHING => \true];
-        if ($easy->createResponseException) {
-            return P\Create::rejectionFor(new RequestException('An error was encountered while creating the response', $easy->request, $easy->response, $easy->createResponseException, $ctx));
-        }
-        // If an exception was encountered during the onHeaders event, then
-        // return a rejected promise that wraps that exception.
-        if ($easy->onHeadersException) {
-            return P\Create::rejectionFor(new RequestException('An error was encountered during the on_headers event', $easy->request, $easy->response, $easy->onHeadersException, $ctx));
-        }
-        $message = \sprintf('cURL error %s: %s (%s)', $ctx['errno'], $ctx['error'], 'see https://curl.haxx.se/libcurl/c/libcurl-errors.html');
-        $uriString = (string) $easy->request->getUri();
-        if ($uriString !== '' && \false === \strpos($ctx['error'], $uriString)) {
-            $message .= \sprintf(' for %s', $uriString);
-        }
-        // Create a connection exception if it was a specific error code.
-        $error = isset($connectionErrors[$easy->errno]) ? new ConnectException($message, $easy->request, null, $ctx) : new RequestException($message, $easy->request, $easy->response, null, $ctx);
-        return P\Create::rejectionFor($error);
-    }
-    /**
-     * @return array<int|string, mixed>
-     */
-    private function getDefaultConf(EasyHandle $easy) : array
-    {
-        $conf = ['_headers' => $easy->request->getHeaders(), \CURLOPT_CUSTOMREQUEST => $easy->request->getMethod(), \CURLOPT_URL => (string) $easy->request->getUri()->withFragment(''), \CURLOPT_RETURNTRANSFER => \false, \CURLOPT_HEADER => \false, \CURLOPT_CONNECTTIMEOUT => 300];
-        if (\defined('CURLOPT_PROTOCOLS')) {
-            $conf[\CURLOPT_PROTOCOLS] = \CURLPROTO_HTTP | \CURLPROTO_HTTPS;
-        }
-        $version = $easy->request->getProtocolVersion();
-        if ($version == 1.1) {
-            $conf[\CURLOPT_HTTP_VERSION] = \CURL_HTTP_VERSION_1_1;
-        } elseif ($version == 2.0) {
-            $conf[\CURLOPT_HTTP_VERSION] = \CURL_HTTP_VERSION_2_0;
-        } else {
-            $conf[\CURLOPT_HTTP_VERSION] = \CURL_HTTP_VERSION_1_0;
-        }
-        return $conf;
-    }
-    private function applyMethod(EasyHandle $easy, array &$conf) : void
-    {
-        $body = $easy->request->getBody();
-        $size = $body->getSize();
-        if ($size === null || $size > 0) {
-            $this->applyBody($easy->request, $easy->options, $conf);
-            return;
-        }
-        $method = $easy->request->getMethod();
-        if ($method === 'PUT' || $method === 'POST') {
-            // See https://datatracker.ietf.org/doc/html/rfc7230#section-3.3.2
-            if (!$easy->request->hasHeader('Content-Length')) {
-                $conf[\CURLOPT_HTTPHEADER][] = 'Content-Length: 0';
-            }
-        } elseif ($method === 'HEAD') {
-            $conf[\CURLOPT_NOBODY] = \true;
-            unset($conf[\CURLOPT_WRITEFUNCTION], $conf[\CURLOPT_READFUNCTION], $conf[\CURLOPT_FILE], $conf[\CURLOPT_INFILE]);
-        }
-    }
-    private function applyBody(RequestInterface $request, array $options, array &$conf) : void
-    {
-        $size = $request->hasHeader('Content-Length') ? (int) $request->getHeaderLine('Content-Length') : null;
-        // Send the body as a string if the size is less than 1MB OR if the
-        // [curl][body_as_string] request value is set.
-        if ($size !== null && $size < 1000000 || !empty($options['_body_as_string'])) {
-            $conf[\CURLOPT_POSTFIELDS] = (string) $request->getBody();
-            // Don't duplicate the Content-Length header
-            $this->removeHeader('Content-Length', $conf);
-            $this->removeHeader('Transfer-Encoding', $conf);
-        } else {
-            $conf[\CURLOPT_UPLOAD] = \true;
-            if ($size !== null) {
-                $conf[\CURLOPT_INFILESIZE] = $size;
-                $this->removeHeader('Content-Length', $conf);
-            }
-            $body = $request->getBody();
-            if ($body->isSeekable()) {
-                $body->rewind();
-            }
-            $conf[\CURLOPT_READFUNCTION] = static function ($ch, $fd, $length) use($body) {
-                return $body->read($length);
-            };
-        }
-        // If the Expect header is not present, prevent curl from adding it
-        if (!$request->hasHeader('Expect')) {
-            $conf[\CURLOPT_HTTPHEADER][] = 'Expect:';
-        }
-        // cURL sometimes adds a content-type by default. Prevent this.
-        if (!$request->hasHeader('Content-Type')) {
-            $conf[\CURLOPT_HTTPHEADER][] = 'Content-Type:';
-        }
-    }
-    private function applyHeaders(EasyHandle $easy, array &$conf) : void
-    {
-        foreach ($conf['_headers'] as $name => $values) {
-            foreach ($values as $value) {
-                $value = (string) $value;
-                if ($value === '') {
-                    // cURL requires a special format for empty headers.
-                    // See https://github.com/guzzle/guzzle/issues/1882 for more details.
-                    $conf[\CURLOPT_HTTPHEADER][] = "{$name};";
-                } else {
-                    $conf[\CURLOPT_HTTPHEADER][] = "{$name}: {$value}";
-                }
-            }
-        }
-        // Remove the Accept header if one was not set
-        if (!$easy->request->hasHeader('Accept')) {
-            $conf[\CURLOPT_HTTPHEADER][] = 'Accept:';
-        }
-    }
-    /**
-     * Remove a header from the options array.
-     *
-     * @param string $name    Case-insensitive header to remove
-     * @param array  $options Array of options to modify
-     */
-    private function removeHeader(string $name, array &$options) : void
-    {
-        foreach (\array_keys($options['_headers']) as $key) {
-            if (!\strcasecmp($key, $name)) {
-                unset($options['_headers'][$key]);
-                return;
-            }
-        }
-    }
-    private function applyHandlerOptions(EasyHandle $easy, array &$conf) : void
-    {
-        $options = $easy->options;
-        if (isset($options['verify'])) {
-            if ($options['verify'] === \false) {
-                unset($conf[\CURLOPT_CAINFO]);
-                $conf[\CURLOPT_SSL_VERIFYHOST] = 0;
-                $conf[\CURLOPT_SSL_VERIFYPEER] = \false;
-            } else {
-                $conf[\CURLOPT_SSL_VERIFYHOST] = 2;
-                $conf[\CURLOPT_SSL_VERIFYPEER] = \true;
-                if (\is_string($options['verify'])) {
-                    // Throw an error if the file/folder/link path is not valid or doesn't exist.
-                    if (!\file_exists($options['verify'])) {
-                        throw new \InvalidArgumentException("SSL CA bundle not found: {$options['verify']}");
-                    }
-                    // If it's a directory or a link to a directory use CURLOPT_CAPATH.
-                    // If not, it's probably a file, or a link to a file, so use CURLOPT_CAINFO.
-                    if (\is_dir($options['verify']) || \is_link($options['verify']) === \true && ($verifyLink = \readlink($options['verify'])) !== \false && \is_dir($verifyLink)) {
-                        $conf[\CURLOPT_CAPATH] = $options['verify'];
-                    } else {
-                        $conf[\CURLOPT_CAINFO] = $options['verify'];
-                    }
-                }
-            }
-        }
-        if (!isset($options['curl'][\CURLOPT_ENCODING]) && !empty($options['decode_content'])) {
-            $accept = $easy->request->getHeaderLine('Accept-Encoding');
-            if ($accept) {
-                $conf[\CURLOPT_ENCODING] = $accept;
-            } else {
-                // The empty string enables all available decoders and implicitly
-                // sets a matching 'Accept-Encoding' header.
-                $conf[\CURLOPT_ENCODING] = '';
-                // But as the user did not specify any acceptable encodings we need
-                // to overwrite this implicit header with an empty one.
-                $conf[\CURLOPT_HTTPHEADER][] = 'Accept-Encoding:';
-            }
-        }
-        if (!isset($options['sink'])) {
-            // Use a default temp stream if no sink was set.
-            $options['sink'] = \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Utils::tryFopen('php://temp', 'w+');
-        }
-        $sink = $options['sink'];
-        if (!\is_string($sink)) {
-            $sink = \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Utils::streamFor($sink);
-        } elseif (!\is_dir(\dirname($sink))) {
-            // Ensure that the directory exists before failing in curl.
-            throw new \RuntimeException(\sprintf('Directory %s does not exist for sink value of %s', \dirname($sink), $sink));
-        } else {
-            $sink = new LazyOpenStream($sink, 'w+');
-        }
-        $easy->sink = $sink;
-        $conf[\CURLOPT_WRITEFUNCTION] = static function ($ch, $write) use($sink) : int {
-            return $sink->write($write);
-        };
-        $timeoutRequiresNoSignal = \false;
-        if (isset($options['timeout'])) {
-            $timeoutRequiresNoSignal |= $options['timeout'] < 1;
-            $conf[\CURLOPT_TIMEOUT_MS] = $options['timeout'] * 1000;
-        }
-        // CURL default value is CURL_IPRESOLVE_WHATEVER
-        if (isset($options['force_ip_resolve'])) {
-            if ('v4' === $options['force_ip_resolve']) {
-                $conf[\CURLOPT_IPRESOLVE] = \CURL_IPRESOLVE_V4;
-            } elseif ('v6' === $options['force_ip_resolve']) {
-                $conf[\CURLOPT_IPRESOLVE] = \CURL_IPRESOLVE_V6;
-            }
-        }
-        if (isset($options['connect_timeout'])) {
-            $timeoutRequiresNoSignal |= $options['connect_timeout'] < 1;
-            $conf[\CURLOPT_CONNECTTIMEOUT_MS] = $options['connect_timeout'] * 1000;
-        }
-        if ($timeoutRequiresNoSignal && \strtoupper(\substr(\PHP_OS, 0, 3)) !== 'WIN') {
-            $conf[\CURLOPT_NOSIGNAL] = \true;
-        }
-        if (isset($options['proxy'])) {
-            if (!\is_array($options['proxy'])) {
-                $conf[\CURLOPT_PROXY] = $options['proxy'];
-            } else {
-                $scheme = $easy->request->getUri()->getScheme();
-                if (isset($options['proxy'][$scheme])) {
-                    $host = $easy->request->getUri()->getHost();
-                    if (isset($options['proxy']['no']) && Utils::isHostInNoProxy($host, $options['proxy']['no'])) {
-                        unset($conf[\CURLOPT_PROXY]);
-                    } else {
-                        $conf[\CURLOPT_PROXY] = $options['proxy'][$scheme];
-                    }
-                }
-            }
-        }
-        if (isset($options['crypto_method'])) {
-            if (\STREAM_CRYPTO_METHOD_TLSv1_0_CLIENT === $options['crypto_method']) {
-                if (!\defined('CURL_SSLVERSION_TLSv1_0')) {
-                    throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.0 not supported by your version of cURL');
-                }
-                $conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_0;
-            } elseif (\STREAM_CRYPTO_METHOD_TLSv1_1_CLIENT === $options['crypto_method']) {
-                if (!\defined('CURL_SSLVERSION_TLSv1_1')) {
-                    throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.1 not supported by your version of cURL');
-                }
-                $conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_1;
-            } elseif (\STREAM_CRYPTO_METHOD_TLSv1_2_CLIENT === $options['crypto_method']) {
-                if (!\defined('CURL_SSLVERSION_TLSv1_2')) {
-                    throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.2 not supported by your version of cURL');
-                }
-                $conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_2;
-            } elseif (\defined('STREAM_CRYPTO_METHOD_TLSv1_3_CLIENT') && \STREAM_CRYPTO_METHOD_TLSv1_3_CLIENT === $options['crypto_method']) {
-                if (!\defined('CURL_SSLVERSION_TLSv1_3')) {
-                    throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.3 not supported by your version of cURL');
-                }
-                $conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_3;
-            } else {
-                throw new \InvalidArgumentException('Invalid crypto_method request option: unknown version provided');
-            }
-        }
-        if (isset($options['cert'])) {
-            $cert = $options['cert'];
-            if (\is_array($cert)) {
-                $conf[\CURLOPT_SSLCERTPASSWD] = $cert[1];
-                $cert = $cert[0];
-            }
-            if (!\file_exists($cert)) {
-                throw new \InvalidArgumentException("SSL certificate not found: {$cert}");
-            }
-            // OpenSSL (versions 0.9.3 and later) also support "P12" for PKCS#12-encoded files.
-            // see https://curl.se/libcurl/c/CURLOPT_SSLCERTTYPE.html
-            $ext = \pathinfo($cert, \PATHINFO_EXTENSION);
-            if (\preg_match('#^(der|p12)$#i', $ext)) {
-                $conf[\CURLOPT_SSLCERTTYPE] = \strtoupper($ext);
-            }
-            $conf[\CURLOPT_SSLCERT] = $cert;
-        }
-        if (isset($options['ssl_key'])) {
-            if (\is_array($options['ssl_key'])) {
-                if (\count($options['ssl_key']) === 2) {
-                    [$sslKey, $conf[\CURLOPT_SSLKEYPASSWD]] = $options['ssl_key'];
-                } else {
-                    [$sslKey] = $options['ssl_key'];
-                }
-            }
-            $sslKey = $sslKey ?? $options['ssl_key'];
-            if (!\file_exists($sslKey)) {
-                throw new \InvalidArgumentException("SSL private key not found: {$sslKey}");
-            }
-            $conf[\CURLOPT_SSLKEY] = $sslKey;
-        }
-        if (isset($options['progress'])) {
-            $progress = $options['progress'];
-            if (!\is_callable($progress)) {
-                throw new \InvalidArgumentException('progress client option must be callable');
-            }
-            $conf[\CURLOPT_NOPROGRESS] = \false;
-            $conf[\CURLOPT_PROGRESSFUNCTION] = static function ($resource, int $downloadSize, int $downloaded, int $uploadSize, int $uploaded) use($progress) {
-                $progress($downloadSize, $downloaded, $uploadSize, $uploaded);
-            };
-        }
-        if (!empty($options['debug'])) {
-            $conf[\CURLOPT_STDERR] = Utils::debugResource($options['debug']);
-            $conf[\CURLOPT_VERBOSE] = \true;
-        }
-    }
-    /**
-     * This function ensures that a response was set on a transaction. If one
-     * was not set, then the request is retried if possible. This error
-     * typically means you are sending a payload, curl encountered a
-     * "Connection died, retrying a fresh connect" error, tried to rewind the
-     * stream, and then encountered a "necessary data rewind wasn't possible"
-     * error, causing the request to be sent through curl_multi_info_read()
-     * without an error status.
-     *
-     * @param callable(RequestInterface, array): PromiseInterface $handler
-     */
-    private static function retryFailedRewind(callable $handler, EasyHandle $easy, array $ctx) : PromiseInterface
-    {
-        try {
-            // Only rewind if the body has been read from.
-            $body = $easy->request->getBody();
-            if ($body->tell() > 0) {
-                $body->rewind();
-            }
-        } catch (\RuntimeException $e) {
-            $ctx['error'] = 'The connection unexpectedly failed without ' . 'providing an error. The request would have been retried, ' . 'but attempting to rewind the request body failed. ' . 'Exception: ' . $e;
-            return self::createRejection($easy, $ctx);
-        }
-        // Retry no more than 3 times before giving up.
-        if (!isset($easy->options['_curl_retries'])) {
-            $easy->options['_curl_retries'] = 1;
-        } elseif ($easy->options['_curl_retries'] == 2) {
-            $ctx['error'] = 'The cURL request was retried 3 times ' . 'and did not succeed. The most likely reason for the failure ' . 'is that cURL was unable to rewind the body of the request ' . 'and subsequent retries resulted in the same error. Turn on ' . 'the debug option to see what went wrong. See ' . 'https://bugs.php.net/bug.php?id=47204 for more information.';
-            return self::createRejection($easy, $ctx);
-        } else {
-            ++$easy->options['_curl_retries'];
-        }
-        return $handler($easy->request, $easy->options);
-    }
-    private function createHeaderFn(EasyHandle $easy) : callable
-    {
-        if (isset($easy->options['on_headers'])) {
-            $onHeaders = $easy->options['on_headers'];
-            if (!\is_callable($onHeaders)) {
-                throw new \InvalidArgumentException('on_headers must be callable');
-            }
-        } else {
-            $onHeaders = null;
-        }
-        return static function ($ch, $h) use($onHeaders, $easy, &$startingResponse) {
-            $value = \trim($h);
-            if ($value === '') {
-                $startingResponse = \true;
-                try {
-                    $easy->createResponse();
-                } catch (\Exception $e) {
-                    $easy->createResponseException = $e;
-                    return -1;
-                }
-                if ($onHeaders !== null) {
-                    try {
-                        $onHeaders($easy->response);
-                    } catch (\Exception $e) {
-                        // Associate the exception with the handle and trigger
-                        // a curl header write error by returning 0.
-                        $easy->onHeadersException = $e;
-                        return -1;
-                    }
-                }
-            } elseif ($startingResponse) {
-                $startingResponse = \false;
-                $easy->headers = [$value];
-            } else {
-                $easy->headers[] = $value;
-            }
-            return \strlen($h);
-        };
-    }
-    public function __destruct()
-    {
-        foreach ($this->handles as $id => $handle) {
-            \curl_close($handle);
-            unset($this->handles[$id]);
-        }
-    }
+	public const CURL_VERSION_STR = 'curl_version';
+	/**
+	 * @deprecated
+	 */
+	public const LOW_CURL_VERSION_NUMBER = '7.21.2';
+	/**
+	 * @var resource[]|\CurlHandle[]
+	 */
+	private $handles = [];
+	/**
+	 * @var int Total number of idle handles to keep in cache
+	 */
+	private $maxHandles;
+	/**
+	 * @param int $maxHandles Maximum number of idle handles.
+	 */
+	public function __construct(int $maxHandles)
+	{
+		$this->maxHandles = $maxHandles;
+	}
+	public function create(RequestInterface $request, array $options) : EasyHandle
+	{
+		if (isset($options['curl']['body_as_string'])) {
+			$options['_body_as_string'] = $options['curl']['body_as_string'];
+			unset($options['curl']['body_as_string']);
+		}
+		$easy = new EasyHandle();
+		$easy->request = $request;
+		$easy->options = $options;
+		$conf = $this->getDefaultConf($easy);
+		$this->applyMethod($easy, $conf);
+		$this->applyHandlerOptions($easy, $conf);
+		$this->applyHeaders($easy, $conf);
+		unset($conf['_headers']);
+		// Add handler options from the request configuration options
+		if (isset($options['curl'])) {
+			$conf = \array_replace($conf, $options['curl']);
+		}
+		$conf[\CURLOPT_HEADERFUNCTION] = $this->createHeaderFn($easy);
+		$easy->handle = $this->handles ? \array_pop($this->handles) : \curl_init();
+		\curl_setopt_array($easy->handle, $conf);
+		return $easy;
+	}
+	public function release(EasyHandle $easy) : void
+	{
+		$resource = $easy->handle;
+		unset($easy->handle);
+		if (\count($this->handles) >= $this->maxHandles) {
+			\curl_close($resource);
+		} else {
+			// Remove all callback functions as they can hold onto references
+			// and are not cleaned up by curl_reset. Using curl_setopt_array
+			// does not work for some reason, so removing each one
+			// individually.
+			\curl_setopt($resource, \CURLOPT_HEADERFUNCTION, null);
+			\curl_setopt($resource, \CURLOPT_READFUNCTION, null);
+			\curl_setopt($resource, \CURLOPT_WRITEFUNCTION, null);
+			\curl_setopt($resource, \CURLOPT_PROGRESSFUNCTION, null);
+			\curl_reset($resource);
+			$this->handles[] = $resource;
+		}
+	}
+	/**
+	 * Completes a cURL transaction, either returning a response promise or a
+	 * rejected promise.
+	 *
+	 * @param callable(RequestInterface, array): PromiseInterface $handler
+	 * @param CurlFactoryInterface                                $factory Dictates how the handle is released
+	 */
+	public static function finish(callable $handler, EasyHandle $easy, CurlFactoryInterface $factory) : PromiseInterface
+	{
+		if (isset($easy->options['on_stats'])) {
+			self::invokeStats($easy);
+		}
+		if (!$easy->response || $easy->errno) {
+			return self::finishError($handler, $easy, $factory);
+		}
+		// Return the response if it is present and there is no error.
+		$factory->release($easy);
+		// Rewind the body of the response if possible.
+		$body = $easy->response->getBody();
+		if ($body->isSeekable()) {
+			$body->rewind();
+		}
+		return new FulfilledPromise($easy->response);
+	}
+	private static function invokeStats(EasyHandle $easy) : void
+	{
+		$curlStats = \curl_getinfo($easy->handle);
+		$curlStats['appconnect_time'] = \curl_getinfo($easy->handle, \CURLINFO_APPCONNECT_TIME);
+		$stats = new TransferStats($easy->request, $easy->response, $curlStats['total_time'], $easy->errno, $curlStats);
+		$easy->options['on_stats']($stats);
+	}
+	/**
+	 * @param callable(RequestInterface, array): PromiseInterface $handler
+	 */
+	private static function finishError(callable $handler, EasyHandle $easy, CurlFactoryInterface $factory) : PromiseInterface
+	{
+		// Get error information and release the handle to the factory.
+		$ctx = ['errno' => $easy->errno, 'error' => \curl_error($easy->handle), 'appconnect_time' => \curl_getinfo($easy->handle, \CURLINFO_APPCONNECT_TIME)] + \curl_getinfo($easy->handle);
+		$ctx[self::CURL_VERSION_STR] = \curl_version()['version'];
+		$factory->release($easy);
+		// Retry when nothing is present or when curl failed to rewind.
+		if (empty($easy->options['_err_message']) && (!$easy->errno || $easy->errno == 65)) {
+			return self::retryFailedRewind($handler, $easy, $ctx);
+		}
+		return self::createRejection($easy, $ctx);
+	}
+	private static function createRejection(EasyHandle $easy, array $ctx) : PromiseInterface
+	{
+		static $connectionErrors = [\CURLE_OPERATION_TIMEOUTED => \true, \CURLE_COULDNT_RESOLVE_HOST => \true, \CURLE_COULDNT_CONNECT => \true, \CURLE_SSL_CONNECT_ERROR => \true, \CURLE_GOT_NOTHING => \true];
+		if ($easy->createResponseException) {
+			return P\Create::rejectionFor(new RequestException('An error was encountered while creating the response', $easy->request, $easy->response, $easy->createResponseException, $ctx));
+		}
+		// If an exception was encountered during the onHeaders event, then
+		// return a rejected promise that wraps that exception.
+		if ($easy->onHeadersException) {
+			return P\Create::rejectionFor(new RequestException('An error was encountered during the on_headers event', $easy->request, $easy->response, $easy->onHeadersException, $ctx));
+		}
+		$message = \sprintf('cURL error %s: %s (%s)', $ctx['errno'], $ctx['error'], 'see https://curl.haxx.se/libcurl/c/libcurl-errors.html');
+		$uriString = (string) $easy->request->getUri();
+		if ($uriString !== '' && \false === \strpos($ctx['error'], $uriString)) {
+			$message .= \sprintf(' for %s', $uriString);
+		}
+		// Create a connection exception if it was a specific error code.
+		$error = isset($connectionErrors[$easy->errno]) ? new ConnectException($message, $easy->request, null, $ctx) : new RequestException($message, $easy->request, $easy->response, null, $ctx);
+		return P\Create::rejectionFor($error);
+	}
+	/**
+	 * @return array<int|string, mixed>
+	 */
+	private function getDefaultConf(EasyHandle $easy) : array
+	{
+		$conf = ['_headers' => $easy->request->getHeaders(), \CURLOPT_CUSTOMREQUEST => $easy->request->getMethod(), \CURLOPT_URL => (string) $easy->request->getUri()->withFragment(''), \CURLOPT_RETURNTRANSFER => \false, \CURLOPT_HEADER => \false, \CURLOPT_CONNECTTIMEOUT => 300];
+		if (\defined('CURLOPT_PROTOCOLS')) {
+			$conf[\CURLOPT_PROTOCOLS] = \CURLPROTO_HTTP | \CURLPROTO_HTTPS;
+		}
+		$version = $easy->request->getProtocolVersion();
+		if ($version == 1.1) {
+			$conf[\CURLOPT_HTTP_VERSION] = \CURL_HTTP_VERSION_1_1;
+		} elseif ($version == 2.0) {
+			$conf[\CURLOPT_HTTP_VERSION] = \CURL_HTTP_VERSION_2_0;
+		} else {
+			$conf[\CURLOPT_HTTP_VERSION] = \CURL_HTTP_VERSION_1_0;
+		}
+		return $conf;
+	}
+	private function applyMethod(EasyHandle $easy, array &$conf) : void
+	{
+		$body = $easy->request->getBody();
+		$size = $body->getSize();
+		if ($size === null || $size > 0) {
+			$this->applyBody($easy->request, $easy->options, $conf);
+			return;
+		}
+		$method = $easy->request->getMethod();
+		if ($method === 'PUT' || $method === 'POST') {
+			// See https://datatracker.ietf.org/doc/html/rfc7230#section-3.3.2
+			if (!$easy->request->hasHeader('Content-Length')) {
+				$conf[\CURLOPT_HTTPHEADER][] = 'Content-Length: 0';
+			}
+		} elseif ($method === 'HEAD') {
+			$conf[\CURLOPT_NOBODY] = \true;
+			unset($conf[\CURLOPT_WRITEFUNCTION], $conf[\CURLOPT_READFUNCTION], $conf[\CURLOPT_FILE], $conf[\CURLOPT_INFILE]);
+		}
+	}
+	private function applyBody(RequestInterface $request, array $options, array &$conf) : void
+	{
+		$size = $request->hasHeader('Content-Length') ? (int) $request->getHeaderLine('Content-Length') : null;
+		// Send the body as a string if the size is less than 1MB OR if the
+		// [curl][body_as_string] request value is set.
+		if ($size !== null && $size < 1000000 || !empty($options['_body_as_string'])) {
+			$conf[\CURLOPT_POSTFIELDS] = (string) $request->getBody();
+			// Don't duplicate the Content-Length header
+			$this->removeHeader('Content-Length', $conf);
+			$this->removeHeader('Transfer-Encoding', $conf);
+		} else {
+			$conf[\CURLOPT_UPLOAD] = \true;
+			if ($size !== null) {
+				$conf[\CURLOPT_INFILESIZE] = $size;
+				$this->removeHeader('Content-Length', $conf);
+			}
+			$body = $request->getBody();
+			if ($body->isSeekable()) {
+				$body->rewind();
+			}
+			$conf[\CURLOPT_READFUNCTION] = static function ($ch, $fd, $length) use($body) {
+				return $body->read($length);
+			};
+		}
+		// If the Expect header is not present, prevent curl from adding it
+		if (!$request->hasHeader('Expect')) {
+			$conf[\CURLOPT_HTTPHEADER][] = 'Expect:';
+		}
+		// cURL sometimes adds a content-type by default. Prevent this.
+		if (!$request->hasHeader('Content-Type')) {
+			$conf[\CURLOPT_HTTPHEADER][] = 'Content-Type:';
+		}
+	}
+	private function applyHeaders(EasyHandle $easy, array &$conf) : void
+	{
+		foreach ($conf['_headers'] as $name => $values) {
+			foreach ($values as $value) {
+				$value = (string) $value;
+				if ($value === '') {
+					// cURL requires a special format for empty headers.
+					// See https://github.com/guzzle/guzzle/issues/1882 for more details.
+					$conf[\CURLOPT_HTTPHEADER][] = "{$name};";
+				} else {
+					$conf[\CURLOPT_HTTPHEADER][] = "{$name}: {$value}";
+				}
+			}
+		}
+		// Remove the Accept header if one was not set
+		if (!$easy->request->hasHeader('Accept')) {
+			$conf[\CURLOPT_HTTPHEADER][] = 'Accept:';
+		}
+	}
+	/**
+	 * Remove a header from the options array.
+	 *
+	 * @param string $name    Case-insensitive header to remove
+	 * @param array  $options Array of options to modify
+	 */
+	private function removeHeader(string $name, array &$options) : void
+	{
+		foreach (\array_keys($options['_headers']) as $key) {
+			if (!\strcasecmp($key, $name)) {
+				unset($options['_headers'][$key]);
+				return;
+			}
+		}
+	}
+	private function applyHandlerOptions(EasyHandle $easy, array &$conf) : void
+	{
+		$options = $easy->options;
+		if (isset($options['verify'])) {
+			if ($options['verify'] === \false) {
+				unset($conf[\CURLOPT_CAINFO]);
+				$conf[\CURLOPT_SSL_VERIFYHOST] = 0;
+				$conf[\CURLOPT_SSL_VERIFYPEER] = \false;
+			} else {
+				$conf[\CURLOPT_SSL_VERIFYHOST] = 2;
+				$conf[\CURLOPT_SSL_VERIFYPEER] = \true;
+				if (\is_string($options['verify'])) {
+					// Throw an error if the file/folder/link path is not valid or doesn't exist.
+					if (!\file_exists($options['verify'])) {
+						throw new \InvalidArgumentException("SSL CA bundle not found: {$options['verify']}");
+					}
+					// If it's a directory or a link to a directory use CURLOPT_CAPATH.
+					// If not, it's probably a file, or a link to a file, so use CURLOPT_CAINFO.
+					if (\is_dir($options['verify']) || \is_link($options['verify']) === \true && ($verifyLink = \readlink($options['verify'])) !== \false && \is_dir($verifyLink)) {
+						$conf[\CURLOPT_CAPATH] = $options['verify'];
+					} else {
+						$conf[\CURLOPT_CAINFO] = $options['verify'];
+					}
+				}
+			}
+		}
+		if (!isset($options['curl'][\CURLOPT_ENCODING]) && !empty($options['decode_content'])) {
+			$accept = $easy->request->getHeaderLine('Accept-Encoding');
+			if ($accept) {
+				$conf[\CURLOPT_ENCODING] = $accept;
+			} else {
+				// The empty string enables all available decoders and implicitly
+				// sets a matching 'Accept-Encoding' header.
+				$conf[\CURLOPT_ENCODING] = '';
+				// But as the user did not specify any acceptable encodings we need
+				// to overwrite this implicit header with an empty one.
+				$conf[\CURLOPT_HTTPHEADER][] = 'Accept-Encoding:';
+			}
+		}
+		if (!isset($options['sink'])) {
+			// Use a default temp stream if no sink was set.
+			$options['sink'] = \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Utils::tryFopen('php://temp', 'w+');
+		}
+		$sink = $options['sink'];
+		if (!\is_string($sink)) {
+			$sink = \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Utils::streamFor($sink);
+		} elseif (!\is_dir(\dirname($sink))) {
+			// Ensure that the directory exists before failing in curl.
+			throw new \RuntimeException(\sprintf('Directory %s does not exist for sink value of %s', \dirname($sink), $sink));
+		} else {
+			$sink = new LazyOpenStream($sink, 'w+');
+		}
+		$easy->sink = $sink;
+		$conf[\CURLOPT_WRITEFUNCTION] = static function ($ch, $write) use($sink) : int {
+			return $sink->write($write);
+		};
+		$timeoutRequiresNoSignal = \false;
+		if (isset($options['timeout'])) {
+			$timeoutRequiresNoSignal |= $options['timeout'] < 1;
+			$conf[\CURLOPT_TIMEOUT_MS] = $options['timeout'] * 1000;
+		}
+		// CURL default value is CURL_IPRESOLVE_WHATEVER
+		if (isset($options['force_ip_resolve'])) {
+			if ('v4' === $options['force_ip_resolve']) {
+				$conf[\CURLOPT_IPRESOLVE] = \CURL_IPRESOLVE_V4;
+			} elseif ('v6' === $options['force_ip_resolve']) {
+				$conf[\CURLOPT_IPRESOLVE] = \CURL_IPRESOLVE_V6;
+			}
+		}
+		if (isset($options['connect_timeout'])) {
+			$timeoutRequiresNoSignal |= $options['connect_timeout'] < 1;
+			$conf[\CURLOPT_CONNECTTIMEOUT_MS] = $options['connect_timeout'] * 1000;
+		}
+		if ($timeoutRequiresNoSignal && \strtoupper(\substr(\PHP_OS, 0, 3)) !== 'WIN') {
+			$conf[\CURLOPT_NOSIGNAL] = \true;
+		}
+		if (isset($options['proxy'])) {
+			if (!\is_array($options['proxy'])) {
+				$conf[\CURLOPT_PROXY] = $options['proxy'];
+			} else {
+				$scheme = $easy->request->getUri()->getScheme();
+				if (isset($options['proxy'][$scheme])) {
+					$host = $easy->request->getUri()->getHost();
+					if (isset($options['proxy']['no']) && Utils::isHostInNoProxy($host, $options['proxy']['no'])) {
+						unset($conf[\CURLOPT_PROXY]);
+					} else {
+						$conf[\CURLOPT_PROXY] = $options['proxy'][$scheme];
+					}
+				}
+			}
+		}
+		if (isset($options['crypto_method'])) {
+			if (\STREAM_CRYPTO_METHOD_TLSv1_0_CLIENT === $options['crypto_method']) {
+				if (!\defined('CURL_SSLVERSION_TLSv1_0')) {
+					throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.0 not supported by your version of cURL');
+				}
+				$conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_0;
+			} elseif (\STREAM_CRYPTO_METHOD_TLSv1_1_CLIENT === $options['crypto_method']) {
+				if (!\defined('CURL_SSLVERSION_TLSv1_1')) {
+					throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.1 not supported by your version of cURL');
+				}
+				$conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_1;
+			} elseif (\STREAM_CRYPTO_METHOD_TLSv1_2_CLIENT === $options['crypto_method']) {
+				if (!\defined('CURL_SSLVERSION_TLSv1_2')) {
+					throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.2 not supported by your version of cURL');
+				}
+				$conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_2;
+			} elseif (\defined('STREAM_CRYPTO_METHOD_TLSv1_3_CLIENT') && \STREAM_CRYPTO_METHOD_TLSv1_3_CLIENT === $options['crypto_method']) {
+				if (!\defined('CURL_SSLVERSION_TLSv1_3')) {
+					throw new \InvalidArgumentException('Invalid crypto_method request option: TLS 1.3 not supported by your version of cURL');
+				}
+				$conf[\CURLOPT_SSLVERSION] = \CURL_SSLVERSION_TLSv1_3;
+			} else {
+				throw new \InvalidArgumentException('Invalid crypto_method request option: unknown version provided');
+			}
+		}
+		if (isset($options['cert'])) {
+			$cert = $options['cert'];
+			if (\is_array($cert)) {
+				$conf[\CURLOPT_SSLCERTPASSWD] = $cert[1];
+				$cert = $cert[0];
+			}
+			if (!\file_exists($cert)) {
+				throw new \InvalidArgumentException("SSL certificate not found: {$cert}");
+			}
+			// OpenSSL (versions 0.9.3 and later) also support "P12" for PKCS#12-encoded files.
+			// see https://curl.se/libcurl/c/CURLOPT_SSLCERTTYPE.html
+			$ext = \pathinfo($cert, \PATHINFO_EXTENSION);
+			if (\preg_match('#^(der|p12)$#i', $ext)) {
+				$conf[\CURLOPT_SSLCERTTYPE] = \strtoupper($ext);
+			}
+			$conf[\CURLOPT_SSLCERT] = $cert;
+		}
+		if (isset($options['ssl_key'])) {
+			if (\is_array($options['ssl_key'])) {
+				if (\count($options['ssl_key']) === 2) {
+					[$sslKey, $conf[\CURLOPT_SSLKEYPASSWD]] = $options['ssl_key'];
+				} else {
+					[$sslKey] = $options['ssl_key'];
+				}
+			}
+			$sslKey = $sslKey ?? $options['ssl_key'];
+			if (!\file_exists($sslKey)) {
+				throw new \InvalidArgumentException("SSL private key not found: {$sslKey}");
+			}
+			$conf[\CURLOPT_SSLKEY] = $sslKey;
+		}
+		if (isset($options['progress'])) {
+			$progress = $options['progress'];
+			if (!\is_callable($progress)) {
+				throw new \InvalidArgumentException('progress client option must be callable');
+			}
+			$conf[\CURLOPT_NOPROGRESS] = \false;
+			$conf[\CURLOPT_PROGRESSFUNCTION] = static function ($resource, int $downloadSize, int $downloaded, int $uploadSize, int $uploaded) use($progress) {
+				$progress($downloadSize, $downloaded, $uploadSize, $uploaded);
+			};
+		}
+		if (!empty($options['debug'])) {
+			$conf[\CURLOPT_STDERR] = Utils::debugResource($options['debug']);
+			$conf[\CURLOPT_VERBOSE] = \true;
+		}
+	}
+	/**
+	 * This function ensures that a response was set on a transaction. If one
+	 * was not set, then the request is retried if possible. This error
+	 * typically means you are sending a payload, curl encountered a
+	 * "Connection died, retrying a fresh connect" error, tried to rewind the
+	 * stream, and then encountered a "necessary data rewind wasn't possible"
+	 * error, causing the request to be sent through curl_multi_info_read()
+	 * without an error status.
+	 *
+	 * @param callable(RequestInterface, array): PromiseInterface $handler
+	 */
+	private static function retryFailedRewind(callable $handler, EasyHandle $easy, array $ctx) : PromiseInterface
+	{
+		try {
+			// Only rewind if the body has been read from.
+			$body = $easy->request->getBody();
+			if ($body->tell() > 0) {
+				$body->rewind();
+			}
+		} catch (\RuntimeException $e) {
+			$ctx['error'] = 'The connection unexpectedly failed without ' . 'providing an error. The request would have been retried, ' . 'but attempting to rewind the request body failed. ' . 'Exception: ' . $e;
+			return self::createRejection($easy, $ctx);
+		}
+		// Retry no more than 3 times before giving up.
+		if (!isset($easy->options['_curl_retries'])) {
+			$easy->options['_curl_retries'] = 1;
+		} elseif ($easy->options['_curl_retries'] == 2) {
+			$ctx['error'] = 'The cURL request was retried 3 times ' . 'and did not succeed. The most likely reason for the failure ' . 'is that cURL was unable to rewind the body of the request ' . 'and subsequent retries resulted in the same error. Turn on ' . 'the debug option to see what went wrong. See ' . 'https://bugs.php.net/bug.php?id=47204 for more information.';
+			return self::createRejection($easy, $ctx);
+		} else {
+			++$easy->options['_curl_retries'];
+		}
+		return $handler($easy->request, $easy->options);
+	}
+	private function createHeaderFn(EasyHandle $easy) : callable
+	{
+		if (isset($easy->options['on_headers'])) {
+			$onHeaders = $easy->options['on_headers'];
+			if (!\is_callable($onHeaders)) {
+				throw new \InvalidArgumentException('on_headers must be callable');
+			}
+		} else {
+			$onHeaders = null;
+		}
+		return static function ($ch, $h) use($onHeaders, $easy, &$startingResponse) {
+			$value = \trim($h);
+			if ($value === '') {
+				$startingResponse = \true;
+				try {
+					$easy->createResponse();
+				} catch (\Exception $e) {
+					$easy->createResponseException = $e;
+					return -1;
+				}
+				if ($onHeaders !== null) {
+					try {
+						$onHeaders($easy->response);
+					} catch (\Exception $e) {
+						// Associate the exception with the handle and trigger
+						// a curl header write error by returning 0.
+						$easy->onHeadersException = $e;
+						return -1;
+					}
+				}
+			} elseif ($startingResponse) {
+				$startingResponse = \false;
+				$easy->headers = [$value];
+			} else {
+				$easy->headers[] = $value;
+			}
+			return \strlen($h);
+		};
+	}
+	public function __destruct()
+	{
+		foreach ($this->handles as $id => $handle) {
+			\curl_close($handle);
+			unset($this->handles[$id]);
+		}
+	}
 }

Spacing +11 added lines, -11 removed lines

@@ -138,7 +138,7 @@ 
             return P\Create::rejectionFor(new RequestException('An error was encountered during the on_headers event', $easy->request, $easy->response, $easy->onHeadersException, $ctx));
         }
         $message = \sprintf('cURL error %s: %s (%s)', $ctx['errno'], $ctx['error'], 'see https://curl.haxx.se/libcurl/c/libcurl-errors.html');
-        $uriString = (string) $easy->request->getUri();
+        $uriString = (string)$easy->request->getUri();
         if ($uriString !== '' && \false === \strpos($ctx['error'], $uriString)) {
             $message .= \sprintf(' for %s', $uriString);
         }
@@ -151,7 +151,7 @@ 
      */
     private function getDefaultConf(EasyHandle $easy) : array
     {
-        $conf = ['_headers' => $easy->request->getHeaders(), \CURLOPT_CUSTOMREQUEST => $easy->request->getMethod(), \CURLOPT_URL => (string) $easy->request->getUri()->withFragment(''), \CURLOPT_RETURNTRANSFER => \false, \CURLOPT_HEADER => \false, \CURLOPT_CONNECTTIMEOUT => 300];
+        $conf = ['_headers' => $easy->request->getHeaders(), \CURLOPT_CUSTOMREQUEST => $easy->request->getMethod(), \CURLOPT_URL => (string)$easy->request->getUri()->withFragment(''), \CURLOPT_RETURNTRANSFER => \false, \CURLOPT_HEADER => \false, \CURLOPT_CONNECTTIMEOUT => 300];
         if (\defined('CURLOPT_PROTOCOLS')) {
             $conf[\CURLOPT_PROTOCOLS] = \CURLPROTO_HTTP | \CURLPROTO_HTTPS;
         }
@@ -186,11 +186,11 @@ 
     }
     private function applyBody(RequestInterface $request, array $options, array &$conf) : void
     {
-        $size = $request->hasHeader('Content-Length') ? (int) $request->getHeaderLine('Content-Length') : null;
+        $size = $request->hasHeader('Content-Length') ? (int)$request->getHeaderLine('Content-Length') : null;
         // Send the body as a string if the size is less than 1MB OR if the
         // [curl][body_as_string] request value is set.
         if ($size !== null && $size < 1000000 || !empty($options['_body_as_string'])) {
-            $conf[\CURLOPT_POSTFIELDS] = (string) $request->getBody();
+            $conf[\CURLOPT_POSTFIELDS] = (string)$request->getBody();
             // Don't duplicate the Content-Length header
             $this->removeHeader('Content-Length', $conf);
             $this->removeHeader('Transfer-Encoding', $conf);
@@ -204,7 +204,7 @@ 
             if ($body->isSeekable()) {
                 $body->rewind();
             }
-            $conf[\CURLOPT_READFUNCTION] = static function ($ch, $fd, $length) use($body) {
+            $conf[\CURLOPT_READFUNCTION] = static function($ch, $fd, $length) use($body) {
                 return $body->read($length);
             };
         }
@@ -221,7 +221,7 @@ 
     {
         foreach ($conf['_headers'] as $name => $values) {
             foreach ($values as $value) {
-                $value = (string) $value;
+                $value = (string)$value;
                 if ($value === '') {
                     // cURL requires a special format for empty headers.
                     // See https://github.com/guzzle/guzzle/issues/1882 for more details.
@@ -304,7 +304,7 @@ 
             $sink = new LazyOpenStream($sink, 'w+');
         }
         $easy->sink = $sink;
-        $conf[\CURLOPT_WRITEFUNCTION] = static function ($ch, $write) use($sink) : int {
+        $conf[\CURLOPT_WRITEFUNCTION] = static function($ch, $write) use($sink) : int {
             return $sink->write($write);
         };
         $timeoutRequiresNoSignal = \false;
@@ -404,7 +404,7 @@ 
                 throw new \InvalidArgumentException('progress client option must be callable');
             }
             $conf[\CURLOPT_NOPROGRESS] = \false;
-            $conf[\CURLOPT_PROGRESSFUNCTION] = static function ($resource, int $downloadSize, int $downloaded, int $uploadSize, int $uploaded) use($progress) {
+            $conf[\CURLOPT_PROGRESSFUNCTION] = static function($resource, int $downloadSize, int $downloaded, int $uploadSize, int $uploaded) use($progress) {
                 $progress($downloadSize, $downloaded, $uploadSize, $uploaded);
             };
         }
@@ -433,14 +433,14 @@ 
                 $body->rewind();
             }
         } catch (\RuntimeException $e) {
-            $ctx['error'] = 'The connection unexpectedly failed without ' . 'providing an error. The request would have been retried, ' . 'but attempting to rewind the request body failed. ' . 'Exception: ' . $e;
+            $ctx['error'] = 'The connection unexpectedly failed without '.'providing an error. The request would have been retried, '.'but attempting to rewind the request body failed. '.'Exception: '.$e;
             return self::createRejection($easy, $ctx);
         }
         // Retry no more than 3 times before giving up.
         if (!isset($easy->options['_curl_retries'])) {
             $easy->options['_curl_retries'] = 1;
         } elseif ($easy->options['_curl_retries'] == 2) {
-            $ctx['error'] = 'The cURL request was retried 3 times ' . 'and did not succeed. The most likely reason for the failure ' . 'is that cURL was unable to rewind the body of the request ' . 'and subsequent retries resulted in the same error. Turn on ' . 'the debug option to see what went wrong. See ' . 'https://bugs.php.net/bug.php?id=47204 for more information.';
+            $ctx['error'] = 'The cURL request was retried 3 times '.'and did not succeed. The most likely reason for the failure '.'is that cURL was unable to rewind the body of the request '.'and subsequent retries resulted in the same error. Turn on '.'the debug option to see what went wrong. See '.'https://bugs.php.net/bug.php?id=47204 for more information.';
             return self::createRejection($easy, $ctx);
         } else {
             ++$easy->options['_curl_retries'];
@@ -457,7 +457,7 @@ 
         } else {
             $onHeaders = null;
         }
-        return static function ($ch, $h) use($onHeaders, $easy, &$startingResponse) {
+        return static function($ch, $h) use($onHeaders, $easy, &$startingResponse) {
             $value = \trim($h);
             if ($value === '') {
                 $startingResponse = \true;

Braces +1 added lines, -2 removed lines

@@ -16,8 +16,7 @@
  *
  * @final
  */
-class CurlFactory implements CurlFactoryInterface
-{
+class CurlFactory implements CurlFactoryInterface {
     public const CURL_VERSION_STR = 'curl_version';
     /**
      * @deprecated