nextcloud / fulltextsearch_elasticsearch

lib/Vendor/Http/Discovery/Strategy/DiscoveryStrategy.php

Indentation +11 added lines, -11 removed lines

@@ -9,15 +9,15 @@
  */
 interface DiscoveryStrategy
 {
-    /**
-     * Find a resource of a specific type.
-     *
-     * @param string $type
-     *
-     * @return array The return value is always an array with zero or more elements. Each
-     *               element is an array with two keys ['class' => string, 'condition' => mixed].
-     *
-     * @throws StrategyUnavailableException if we cannot use this strategy
-     */
-    public static function getCandidates($type);
+	/**
+	 * Find a resource of a specific type.
+	 *
+	 * @param string $type
+	 *
+	 * @return array The return value is always an array with zero or more elements. Each
+	 *               element is an array with two keys ['class' => string, 'condition' => mixed].
+	 *
+	 * @throws StrategyUnavailableException if we cannot use this strategy
+	 */
+	public static function getCandidates($type);
 }

lib/Vendor/GuzzleHttp/functions_include.php

Indentation +1 added lines, -1 removed lines

@@ -4,5 +4,5 @@
 
 // Don't redefine the functions if included multiple times.
 if (!\function_exists('OCA\\FullTextSearch_Elasticsearch\\Vendor\\GuzzleHttp\\describe_type')) {
-    require __DIR__ . '/functions.php';
+	require __DIR__ . '/functions.php';
 }

lib/Vendor/GuzzleHttp/RedirectMiddleware.php

Indentation +141 added lines, -141 removed lines

