nextcloud / fulltextsearch_elasticsearch

lib/Vendor/GuzzleHttp/Client.php

Indentation +464 added lines, -464 removed lines

@@ -16,468 +16,468 @@
  */
 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
-     *   OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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
+	 *   OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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 \OCA\FullTextSearch_Elasticsearch\Vendor\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/Promise/Utils.php

Indentation +229 added lines, -229 removed lines

@@ -6,254 +6,254 @@
 
 final class Utils
 {
-    /**
-     * Get the global task queue used for promise resolution.
-     *
-     * This task queue MUST be run in an event loop in order for promises to be
-     * settled asynchronously. It will be automatically run when synchronously
-     * waiting on a promise.
-     *
-     * <code>
-     * while ($eventLoop->isRunning()) {
-     *     OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise\Utils::queue()->run();
-     * }
-     * </code>
-     *
-     * @param TaskQueueInterface|null $assign Optionally specify a new queue instance.
-     */
-    public static function queue(TaskQueueInterface $assign = null): TaskQueueInterface
-    {
-        static $queue;
+	/**
+	 * Get the global task queue used for promise resolution.
+	 *
+	 * This task queue MUST be run in an event loop in order for promises to be
+	 * settled asynchronously. It will be automatically run when synchronously
+	 * waiting on a promise.
+	 *
+	 * <code>
+	 * while ($eventLoop->isRunning()) {
+	 *     OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise\Utils::queue()->run();
+	 * }
+	 * </code>
+	 *
+	 * @param TaskQueueInterface|null $assign Optionally specify a new queue instance.
+	 */
+	public static function queue(TaskQueueInterface $assign = null): TaskQueueInterface
+	{
+		static $queue;
 
-        if ($assign) {
-            $queue = $assign;
-        } elseif (!$queue) {
-            $queue = new TaskQueue();
-        }
+		if ($assign) {
+			$queue = $assign;
+		} elseif (!$queue) {
+			$queue = new TaskQueue();
+		}
 
-        return $queue;
-    }
+		return $queue;
+	}
 
-    /**
-     * Adds a function to run in the task queue when it is next `run()` and
-     * returns a promise that is fulfilled or rejected with the result.
-     *
-     * @param callable $task Task function to run.
-     */
-    public static function task(callable $task): PromiseInterface
-    {
-        $queue = self::queue();
-        $promise = new Promise([$queue, 'run']);
-        $queue->add(function () use ($task, $promise): void {
-            try {
-                if (Is::pending($promise)) {
-                    $promise->resolve($task());
-                }
-            } catch (\Throwable $e) {
-                $promise->reject($e);
-            }
-        });
+	/**
+	 * Adds a function to run in the task queue when it is next `run()` and
+	 * returns a promise that is fulfilled or rejected with the result.
+	 *
+	 * @param callable $task Task function to run.
+	 */
+	public static function task(callable $task): PromiseInterface
+	{
+		$queue = self::queue();
+		$promise = new Promise([$queue, 'run']);
+		$queue->add(function () use ($task, $promise): void {
+			try {
+				if (Is::pending($promise)) {
+					$promise->resolve($task());
+				}
+			} catch (\Throwable $e) {
+				$promise->reject($e);
+			}
+		});
 
-        return $promise;
-    }
+		return $promise;
+	}
 
-    /**
-     * Synchronously waits on a promise to resolve and returns an inspection
-     * state array.
-     *
-     * Returns a state associative array containing a "state" key mapping to a
-     * valid promise state. If the state of the promise is "fulfilled", the
-     * array will contain a "value" key mapping to the fulfilled value of the
-     * promise. If the promise is rejected, the array will contain a "reason"
-     * key mapping to the rejection reason of the promise.
-     *
-     * @param PromiseInterface $promise Promise or value.
-     */
-    public static function inspect(PromiseInterface $promise): array
-    {
-        try {
-            return [
-                'state' => PromiseInterface::FULFILLED,
-                'value' => $promise->wait(),
-            ];
-        } catch (RejectionException $e) {
-            return ['state' => PromiseInterface::REJECTED, 'reason' => $e->getReason()];
-        } catch (\Throwable $e) {
-            return ['state' => PromiseInterface::REJECTED, 'reason' => $e];
-        }
-    }
+	/**
+	 * Synchronously waits on a promise to resolve and returns an inspection
+	 * state array.
+	 *
+	 * Returns a state associative array containing a "state" key mapping to a
+	 * valid promise state. If the state of the promise is "fulfilled", the
+	 * array will contain a "value" key mapping to the fulfilled value of the
+	 * promise. If the promise is rejected, the array will contain a "reason"
+	 * key mapping to the rejection reason of the promise.
+	 *
+	 * @param PromiseInterface $promise Promise or value.
+	 */
+	public static function inspect(PromiseInterface $promise): array
+	{
+		try {
+			return [
+				'state' => PromiseInterface::FULFILLED,
+				'value' => $promise->wait(),
+			];
+		} catch (RejectionException $e) {
+			return ['state' => PromiseInterface::REJECTED, 'reason' => $e->getReason()];
+		} catch (\Throwable $e) {
+			return ['state' => PromiseInterface::REJECTED, 'reason' => $e];
+		}
+	}
 
-    /**
-     * Waits on all of the provided promises, but does not unwrap rejected
-     * promises as thrown exception.
-     *
-     * Returns an array of inspection state arrays.
-     *
-     * @see inspect for the inspection state array format.
-     *
-     * @param PromiseInterface[] $promises Traversable of promises to wait upon.
-     */
-    public static function inspectAll($promises): array
-    {
-        $results = [];
-        foreach ($promises as $key => $promise) {
-            $results[$key] = self::inspect($promise);
-        }
+	/**
+	 * Waits on all of the provided promises, but does not unwrap rejected
+	 * promises as thrown exception.
+	 *
+	 * Returns an array of inspection state arrays.
+	 *
+	 * @see inspect for the inspection state array format.
+	 *
+	 * @param PromiseInterface[] $promises Traversable of promises to wait upon.
+	 */
+	public static function inspectAll($promises): array
+	{
+		$results = [];
+		foreach ($promises as $key => $promise) {
+			$results[$key] = self::inspect($promise);
+		}
 
-        return $results;
-    }
+		return $results;
+	}
 
-    /**
-     * Waits on all of the provided promises and returns the fulfilled values.
-     *
-     * Returns an array that contains the value of each promise (in the same
-     * order the promises were provided). An exception is thrown if any of the
-     * promises are rejected.
-     *
-     * @param iterable<PromiseInterface> $promises Iterable of PromiseInterface objects to wait on.
-     *
-     * @throws \Throwable on error
-     */
-    public static function unwrap($promises): array
-    {
-        $results = [];
-        foreach ($promises as $key => $promise) {
-            $results[$key] = $promise->wait();
-        }
+	/**
+	 * Waits on all of the provided promises and returns the fulfilled values.
+	 *
+	 * Returns an array that contains the value of each promise (in the same
+	 * order the promises were provided). An exception is thrown if any of the
+	 * promises are rejected.
+	 *
+	 * @param iterable<PromiseInterface> $promises Iterable of PromiseInterface objects to wait on.
+	 *
+	 * @throws \Throwable on error
+	 */
+	public static function unwrap($promises): array
+	{
+		$results = [];
+		foreach ($promises as $key => $promise) {
+			$results[$key] = $promise->wait();
+		}
 
-        return $results;
-    }
+		return $results;
+	}
 
-    /**
-     * Given an array of promises, return a promise that is fulfilled when all
-     * the items in the array are fulfilled.
-     *
-     * The promise's fulfillment value is an array with fulfillment values at
-     * respective positions to the original array. If any promise in the array
-     * rejects, the returned promise is rejected with the rejection reason.
-     *
-     * @param mixed $promises  Promises or values.
-     * @param bool  $recursive If true, resolves new promises that might have been added to the stack during its own resolution.
-     */
-    public static function all($promises, bool $recursive = false): PromiseInterface
-    {
-        $results = [];
-        $promise = Each::of(
-            $promises,
-            function ($value, $idx) use (&$results): void {
-                $results[$idx] = $value;
-            },
-            function ($reason, $idx, Promise $aggregate): void {
-                $aggregate->reject($reason);
-            }
-        )->then(function () use (&$results) {
-            ksort($results);
+	/**
+	 * Given an array of promises, return a promise that is fulfilled when all
+	 * the items in the array are fulfilled.
+	 *
+	 * The promise's fulfillment value is an array with fulfillment values at
+	 * respective positions to the original array. If any promise in the array
+	 * rejects, the returned promise is rejected with the rejection reason.
+	 *
+	 * @param mixed $promises  Promises or values.
+	 * @param bool  $recursive If true, resolves new promises that might have been added to the stack during its own resolution.
+	 */
+	public static function all($promises, bool $recursive = false): PromiseInterface
+	{
+		$results = [];
+		$promise = Each::of(
+			$promises,
+			function ($value, $idx) use (&$results): void {
+				$results[$idx] = $value;
+			},
+			function ($reason, $idx, Promise $aggregate): void {
+				$aggregate->reject($reason);
+			}
+		)->then(function () use (&$results) {
+			ksort($results);
 
-            return $results;
-        });
+			return $results;
+		});
 
-        if (true === $recursive) {
-            $promise = $promise->then(function ($results) use ($recursive, &$promises) {
-                foreach ($promises as $promise) {
-                    if (Is::pending($promise)) {
-                        return self::all($promises, $recursive);
-                    }
-                }
+		if (true === $recursive) {
+			$promise = $promise->then(function ($results) use ($recursive, &$promises) {
+				foreach ($promises as $promise) {
+					if (Is::pending($promise)) {
+						return self::all($promises, $recursive);
+					}
+				}
 
-                return $results;
-            });
-        }
+				return $results;
+			});
+		}
 
-        return $promise;
-    }
+		return $promise;
+	}
 
-    /**
-     * Initiate a competitive race between multiple promises or values (values
-     * will become immediately fulfilled promises).
-     *
-     * When count amount of promises have been fulfilled, the returned promise
-     * is fulfilled with an array that contains the fulfillment values of the
-     * winners in order of resolution.
-     *
-     * This promise is rejected with a {@see AggregateException} if the number
-     * of fulfilled promises is less than the desired $count.
-     *
-     * @param int   $count    Total number of promises.
-     * @param mixed $promises Promises or values.
-     */
-    public static function some(int $count, $promises): PromiseInterface
-    {
-        $results = [];
-        $rejections = [];
+	/**
+	 * Initiate a competitive race between multiple promises or values (values
+	 * will become immediately fulfilled promises).
+	 *
+	 * When count amount of promises have been fulfilled, the returned promise
+	 * is fulfilled with an array that contains the fulfillment values of the
+	 * winners in order of resolution.
+	 *
+	 * This promise is rejected with a {@see AggregateException} if the number
+	 * of fulfilled promises is less than the desired $count.
+	 *
+	 * @param int   $count    Total number of promises.
+	 * @param mixed $promises Promises or values.
+	 */
+	public static function some(int $count, $promises): PromiseInterface
+	{
+		$results = [];
+		$rejections = [];
 
-        return Each::of(
-            $promises,
-            function ($value, $idx, PromiseInterface $p) use (&$results, $count): void {
-                if (Is::settled($p)) {
-                    return;
-                }
-                $results[$idx] = $value;
-                if (count($results) >= $count) {
-                    $p->resolve(null);
-                }
-            },
-            function ($reason) use (&$rejections): void {
-                $rejections[] = $reason;
-            }
-        )->then(
-            function () use (&$results, &$rejections, $count) {
-                if (count($results) !== $count) {
-                    throw new AggregateException(
-                        'Not enough promises to fulfill count',
-                        $rejections
-                    );
-                }
-                ksort($results);
+		return Each::of(
+			$promises,
+			function ($value, $idx, PromiseInterface $p) use (&$results, $count): void {
+				if (Is::settled($p)) {
+					return;
+				}
+				$results[$idx] = $value;
+				if (count($results) >= $count) {
+					$p->resolve(null);
+				}
+			},
+			function ($reason) use (&$rejections): void {
+				$rejections[] = $reason;
+			}
+		)->then(
+			function () use (&$results, &$rejections, $count) {
+				if (count($results) !== $count) {
+					throw new AggregateException(
+						'Not enough promises to fulfill count',
+						$rejections
+					);
+				}
+				ksort($results);
 
-                return array_values($results);
-            }
-        );
-    }
+				return array_values($results);
+			}
+		);
+	}
 
-    /**
-     * Like some(), with 1 as count. However, if the promise fulfills, the
-     * fulfillment value is not an array of 1 but the value directly.
-     *
-     * @param mixed $promises Promises or values.
-     */
-    public static function any($promises): PromiseInterface
-    {
-        return self::some(1, $promises)->then(function ($values) {
-            return $values[0];
-        });
-    }
+	/**
+	 * Like some(), with 1 as count. However, if the promise fulfills, the
+	 * fulfillment value is not an array of 1 but the value directly.
+	 *
+	 * @param mixed $promises Promises or values.
+	 */
+	public static function any($promises): PromiseInterface
+	{
+		return self::some(1, $promises)->then(function ($values) {
+			return $values[0];
+		});
+	}
 
-    /**
-     * Returns a promise that is fulfilled when all of the provided promises have
-     * been fulfilled or rejected.
-     *
-     * The returned promise is fulfilled with an array of inspection state arrays.
-     *
-     * @see inspect for the inspection state array format.
-     *
-     * @param mixed $promises Promises or values.
-     */
-    public static function settle($promises): PromiseInterface
-    {
-        $results = [];
+	/**
+	 * Returns a promise that is fulfilled when all of the provided promises have
+	 * been fulfilled or rejected.
+	 *
+	 * The returned promise is fulfilled with an array of inspection state arrays.
+	 *
+	 * @see inspect for the inspection state array format.
+	 *
+	 * @param mixed $promises Promises or values.
+	 */
+	public static function settle($promises): PromiseInterface
+	{
+		$results = [];
 
-        return Each::of(
-            $promises,
-            function ($value, $idx) use (&$results): void {
-                $results[$idx] = ['state' => PromiseInterface::FULFILLED, 'value' => $value];
-            },
-            function ($reason, $idx) use (&$results): void {
-                $results[$idx] = ['state' => PromiseInterface::REJECTED, 'reason' => $reason];
-            }
-        )->then(function () use (&$results) {
-            ksort($results);
+		return Each::of(
+			$promises,
+			function ($value, $idx) use (&$results): void {
+				$results[$idx] = ['state' => PromiseInterface::FULFILLED, 'value' => $value];
+			},
+			function ($reason, $idx) use (&$results): void {
+				$results[$idx] = ['state' => PromiseInterface::REJECTED, 'reason' => $reason];
+			}
+		)->then(function () use (&$results) {
+			ksort($results);
 
-            return $results;
-        });
-    }
+			return $results;
+		});
+	}
 }

