nextcloud / fulltextsearch_elasticsearch

lib/Vendor/Http/Discovery/MessageFactoryDiscovery.php

Braces +1 added lines, -2 removed lines

@@ -12,8 +12,7 @@
  *
  * @deprecated This will be removed in 2.0. Consider using Psr17FactoryDiscovery.
  */
-final class MessageFactoryDiscovery extends ClassDiscovery
-{
+final class MessageFactoryDiscovery extends ClassDiscovery {
     /**
      * Finds a Message Factory.
      *

Indentation +16 added lines, -16 removed lines

@@ -13,20 +13,20 @@
  */
 final class MessageFactoryDiscovery extends ClassDiscovery
 {
-    /**
-     * Finds a Message Factory.
-     *
-     * @return MessageFactory
-     *
-     * @throws Exception\NotFoundException
-     */
-    public static function find()
-    {
-        try {
-            $messageFactory = static::findOneByType(MessageFactory::class);
-        } catch (DiscoveryFailedException $e) {
-            throw new NotFoundException('No php-http message factories found. Note that the php-http message factories are deprecated in favor of the PSR-17 message factories. To use the legacy Guzzle, Diactoros or Slim Framework factories of php-http, install php-http/message and php-http/message-factory and the chosen message implementation.', 0, $e);
-        }
-        return static::instantiateClass($messageFactory);
-    }
+	/**
+	 * Finds a Message Factory.
+	 *
+	 * @return MessageFactory
+	 *
+	 * @throws Exception\NotFoundException
+	 */
+	public static function find()
+	{
+		try {
+			$messageFactory = static::findOneByType(MessageFactory::class);
+		} catch (DiscoveryFailedException $e) {
+			throw new NotFoundException('No php-http message factories found. Note that the php-http message factories are deprecated in favor of the PSR-17 message factories. To use the legacy Guzzle, Diactoros or Slim Framework factories of php-http, install php-http/message and php-http/message-factory and the chosen message implementation.', 0, $e);
+		}
+		return static::instantiateClass($messageFactory);
+	}
 }

lib/Vendor/Http/Promise/FulfilledPromise.php

Braces +1 added lines, -2 removed lines

@@ -7,8 +7,7 @@
  *
  * @author Joel Wurtz <joel.wurtz@gmail.com>
  */
-final class FulfilledPromise implements Promise
-{
+final class FulfilledPromise implements Promise {
     /**
      * @var mixed
      */

Indentation +33 added lines, -33 removed lines

@@ -9,37 +9,37 @@
  */
 final class FulfilledPromise implements Promise
 {
-    /**
-     * @var mixed
-     */
-    private $result;
-    /**
-     * @param mixed $result
-     */
-    public function __construct($result)
-    {
-        $this->result = $result;
-    }
-    public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
-    {
-        if (null === $onFulfilled) {
-            return $this;
-        }
-        try {
-            return new self($onFulfilled($this->result));
-        } catch (\Exception $e) {
-            return new RejectedPromise($e);
-        }
-    }
-    public function getState()
-    {
-        return Promise::FULFILLED;
-    }
-    public function wait($unwrap = \true)
-    {
-        if ($unwrap) {
-            return $this->result;
-        }
-        return null;
-    }
+	/**
+	 * @var mixed
+	 */
+	private $result;
+	/**
+	 * @param mixed $result
+	 */
+	public function __construct($result)
+	{
+		$this->result = $result;
+	}
+	public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
+	{
+		if (null === $onFulfilled) {
+			return $this;
+		}
+		try {
+			return new self($onFulfilled($this->result));
+		} catch (\Exception $e) {
+			return new RejectedPromise($e);
+		}
+	}
+	public function getState()
+	{
+		return Promise::FULFILLED;
+	}
+	public function wait($unwrap = \true)
+	{
+		if ($unwrap) {
+			return $this->result;
+		}
+		return null;
+	}
 }

lib/Vendor/Http/Promise/Promise.php

Braces +1 added lines, -2 removed lines

@@ -13,8 +13,7 @@
  * @author Joel Wurtz <joel.wurtz@gmail.com>
  * @author Márk Sági-Kazár <mark.sagikazar@gmail.com>
  */
-interface Promise
-{
+interface Promise {
     /**
      * Promise has not been fulfilled or rejected.
      */

Indentation +46 added lines, -46 removed lines

@@ -15,50 +15,50 @@
  */
 interface Promise
 {
-    /**
-     * Promise has not been fulfilled or rejected.
-     */
-    const PENDING = 'pending';
-    /**
-     * Promise has been fulfilled.
-     */
-    const FULFILLED = 'fulfilled';
-    /**
-     * Promise has been rejected.
-     */
-    const REJECTED = 'rejected';
-    /**
-     * Adds behavior for when the promise is resolved or rejected (response will be available, or error happens).
-     *
-     * If you do not care about one of the cases, you can set the corresponding callable to null
-     * The callback will be called when the value arrived and never more than once.
-     *
-     * @param callable|null $onFulfilled called when a response will be available
-     * @param callable|null $onRejected  called when an exception occurs
-     *
-     * @return Promise a new resolved promise with value of the executed callback (onFulfilled / onRejected)
-     */
-    public function then(?callable $onFulfilled = null, ?callable $onRejected = null);
-    /**
-     * Returns the state of the promise, one of PENDING, FULFILLED or REJECTED.
-     *
-     * @return string
-     */
-    public function getState();
-    /**
-     * Wait for the promise to be fulfilled or rejected.
-     *
-     * When this method returns, the request has been resolved and if callables have been
-     * specified, the appropriate one has terminated.
-     *
-     * When $unwrap is true (the default), the response is returned, or the exception thrown
-     * on failure. Otherwise, nothing is returned or thrown.
-     *
-     * @param bool $unwrap Whether to return resolved value / throw reason or not
-     *
-     * @return ($unwrap is true ? mixed : null) Resolved value, null if $unwrap is set to false
-     *
-     * @throws \Throwable the rejection reason if $unwrap is set to true and the request failed
-     */
-    public function wait($unwrap = \true);
+	/**
+	 * Promise has not been fulfilled or rejected.
+	 */
+	const PENDING = 'pending';
+	/**
+	 * Promise has been fulfilled.
+	 */
+	const FULFILLED = 'fulfilled';
+	/**
+	 * Promise has been rejected.
+	 */
+	const REJECTED = 'rejected';
+	/**
+	 * Adds behavior for when the promise is resolved or rejected (response will be available, or error happens).
+	 *
+	 * If you do not care about one of the cases, you can set the corresponding callable to null
+	 * The callback will be called when the value arrived and never more than once.
+	 *
+	 * @param callable|null $onFulfilled called when a response will be available
+	 * @param callable|null $onRejected  called when an exception occurs
+	 *
+	 * @return Promise a new resolved promise with value of the executed callback (onFulfilled / onRejected)
+	 */
+	public function then(?callable $onFulfilled = null, ?callable $onRejected = null);
+	/**
+	 * Returns the state of the promise, one of PENDING, FULFILLED or REJECTED.
+	 *
+	 * @return string
+	 */
+	public function getState();
+	/**
+	 * Wait for the promise to be fulfilled or rejected.
+	 *
+	 * When this method returns, the request has been resolved and if callables have been
+	 * specified, the appropriate one has terminated.
+	 *
+	 * When $unwrap is true (the default), the response is returned, or the exception thrown
+	 * on failure. Otherwise, nothing is returned or thrown.
+	 *
+	 * @param bool $unwrap Whether to return resolved value / throw reason or not
+	 *
+	 * @return ($unwrap is true ? mixed : null) Resolved value, null if $unwrap is set to false
+	 *
+	 * @throws \Throwable the rejection reason if $unwrap is set to true and the request failed
+	 */
+	public function wait($unwrap = \true);
 }

lib/Vendor/Http/Promise/RejectedPromise.php

Braces +1 added lines, -2 removed lines

@@ -7,8 +7,7 @@
  *
  * @author Joel Wurtz <joel.wurtz@gmail.com>
  */
-final class RejectedPromise implements Promise
-{
+final class RejectedPromise implements Promise {
     /**
      * @var \Throwable
      */

Indentation +30 added lines, -30 removed lines

@@ -9,34 +9,34 @@
  */
 final class RejectedPromise implements Promise
 {
-    /**
-     * @var \Throwable
-     */
-    private $exception;
-    public function __construct(\Throwable $exception)
-    {
-        $this->exception = $exception;
-    }
-    public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
-    {
-        if (null === $onRejected) {
-            return $this;
-        }
-        try {
-            return new FulfilledPromise($onRejected($this->exception));
-        } catch (\Exception $e) {
-            return new self($e);
-        }
-    }
-    public function getState()
-    {
-        return Promise::REJECTED;
-    }
-    public function wait($unwrap = \true)
-    {
-        if ($unwrap) {
-            throw $this->exception;
-        }
-        return null;
-    }
+	/**
+	 * @var \Throwable
+	 */
+	private $exception;
+	public function __construct(\Throwable $exception)
+	{
+		$this->exception = $exception;
+	}
+	public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
+	{
+		if (null === $onRejected) {
+			return $this;
+		}
+		try {
+			return new FulfilledPromise($onRejected($this->exception));
+		} catch (\Exception $e) {
+			return new self($e);
+		}
+	}
+	public function getState()
+	{
+		return Promise::REJECTED;
+	}
+	public function wait($unwrap = \true)
+	{
+		if ($unwrap) {
+			throw $this->exception;
+		}
+		return null;
+	}
 }

lib/Vendor/Http/Client/Exception.php

Braces +1 added lines, -2 removed lines

@@ -9,6 +9,5 @@
  *
  * @author Márk Sági-Kazár <mark.sagikazar@gmail.com>
  */
-interface Exception extends PsrClientException
-{
+interface Exception extends PsrClientException {
 }

lib/Vendor/Http/Client/HttpAsyncClient.php

Braces +1 added lines, -2 removed lines

@@ -10,8 +10,7 @@
  *
  * @author Joel Wurtz <joel.wurtz@gmail.com>
  */
-interface HttpAsyncClient
-{
+interface HttpAsyncClient {
     /**
      * Sends a PSR-7 request in an asynchronous way.
      *

Indentation +10 added lines, -10 removed lines

@@ -11,14 +11,14 @@
  */
 interface HttpAsyncClient
 {
-    /**
-     * Sends a PSR-7 request in an asynchronous way.
-     *
-     * Exceptions related to processing the request are available from the returned Promise.
-     *
-     * @return Promise resolves a PSR-7 Response or fails with an Http\Client\Exception
-     *
-     * @throws \Exception If processing the request is impossible (eg. bad configuration).
-     */
-    public function sendAsyncRequest(RequestInterface $request);
+	/**
+	 * Sends a PSR-7 request in an asynchronous way.
+	 *
+	 * Exceptions related to processing the request are available from the returned Promise.
+	 *
+	 * @return Promise resolves a PSR-7 Response or fails with an Http\Client\Exception
+	 *
+	 * @throws \Exception If processing the request is impossible (eg. bad configuration).
+	 */
+	public function sendAsyncRequest(RequestInterface $request);
 }

lib/Vendor/Http/Client/Exception/HttpException.php

Braces +1 added lines, -2 removed lines

@@ -12,8 +12,7 @@
  *
  * @author Márk Sági-Kazár <mark.sagikazar@gmail.com>
  */
-class HttpException extends RequestException
-{
+class HttpException extends RequestException {
     /**
      * @var ResponseInterface
      */

Indentation +30 added lines, -30 removed lines

@@ -13,34 +13,34 @@
  */
 class HttpException extends RequestException
 {
-    /**
-     * @var ResponseInterface
-     */
-    protected $response;
-    /**
-     * @param string $message
-     */
-    public function __construct($message, RequestInterface $request, ResponseInterface $response, ?\Exception $previous = null)
-    {
-        parent::__construct($message, $request, $previous);
-        $this->response = $response;
-        $this->code = $response->getStatusCode();
-    }
-    /**
-     * Returns the response.
-     *
-     * @return ResponseInterface
-     */
-    public function getResponse()
-    {
-        return $this->response;
-    }
-    /**
-     * Factory method to create a new exception with a normalized error message.
-     */
-    public static function create(RequestInterface $request, ResponseInterface $response, ?\Exception $previous = null)
-    {
-        $message = \sprintf('[url] %s [http method] %s [status code] %s [reason phrase] %s', $request->getRequestTarget(), $request->getMethod(), $response->getStatusCode(), $response->getReasonPhrase());
-        return new static($message, $request, $response, $previous);
-    }
+	/**
+	 * @var ResponseInterface
+	 */
+	protected $response;
+	/**
+	 * @param string $message
+	 */
+	public function __construct($message, RequestInterface $request, ResponseInterface $response, ?\Exception $previous = null)
+	{
+		parent::__construct($message, $request, $previous);
+		$this->response = $response;
+		$this->code = $response->getStatusCode();
+	}
+	/**
+	 * Returns the response.
+	 *
+	 * @return ResponseInterface
+	 */
+	public function getResponse()
+	{
+		return $this->response;
+	}
+	/**
+	 * Factory method to create a new exception with a normalized error message.
+	 */
+	public static function create(RequestInterface $request, ResponseInterface $response, ?\Exception $previous = null)
+	{
+		$message = \sprintf('[url] %s [http method] %s [status code] %s [reason phrase] %s', $request->getRequestTarget(), $request->getMethod(), $response->getStatusCode(), $response->getReasonPhrase());
+		return new static($message, $request, $response, $previous);
+	}
 }

lib/Vendor/Http/Client/Promise/HttpRejectedPromise.php

Braces +1 added lines, -2 removed lines

@@ -5,8 +5,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Http\Client\Exception;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Http\Promise\Promise;
 
-final class HttpRejectedPromise implements Promise
-{
+final class HttpRejectedPromise implements Promise {
     /**
      * @var Exception
      */

Indentation +33 added lines, -33 removed lines

@@ -6,37 +6,37 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Http\Promise\Promise;
 final class HttpRejectedPromise implements Promise
 {
-    /**
-     * @var Exception
-     */
-    private $exception;
-    public function __construct(Exception $exception)
-    {
-        $this->exception = $exception;
-    }
-    public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
-    {
-        if (null === $onRejected) {
-            return $this;
-        }
-        try {
-            $result = $onRejected($this->exception);
-            if ($result instanceof Promise) {
-                return $result;
-            }
-            return new HttpFulfilledPromise($result);
-        } catch (Exception $e) {
-            return new self($e);
-        }
-    }
-    public function getState()
-    {
-        return Promise::REJECTED;
-    }
-    public function wait($unwrap = \true)
-    {
-        if ($unwrap) {
-            throw $this->exception;
-        }
-    }
+	/**
+	 * @var Exception
+	 */
+	private $exception;
+	public function __construct(Exception $exception)
+	{
+		$this->exception = $exception;
+	}
+	public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
+	{
+		if (null === $onRejected) {
+			return $this;
+		}
+		try {
+			$result = $onRejected($this->exception);
+			if ($result instanceof Promise) {
+				return $result;
+			}
+			return new HttpFulfilledPromise($result);
+		} catch (Exception $e) {
+			return new self($e);
+		}
+	}
+	public function getState()
+	{
+		return Promise::REJECTED;
+	}
+	public function wait($unwrap = \true)
+	{
+		if ($unwrap) {
+			throw $this->exception;
+		}
+	}
 }

lib/Vendor/GuzzleHttp/PrepareBodyMiddleware.php

Braces +1 added lines, -2 removed lines

@@ -11,8 +11,7 @@
  *
  * @final
  */
-class PrepareBodyMiddleware
-{
+class PrepareBodyMiddleware {
     /**
      * @var callable(RequestInterface, array): PromiseInterface
      */

Spacing +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
         // determined, or the size is greater than the cutoff threshold
         $body = $request->getBody();
         $size = $body->getSize();
-        if ($size === null || $size >= (int) $expect || !$body->isSeekable()) {
+        if ($size === null || $size >= (int)$expect || !$body->isSeekable()) {
             $modify['set_headers']['Expect'] = '100-Continue';
         }
     }

Indentation +71 added lines, -71 removed lines

@@ -12,75 +12,75 @@
  */
 class PrepareBodyMiddleware
 {
-    /**
-     * @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;
-        // Don't do anything if the request has no body.
-        if ($request->getBody()->getSize() === 0) {
-            return $fn($request, $options);
-        }
-        $modify = [];
-        // Add a default content-type if possible.
-        if (!$request->hasHeader('Content-Type')) {
-            if ($uri = $request->getBody()->getMetadata('uri')) {
-                if (\is_string($uri) && ($type = Psr7\MimeType::fromFilename($uri))) {
-                    $modify['set_headers']['Content-Type'] = $type;
-                }
-            }
-        }
-        // Add a default content-length or transfer-encoding header.
-        if (!$request->hasHeader('Content-Length') && !$request->hasHeader('Transfer-Encoding')) {
-            $size = $request->getBody()->getSize();
-            if ($size !== null) {
-                $modify['set_headers']['Content-Length'] = $size;
-            } else {
-                $modify['set_headers']['Transfer-Encoding'] = 'chunked';
-            }
-        }
-        // Add the expect header if needed.
-        $this->addExpectHeader($request, $options, $modify);
-        return $fn(Psr7\Utils::modifyRequest($request, $modify), $options);
-    }
-    /**
-     * Add expect header
-     */
-    private function addExpectHeader(RequestInterface $request, array $options, array &$modify) : void
-    {
-        // Determine if the Expect header should be used
-        if ($request->hasHeader('Expect')) {
-            return;
-        }
-        $expect = $options['expect'] ?? null;
-        // Return if disabled or using HTTP/1.0
-        if ($expect === \false || $request->getProtocolVersion() === '1.0') {
-            return;
-        }
-        // The expect header is unconditionally enabled
-        if ($expect === \true) {
-            $modify['set_headers']['Expect'] = '100-Continue';
-            return;
-        }
-        // By default, send the expect header when the payload is > 1mb
-        if ($expect === null) {
-            $expect = 1048576;
-        }
-        // Always add if the body cannot be rewound, the size cannot be
-        // determined, or the size is greater than the cutoff threshold
-        $body = $request->getBody();
-        $size = $body->getSize();
-        if ($size === null || $size >= (int) $expect || !$body->isSeekable()) {
-            $modify['set_headers']['Expect'] = '100-Continue';
-        }
-    }
+	/**
+	 * @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;
+		// Don't do anything if the request has no body.
+		if ($request->getBody()->getSize() === 0) {
+			return $fn($request, $options);
+		}
+		$modify = [];
+		// Add a default content-type if possible.
+		if (!$request->hasHeader('Content-Type')) {
+			if ($uri = $request->getBody()->getMetadata('uri')) {
+				if (\is_string($uri) && ($type = Psr7\MimeType::fromFilename($uri))) {
+					$modify['set_headers']['Content-Type'] = $type;
+				}
+			}
+		}
+		// Add a default content-length or transfer-encoding header.
+		if (!$request->hasHeader('Content-Length') && !$request->hasHeader('Transfer-Encoding')) {
+			$size = $request->getBody()->getSize();
+			if ($size !== null) {
+				$modify['set_headers']['Content-Length'] = $size;
+			} else {
+				$modify['set_headers']['Transfer-Encoding'] = 'chunked';
+			}
+		}
+		// Add the expect header if needed.
+		$this->addExpectHeader($request, $options, $modify);
+		return $fn(Psr7\Utils::modifyRequest($request, $modify), $options);
+	}
+	/**
+	 * Add expect header
+	 */
+	private function addExpectHeader(RequestInterface $request, array $options, array &$modify) : void
+	{
+		// Determine if the Expect header should be used
+		if ($request->hasHeader('Expect')) {
+			return;
+		}
+		$expect = $options['expect'] ?? null;
+		// Return if disabled or using HTTP/1.0
+		if ($expect === \false || $request->getProtocolVersion() === '1.0') {
+			return;
+		}
+		// The expect header is unconditionally enabled
+		if ($expect === \true) {
+			$modify['set_headers']['Expect'] = '100-Continue';
+			return;
+		}
+		// By default, send the expect header when the payload is > 1mb
+		if ($expect === null) {
+			$expect = 1048576;
+		}
+		// Always add if the body cannot be rewound, the size cannot be
+		// determined, or the size is greater than the cutoff threshold
+		$body = $request->getBody();
+		$size = $body->getSize();
+		if ($size === null || $size >= (int) $expect || !$body->isSeekable()) {
+			$modify['set_headers']['Expect'] = '100-Continue';
+		}
+	}
 }