@@ -18,145 +18,145 @@
  */
 class RedirectMiddleware
 {
-    public const HISTORY_HEADER = 'X-Guzzle-Redirect-History';
-    public const STATUS_HISTORY_HEADER = 'X-Guzzle-Redirect-Status-History';
-    /**
-     * @var array
-     */
-    public static $defaultSettings = ['max' => 5, 'protocols' => ['http', 'https'], 'strict' => \false, 'referer' => \false, 'track_redirects' => \false];
-    /**
-     * @var callable(RequestInterface, array): PromiseInterface
-     */
-    private $nextHandler;
-    /**
-     * @param callable(RequestInterface, array): PromiseInterface $nextHandler Next handler to invoke.
-     */
-    public function __construct(callable $nextHandler)
-    {
-        $this->nextHandler = $nextHandler;
-    }
-    public function __invoke(RequestInterface $request, array $options) : PromiseInterface
-    {
-        $fn = $this->nextHandler;
-        if (empty($options['allow_redirects'])) {
-            return $fn($request, $options);
-        }
-        if ($options['allow_redirects'] === \true) {
-            $options['allow_redirects'] = self::$defaultSettings;
-        } elseif (!\is_array($options['allow_redirects'])) {
-            throw new \InvalidArgumentException('allow_redirects must be true, false, or array');
-        } else {
-            // Merge the default settings with the provided settings
-            $options['allow_redirects'] += self::$defaultSettings;
-        }
-        if (empty($options['allow_redirects']['max'])) {
-            return $fn($request, $options);
-        }
-        return $fn($request, $options)->then(function (ResponseInterface $response) use($request, $options) {
-            return $this->checkRedirect($request, $options, $response);
-        });
-    }
-    /**
-     * @return ResponseInterface|PromiseInterface
-     */
-    public function checkRedirect(RequestInterface $request, array $options, ResponseInterface $response)
-    {
-        if (\strpos((string) $response->getStatusCode(), '3') !== 0 || !$response->hasHeader('Location')) {
-            return $response;
-        }
-        $this->guardMax($request, $response, $options);
-        $nextRequest = $this->modifyRequest($request, $options, $response);
-        // If authorization is handled by curl, unset it if URI is cross-origin.
-        if (Psr7\UriComparator::isCrossOrigin($request->getUri(), $nextRequest->getUri()) && \defined('\\CURLOPT_HTTPAUTH')) {
-            unset($options['curl'][\CURLOPT_HTTPAUTH], $options['curl'][\CURLOPT_USERPWD]);
-        }
-        if (isset($options['allow_redirects']['on_redirect'])) {
-            $options['allow_redirects']['on_redirect']($request, $response, $nextRequest->getUri());
-        }
-        $promise = $this($nextRequest, $options);
-        // Add headers to be able to track history of redirects.
-        if (!empty($options['allow_redirects']['track_redirects'])) {
-            return $this->withTracking($promise, (string) $nextRequest->getUri(), $response->getStatusCode());
-        }
-        return $promise;
-    }
-    /**
-     * Enable tracking on promise.
-     */
-    private function withTracking(PromiseInterface $promise, string $uri, int $statusCode) : PromiseInterface
-    {
-        return $promise->then(static function (ResponseInterface $response) use($uri, $statusCode) {
-            // Note that we are pushing to the front of the list as this
-            // would be an earlier response than what is currently present
-            // in the history header.
-            $historyHeader = $response->getHeader(self::HISTORY_HEADER);
-            $statusHeader = $response->getHeader(self::STATUS_HISTORY_HEADER);
-            \array_unshift($historyHeader, $uri);
-            \array_unshift($statusHeader, (string) $statusCode);
-            return $response->withHeader(self::HISTORY_HEADER, $historyHeader)->withHeader(self::STATUS_HISTORY_HEADER, $statusHeader);
-        });
-    }
-    /**
-     * Check for too many redirects.
-     *
-     * @throws TooManyRedirectsException Too many redirects.
-     */
-    private function guardMax(RequestInterface $request, ResponseInterface $response, array &$options) : void
-    {
-        $current = $options['__redirect_count'] ?? 0;
-        $options['__redirect_count'] = $current + 1;
-        $max = $options['allow_redirects']['max'];
-        if ($options['__redirect_count'] > $max) {
-            throw new TooManyRedirectsException("Will not follow more than {$max} redirects", $request, $response);
-        }
-    }
-    public function modifyRequest(RequestInterface $request, array $options, ResponseInterface $response) : RequestInterface
-    {
-        // Request modifications to apply.
-        $modify = [];
-        $protocols = $options['allow_redirects']['protocols'];
-        // Use a GET request if this is an entity enclosing request and we are
-        // not forcing RFC compliance, but rather emulating what all browsers
-        // would do.
-        $statusCode = $response->getStatusCode();
-        if ($statusCode == 303 || $statusCode <= 302 && !$options['allow_redirects']['strict']) {
-            $safeMethods = ['GET', 'HEAD', 'OPTIONS'];
-            $requestMethod = $request->getMethod();
-            $modify['method'] = \in_array($requestMethod, $safeMethods) ? $requestMethod : 'GET';
-            $modify['body'] = '';
-        }
-        $uri = self::redirectUri($request, $response, $protocols);
-        if (isset($options['idn_conversion']) && $options['idn_conversion'] !== \false) {
-            $idnOptions = $options['idn_conversion'] === \true ? \IDNA_DEFAULT : $options['idn_conversion'];
-            $uri = Utils::idnUriConvert($uri, $idnOptions);
-        }
-        $modify['uri'] = $uri;
-        Psr7\Message::rewindBody($request);
-        // Add the Referer header if it is told to do so and only
-        // add the header if we are not redirecting from https to http.
-        if ($options['allow_redirects']['referer'] && $modify['uri']->getScheme() === $request->getUri()->getScheme()) {
-            $uri = $request->getUri()->withUserInfo('');
-            $modify['set_headers']['Referer'] = (string) $uri;
-        } else {
-            $modify['remove_headers'][] = 'Referer';
-        }
-        // Remove Authorization and Cookie headers if URI is cross-origin.
-        if (Psr7\UriComparator::isCrossOrigin($request->getUri(), $modify['uri'])) {
-            $modify['remove_headers'][] = 'Authorization';
-            $modify['remove_headers'][] = 'Cookie';
-        }
-        return Psr7\Utils::modifyRequest($request, $modify);
-    }
-    /**
-     * Set the appropriate URL on the request based on the location header.
-     */
-    private static function redirectUri(RequestInterface $request, ResponseInterface $response, array $protocols) : UriInterface
-    {
-        $location = Psr7\UriResolver::resolve($request->getUri(), new Psr7\Uri($response->getHeaderLine('Location')));
-        // Ensure that the redirect URI is allowed based on the protocols.
-        if (!\in_array($location->getScheme(), $protocols)) {
-            throw new BadResponseException(\sprintf('Redirect URI, %s, does not use one of the allowed redirect protocols: %s', $location, \implode(', ', $protocols)), $request, $response);
-        }
-        return $location;
-    }
+	public const HISTORY_HEADER = 'X-Guzzle-Redirect-History';
+	public const STATUS_HISTORY_HEADER = 'X-Guzzle-Redirect-Status-History';
+	/**
+	 * @var array
+	 */
+	public static $defaultSettings = ['max' => 5, 'protocols' => ['http', 'https'], 'strict' => \false, 'referer' => \false, 'track_redirects' => \false];
+	/**
+	 * @var callable(RequestInterface, array): PromiseInterface
+	 */
+	private $nextHandler;
+	/**
+	 * @param callable(RequestInterface, array): PromiseInterface $nextHandler Next handler to invoke.
+	 */
+	public function __construct(callable $nextHandler)
+	{
+		$this->nextHandler = $nextHandler;
+	}
+	public function __invoke(RequestInterface $request, array $options) : PromiseInterface
+	{
+		$fn = $this->nextHandler;
+		if (empty($options['allow_redirects'])) {
+			return $fn($request, $options);
+		}
+		if ($options['allow_redirects'] === \true) {
+			$options['allow_redirects'] = self::$defaultSettings;
+		} elseif (!\is_array($options['allow_redirects'])) {
+			throw new \InvalidArgumentException('allow_redirects must be true, false, or array');
+		} else {
+			// Merge the default settings with the provided settings
+			$options['allow_redirects'] += self::$defaultSettings;
+		}
+		if (empty($options['allow_redirects']['max'])) {
+			return $fn($request, $options);
+		}
+		return $fn($request, $options)->then(function (ResponseInterface $response) use($request, $options) {
+			return $this->checkRedirect($request, $options, $response);
+		});
+	}
+	/**
+	 * @return ResponseInterface|PromiseInterface
+	 */
+	public function checkRedirect(RequestInterface $request, array $options, ResponseInterface $response)
+	{
+		if (\strpos((string) $response->getStatusCode(), '3') !== 0 || !$response->hasHeader('Location')) {
+			return $response;
+		}
+		$this->guardMax($request, $response, $options);
+		$nextRequest = $this->modifyRequest($request, $options, $response);
+		// If authorization is handled by curl, unset it if URI is cross-origin.
+		if (Psr7\UriComparator::isCrossOrigin($request->getUri(), $nextRequest->getUri()) && \defined('\\CURLOPT_HTTPAUTH')) {
+			unset($options['curl'][\CURLOPT_HTTPAUTH], $options['curl'][\CURLOPT_USERPWD]);
+		}
+		if (isset($options['allow_redirects']['on_redirect'])) {
+			$options['allow_redirects']['on_redirect']($request, $response, $nextRequest->getUri());
+		}
+		$promise = $this($nextRequest, $options);
+		// Add headers to be able to track history of redirects.
+		if (!empty($options['allow_redirects']['track_redirects'])) {
+			return $this->withTracking($promise, (string) $nextRequest->getUri(), $response->getStatusCode());
+		}
+		return $promise;
+	}
+	/**
+	 * Enable tracking on promise.
+	 */
+	private function withTracking(PromiseInterface $promise, string $uri, int $statusCode) : PromiseInterface
+	{
+		return $promise->then(static function (ResponseInterface $response) use($uri, $statusCode) {
+			// Note that we are pushing to the front of the list as this
+			// would be an earlier response than what is currently present
+			// in the history header.
+			$historyHeader = $response->getHeader(self::HISTORY_HEADER);
+			$statusHeader = $response->getHeader(self::STATUS_HISTORY_HEADER);
+			\array_unshift($historyHeader, $uri);
+			\array_unshift($statusHeader, (string) $statusCode);
+			return $response->withHeader(self::HISTORY_HEADER, $historyHeader)->withHeader(self::STATUS_HISTORY_HEADER, $statusHeader);
+		});
+	}
+	/**
+	 * Check for too many redirects.
+	 *
+	 * @throws TooManyRedirectsException Too many redirects.
+	 */
+	private function guardMax(RequestInterface $request, ResponseInterface $response, array &$options) : void
+	{
+		$current = $options['__redirect_count'] ?? 0;
+		$options['__redirect_count'] = $current + 1;
+		$max = $options['allow_redirects']['max'];
+		if ($options['__redirect_count'] > $max) {
+			throw new TooManyRedirectsException("Will not follow more than {$max} redirects", $request, $response);
+		}
+	}
+	public function modifyRequest(RequestInterface $request, array $options, ResponseInterface $response) : RequestInterface
+	{
+		// Request modifications to apply.
+		$modify = [];
+		$protocols = $options['allow_redirects']['protocols'];
+		// Use a GET request if this is an entity enclosing request and we are
+		// not forcing RFC compliance, but rather emulating what all browsers
+		// would do.
+		$statusCode = $response->getStatusCode();
+		if ($statusCode == 303 || $statusCode <= 302 && !$options['allow_redirects']['strict']) {
+			$safeMethods = ['GET', 'HEAD', 'OPTIONS'];
+			$requestMethod = $request->getMethod();
+			$modify['method'] = \in_array($requestMethod, $safeMethods) ? $requestMethod : 'GET';
+			$modify['body'] = '';
+		}
+		$uri = self::redirectUri($request, $response, $protocols);
+		if (isset($options['idn_conversion']) && $options['idn_conversion'] !== \false) {
+			$idnOptions = $options['idn_conversion'] === \true ? \IDNA_DEFAULT : $options['idn_conversion'];
+			$uri = Utils::idnUriConvert($uri, $idnOptions);
+		}
+		$modify['uri'] = $uri;
+		Psr7\Message::rewindBody($request);
+		// Add the Referer header if it is told to do so and only
+		// add the header if we are not redirecting from https to http.
+		if ($options['allow_redirects']['referer'] && $modify['uri']->getScheme() === $request->getUri()->getScheme()) {
+			$uri = $request->getUri()->withUserInfo('');
+			$modify['set_headers']['Referer'] = (string) $uri;
+		} else {
+			$modify['remove_headers'][] = 'Referer';
+		}
+		// Remove Authorization and Cookie headers if URI is cross-origin.
+		if (Psr7\UriComparator::isCrossOrigin($request->getUri(), $modify['uri'])) {
+			$modify['remove_headers'][] = 'Authorization';
+			$modify['remove_headers'][] = 'Cookie';
+		}
+		return Psr7\Utils::modifyRequest($request, $modify);
+	}
+	/**
+	 * Set the appropriate URL on the request based on the location header.
+	 */
+	private static function redirectUri(RequestInterface $request, ResponseInterface $response, array $protocols) : UriInterface
+	{
+		$location = Psr7\UriResolver::resolve($request->getUri(), new Psr7\Uri($response->getHeaderLine('Location')));
+		// Ensure that the redirect URI is allowed based on the protocols.
+		if (!\in_array($location->getScheme(), $protocols)) {
+			throw new BadResponseException(\sprintf('Redirect URI, %s, does not use one of the allowed redirect protocols: %s', $location, \implode(', ', $protocols)), $request, $response);
+		}
+		return $location;
+	}
 }

