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

Indentation +384 added lines, -384 removed lines

@@ -15,388 +15,388 @@
  */
 class Client implements ClientInterface, \OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Client\ClientInterface
 {
-    use ClientTrait;
-    /**
-     * @var array Default request options
-     */
-    private $config;
-    /**
-     * Clients accept an array of constructor parameters.
-     *
-     * Here's an example of creating a client using a base_uri and an array of
-     * default request options to apply to each request:
-     *
-     *     $client = new Client([
-     *         'base_uri'        => 'http://www.foo.com/1.0/',
-     *         'timeout'         => 0,
-     *         'allow_redirects' => false,
-     *         'proxy'           => '192.168.16.1:10'
-     *     ]);
-     *
-     * Client configuration settings include the following options:
-     *
-     * - handler: (callable) Function that transfers HTTP requests over the
-     *   wire. The function is called with a Psr7\Http\Message\RequestInterface
-     *   and array of transfer options, and must return a
-     *   GuzzleHttp\Promise\PromiseInterface that is fulfilled with a
-     *   Psr7\Http\Message\ResponseInterface on success.
-     *   If no handler is provided, a default handler will be created
-     *   that enables all of the request options below by attaching all of the
-     *   default middleware to the handler.
-     * - base_uri: (string|UriInterface) Base URI of the client that is merged
-     *   into relative URIs. Can be a string or instance of UriInterface.
-     * - **: any request option
-     *
-     * @param array $config Client configuration settings.
-     *
-     * @see \GuzzleHttp\RequestOptions for a list of available request options.
-     */
-    public function __construct(array $config = [])
-    {
-        if (!isset($config['handler'])) {
-            $config['handler'] = HandlerStack::create();
-        } elseif (!\is_callable($config['handler'])) {
-            throw new InvalidArgumentException('handler must be a callable');
-        }
-        // Convert the base_uri to a UriInterface
-        if (isset($config['base_uri'])) {
-            $config['base_uri'] = Psr7\Utils::uriFor($config['base_uri']);
-        }
-        $this->configureDefaults($config);
-    }
-    /**
-     * @param string $method
-     * @param array  $args
-     *
-     * @return PromiseInterface|ResponseInterface
-     *
-     * @deprecated Client::__call will be removed in guzzlehttp/guzzle:8.0.
-     */
-    public function __call($method, $args)
-    {
-        if (\count($args) < 1) {
-            throw new InvalidArgumentException('Magic request methods require a URI and optional options array');
-        }
-        $uri = $args[0];
-        $opts = $args[1] ?? [];
-        return \substr($method, -5) === 'Async' ? $this->requestAsync(\substr($method, 0, -5), $uri, $opts) : $this->request($method, $uri, $opts);
-    }
-    /**
-     * Asynchronously send an HTTP request.
-     *
-     * @param array $options Request options to apply to the given
-     *                       request and to the transfer. See \GuzzleHttp\RequestOptions.
-     */
-    public function sendAsync(RequestInterface $request, array $options = []) : PromiseInterface
-    {
-        // Merge the base URI into the request URI if needed.
-        $options = $this->prepareDefaults($options);
-        return $this->transfer($request->withUri($this->buildUri($request->getUri(), $options), $request->hasHeader('Host')), $options);
-    }
-    /**
-     * Send an HTTP request.
-     *
-     * @param array $options Request options to apply to the given
-     *                       request and to the transfer. See \GuzzleHttp\RequestOptions.
-     *
-     * @throws GuzzleException
-     */
-    public function send(RequestInterface $request, array $options = []) : ResponseInterface
-    {
-        $options[RequestOptions::SYNCHRONOUS] = \true;
-        return $this->sendAsync($request, $options)->wait();
-    }
-    /**
-     * The HttpClient PSR (PSR-18) specify this method.
-     *
-     * {@inheritDoc}
-     */
-    public function sendRequest(RequestInterface $request) : ResponseInterface
-    {
-        $options[RequestOptions::SYNCHRONOUS] = \true;
-        $options[RequestOptions::ALLOW_REDIRECTS] = \false;
-        $options[RequestOptions::HTTP_ERRORS] = \false;
-        return $this->sendAsync($request, $options)->wait();
-    }
-    /**
-     * Create and send an asynchronous HTTP request.
-     *
-     * Use an absolute path to override the base path of the client, or a
-     * relative path to append to the base path of the client. The URL can
-     * contain the query string as well. Use an array to provide a URL
-     * template and additional variables to use in the URL template expansion.
-     *
-     * @param string              $method  HTTP method
-     * @param string|UriInterface $uri     URI object or string.
-     * @param array               $options Request options to apply. See \GuzzleHttp\RequestOptions.
-     */
-    public function requestAsync(string $method, $uri = '', array $options = []) : PromiseInterface
-    {
-        $options = $this->prepareDefaults($options);
-        // Remove request modifying parameter because it can be done up-front.
-        $headers = $options['headers'] ?? [];
-        $body = $options['body'] ?? null;
-        $version = $options['version'] ?? '1.1';
-        // Merge the URI into the base URI.
-        $uri = $this->buildUri(Psr7\Utils::uriFor($uri), $options);
-        if (\is_array($body)) {
-            throw $this->invalidBody();
-        }
-        $request = new Psr7\Request($method, $uri, $headers, $body, $version);
-        // Remove the option so that they are not doubly-applied.
-        unset($options['headers'], $options['body'], $options['version']);
-        return $this->transfer($request, $options);
-    }
-    /**
-     * Create and send an HTTP request.
-     *
-     * Use an absolute path to override the base path of the client, or a
-     * relative path to append to the base path of the client. The URL can
-     * contain the query string as well.
-     *
-     * @param string              $method  HTTP method.
-     * @param string|UriInterface $uri     URI object or string.
-     * @param array               $options Request options to apply. See \GuzzleHttp\RequestOptions.
-     *
-     * @throws GuzzleException
-     */
-    public function request(string $method, $uri = '', array $options = []) : ResponseInterface
-    {
-        $options[RequestOptions::SYNCHRONOUS] = \true;
-        return $this->requestAsync($method, $uri, $options)->wait();
-    }
-    /**
-     * Get a client configuration option.
-     *
-     * These options include default request options of the client, a "handler"
-     * (if utilized by the concrete client), and a "base_uri" if utilized by
-     * the concrete client.
-     *
-     * @param string|null $option The config option to retrieve.
-     *
-     * @return mixed
-     *
-     * @deprecated Client::getConfig will be removed in guzzlehttp/guzzle:8.0.
-     */
-    public function getConfig(string $option = null)
-    {
-        return $option === null ? $this->config : $this->config[$option] ?? null;
-    }
-    private function buildUri(UriInterface $uri, array $config) : UriInterface
-    {
-        if (isset($config['base_uri'])) {
-            $uri = Psr7\UriResolver::resolve(Psr7\Utils::uriFor($config['base_uri']), $uri);
-        }
-        if (isset($config['idn_conversion']) && $config['idn_conversion'] !== \false) {
-            $idnOptions = $config['idn_conversion'] === \true ? \IDNA_DEFAULT : $config['idn_conversion'];
-            $uri = Utils::idnUriConvert($uri, $idnOptions);
-        }
-        return $uri->getScheme() === '' && $uri->getHost() !== '' ? $uri->withScheme('http') : $uri;
-    }
-    /**
-     * Configures the default options for a client.
-     */
-    private function configureDefaults(array $config) : void
-    {
-        $defaults = ['allow_redirects' => RedirectMiddleware::$defaultSettings, 'http_errors' => \true, 'decode_content' => \true, 'verify' => \true, 'cookies' => \false, 'idn_conversion' => \false];
-        // Use the standard Linux HTTP_PROXY and HTTPS_PROXY if set.
-        // We can only trust the HTTP_PROXY environment variable in a CLI
-        // process due to the fact that PHP has no reliable mechanism to
-        // get environment variables that start with "HTTP_".
-        if (\PHP_SAPI === 'cli' && ($proxy = Utils::getenv('HTTP_PROXY'))) {
-            $defaults['proxy']['http'] = $proxy;
-        }
-        if ($proxy = Utils::getenv('HTTPS_PROXY')) {
-            $defaults['proxy']['https'] = $proxy;
-        }
-        if ($noProxy = Utils::getenv('NO_PROXY')) {
-            $cleanedNoProxy = \str_replace(' ', '', $noProxy);
-            $defaults['proxy']['no'] = \explode(',', $cleanedNoProxy);
-        }
-        $this->config = $config + $defaults;
-        if (!empty($config['cookies']) && $config['cookies'] === \true) {
-            $this->config['cookies'] = new CookieJar();
-        }
-        // Add the default user-agent header.
-        if (!isset($this->config['headers'])) {
-            $this->config['headers'] = ['User-Agent' => Utils::defaultUserAgent()];
-        } else {
-            // Add the User-Agent header if one was not already set.
-            foreach (\array_keys($this->config['headers']) as $name) {
-                if (\strtolower($name) === 'user-agent') {
-                    return;
-                }
-            }
-            $this->config['headers']['User-Agent'] = Utils::defaultUserAgent();
-        }
-    }
-    /**
-     * Merges default options into the array.
-     *
-     * @param array $options Options to modify by reference
-     */
-    private function prepareDefaults(array $options) : array
-    {
-        $defaults = $this->config;
-        if (!empty($defaults['headers'])) {
-            // Default headers are only added if they are not present.
-            $defaults['_conditional'] = $defaults['headers'];
-            unset($defaults['headers']);
-        }
-        // Special handling for headers is required as they are added as
-        // conditional headers and as headers passed to a request ctor.
-        if (\array_key_exists('headers', $options)) {
-            // Allows default headers to be unset.
-            if ($options['headers'] === null) {
-                $defaults['_conditional'] = [];
-                unset($options['headers']);
-            } elseif (!\is_array($options['headers'])) {
-                throw new InvalidArgumentException('headers must be an array');
-            }
-        }
-        // Shallow merge defaults underneath options.
-        $result = $options + $defaults;
-        // Remove null values.
-        foreach ($result as $k => $v) {
-            if ($v === null) {
-                unset($result[$k]);
-            }
-        }
-        return $result;
-    }
-    /**
-     * Transfers the given request and applies request options.
-     *
-     * The URI of the request is not modified and the request options are used
-     * as-is without merging in default options.
-     *
-     * @param array $options See \GuzzleHttp\RequestOptions.
-     */
-    private function transfer(RequestInterface $request, array $options) : PromiseInterface
-    {
-        $request = $this->applyOptions($request, $options);
-        /** @var HandlerStack $handler */
-        $handler = $options['handler'];
-        try {
-            return P\Create::promiseFor($handler($request, $options));
-        } catch (\Exception $e) {
-            return P\Create::rejectionFor($e);
-        }
-    }
-    /**
-     * Applies the array of request options to a request.
-     */
-    private function applyOptions(RequestInterface $request, array &$options) : RequestInterface
-    {
-        $modify = ['set_headers' => []];
-        if (isset($options['headers'])) {
-            if (\array_keys($options['headers']) === \range(0, \count($options['headers']) - 1)) {
-                throw new InvalidArgumentException('The headers array must have header name as keys.');
-            }
-            $modify['set_headers'] = $options['headers'];
-            unset($options['headers']);
-        }
-        if (isset($options['form_params'])) {
-            if (isset($options['multipart'])) {
-                throw new InvalidArgumentException('You cannot use ' . 'form_params and multipart at the same time. Use the ' . 'form_params option if you want to send application/' . 'x-www-form-urlencoded requests, and the multipart ' . 'option to send multipart/form-data requests.');
-            }
-            $options['body'] = \http_build_query($options['form_params'], '', '&');
-            unset($options['form_params']);
-            // Ensure that we don't have the header in different case and set the new value.
-            $options['_conditional'] = Psr7\Utils::caselessRemove(['Content-Type'], $options['_conditional']);
-            $options['_conditional']['Content-Type'] = 'application/x-www-form-urlencoded';
-        }
-        if (isset($options['multipart'])) {
-            $options['body'] = new Psr7\MultipartStream($options['multipart']);
-            unset($options['multipart']);
-        }
-        if (isset($options['json'])) {
-            $options['body'] = Utils::jsonEncode($options['json']);
-            unset($options['json']);
-            // Ensure that we don't have the header in different case and set the new value.
-            $options['_conditional'] = Psr7\Utils::caselessRemove(['Content-Type'], $options['_conditional']);
-            $options['_conditional']['Content-Type'] = 'application/json';
-        }
-        if (!empty($options['decode_content']) && $options['decode_content'] !== \true) {
-            // Ensure that we don't have the header in different case and set the new value.
-            $options['_conditional'] = Psr7\Utils::caselessRemove(['Accept-Encoding'], $options['_conditional']);
-            $modify['set_headers']['Accept-Encoding'] = $options['decode_content'];
-        }
-        if (isset($options['body'])) {
-            if (\is_array($options['body'])) {
-                throw $this->invalidBody();
-            }
-            $modify['body'] = Psr7\Utils::streamFor($options['body']);
-            unset($options['body']);
-        }
-        if (!empty($options['auth']) && \is_array($options['auth'])) {
-            $value = $options['auth'];
-            $type = isset($value[2]) ? \strtolower($value[2]) : 'basic';
-            switch ($type) {
-                case 'basic':
-                    // Ensure that we don't have the header in different case and set the new value.
-                    $modify['set_headers'] = Psr7\Utils::caselessRemove(['Authorization'], $modify['set_headers']);
-                    $modify['set_headers']['Authorization'] = 'Basic ' . \base64_encode("{$value[0]}:{$value[1]}");
-                    break;
-                case 'digest':
-                    // @todo: Do not rely on curl
-                    $options['curl'][\CURLOPT_HTTPAUTH] = \CURLAUTH_DIGEST;
-                    $options['curl'][\CURLOPT_USERPWD] = "{$value[0]}:{$value[1]}";
-                    break;
-                case 'ntlm':
-                    $options['curl'][\CURLOPT_HTTPAUTH] = \CURLAUTH_NTLM;
-                    $options['curl'][\CURLOPT_USERPWD] = "{$value[0]}:{$value[1]}";
-                    break;
-            }
-        }
-        if (isset($options['query'])) {
-            $value = $options['query'];
-            if (\is_array($value)) {
-                $value = \http_build_query($value, '', '&', \PHP_QUERY_RFC3986);
-            }
-            if (!\is_string($value)) {
-                throw new InvalidArgumentException('query must be a string or array');
-            }
-            $modify['query'] = $value;
-            unset($options['query']);
-        }
-        // Ensure that sink is not an invalid value.
-        if (isset($options['sink'])) {
-            // TODO: Add more sink validation?
-            if (\is_bool($options['sink'])) {
-                throw new InvalidArgumentException('sink must not be a boolean');
-            }
-        }
-        if (isset($options['version'])) {
-            $modify['version'] = $options['version'];
-        }
-        $request = Psr7\Utils::modifyRequest($request, $modify);
-        if ($request->getBody() instanceof Psr7\MultipartStream) {
-            // Use a multipart/form-data POST if a Content-Type is not set.
-            // Ensure that we don't have the header in different case and set the new value.
-            $options['_conditional'] = Psr7\Utils::caselessRemove(['Content-Type'], $options['_conditional']);
-            $options['_conditional']['Content-Type'] = 'multipart/form-data; boundary=' . $request->getBody()->getBoundary();
-        }
-        // Merge in conditional headers if they are not present.
-        if (isset($options['_conditional'])) {
-            // Build up the changes so it's in a single clone of the message.
-            $modify = [];
-            foreach ($options['_conditional'] as $k => $v) {
-                if (!$request->hasHeader($k)) {
-                    $modify['set_headers'][$k] = $v;
-                }
-            }
-            $request = Psr7\Utils::modifyRequest($request, $modify);
-            // Don't pass this internal value along to middleware/handlers.
-            unset($options['_conditional']);
-        }
-        return $request;
-    }
-    /**
-     * Return an InvalidArgumentException with pre-set message.
-     */
-    private function invalidBody() : InvalidArgumentException
-    {
-        return new InvalidArgumentException('Passing in the "body" request ' . 'option as an array to send a request is not supported. ' . 'Please use the "form_params" request option to send a ' . 'application/x-www-form-urlencoded request, or the "multipart" ' . 'request option to send a multipart/form-data request.');
-    }
+	use ClientTrait;
+	/**
+	 * @var array Default request options
+	 */
+	private $config;
+	/**
+	 * Clients accept an array of constructor parameters.
+	 *
+	 * Here's an example of creating a client using a base_uri and an array of
+	 * default request options to apply to each request:
+	 *
+	 *     $client = new Client([
+	 *         'base_uri'        => 'http://www.foo.com/1.0/',
+	 *         'timeout'         => 0,
+	 *         'allow_redirects' => false,
+	 *         'proxy'           => '192.168.16.1:10'
+	 *     ]);
+	 *
+	 * Client configuration settings include the following options:
+	 *
+	 * - handler: (callable) Function that transfers HTTP requests over the
+	 *   wire. The function is called with a Psr7\Http\Message\RequestInterface
+	 *   and array of transfer options, and must return a
+	 *   GuzzleHttp\Promise\PromiseInterface that is fulfilled with a
+	 *   Psr7\Http\Message\ResponseInterface on success.
+	 *   If no handler is provided, a default handler will be created
+	 *   that enables all of the request options below by attaching all of the
+	 *   default middleware to the handler.
+	 * - base_uri: (string|UriInterface) Base URI of the client that is merged
+	 *   into relative URIs. Can be a string or instance of UriInterface.
+	 * - **: any request option
+	 *
+	 * @param array $config Client configuration settings.
+	 *
+	 * @see \GuzzleHttp\RequestOptions for a list of available request options.
+	 */
+	public function __construct(array $config = [])
+	{
+		if (!isset($config['handler'])) {
+			$config['handler'] = HandlerStack::create();
+		} elseif (!\is_callable($config['handler'])) {
+			throw new InvalidArgumentException('handler must be a callable');
+		}
+		// Convert the base_uri to a UriInterface
+		if (isset($config['base_uri'])) {
+			$config['base_uri'] = Psr7\Utils::uriFor($config['base_uri']);
+		}
+		$this->configureDefaults($config);
+	}
+	/**
+	 * @param string $method
+	 * @param array  $args
+	 *
+	 * @return PromiseInterface|ResponseInterface
+	 *
+	 * @deprecated Client::__call will be removed in guzzlehttp/guzzle:8.0.
+	 */
+	public function __call($method, $args)
+	{
+		if (\count($args) < 1) {
+			throw new InvalidArgumentException('Magic request methods require a URI and optional options array');
+		}
+		$uri = $args[0];
+		$opts = $args[1] ?? [];
+		return \substr($method, -5) === 'Async' ? $this->requestAsync(\substr($method, 0, -5), $uri, $opts) : $this->request($method, $uri, $opts);
+	}
+	/**
+	 * Asynchronously send an HTTP request.
+	 *
+	 * @param array $options Request options to apply to the given
+	 *                       request and to the transfer. See \GuzzleHttp\RequestOptions.
+	 */
+	public function sendAsync(RequestInterface $request, array $options = []) : PromiseInterface
+	{
+		// Merge the base URI into the request URI if needed.
+		$options = $this->prepareDefaults($options);
+		return $this->transfer($request->withUri($this->buildUri($request->getUri(), $options), $request->hasHeader('Host')), $options);
+	}
+	/**
+	 * Send an HTTP request.
+	 *
+	 * @param array $options Request options to apply to the given
+	 *                       request and to the transfer. See \GuzzleHttp\RequestOptions.
+	 *
+	 * @throws GuzzleException
+	 */
+	public function send(RequestInterface $request, array $options = []) : ResponseInterface
+	{
+		$options[RequestOptions::SYNCHRONOUS] = \true;
+		return $this->sendAsync($request, $options)->wait();
+	}
+	/**
+	 * The HttpClient PSR (PSR-18) specify this method.
+	 *
+	 * {@inheritDoc}
+	 */
+	public function sendRequest(RequestInterface $request) : ResponseInterface
+	{
+		$options[RequestOptions::SYNCHRONOUS] = \true;
+		$options[RequestOptions::ALLOW_REDIRECTS] = \false;
+		$options[RequestOptions::HTTP_ERRORS] = \false;
+		return $this->sendAsync($request, $options)->wait();
+	}
+	/**
+	 * Create and send an asynchronous HTTP request.
+	 *
+	 * Use an absolute path to override the base path of the client, or a
+	 * relative path to append to the base path of the client. The URL can
+	 * contain the query string as well. Use an array to provide a URL
+	 * template and additional variables to use in the URL template expansion.
+	 *
+	 * @param string              $method  HTTP method
+	 * @param string|UriInterface $uri     URI object or string.
+	 * @param array               $options Request options to apply. See \GuzzleHttp\RequestOptions.
+	 */
+	public function requestAsync(string $method, $uri = '', array $options = []) : PromiseInterface
+	{
+		$options = $this->prepareDefaults($options);
+		// Remove request modifying parameter because it can be done up-front.
+		$headers = $options['headers'] ?? [];
+		$body = $options['body'] ?? null;
+		$version = $options['version'] ?? '1.1';
+		// Merge the URI into the base URI.
+		$uri = $this->buildUri(Psr7\Utils::uriFor($uri), $options);
+		if (\is_array($body)) {
+			throw $this->invalidBody();
+		}
+		$request = new Psr7\Request($method, $uri, $headers, $body, $version);
+		// Remove the option so that they are not doubly-applied.
+		unset($options['headers'], $options['body'], $options['version']);
+		return $this->transfer($request, $options);
+	}
+	/**
+	 * Create and send an HTTP request.
+	 *
+	 * Use an absolute path to override the base path of the client, or a
+	 * relative path to append to the base path of the client. The URL can
+	 * contain the query string as well.
+	 *
+	 * @param string              $method  HTTP method.
+	 * @param string|UriInterface $uri     URI object or string.
+	 * @param array               $options Request options to apply. See \GuzzleHttp\RequestOptions.
+	 *
+	 * @throws GuzzleException
+	 */
+	public function request(string $method, $uri = '', array $options = []) : ResponseInterface
+	{
+		$options[RequestOptions::SYNCHRONOUS] = \true;
+		return $this->requestAsync($method, $uri, $options)->wait();
+	}
+	/**
+	 * Get a client configuration option.
+	 *
+	 * These options include default request options of the client, a "handler"
+	 * (if utilized by the concrete client), and a "base_uri" if utilized by
+	 * the concrete client.
+	 *
+	 * @param string|null $option The config option to retrieve.
+	 *
+	 * @return mixed
+	 *
+	 * @deprecated Client::getConfig will be removed in guzzlehttp/guzzle:8.0.
+	 */
+	public function getConfig(string $option = null)
+	{
+		return $option === null ? $this->config : $this->config[$option] ?? null;
+	}
+	private function buildUri(UriInterface $uri, array $config) : UriInterface
+	{
+		if (isset($config['base_uri'])) {
+			$uri = Psr7\UriResolver::resolve(Psr7\Utils::uriFor($config['base_uri']), $uri);
+		}
+		if (isset($config['idn_conversion']) && $config['idn_conversion'] !== \false) {
+			$idnOptions = $config['idn_conversion'] === \true ? \IDNA_DEFAULT : $config['idn_conversion'];
+			$uri = Utils::idnUriConvert($uri, $idnOptions);
+		}
+		return $uri->getScheme() === '' && $uri->getHost() !== '' ? $uri->withScheme('http') : $uri;
+	}
+	/**
+	 * Configures the default options for a client.
+	 */
+	private function configureDefaults(array $config) : void
+	{
+		$defaults = ['allow_redirects' => RedirectMiddleware::$defaultSettings, 'http_errors' => \true, 'decode_content' => \true, 'verify' => \true, 'cookies' => \false, 'idn_conversion' => \false];
+		// Use the standard Linux HTTP_PROXY and HTTPS_PROXY if set.
+		// We can only trust the HTTP_PROXY environment variable in a CLI
+		// process due to the fact that PHP has no reliable mechanism to
+		// get environment variables that start with "HTTP_".
+		if (\PHP_SAPI === 'cli' && ($proxy = Utils::getenv('HTTP_PROXY'))) {
+			$defaults['proxy']['http'] = $proxy;
+		}
+		if ($proxy = Utils::getenv('HTTPS_PROXY')) {
+			$defaults['proxy']['https'] = $proxy;
+		}
+		if ($noProxy = Utils::getenv('NO_PROXY')) {
+			$cleanedNoProxy = \str_replace(' ', '', $noProxy);
+			$defaults['proxy']['no'] = \explode(',', $cleanedNoProxy);
+		}
+		$this->config = $config + $defaults;
+		if (!empty($config['cookies']) && $config['cookies'] === \true) {
+			$this->config['cookies'] = new CookieJar();
+		}
+		// Add the default user-agent header.
+		if (!isset($this->config['headers'])) {
+			$this->config['headers'] = ['User-Agent' => Utils::defaultUserAgent()];
+		} else {
+			// Add the User-Agent header if one was not already set.
+			foreach (\array_keys($this->config['headers']) as $name) {
+				if (\strtolower($name) === 'user-agent') {
+					return;
+				}
+			}
+			$this->config['headers']['User-Agent'] = Utils::defaultUserAgent();
+		}
+	}
+	/**
+	 * Merges default options into the array.
+	 *
+	 * @param array $options Options to modify by reference
+	 */
+	private function prepareDefaults(array $options) : array
+	{
+		$defaults = $this->config;
+		if (!empty($defaults['headers'])) {
+			// Default headers are only added if they are not present.
+			$defaults['_conditional'] = $defaults['headers'];
+			unset($defaults['headers']);
+		}
+		// Special handling for headers is required as they are added as
+		// conditional headers and as headers passed to a request ctor.
+		if (\array_key_exists('headers', $options)) {
+			// Allows default headers to be unset.
+			if ($options['headers'] === null) {
+				$defaults['_conditional'] = [];
+				unset($options['headers']);
+			} elseif (!\is_array($options['headers'])) {
+				throw new InvalidArgumentException('headers must be an array');
+			}
+		}
+		// Shallow merge defaults underneath options.
+		$result = $options + $defaults;
+		// Remove null values.
+		foreach ($result as $k => $v) {
+			if ($v === null) {
+				unset($result[$k]);
+			}
+		}
+		return $result;
+	}
+	/**
+	 * Transfers the given request and applies request options.
+	 *
+	 * The URI of the request is not modified and the request options are used
+	 * as-is without merging in default options.
+	 *
+	 * @param array $options See \GuzzleHttp\RequestOptions.
+	 */
+	private function transfer(RequestInterface $request, array $options) : PromiseInterface
+	{
+		$request = $this->applyOptions($request, $options);
+		/** @var HandlerStack $handler */
+		$handler = $options['handler'];
+		try {
+			return P\Create::promiseFor($handler($request, $options));
+		} catch (\Exception $e) {
+			return P\Create::rejectionFor($e);
+		}
+	}
+	/**
+	 * Applies the array of request options to a request.
+	 */
+	private function applyOptions(RequestInterface $request, array &$options) : RequestInterface
+	{
+		$modify = ['set_headers' => []];
+		if (isset($options['headers'])) {
+			if (\array_keys($options['headers']) === \range(0, \count($options['headers']) - 1)) {
+				throw new InvalidArgumentException('The headers array must have header name as keys.');
+			}
+			$modify['set_headers'] = $options['headers'];
+			unset($options['headers']);
+		}
+		if (isset($options['form_params'])) {
+			if (isset($options['multipart'])) {
+				throw new InvalidArgumentException('You cannot use ' . 'form_params and multipart at the same time. Use the ' . 'form_params option if you want to send application/' . 'x-www-form-urlencoded requests, and the multipart ' . 'option to send multipart/form-data requests.');
+			}
+			$options['body'] = \http_build_query($options['form_params'], '', '&');
+			unset($options['form_params']);
+			// Ensure that we don't have the header in different case and set the new value.
+			$options['_conditional'] = Psr7\Utils::caselessRemove(['Content-Type'], $options['_conditional']);
+			$options['_conditional']['Content-Type'] = 'application/x-www-form-urlencoded';
+		}
+		if (isset($options['multipart'])) {
+			$options['body'] = new Psr7\MultipartStream($options['multipart']);
+			unset($options['multipart']);
+		}
+		if (isset($options['json'])) {
+			$options['body'] = Utils::jsonEncode($options['json']);
+			unset($options['json']);
+			// Ensure that we don't have the header in different case and set the new value.
+			$options['_conditional'] = Psr7\Utils::caselessRemove(['Content-Type'], $options['_conditional']);
+			$options['_conditional']['Content-Type'] = 'application/json';
+		}
+		if (!empty($options['decode_content']) && $options['decode_content'] !== \true) {
+			// Ensure that we don't have the header in different case and set the new value.
+			$options['_conditional'] = Psr7\Utils::caselessRemove(['Accept-Encoding'], $options['_conditional']);
+			$modify['set_headers']['Accept-Encoding'] = $options['decode_content'];
+		}
+		if (isset($options['body'])) {
+			if (\is_array($options['body'])) {
+				throw $this->invalidBody();
+			}
+			$modify['body'] = Psr7\Utils::streamFor($options['body']);
+			unset($options['body']);
+		}
+		if (!empty($options['auth']) && \is_array($options['auth'])) {
+			$value = $options['auth'];
+			$type = isset($value[2]) ? \strtolower($value[2]) : 'basic';
+			switch ($type) {
+				case 'basic':
+					// Ensure that we don't have the header in different case and set the new value.
+					$modify['set_headers'] = Psr7\Utils::caselessRemove(['Authorization'], $modify['set_headers']);
+					$modify['set_headers']['Authorization'] = 'Basic ' . \base64_encode("{$value[0]}:{$value[1]}");
+					break;
+				case 'digest':
+					// @todo: Do not rely on curl
+					$options['curl'][\CURLOPT_HTTPAUTH] = \CURLAUTH_DIGEST;
+					$options['curl'][\CURLOPT_USERPWD] = "{$value[0]}:{$value[1]}";
+					break;
+				case 'ntlm':
+					$options['curl'][\CURLOPT_HTTPAUTH] = \CURLAUTH_NTLM;
+					$options['curl'][\CURLOPT_USERPWD] = "{$value[0]}:{$value[1]}";
+					break;
+			}
+		}
+		if (isset($options['query'])) {
+			$value = $options['query'];
+			if (\is_array($value)) {
+				$value = \http_build_query($value, '', '&', \PHP_QUERY_RFC3986);
+			}
+			if (!\is_string($value)) {
+				throw new InvalidArgumentException('query must be a string or array');
+			}
+			$modify['query'] = $value;
+			unset($options['query']);
+		}
+		// Ensure that sink is not an invalid value.
+		if (isset($options['sink'])) {
+			// TODO: Add more sink validation?
+			if (\is_bool($options['sink'])) {
+				throw new InvalidArgumentException('sink must not be a boolean');
+			}
+		}
+		if (isset($options['version'])) {
+			$modify['version'] = $options['version'];
+		}
+		$request = Psr7\Utils::modifyRequest($request, $modify);
+		if ($request->getBody() instanceof Psr7\MultipartStream) {
+			// Use a multipart/form-data POST if a Content-Type is not set.
+			// Ensure that we don't have the header in different case and set the new value.
+			$options['_conditional'] = Psr7\Utils::caselessRemove(['Content-Type'], $options['_conditional']);
+			$options['_conditional']['Content-Type'] = 'multipart/form-data; boundary=' . $request->getBody()->getBoundary();
+		}
+		// Merge in conditional headers if they are not present.
+		if (isset($options['_conditional'])) {
+			// Build up the changes so it's in a single clone of the message.
+			$modify = [];
+			foreach ($options['_conditional'] as $k => $v) {
+				if (!$request->hasHeader($k)) {
+					$modify['set_headers'][$k] = $v;
+				}
+			}
+			$request = Psr7\Utils::modifyRequest($request, $modify);
+			// Don't pass this internal value along to middleware/handlers.
+			unset($options['_conditional']);
+		}
+		return $request;
+	}
+	/**
+	 * Return an InvalidArgumentException with pre-set message.
+	 */
+	private function invalidBody() : InvalidArgumentException
+	{
+		return new InvalidArgumentException('Passing in the "body" request ' . 'option as an array to send a request is not supported. ' . 'Please use the "form_params" request option to send a ' . 'application/x-www-form-urlencoded request, or the "multipart" ' . 'request option to send a multipart/form-data request.');
+	}
 }