Spacing +12 added lines, -12 removed lines

@@ -44,7 +44,7 @@ 
     {
         $queue = self::queue();
         $promise = new Promise([$queue, 'run']);
-        $queue->add(function () use ($task, $promise): void {
+        $queue->add(function() use ($task, $promise): void {
             try {
                 if (Is::pending($promise)) {
                     $promise->resolve($task());
@@ -140,20 +140,20 @@ 
         $results = [];
         $promise = Each::of(
             $promises,
-            function ($value, $idx) use (&$results): void {
+            function($value, $idx) use (&$results): void {
                 $results[$idx] = $value;
             },
-            function ($reason, $idx, Promise $aggregate): void {
+            function($reason, $idx, Promise $aggregate): void {
                 $aggregate->reject($reason);
             }
-        )->then(function () use (&$results) {
+        )->then(function() use (&$results) {
             ksort($results);
 
             return $results;
         });
 
         if (true === $recursive) {
-            $promise = $promise->then(function ($results) use ($recursive, &$promises) {
+            $promise = $promise->then(function($results) use ($recursive, &$promises) {
                 foreach ($promises as $promise) {
                     if (Is::pending($promise)) {
                         return self::all($promises, $recursive);
@@ -188,7 +188,7 @@ 
 
         return Each::of(
             $promises,
-            function ($value, $idx, PromiseInterface $p) use (&$results, $count): void {
+            function($value, $idx, PromiseInterface $p) use (&$results, $count): void {
                 if (Is::settled($p)) {
                     return;
                 }
@@ -197,11 +197,11 @@ 
                     $p->resolve(null);
                 }
             },
-            function ($reason) use (&$rejections): void {
+            function($reason) use (&$rejections): void {
                 $rejections[] = $reason;
             }
         )->then(
-            function () use (&$results, &$rejections, $count) {
+            function() use (&$results, &$rejections, $count) {
                 if (count($results) !== $count) {
                     throw new AggregateException(
                         'Not enough promises to fulfill count',
@@ -223,7 +223,7 @@ 
      */
     public static function any($promises): PromiseInterface
     {
-        return self::some(1, $promises)->then(function ($values) {
+        return self::some(1, $promises)->then(function($values) {
             return $values[0];
         });
     }
@@ -244,13 +244,13 @@ 
 
         return Each::of(
             $promises,
-            function ($value, $idx) use (&$results): void {
+            function($value, $idx) use (&$results): void {
                 $results[$idx] = ['state' => PromiseInterface::FULFILLED, 'value' => $value];
             },
-            function ($reason, $idx) use (&$results): void {
+            function($reason, $idx) use (&$results): void {
                 $results[$idx] = ['state' => PromiseInterface::REJECTED, 'reason' => $reason];
             }
-        )->then(function () use (&$results) {
+        )->then(function() use (&$results) {
             ksort($results);
 
             return $results;

Braces +1 added lines, -2 removed lines

@@ -4,8 +4,7 @@
 
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise;
 
-final class Utils
-{
+final class Utils {
     /**
      * Get the global task queue used for promise resolution.
      *

lib/Vendor/GuzzleHttp/Promise/Coroutine.php

Indentation +114 added lines, -114 removed lines

@@ -45,118 +45,118 @@
  */
 final class Coroutine implements PromiseInterface
 {
-    /**
-     * @var PromiseInterface|null
-     */
-    private $currentPromise;
-
-    /**
-     * @var Generator
-     */
-    private $generator;
-
-    /**
-     * @var Promise
-     */
-    private $result;
-
-    public function __construct(callable $generatorFn)
-    {
-        $this->generator = $generatorFn();
-        $this->result = new Promise(function (): void {
-            while (isset($this->currentPromise)) {
-                $this->currentPromise->wait();
-            }
-        });
-        try {
-            $this->nextCoroutine($this->generator->current());
-        } catch (Throwable $throwable) {
-            $this->result->reject($throwable);
-        }
-    }
-
-    /**
-     * Create a new coroutine.
-     */
-    public static function of(callable $generatorFn): self
-    {
-        return new self($generatorFn);
-    }
-
-    public function then(
-        callable $onFulfilled = null,
-        callable $onRejected = null
-    ): PromiseInterface {
-        return $this->result->then($onFulfilled, $onRejected);
-    }
-
-    public function otherwise(callable $onRejected): PromiseInterface
-    {
-        return $this->result->otherwise($onRejected);
-    }
-
-    public function wait(bool $unwrap = true)
-    {
-        return $this->result->wait($unwrap);
-    }
-
-    public function getState(): string
-    {
-        return $this->result->getState();
-    }
-
-    public function resolve($value): void
-    {
-        $this->result->resolve($value);
-    }
-
-    public function reject($reason): void
-    {
-        $this->result->reject($reason);
-    }
-
-    public function cancel(): void
-    {
-        $this->currentPromise->cancel();
-        $this->result->cancel();
-    }
-
-    private function nextCoroutine($yielded): void
-    {
-        $this->currentPromise = Create::promiseFor($yielded)
-            ->then([$this, '_handleSuccess'], [$this, '_handleFailure']);
-    }
-
-    /**
-     * @internal
-     */
-    public function _handleSuccess($value): void
-    {
-        unset($this->currentPromise);
-        try {
-            $next = $this->generator->send($value);
-            if ($this->generator->valid()) {
-                $this->nextCoroutine($next);
-            } else {
-                $this->result->resolve($value);
-            }
-        } catch (Throwable $throwable) {
-            $this->result->reject($throwable);
-        }
-    }
-
-    /**
-     * @internal
-     */
-    public function _handleFailure($reason): void
-    {
-        unset($this->currentPromise);
-        try {
-            $nextYield = $this->generator->throw(Create::exceptionFor($reason));
-            // The throw was caught, so keep iterating on the coroutine
-            $this->nextCoroutine($nextYield);
-        } catch (Throwable $throwable) {
-            $this->result->reject($throwable);
-        }
-    }
+	/**
+	 * @var PromiseInterface|null
+	 */
+	private $currentPromise;
+
+	/**
+	 * @var Generator
+	 */
+	private $generator;
+
+	/**
+	 * @var Promise
+	 */
+	private $result;
+
+	public function __construct(callable $generatorFn)
+	{
+		$this->generator = $generatorFn();
+		$this->result = new Promise(function (): void {
+			while (isset($this->currentPromise)) {
+				$this->currentPromise->wait();
+			}
+		});
+		try {
+			$this->nextCoroutine($this->generator->current());
+		} catch (Throwable $throwable) {
+			$this->result->reject($throwable);
+		}
+	}
+
+	/**
+	 * Create a new coroutine.
+	 */
+	public static function of(callable $generatorFn): self
+	{
+		return new self($generatorFn);
+	}
+
+	public function then(
+		callable $onFulfilled = null,
+		callable $onRejected = null
+	): PromiseInterface {
+		return $this->result->then($onFulfilled, $onRejected);
+	}
+
+	public function otherwise(callable $onRejected): PromiseInterface
+	{
+		return $this->result->otherwise($onRejected);
+	}
+
+	public function wait(bool $unwrap = true)
+	{
+		return $this->result->wait($unwrap);
+	}
+
+	public function getState(): string
+	{
+		return $this->result->getState();
+	}
+
+	public function resolve($value): void
+	{
+		$this->result->resolve($value);
+	}
+
+	public function reject($reason): void
+	{
+		$this->result->reject($reason);
+	}
+
+	public function cancel(): void
+	{
+		$this->currentPromise->cancel();
+		$this->result->cancel();
+	}
+
+	private function nextCoroutine($yielded): void
+	{
+		$this->currentPromise = Create::promiseFor($yielded)
+			->then([$this, '_handleSuccess'], [$this, '_handleFailure']);
+	}
+
+	/**
+	 * @internal
+	 */
+	public function _handleSuccess($value): void
+	{
+		unset($this->currentPromise);
+		try {
+			$next = $this->generator->send($value);
+			if ($this->generator->valid()) {
+				$this->nextCoroutine($next);
+			} else {
+				$this->result->resolve($value);
+			}
+		} catch (Throwable $throwable) {
+			$this->result->reject($throwable);
+		}
+	}
+
+	/**
+	 * @internal
+	 */
+	public function _handleFailure($reason): void
+	{
+		unset($this->currentPromise);
+		try {
+			$nextYield = $this->generator->throw(Create::exceptionFor($reason));
+			// The throw was caught, so keep iterating on the coroutine
+			$this->nextCoroutine($nextYield);
+		} catch (Throwable $throwable) {
+			$this->result->reject($throwable);
+		}
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
     public function __construct(callable $generatorFn)
     {
         $this->generator = $generatorFn();
-        $this->result = new Promise(function (): void {
+        $this->result = new Promise(function(): void {
             while (isset($this->currentPromise)) {
                 $this->currentPromise->wait();
             }

Braces +1 added lines, -2 removed lines

@@ -43,8 +43,7 @@
  *
  * @see https://github.com/petkaantonov/bluebird/blob/master/API.md#generators inspiration
  */
-final class Coroutine implements PromiseInterface
-{
+final class Coroutine implements PromiseInterface {
     /**
      * @var PromiseInterface|null
      */

lib/Vendor/GuzzleHttp/Promise/RejectionException.php

Indentation +35 added lines, -35 removed lines

@@ -11,39 +11,39 @@
  */
 class RejectionException extends \RuntimeException
 {
-    /** @var mixed Rejection reason. */
-    private $reason;
-
-    /**
-     * @param mixed       $reason      Rejection reason.
-     * @param string|null $description Optional description.
-     */
-    public function __construct($reason, string $description = null)
-    {
-        $this->reason = $reason;
-
-        $message = 'The promise was rejected';
-
-        if ($description) {
-            $message .= ' with reason: '.$description;
-        } elseif (is_string($reason)
-            || (is_object($reason) && method_exists($reason, '__toString'))
-        ) {
-            $message .= ' with reason: '.$this->reason;
-        } elseif ($reason instanceof \JsonSerializable) {
-            $message .= ' with reason: '.json_encode($this->reason, JSON_PRETTY_PRINT);
-        }
-
-        parent::__construct($message);
-    }
-
-    /**
-     * Returns the rejection reason.
-     *
-     * @return mixed
-     */
-    public function getReason()
-    {
-        return $this->reason;
-    }
+	/** @var mixed Rejection reason. */
+	private $reason;
+
+	/**
+	 * @param mixed       $reason      Rejection reason.
+	 * @param string|null $description Optional description.
+	 */
+	public function __construct($reason, string $description = null)
+	{
+		$this->reason = $reason;
+
+		$message = 'The promise was rejected';
+
+		if ($description) {
+			$message .= ' with reason: '.$description;
+		} elseif (is_string($reason)
+			|| (is_object($reason) && method_exists($reason, '__toString'))
+		) {
+			$message .= ' with reason: '.$this->reason;
+		} elseif ($reason instanceof \JsonSerializable) {
+			$message .= ' with reason: '.json_encode($this->reason, JSON_PRETTY_PRINT);
+		}
+
+		parent::__construct($message);
+	}
+
+	/**
+	 * Returns the rejection reason.
+	 *
+	 * @return mixed
+	 */
+	public function getReason()
+	{
+		return $this->reason;
+	}
 }

lib/Vendor/GuzzleHttp/Promise/Each.php

Indentation +70 added lines, -70 removed lines

@@ -6,76 +6,76 @@
 
 final class Each
 {
-    /**
-     * Given an iterator that yields promises or values, returns a promise that
-     * is fulfilled with a null value when the iterator has been consumed or
-     * the aggregate promise has been fulfilled or rejected.
-     *
-     * $onFulfilled is a function that accepts the fulfilled value, iterator
-     * index, and the aggregate promise. The callback can invoke any necessary
-     * side effects and choose to resolve or reject the aggregate if needed.
-     *
-     * $onRejected is a function that accepts the rejection reason, iterator
-     * index, and the aggregate promise. The callback can invoke any necessary
-     * side effects and choose to resolve or reject the aggregate if needed.
-     *
-     * @param mixed $iterable Iterator or array to iterate over.
-     */
-    public static function of(
-        $iterable,
-        callable $onFulfilled = null,
-        callable $onRejected = null
-    ): PromiseInterface {
-        return (new EachPromise($iterable, [
-            'fulfilled' => $onFulfilled,
-            'rejected' => $onRejected,
-        ]))->promise();
-    }
+	/**
+	 * Given an iterator that yields promises or values, returns a promise that
+	 * is fulfilled with a null value when the iterator has been consumed or
+	 * the aggregate promise has been fulfilled or rejected.
+	 *
+	 * $onFulfilled is a function that accepts the fulfilled value, iterator
+	 * index, and the aggregate promise. The callback can invoke any necessary
+	 * side effects and choose to resolve or reject the aggregate if needed.
+	 *
+	 * $onRejected is a function that accepts the rejection reason, iterator
+	 * index, and the aggregate promise. The callback can invoke any necessary
+	 * side effects and choose to resolve or reject the aggregate if needed.
+	 *
+	 * @param mixed $iterable Iterator or array to iterate over.
+	 */
+	public static function of(
+		$iterable,
+		callable $onFulfilled = null,
+		callable $onRejected = null
+	): PromiseInterface {
+		return (new EachPromise($iterable, [
+			'fulfilled' => $onFulfilled,
+			'rejected' => $onRejected,
+		]))->promise();
+	}
 
-    /**
-     * Like of, but only allows a certain number of outstanding promises at any
-     * given time.
-     *
-     * $concurrency may be an integer or a function that accepts the number of
-     * pending promises and returns a numeric concurrency limit value to allow
-     * for dynamic a concurrency size.
-     *
-     * @param mixed        $iterable
-     * @param int|callable $concurrency
-     */
-    public static function ofLimit(
-        $iterable,
-        $concurrency,
-        callable $onFulfilled = null,
-        callable $onRejected = null
-    ): PromiseInterface {
-        return (new EachPromise($iterable, [
-            'fulfilled' => $onFulfilled,
-            'rejected' => $onRejected,
-            'concurrency' => $concurrency,
-        ]))->promise();
-    }
+	/**
+	 * Like of, but only allows a certain number of outstanding promises at any
+	 * given time.
+	 *
+	 * $concurrency may be an integer or a function that accepts the number of
+	 * pending promises and returns a numeric concurrency limit value to allow
+	 * for dynamic a concurrency size.
+	 *
+	 * @param mixed        $iterable
+	 * @param int|callable $concurrency
+	 */
+	public static function ofLimit(
+		$iterable,
+		$concurrency,
+		callable $onFulfilled = null,
+		callable $onRejected = null
+	): PromiseInterface {
+		return (new EachPromise($iterable, [
+			'fulfilled' => $onFulfilled,
+			'rejected' => $onRejected,
+			'concurrency' => $concurrency,
+		]))->promise();
+	}
 
-    /**
-     * Like limit, but ensures that no promise in the given $iterable argument
-     * is rejected. If any promise is rejected, then the aggregate promise is
-     * rejected with the encountered rejection.
-     *
-     * @param mixed        $iterable
-     * @param int|callable $concurrency
-     */
-    public static function ofLimitAll(
-        $iterable,
-        $concurrency,
-        callable $onFulfilled = null
-    ): PromiseInterface {
-        return self::ofLimit(
-            $iterable,
-            $concurrency,
-            $onFulfilled,
-            function ($reason, $idx, PromiseInterface $aggregate): void {
-                $aggregate->reject($reason);
-            }
-        );
-    }
+	/**
+	 * Like limit, but ensures that no promise in the given $iterable argument
+	 * is rejected. If any promise is rejected, then the aggregate promise is
+	 * rejected with the encountered rejection.
+	 *
+	 * @param mixed        $iterable
+	 * @param int|callable $concurrency
+	 */
+	public static function ofLimitAll(
+		$iterable,
+		$concurrency,
+		callable $onFulfilled = null
+	): PromiseInterface {
+		return self::ofLimit(
+			$iterable,
+			$concurrency,
+			$onFulfilled,
+			function ($reason, $idx, PromiseInterface $aggregate): void {
+				$aggregate->reject($reason);
+			}
+		);
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -73,7 +73,7 @@
             $iterable,
             $concurrency,
             $onFulfilled,
-            function ($reason, $idx, PromiseInterface $aggregate): void {
+            function($reason, $idx, PromiseInterface $aggregate): void {
                 $aggregate->reject($reason);
             }
         );

Braces +1 added lines, -2 removed lines

@@ -4,8 +4,7 @@
 
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise;
 
-final class Each
-{
+final class Each {
     /**
      * Given an iterator that yields promises or values, returns a promise that
      * is fulfilled with a null value when the iterator has been consumed or

lib/Vendor/GuzzleHttp/Promise/TaskQueue.php

Indentation +46 added lines, -46 removed lines

@@ -17,55 +17,55 @@
  */
 class TaskQueue implements TaskQueueInterface
 {
-    private $enableShutdown = true;
-    private $queue = [];
+	private $enableShutdown = true;
+	private $queue = [];
 
-    public function __construct(bool $withShutdown = true)
-    {
-        if ($withShutdown) {
-            register_shutdown_function(function (): void {
-                if ($this->enableShutdown) {
-                    // Only run the tasks if an E_ERROR didn't occur.
-                    $err = error_get_last();
-                    if (!$err || ($err['type'] ^ E_ERROR)) {
-                        $this->run();
-                    }
-                }
-            });
-        }
-    }
+	public function __construct(bool $withShutdown = true)
+	{
+		if ($withShutdown) {
+			register_shutdown_function(function (): void {
+				if ($this->enableShutdown) {
+					// Only run the tasks if an E_ERROR didn't occur.
+					$err = error_get_last();
+					if (!$err || ($err['type'] ^ E_ERROR)) {
+						$this->run();
+					}
+				}
+			});
+		}
+	}
 
-    public function isEmpty(): bool
-    {
-        return !$this->queue;
-    }
+	public function isEmpty(): bool
+	{
+		return !$this->queue;
+	}
 
-    public function add(callable $task): void
-    {
-        $this->queue[] = $task;
-    }
+	public function add(callable $task): void
+	{
+		$this->queue[] = $task;
+	}
 
-    public function run(): void
-    {
-        while ($task = array_shift($this->queue)) {
-            /** @var callable $task */
-            $task();
-        }
-    }
+	public function run(): void
+	{
+		while ($task = array_shift($this->queue)) {
+			/** @var callable $task */
+			$task();
+		}
+	}
 
-    /**
-     * The task queue will be run and exhausted by default when the process
-     * exits IFF the exit is not the result of a PHP E_ERROR error.
-     *
-     * You can disable running the automatic shutdown of the queue by calling
-     * this function. If you disable the task queue shutdown process, then you
-     * MUST either run the task queue (as a result of running your event loop
-     * or manually using the run() method) or wait on each outstanding promise.
-     *
-     * Note: This shutdown will occur before any destructors are triggered.
-     */
-    public function disableShutdown(): void
-    {
-        $this->enableShutdown = false;
-    }
+	/**
+	 * The task queue will be run and exhausted by default when the process
+	 * exits IFF the exit is not the result of a PHP E_ERROR error.
+	 *
+	 * You can disable running the automatic shutdown of the queue by calling
+	 * this function. If you disable the task queue shutdown process, then you
+	 * MUST either run the task queue (as a result of running your event loop
+	 * or manually using the run() method) or wait on each outstanding promise.
+	 *
+	 * Note: This shutdown will occur before any destructors are triggered.
+	 */
+	public function disableShutdown(): void
+	{
+		$this->enableShutdown = false;
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
     public function __construct(bool $withShutdown = true)
     {
         if ($withShutdown) {
-            register_shutdown_function(function (): void {
+            register_shutdown_function(function(): void {
                 if ($this->enableShutdown) {
                     // Only run the tasks if an E_ERROR didn't occur.
                     $err = error_get_last();

Braces +1 added lines, -2 removed lines

@@ -15,8 +15,7 @@
  *
  * @final
  */
-class TaskQueue implements TaskQueueInterface
-{
+class TaskQueue implements TaskQueueInterface {
     private $enableShutdown = true;
     private $queue = [];
 

lib/Vendor/GuzzleHttp/Promise/TaskQueueInterface.php

Indentation +13 added lines, -13 removed lines

@@ -6,19 +6,19 @@
 
 interface TaskQueueInterface
 {
-    /**
-     * Returns true if the queue is empty.
-     */
-    public function isEmpty(): bool;
+	/**
+	 * Returns true if the queue is empty.
+	 */
+	public function isEmpty(): bool;
 
-    /**
-     * Adds a task to the queue that will be executed the next time run is
-     * called.
-     */
-    public function add(callable $task): void;
+	/**
+	 * Adds a task to the queue that will be executed the next time run is
+	 * called.
+	 */
+	public function add(callable $task): void;
 
-    /**
-     * Execute all of the pending task in the queue.
-     */
-    public function run(): void;
+	/**
+	 * Execute all of the pending task in the queue.
+	 */
+	public function run(): void;
 }

Braces +1 added lines, -2 removed lines

@@ -4,8 +4,7 @@
 
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise;
 
-interface TaskQueueInterface
-{
+interface TaskQueueInterface {
     /**
      * Returns true if the queue is empty.
      */

lib/Vendor/GuzzleHttp/Promise/FulfilledPromise.php

Indentation +61 added lines, -61 removed lines

@@ -14,76 +14,76 @@
  */
 class FulfilledPromise implements PromiseInterface
 {
-    private $value;
+	private $value;
 
-    /**
-     * @param mixed $value
-     */
-    public function __construct($value)
-    {
-        if (is_object($value) && method_exists($value, 'then')) {
-            throw new \InvalidArgumentException(
-                'You cannot create a FulfilledPromise with a promise.'
-            );
-        }
+	/**
+	 * @param mixed $value
+	 */
+	public function __construct($value)
+	{
+		if (is_object($value) && method_exists($value, 'then')) {
+			throw new \InvalidArgumentException(
+				'You cannot create a FulfilledPromise with a promise.'
+			);
+		}
 
-        $this->value = $value;
-    }
+		$this->value = $value;
+	}
 
-    public function then(
-        callable $onFulfilled = null,
-        callable $onRejected = null
-    ): PromiseInterface {
-        // Return itself if there is no onFulfilled function.
-        if (!$onFulfilled) {
-            return $this;
-        }
+	public function then(
+		callable $onFulfilled = null,
+		callable $onRejected = null
+	): PromiseInterface {
+		// Return itself if there is no onFulfilled function.
+		if (!$onFulfilled) {
+			return $this;
+		}
 
-        $queue = Utils::queue();
-        $p = new Promise([$queue, 'run']);
-        $value = $this->value;
-        $queue->add(static function () use ($p, $value, $onFulfilled): void {
-            if (Is::pending($p)) {
-                try {
-                    $p->resolve($onFulfilled($value));
-                } catch (\Throwable $e) {
-                    $p->reject($e);
-                }
-            }
-        });
+		$queue = Utils::queue();
+		$p = new Promise([$queue, 'run']);
+		$value = $this->value;
+		$queue->add(static function () use ($p, $value, $onFulfilled): void {
+			if (Is::pending($p)) {
+				try {
+					$p->resolve($onFulfilled($value));
+				} catch (\Throwable $e) {
+					$p->reject($e);
+				}
+			}
+		});
 
-        return $p;
-    }
+		return $p;
+	}
 
-    public function otherwise(callable $onRejected): PromiseInterface
-    {
-        return $this->then(null, $onRejected);
-    }
+	public function otherwise(callable $onRejected): PromiseInterface
+	{
+		return $this->then(null, $onRejected);
+	}
 
-    public function wait(bool $unwrap = true)
-    {
-        return $unwrap ? $this->value : null;
-    }
+	public function wait(bool $unwrap = true)
+	{
+		return $unwrap ? $this->value : null;
+	}
 
-    public function getState(): string
-    {
-        return self::FULFILLED;
-    }
+	public function getState(): string
+	{
+		return self::FULFILLED;
+	}
 
-    public function resolve($value): void
-    {
-        if ($value !== $this->value) {
-            throw new \LogicException('Cannot resolve a fulfilled promise');
-        }
-    }
+	public function resolve($value): void
+	{
+		if ($value !== $this->value) {
+			throw new \LogicException('Cannot resolve a fulfilled promise');
+		}
+	}
 
-    public function reject($reason): void
-    {
-        throw new \LogicException('Cannot reject a fulfilled promise');
-    }
+	public function reject($reason): void
+	{
+		throw new \LogicException('Cannot reject a fulfilled promise');
+	}
 
-    public function cancel(): void
-    {
-        // pass
-    }
+	public function cancel(): void
+	{
+		// pass
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
         $queue = Utils::queue();
         $p = new Promise([$queue, 'run']);
         $value = $this->value;
-        $queue->add(static function () use ($p, $value, $onFulfilled): void {
+        $queue->add(static function() use ($p, $value, $onFulfilled): void {
             if (Is::pending($p)) {
                 try {
                     $p->resolve($onFulfilled($value));

Braces +1 added lines, -2 removed lines

@@ -12,8 +12,7 @@
  *
  * @final
  */
-class FulfilledPromise implements PromiseInterface
-{
+class FulfilledPromise implements PromiseInterface {
     private $value;
 
     /**

lib/Vendor/GuzzleHttp/Promise/Create.php

Indentation +60 added lines, -60 removed lines

@@ -6,74 +6,74 @@
 
 final class Create
 {
-    /**
-     * Creates a promise for a value if the value is not a promise.
-     *
-     * @param mixed $value Promise or value.
-     */
-    public static function promiseFor($value): PromiseInterface
-    {
-        if ($value instanceof PromiseInterface) {
-            return $value;
-        }
+	/**
+	 * Creates a promise for a value if the value is not a promise.
+	 *
+	 * @param mixed $value Promise or value.
+	 */
+	public static function promiseFor($value): PromiseInterface
+	{
+		if ($value instanceof PromiseInterface) {
+			return $value;
+		}
 
-        // Return a Guzzle promise that shadows the given promise.
-        if (is_object($value) && method_exists($value, 'then')) {
-            $wfn = method_exists($value, 'wait') ? [$value, 'wait'] : null;
-            $cfn = method_exists($value, 'cancel') ? [$value, 'cancel'] : null;
-            $promise = new Promise($wfn, $cfn);
-            $value->then([$promise, 'resolve'], [$promise, 'reject']);
+		// Return a Guzzle promise that shadows the given promise.
+		if (is_object($value) && method_exists($value, 'then')) {
+			$wfn = method_exists($value, 'wait') ? [$value, 'wait'] : null;
+			$cfn = method_exists($value, 'cancel') ? [$value, 'cancel'] : null;
+			$promise = new Promise($wfn, $cfn);
+			$value->then([$promise, 'resolve'], [$promise, 'reject']);
 
-            return $promise;
-        }
+			return $promise;
+		}
 
-        return new FulfilledPromise($value);
-    }
+		return new FulfilledPromise($value);
+	}
 
-    /**
-     * Creates a rejected promise for a reason if the reason is not a promise.
-     * If the provided reason is a promise, then it is returned as-is.
-     *
-     * @param mixed $reason Promise or reason.
-     */
-    public static function rejectionFor($reason): PromiseInterface
-    {
-        if ($reason instanceof PromiseInterface) {
-            return $reason;
-        }
+	/**
+	 * Creates a rejected promise for a reason if the reason is not a promise.
+	 * If the provided reason is a promise, then it is returned as-is.
+	 *
+	 * @param mixed $reason Promise or reason.
+	 */
+	public static function rejectionFor($reason): PromiseInterface
+	{
+		if ($reason instanceof PromiseInterface) {
+			return $reason;
+		}
 
-        return new RejectedPromise($reason);
-    }
+		return new RejectedPromise($reason);
+	}
 
-    /**
-     * Create an exception for a rejected promise value.
-     *
-     * @param mixed $reason
-     */
-    public static function exceptionFor($reason): \Throwable
-    {
-        if ($reason instanceof \Throwable) {
-            return $reason;
-        }
+	/**
+	 * Create an exception for a rejected promise value.
+	 *
+	 * @param mixed $reason
+	 */
+	public static function exceptionFor($reason): \Throwable
+	{
+		if ($reason instanceof \Throwable) {
+			return $reason;
+		}
 
-        return new RejectionException($reason);
-    }
+		return new RejectionException($reason);
+	}
 
-    /**
-     * Returns an iterator for the given value.
-     *
-     * @param mixed $value
-     */
-    public static function iterFor($value): \Iterator
-    {
-        if ($value instanceof \Iterator) {
-            return $value;
-        }
+	/**
+	 * Returns an iterator for the given value.
+	 *
+	 * @param mixed $value
+	 */
+	public static function iterFor($value): \Iterator
+	{
+		if ($value instanceof \Iterator) {
+			return $value;
+		}
 
-        if (is_array($value)) {
-            return new \ArrayIterator($value);
-        }
+		if (is_array($value)) {
+			return new \ArrayIterator($value);
+		}
 
-        return new \ArrayIterator([$value]);
-    }
+		return new \ArrayIterator([$value]);
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -4,8 +4,7 @@
 
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise;
 
-final class Create
-{
+final class Create {
     /**
      * Creates a promise for a value if the value is not a promise.
      *