lib/Vendor/GuzzleHttp/BodySummarizerInterface.php

Indentation +4 added lines, -4 removed lines

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

lib/Vendor/GuzzleHttp/Psr7/Header.php

Indentation +109 added lines, -109 removed lines

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

lib/Vendor/GuzzleHttp/Psr7/PumpStream.php

Indentation +130 added lines, -130 removed lines

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

lib/Vendor/GuzzleHttp/Psr7/Rfc7230.php

Indentation +11 added lines, -11 removed lines

@@ -8,15 +8,15 @@
  */
 final class Rfc7230
 {
-    /**
-     * Header related regular expressions (based on amphp/http package)
-     *
-     * Note: header delimiter (\r\n) is modified to \r?\n to accept line feed only delimiters for BC reasons.
-     *
-     * @see https://github.com/amphp/http/blob/v1.0.1/src/Rfc7230.php#L12-L15
-     *
-     * @license https://github.com/amphp/http/blob/v1.0.1/LICENSE
-     */
-    public const HEADER_REGEX = "(^([^()<>@,;:\\\"/[\\]?={}\x01- ]++):[ \t]*+((?:[ \t]*+[!-~\x80-\xff]++)*+)[ \t]*+\r?\n)m";
-    public const HEADER_FOLD_REGEX = "(\r?\n[ \t]++)";
+	/**
+	 * Header related regular expressions (based on amphp/http package)
+	 *
+	 * Note: header delimiter (\r\n) is modified to \r?\n to accept line feed only delimiters for BC reasons.
+	 *
+	 * @see https://github.com/amphp/http/blob/v1.0.1/src/Rfc7230.php#L12-L15
+	 *
+	 * @license https://github.com/amphp/http/blob/v1.0.1/LICENSE
+	 */
+	public const HEADER_REGEX = "(^([^()<>@,;:\\\"/[\\]?={}\x01- ]++):[ \t]*+((?:[ \t]*+[!-~\x80-\xff]++)*+)[ \t]*+\r?\n)m";
+	public const HEADER_FOLD_REGEX = "(\r?\n[ \t]++)";
 }

lib/Vendor/GuzzleHttp/Psr7/FnStream.php

Indentation +133 added lines, -133 removed lines

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

lib/Vendor/GuzzleHttp/Psr7/NoSeekStream.php

Indentation +11 added lines, -11 removed lines

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