lib/Vendor/GuzzleHttp/MessageFormatter.php

Indentation +129 added lines, -129 removed lines

@@ -36,133 +36,133 @@
  */
 class MessageFormatter implements MessageFormatterInterface
 {
-    /**
-     * Apache Common Log Format.
-     *
-     * @see https://httpd.apache.org/docs/2.4/logs.html#common
-     *
-     * @var string
-     */
-    public const CLF = '{hostname} {req_header_User-Agent} - [{date_common_log}] "{method} {target} HTTP/{version}" {code} {res_header_Content-Length}';
-    public const DEBUG = ">>>>>>>>\n{request}\n<<<<<<<<\n{response}\n--------\n{error}";
-    public const SHORT = '[{ts}] "{method} {target} HTTP/{version}" {code}';
-    /**
-     * @var string Template used to format log messages
-     */
-    private $template;
-    /**
-     * @param string $template Log message template
-     */
-    public function __construct(?string $template = self::CLF)
-    {
-        $this->template = $template ?: self::CLF;
-    }
-    /**
-     * Returns a formatted message string.
-     *
-     * @param RequestInterface       $request  Request that was sent
-     * @param ResponseInterface|null $response Response that was received
-     * @param \Throwable|null        $error    Exception that was received
-     */
-    public function format(RequestInterface $request, ResponseInterface $response = null, \Throwable $error = null) : string
-    {
-        $cache = [];
-        /** @var string */
-        return \preg_replace_callback('/{\\s*([A-Za-z_\\-\\.0-9]+)\\s*}/', function (array $matches) use($request, $response, $error, &$cache) {
-            if (isset($cache[$matches[1]])) {
-                return $cache[$matches[1]];
-            }
-            $result = '';
-            switch ($matches[1]) {
-                case 'request':
-                    $result = Psr7\Message::toString($request);
-                    break;
-                case 'response':
-                    $result = $response ? Psr7\Message::toString($response) : '';
-                    break;
-                case 'req_headers':
-                    $result = \trim($request->getMethod() . ' ' . $request->getRequestTarget()) . ' HTTP/' . $request->getProtocolVersion() . "\r\n" . $this->headers($request);
-                    break;
-                case 'res_headers':
-                    $result = $response ? \sprintf('HTTP/%s %d %s', $response->getProtocolVersion(), $response->getStatusCode(), $response->getReasonPhrase()) . "\r\n" . $this->headers($response) : 'NULL';
-                    break;
-                case 'req_body':
-                    $result = $request->getBody()->__toString();
-                    break;
-                case 'res_body':
-                    if (!$response instanceof ResponseInterface) {
-                        $result = 'NULL';
-                        break;
-                    }
-                    $body = $response->getBody();
-                    if (!$body->isSeekable()) {
-                        $result = 'RESPONSE_NOT_LOGGEABLE';
-                        break;
-                    }
-                    $result = $response->getBody()->__toString();
-                    break;
-                case 'ts':
-                case 'date_iso_8601':
-                    $result = \gmdate('c');
-                    break;
-                case 'date_common_log':
-                    $result = \date('d/M/Y:H:i:s O');
-                    break;
-                case 'method':
-                    $result = $request->getMethod();
-                    break;
-                case 'version':
-                    $result = $request->getProtocolVersion();
-                    break;
-                case 'uri':
-                case 'url':
-                    $result = $request->getUri()->__toString();
-                    break;
-                case 'target':
-                    $result = $request->getRequestTarget();
-                    break;
-                case 'req_version':
-                    $result = $request->getProtocolVersion();
-                    break;
-                case 'res_version':
-                    $result = $response ? $response->getProtocolVersion() : 'NULL';
-                    break;
-                case 'host':
-                    $result = $request->getHeaderLine('Host');
-                    break;
-                case 'hostname':
-                    $result = \gethostname();
-                    break;
-                case 'code':
-                    $result = $response ? $response->getStatusCode() : 'NULL';
-                    break;
-                case 'phrase':
-                    $result = $response ? $response->getReasonPhrase() : 'NULL';
-                    break;
-                case 'error':
-                    $result = $error ? $error->getMessage() : 'NULL';
-                    break;
-                default:
-                    // handle prefixed dynamic headers
-                    if (\strpos($matches[1], 'req_header_') === 0) {
-                        $result = $request->getHeaderLine(\substr($matches[1], 11));
-                    } elseif (\strpos($matches[1], 'res_header_') === 0) {
-                        $result = $response ? $response->getHeaderLine(\substr($matches[1], 11)) : 'NULL';
-                    }
-            }
-            $cache[$matches[1]] = $result;
-            return $result;
-        }, $this->template);
-    }
-    /**
-     * Get headers from message as string
-     */
-    private function headers(MessageInterface $message) : string
-    {
-        $result = '';
-        foreach ($message->getHeaders() as $name => $values) {
-            $result .= $name . ': ' . \implode(', ', $values) . "\r\n";
-        }
-        return \trim($result);
-    }
+	/**
+	 * Apache Common Log Format.
+	 *
+	 * @see https://httpd.apache.org/docs/2.4/logs.html#common
+	 *
+	 * @var string
+	 */
+	public const CLF = '{hostname} {req_header_User-Agent} - [{date_common_log}] "{method} {target} HTTP/{version}" {code} {res_header_Content-Length}';
+	public const DEBUG = ">>>>>>>>\n{request}\n<<<<<<<<\n{response}\n--------\n{error}";
+	public const SHORT = '[{ts}] "{method} {target} HTTP/{version}" {code}';
+	/**
+	 * @var string Template used to format log messages
+	 */
+	private $template;
+	/**
+	 * @param string $template Log message template
+	 */
+	public function __construct(?string $template = self::CLF)
+	{
+		$this->template = $template ?: self::CLF;
+	}
+	/**
+	 * Returns a formatted message string.
+	 *
+	 * @param RequestInterface       $request  Request that was sent
+	 * @param ResponseInterface|null $response Response that was received
+	 * @param \Throwable|null        $error    Exception that was received
+	 */
+	public function format(RequestInterface $request, ResponseInterface $response = null, \Throwable $error = null) : string
+	{
+		$cache = [];
+		/** @var string */
+		return \preg_replace_callback('/{\\s*([A-Za-z_\\-\\.0-9]+)\\s*}/', function (array $matches) use($request, $response, $error, &$cache) {
+			if (isset($cache[$matches[1]])) {
+				return $cache[$matches[1]];
+			}
+			$result = '';
+			switch ($matches[1]) {
+				case 'request':
+					$result = Psr7\Message::toString($request);
+					break;
+				case 'response':
+					$result = $response ? Psr7\Message::toString($response) : '';
+					break;
+				case 'req_headers':
+					$result = \trim($request->getMethod() . ' ' . $request->getRequestTarget()) . ' HTTP/' . $request->getProtocolVersion() . "\r\n" . $this->headers($request);
+					break;
+				case 'res_headers':
+					$result = $response ? \sprintf('HTTP/%s %d %s', $response->getProtocolVersion(), $response->getStatusCode(), $response->getReasonPhrase()) . "\r\n" . $this->headers($response) : 'NULL';
+					break;
+				case 'req_body':
+					$result = $request->getBody()->__toString();
+					break;
+				case 'res_body':
+					if (!$response instanceof ResponseInterface) {
+						$result = 'NULL';
+						break;
+					}
+					$body = $response->getBody();
+					if (!$body->isSeekable()) {
+						$result = 'RESPONSE_NOT_LOGGEABLE';
+						break;
+					}
+					$result = $response->getBody()->__toString();
+					break;
+				case 'ts':
+				case 'date_iso_8601':
+					$result = \gmdate('c');
+					break;
+				case 'date_common_log':
+					$result = \date('d/M/Y:H:i:s O');
+					break;
+				case 'method':
+					$result = $request->getMethod();
+					break;
+				case 'version':
+					$result = $request->getProtocolVersion();
+					break;
+				case 'uri':
+				case 'url':
+					$result = $request->getUri()->__toString();
+					break;
+				case 'target':
+					$result = $request->getRequestTarget();
+					break;
+				case 'req_version':
+					$result = $request->getProtocolVersion();
+					break;
+				case 'res_version':
+					$result = $response ? $response->getProtocolVersion() : 'NULL';
+					break;
+				case 'host':
+					$result = $request->getHeaderLine('Host');
+					break;
+				case 'hostname':
+					$result = \gethostname();
+					break;
+				case 'code':
+					$result = $response ? $response->getStatusCode() : 'NULL';
+					break;
+				case 'phrase':
+					$result = $response ? $response->getReasonPhrase() : 'NULL';
+					break;
+				case 'error':
+					$result = $error ? $error->getMessage() : 'NULL';
+					break;
+				default:
+					// handle prefixed dynamic headers
+					if (\strpos($matches[1], 'req_header_') === 0) {
+						$result = $request->getHeaderLine(\substr($matches[1], 11));
+					} elseif (\strpos($matches[1], 'res_header_') === 0) {
+						$result = $response ? $response->getHeaderLine(\substr($matches[1], 11)) : 'NULL';
+					}
+			}
+			$cache[$matches[1]] = $result;
+			return $result;
+		}, $this->template);
+	}
+	/**
+	 * Get headers from message as string
+	 */
+	private function headers(MessageInterface $message) : string
+	{
+		$result = '';
+		foreach ($message->getHeaders() as $name => $values) {
+			$result .= $name . ': ' . \implode(', ', $values) . "\r\n";
+		}
+		return \trim($result);
+	}
 }

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

Indentation +50 added lines, -50 removed lines

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

lib/Vendor/GuzzleHttp/Psr7/PumpStream.php

Indentation +130 added lines, -130 removed lines

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