nextcloud / fulltextsearch_elasticsearch

lib/Vendor/GuzzleHttp/Promise/Each.php

Indentation +48 added lines, -48 removed lines

@@ -5,52 +5,52 @@
 
 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();
-    }
-    /**
-     * 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);
-        });
-    }
+	/**
+	 * 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 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 +2 added lines, -2 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise;
 
 final class Each
@@ -49,7 +49,7 @@ 
      */
     public static function ofLimitAll($iterable, $concurrency, callable $onFulfilled = null) : PromiseInterface
     {
-        return self::ofLimit($iterable, $concurrency, $onFulfilled, function ($reason, $idx, PromiseInterface $aggregate) : void {
+        return self::ofLimit($iterable, $concurrency, $onFulfilled, function($reason, $idx, PromiseInterface $aggregate) : void {
             $aggregate->reject($reason);
         });
     }

Braces +1 added lines, -2 removed lines

@@ -3,8 +3,7 @@
 declare (strict_types=1);
 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/AggregateException.php

Indentation +4 added lines, -4 removed lines

@@ -8,8 +8,8 @@
  */
 class AggregateException extends RejectionException
 {
-    public function __construct(string $msg, array $reasons)
-    {
-        parent::__construct($reasons, \sprintf('%s; %d rejected promises', $msg, \count($reasons)));
-    }
+	public function __construct(string $msg, array $reasons)
+	{
+		parent::__construct($reasons, \sprintf('%s; %d rejected promises', $msg, \count($reasons)));
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -6,8 +6,7 @@
 /**
  * Exception thrown when too many errors occur in the some() or any() methods.
  */
-class AggregateException extends RejectionException
-{
+class AggregateException extends RejectionException {
     public function __construct(string $msg, array $reasons)
     {
         parent::__construct($reasons, \sprintf('%s; %d rejected promises', $msg, \count($reasons)));

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise;
 
 /**

lib/Vendor/GuzzleHttp/Promise/Utils.php

Indentation +209 added lines, -209 removed lines

@@ -5,213 +5,213 @@
 
 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()) {
-     *     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();
-        }
-        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);
-            }
-        });
-        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];
-        }
-    }
-    /**
-     * 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;
-    }
-    /**
-     * 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;
-    }
-    /**
-     * 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;
-        });
-        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 $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 = [];
-        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);
-        });
-    }
-    /**
-     * 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 = [];
-        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;
-        });
-    }
+	/**
+	 * 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()) {
+	 *     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();
+		}
+		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);
+			}
+		});
+		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];
+		}
+	}
+	/**
+	 * 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;
+	}
+	/**
+	 * 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;
+	}
+	/**
+	 * 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;
+		});
+		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 $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 = [];
+		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);
+		});
+	}
+	/**
+	 * 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 = [];
+		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;
+		});
+	}
 }

Spacing +13 added lines, -13 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Promise;
 
 final class Utils
@@ -40,7 +40,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());
@@ -124,16 +124,16 @@ 
     public static function all($promises, bool $recursive = \false) : PromiseInterface
     {
         $results = [];
-        $promise = Each::of($promises, function ($value, $idx) use(&$results) : void {
+        $promise = Each::of($promises, 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);
@@ -162,7 +162,7 @@ 
     {
         $results = [];
         $rejections = [];
-        return Each::of($promises, function ($value, $idx, PromiseInterface $p) use(&$results, $count) : void {
+        return Each::of($promises, function($value, $idx, PromiseInterface $p) use(&$results, $count) : void {
             if (Is::settled($p)) {
                 return;
             }
@@ -170,9 +170,9 @@ 
             if (\count($results) >= $count) {
                 $p->resolve(null);
             }
-        }, function ($reason) use(&$rejections) : void {
+        }, function($reason) use(&$rejections) : void {
             $rejections[] = $reason;
-        })->then(function () use(&$results, &$rejections, $count) {
+        })->then(function() use(&$results, &$rejections, $count) {
             if (\count($results) !== $count) {
                 throw new AggregateException('Not enough promises to fulfill count', $rejections);
             }
@@ -188,7 +188,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];
         });
     }
@@ -205,11 +205,11 @@ 
     public static function settle($promises) : PromiseInterface
     {
         $results = [];
-        return Each::of($promises, function ($value, $idx) use(&$results) : void {
+        return Each::of($promises, 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

@@ -3,8 +3,7 @@
 declare (strict_types=1);
 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/BodySummarizer.php

Indentation +15 added lines, -15 removed lines

@@ -5,19 +5,19 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\MessageInterface;
 final class BodySummarizer implements BodySummarizerInterface
 {
-    /**
-     * @var int|null
-     */
-    private $truncateAt;
-    public function __construct(int $truncateAt = null)
-    {
-        $this->truncateAt = $truncateAt;
-    }
-    /**
-     * Returns a summarized message body.
-     */
-    public function summarize(MessageInterface $message) : ?string
-    {
-        return $this->truncateAt === null ? \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Message::bodySummary($message) : \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Message::bodySummary($message, $this->truncateAt);
-    }
+	/**
+	 * @var int|null
+	 */
+	private $truncateAt;
+	public function __construct(int $truncateAt = null)
+	{
+		$this->truncateAt = $truncateAt;
+	}
+	/**
+	 * Returns a summarized message body.
+	 */
+	public function summarize(MessageInterface $message) : ?string
+	{
+		return $this->truncateAt === null ? \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Message::bodySummary($message) : \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Message::bodySummary($message, $this->truncateAt);
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -3,8 +3,7 @@
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\MessageInterface;
-final class BodySummarizer implements BodySummarizerInterface
-{
+final class BodySummarizer implements BodySummarizerInterface {
     /**
      * @var int|null
      */

lib/Vendor/GuzzleHttp/Cookie/CookieJarInterface.php

Indentation +53 added lines, -53 removed lines

@@ -18,57 +18,57 @@
  */
 interface CookieJarInterface extends \Countable, \IteratorAggregate
 {
-    /**
-     * Create a request with added cookie headers.
-     *
-     * If no matching cookies are found in the cookie jar, then no Cookie
-     * header is added to the request and the same request is returned.
-     *
-     * @param RequestInterface $request Request object to modify.
-     *
-     * @return RequestInterface returns the modified request.
-     */
-    public function withCookieHeader(RequestInterface $request) : RequestInterface;
-    /**
-     * Extract cookies from an HTTP response and store them in the CookieJar.
-     *
-     * @param RequestInterface  $request  Request that was sent
-     * @param ResponseInterface $response Response that was received
-     */
-    public function extractCookies(RequestInterface $request, ResponseInterface $response) : void;
-    /**
-     * Sets a cookie in the cookie jar.
-     *
-     * @param SetCookie $cookie Cookie to set.
-     *
-     * @return bool Returns true on success or false on failure
-     */
-    public function setCookie(SetCookie $cookie) : bool;
-    /**
-     * Remove cookies currently held in the cookie jar.
-     *
-     * Invoking this method without arguments will empty the whole cookie jar.
-     * If given a $domain argument only cookies belonging to that domain will
-     * be removed. If given a $domain and $path argument, cookies belonging to
-     * the specified path within that domain are removed. If given all three
-     * arguments, then the cookie with the specified name, path and domain is
-     * removed.
-     *
-     * @param string|null $domain Clears cookies matching a domain
-     * @param string|null $path   Clears cookies matching a domain and path
-     * @param string|null $name   Clears cookies matching a domain, path, and name
-     */
-    public function clear(string $domain = null, string $path = null, string $name = null) : void;
-    /**
-     * Discard all sessions cookies.
-     *
-     * Removes cookies that don't have an expire field or a have a discard
-     * field set to true. To be called when the user agent shuts down according
-     * to RFC 2965.
-     */
-    public function clearSessionCookies() : void;
-    /**
-     * Converts the cookie jar to an array.
-     */
-    public function toArray() : array;
+	/**
+	 * Create a request with added cookie headers.
+	 *
+	 * If no matching cookies are found in the cookie jar, then no Cookie
+	 * header is added to the request and the same request is returned.
+	 *
+	 * @param RequestInterface $request Request object to modify.
+	 *
+	 * @return RequestInterface returns the modified request.
+	 */
+	public function withCookieHeader(RequestInterface $request) : RequestInterface;
+	/**
+	 * Extract cookies from an HTTP response and store them in the CookieJar.
+	 *
+	 * @param RequestInterface  $request  Request that was sent
+	 * @param ResponseInterface $response Response that was received
+	 */
+	public function extractCookies(RequestInterface $request, ResponseInterface $response) : void;
+	/**
+	 * Sets a cookie in the cookie jar.
+	 *
+	 * @param SetCookie $cookie Cookie to set.
+	 *
+	 * @return bool Returns true on success or false on failure
+	 */
+	public function setCookie(SetCookie $cookie) : bool;
+	/**
+	 * Remove cookies currently held in the cookie jar.
+	 *
+	 * Invoking this method without arguments will empty the whole cookie jar.
+	 * If given a $domain argument only cookies belonging to that domain will
+	 * be removed. If given a $domain and $path argument, cookies belonging to
+	 * the specified path within that domain are removed. If given all three
+	 * arguments, then the cookie with the specified name, path and domain is
+	 * removed.
+	 *
+	 * @param string|null $domain Clears cookies matching a domain
+	 * @param string|null $path   Clears cookies matching a domain and path
+	 * @param string|null $name   Clears cookies matching a domain, path, and name
+	 */
+	public function clear(string $domain = null, string $path = null, string $name = null) : void;
+	/**
+	 * Discard all sessions cookies.
+	 *
+	 * Removes cookies that don't have an expire field or a have a discard
+	 * field set to true. To be called when the user agent shuts down according
+	 * to RFC 2965.
+	 */
+	public function clearSessionCookies() : void;
+	/**
+	 * Converts the cookie jar to an array.
+	 */
+	public function toArray() : array;
 }

lib/Vendor/GuzzleHttp/Utils.php

Indentation +313 added lines, -313 removed lines

@@ -10,147 +10,147 @@ 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\UriInterface;
 final class Utils
 {
-    /**
-     * Debug function used to describe the provided value type and class.
-     *
-     * @param mixed $input
-     *
-     * @return string Returns a string containing the type of the variable and
-     *                if a class is provided, the class name.
-     */
-    public static function describeType($input) : string
-    {
-        switch (\gettype($input)) {
-            case 'object':
-                return 'object(' . \get_class($input) . ')';
-            case 'array':
-                return 'array(' . \count($input) . ')';
-            default:
-                \ob_start();
-                \var_dump($input);
-                // normalize float vs double
-                /** @var string $varDumpContent */
-                $varDumpContent = \ob_get_clean();
-                return \str_replace('double(', 'float(', \rtrim($varDumpContent));
-        }
-    }
-    /**
-     * Parses an array of header lines into an associative array of headers.
-     *
-     * @param iterable $lines Header lines array of strings in the following
-     *                        format: "Name: Value"
-     */
-    public static function headersFromLines(iterable $lines) : array
-    {
-        $headers = [];
-        foreach ($lines as $line) {
-            $parts = \explode(':', $line, 2);
-            $headers[\trim($parts[0])][] = isset($parts[1]) ? \trim($parts[1]) : null;
-        }
-        return $headers;
-    }
-    /**
-     * Returns a debug stream based on the provided variable.
-     *
-     * @param mixed $value Optional value
-     *
-     * @return resource
-     */
-    public static function debugResource($value = null)
-    {
-        if (\is_resource($value)) {
-            return $value;
-        }
-        if (\defined('STDOUT')) {
-            return \STDOUT;
-        }
-        return \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Utils::tryFopen('php://output', 'w');
-    }
-    /**
-     * Chooses and creates a default handler to use based on the environment.
-     *
-     * The returned handler is not wrapped by any default middlewares.
-     *
-     * @return callable(\Psr\Http\Message\RequestInterface, array): \GuzzleHttp\Promise\PromiseInterface Returns the best handler for the given system.
-     *
-     * @throws \RuntimeException if no viable Handler is available.
-     */
-    public static function chooseHandler() : callable
-    {
-        $handler = null;
-        if (\defined('CURLOPT_CUSTOMREQUEST')) {
-            if (\function_exists('curl_multi_exec') && \function_exists('curl_exec')) {
-                $handler = Proxy::wrapSync(new CurlMultiHandler(), new CurlHandler());
-            } elseif (\function_exists('curl_exec')) {
-                $handler = new CurlHandler();
-            } elseif (\function_exists('curl_multi_exec')) {
-                $handler = new CurlMultiHandler();
-            }
-        }
-        if (\ini_get('allow_url_fopen')) {
-            $handler = $handler ? Proxy::wrapStreaming($handler, new StreamHandler()) : new StreamHandler();
-        } elseif (!$handler) {
-            throw new \RuntimeException('GuzzleHttp requires cURL, the allow_url_fopen ini setting, or a custom HTTP handler.');
-        }
-        return $handler;
-    }
-    /**
-     * Get the default User-Agent string to use with Guzzle.
-     */
-    public static function defaultUserAgent() : string
-    {
-        return \sprintf('GuzzleHttp/%d', ClientInterface::MAJOR_VERSION);
-    }
-    /**
-     * Returns the default cacert bundle for the current system.
-     *
-     * First, the openssl.cafile and curl.cainfo php.ini settings are checked.
-     * If those settings are not configured, then the common locations for
-     * bundles found on Red Hat, CentOS, Fedora, Ubuntu, Debian, FreeBSD, OS X
-     * and Windows are checked. If any of these file locations are found on
-     * disk, they will be utilized.
-     *
-     * Note: the result of this function is cached for subsequent calls.
-     *
-     * @throws \RuntimeException if no bundle can be found.
-     *
-     * @deprecated Utils::defaultCaBundle will be removed in guzzlehttp/guzzle:8.0. This method is not needed in PHP 5.6+.
-     */
-    public static function defaultCaBundle() : string
-    {
-        static $cached = null;
-        static $cafiles = [
-            // Red Hat, CentOS, Fedora (provided by the ca-certificates package)
-            '/etc/pki/tls/certs/ca-bundle.crt',
-            // Ubuntu, Debian (provided by the ca-certificates package)
-            '/etc/ssl/certs/ca-certificates.crt',
-            // FreeBSD (provided by the ca_root_nss package)
-            '/usr/local/share/certs/ca-root-nss.crt',
-            // SLES 12 (provided by the ca-certificates package)
-            '/var/lib/ca-certificates/ca-bundle.pem',
-            // OS X provided by homebrew (using the default path)
-            '/usr/local/etc/openssl/cert.pem',
-            // Google app engine
-            '/etc/ca-certificates.crt',
-            // Windows?
-            'C:\\windows\\system32\\curl-ca-bundle.crt',
-            'C:\\windows\\curl-ca-bundle.crt',
-        ];
-        if ($cached) {
-            return $cached;
-        }
-        if ($ca = \ini_get('openssl.cafile')) {
-            return $cached = $ca;
-        }
-        if ($ca = \ini_get('curl.cainfo')) {
-            return $cached = $ca;
-        }
-        foreach ($cafiles as $filename) {
-            if (\file_exists($filename)) {
-                return $cached = $filename;
-            }
-        }
-        throw new \RuntimeException(<<<EOT
+	/**
+	 * Debug function used to describe the provided value type and class.
+	 *
+	 * @param mixed $input
+	 *
+	 * @return string Returns a string containing the type of the variable and
+	 *                if a class is provided, the class name.
+	 */
+	public static function describeType($input) : string
+	{
+		switch (\gettype($input)) {
+			case 'object':
+				return 'object(' . \get_class($input) . ')';
+			case 'array':
+				return 'array(' . \count($input) . ')';
+			default:
+				\ob_start();
+				\var_dump($input);
+				// normalize float vs double
+				/** @var string $varDumpContent */
+				$varDumpContent = \ob_get_clean();
+				return \str_replace('double(', 'float(', \rtrim($varDumpContent));
+		}
+	}
+	/**
+	 * Parses an array of header lines into an associative array of headers.
+	 *
+	 * @param iterable $lines Header lines array of strings in the following
+	 *                        format: "Name: Value"
+	 */
+	public static function headersFromLines(iterable $lines) : array
+	{
+		$headers = [];
+		foreach ($lines as $line) {
+			$parts = \explode(':', $line, 2);
+			$headers[\trim($parts[0])][] = isset($parts[1]) ? \trim($parts[1]) : null;
+		}
+		return $headers;
+	}
+	/**
+	 * Returns a debug stream based on the provided variable.
+	 *
+	 * @param mixed $value Optional value
+	 *
+	 * @return resource
+	 */
+	public static function debugResource($value = null)
+	{
+		if (\is_resource($value)) {
+			return $value;
+		}
+		if (\defined('STDOUT')) {
+			return \STDOUT;
+		}
+		return \OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7\Utils::tryFopen('php://output', 'w');
+	}
+	/**
+	 * Chooses and creates a default handler to use based on the environment.
+	 *
+	 * The returned handler is not wrapped by any default middlewares.
+	 *
+	 * @return callable(\Psr\Http\Message\RequestInterface, array): \GuzzleHttp\Promise\PromiseInterface Returns the best handler for the given system.
+	 *
+	 * @throws \RuntimeException if no viable Handler is available.
+	 */
+	public static function chooseHandler() : callable
+	{
+		$handler = null;
+		if (\defined('CURLOPT_CUSTOMREQUEST')) {
+			if (\function_exists('curl_multi_exec') && \function_exists('curl_exec')) {
+				$handler = Proxy::wrapSync(new CurlMultiHandler(), new CurlHandler());
+			} elseif (\function_exists('curl_exec')) {
+				$handler = new CurlHandler();
+			} elseif (\function_exists('curl_multi_exec')) {
+				$handler = new CurlMultiHandler();
+			}
+		}
+		if (\ini_get('allow_url_fopen')) {
+			$handler = $handler ? Proxy::wrapStreaming($handler, new StreamHandler()) : new StreamHandler();
+		} elseif (!$handler) {
+			throw new \RuntimeException('GuzzleHttp requires cURL, the allow_url_fopen ini setting, or a custom HTTP handler.');
+		}
+		return $handler;
+	}
+	/**
+	 * Get the default User-Agent string to use with Guzzle.
+	 */
+	public static function defaultUserAgent() : string
+	{
+		return \sprintf('GuzzleHttp/%d', ClientInterface::MAJOR_VERSION);
+	}
+	/**
+	 * Returns the default cacert bundle for the current system.
+	 *
+	 * First, the openssl.cafile and curl.cainfo php.ini settings are checked.
+	 * If those settings are not configured, then the common locations for
+	 * bundles found on Red Hat, CentOS, Fedora, Ubuntu, Debian, FreeBSD, OS X
+	 * and Windows are checked. If any of these file locations are found on
+	 * disk, they will be utilized.
+	 *
+	 * Note: the result of this function is cached for subsequent calls.
+	 *
+	 * @throws \RuntimeException if no bundle can be found.
+	 *
+	 * @deprecated Utils::defaultCaBundle will be removed in guzzlehttp/guzzle:8.0. This method is not needed in PHP 5.6+.
+	 */
+	public static function defaultCaBundle() : string
+	{
+		static $cached = null;
+		static $cafiles = [
+			// Red Hat, CentOS, Fedora (provided by the ca-certificates package)
+			'/etc/pki/tls/certs/ca-bundle.crt',
+			// Ubuntu, Debian (provided by the ca-certificates package)
+			'/etc/ssl/certs/ca-certificates.crt',
+			// FreeBSD (provided by the ca_root_nss package)
+			'/usr/local/share/certs/ca-root-nss.crt',
+			// SLES 12 (provided by the ca-certificates package)
+			'/var/lib/ca-certificates/ca-bundle.pem',
+			// OS X provided by homebrew (using the default path)
+			'/usr/local/etc/openssl/cert.pem',
+			// Google app engine
+			'/etc/ca-certificates.crt',
+			// Windows?
+			'C:\\windows\\system32\\curl-ca-bundle.crt',
+			'C:\\windows\\curl-ca-bundle.crt',
+		];
+		if ($cached) {
+			return $cached;
+		}
+		if ($ca = \ini_get('openssl.cafile')) {
+			return $cached = $ca;
+		}
+		if ($ca = \ini_get('curl.cainfo')) {
+			return $cached = $ca;
+		}
+		foreach ($cafiles as $filename) {
+			if (\file_exists($filename)) {
+				return $cached = $filename;
+			}
+		}
+		throw new \RuntimeException(<<<EOT
 No system CA bundle could be found in any of the the common system locations.
 PHP versions earlier than 5.6 are not properly configured to use the system's
 CA bundle by default. In order to verify peer certificates, you will need to
@@ -164,176 +164,176 @@ 
 https://curl.haxx.se/docs/sslcerts.html for more information.
 EOT
 );
-    }
-    /**
-     * Creates an associative array of lowercase header names to the actual
-     * header casing.
-     */
-    public static function normalizeHeaderKeys(array $headers) : array
-    {
-        $result = [];
-        foreach (\array_keys($headers) as $key) {
-            $result[\strtolower($key)] = $key;
-        }
-        return $result;
-    }
-    /**
-     * Returns true if the provided host matches any of the no proxy areas.
-     *
-     * This method will strip a port from the host if it is present. Each pattern
-     * can be matched with an exact match (e.g., "foo.com" == "foo.com") or a
-     * partial match: (e.g., "foo.com" == "baz.foo.com" and ".foo.com" ==
-     * "baz.foo.com", but ".foo.com" != "foo.com").
-     *
-     * Areas are matched in the following cases:
-     * 1. "*" (without quotes) always matches any hosts.
-     * 2. An exact match.
-     * 3. The area starts with "." and the area is the last part of the host. e.g.
-     *    '.mit.edu' will match any host that ends with '.mit.edu'.
-     *
-     * @param string   $host         Host to check against the patterns.
-     * @param string[] $noProxyArray An array of host patterns.
-     *
-     * @throws InvalidArgumentException
-     */
-    public static function isHostInNoProxy(string $host, array $noProxyArray) : bool
-    {
-        if (\strlen($host) === 0) {
-            throw new InvalidArgumentException('Empty host provided');
-        }
-        // Strip port if present.
-        [$host] = \explode(':', $host, 2);
-        foreach ($noProxyArray as $area) {
-            // Always match on wildcards.
-            if ($area === '*') {
-                return \true;
-            }
-            if (empty($area)) {
-                // Don't match on empty values.
-                continue;
-            }
-            if ($area === $host) {
-                // Exact matches.
-                return \true;
-            }
-            // Special match if the area when prefixed with ".". Remove any
-            // existing leading "." and add a new leading ".".
-            $area = '.' . \ltrim($area, '.');
-            if (\substr($host, -\strlen($area)) === $area) {
-                return \true;
-            }
-        }
-        return \false;
-    }
-    /**
-     * Wrapper for json_decode that throws when an error occurs.
-     *
-     * @param string $json    JSON data to parse
-     * @param bool   $assoc   When true, returned objects will be converted
-     *                        into associative arrays.
-     * @param int    $depth   User specified recursion depth.
-     * @param int    $options Bitmask of JSON decode options.
-     *
-     * @return object|array|string|int|float|bool|null
-     *
-     * @throws InvalidArgumentException if the JSON cannot be decoded.
-     *
-     * @see https://www.php.net/manual/en/function.json-decode.php
-     */
-    public static function jsonDecode(string $json, bool $assoc = \false, int $depth = 512, int $options = 0)
-    {
-        $data = \json_decode($json, $assoc, $depth, $options);
-        if (\JSON_ERROR_NONE !== \json_last_error()) {
-            throw new InvalidArgumentException('json_decode error: ' . \json_last_error_msg());
-        }
-        return $data;
-    }
-    /**
-     * Wrapper for JSON encoding that throws when an error occurs.
-     *
-     * @param mixed $value   The value being encoded
-     * @param int   $options JSON encode option bitmask
-     * @param int   $depth   Set the maximum depth. Must be greater than zero.
-     *
-     * @throws InvalidArgumentException if the JSON cannot be encoded.
-     *
-     * @see https://www.php.net/manual/en/function.json-encode.php
-     */
-    public static function jsonEncode($value, int $options = 0, int $depth = 512) : string
-    {
-        $json = \json_encode($value, $options, $depth);
-        if (\JSON_ERROR_NONE !== \json_last_error()) {
-            throw new InvalidArgumentException('json_encode error: ' . \json_last_error_msg());
-        }
-        /** @var string */
-        return $json;
-    }
-    /**
-     * Wrapper for the hrtime() or microtime() functions
-     * (depending on the PHP version, one of the two is used)
-     *
-     * @return float UNIX timestamp
-     *
-     * @internal
-     */
-    public static function currentTime() : float
-    {
-        return (float) \function_exists('hrtime') ? \hrtime(\true) / 1000000000.0 : \microtime(\true);
-    }
-    /**
-     * @throws InvalidArgumentException
-     *
-     * @internal
-     */
-    public static function idnUriConvert(UriInterface $uri, int $options = 0) : UriInterface
-    {
-        if ($uri->getHost()) {
-            $asciiHost = self::idnToAsci($uri->getHost(), $options, $info);
-            if ($asciiHost === \false) {
-                $errorBitSet = $info['errors'] ?? 0;
-                $errorConstants = \array_filter(\array_keys(\get_defined_constants()), static function (string $name) : bool {
-                    return \substr($name, 0, 11) === 'IDNA_ERROR_';
-                });
-                $errors = [];
-                foreach ($errorConstants as $errorConstant) {
-                    if ($errorBitSet & \constant($errorConstant)) {
-                        $errors[] = $errorConstant;
-                    }
-                }
-                $errorMessage = 'IDN conversion failed';
-                if ($errors) {
-                    $errorMessage .= ' (errors: ' . \implode(', ', $errors) . ')';
-                }
-                throw new InvalidArgumentException($errorMessage);
-            }
-            if ($uri->getHost() !== $asciiHost) {
-                // Replace URI only if the ASCII version is different
-                $uri = $uri->withHost($asciiHost);
-            }
-        }
-        return $uri;
-    }
-    /**
-     * @internal
-     */
-    public static function getenv(string $name) : ?string
-    {
-        if (isset($_SERVER[$name])) {
-            return (string) $_SERVER[$name];
-        }
-        if (\PHP_SAPI === 'cli' && ($value = \getenv($name)) !== \false && $value !== null) {
-            return (string) $value;
-        }
-        return null;
-    }
-    /**
-     * @return string|false
-     */
-    private static function idnToAsci(string $domain, int $options, ?array &$info = [])
-    {
-        if (\function_exists('idn_to_ascii') && \defined('INTL_IDNA_VARIANT_UTS46')) {
-            return \idn_to_ascii($domain, $options, \INTL_IDNA_VARIANT_UTS46, $info);
-        }
-        throw new \Error('ext-idn or symfony/polyfill-intl-idn not loaded or too old');
-    }
+	}
+	/**
+	 * Creates an associative array of lowercase header names to the actual
+	 * header casing.
+	 */
+	public static function normalizeHeaderKeys(array $headers) : array
+	{
+		$result = [];
+		foreach (\array_keys($headers) as $key) {
+			$result[\strtolower($key)] = $key;
+		}
+		return $result;
+	}
+	/**
+	 * Returns true if the provided host matches any of the no proxy areas.
+	 *
+	 * This method will strip a port from the host if it is present. Each pattern
+	 * can be matched with an exact match (e.g., "foo.com" == "foo.com") or a
+	 * partial match: (e.g., "foo.com" == "baz.foo.com" and ".foo.com" ==
+	 * "baz.foo.com", but ".foo.com" != "foo.com").
+	 *
+	 * Areas are matched in the following cases:
+	 * 1. "*" (without quotes) always matches any hosts.
+	 * 2. An exact match.
+	 * 3. The area starts with "." and the area is the last part of the host. e.g.
+	 *    '.mit.edu' will match any host that ends with '.mit.edu'.
+	 *
+	 * @param string   $host         Host to check against the patterns.
+	 * @param string[] $noProxyArray An array of host patterns.
+	 *
+	 * @throws InvalidArgumentException
+	 */
+	public static function isHostInNoProxy(string $host, array $noProxyArray) : bool
+	{
+		if (\strlen($host) === 0) {
+			throw new InvalidArgumentException('Empty host provided');
+		}
+		// Strip port if present.
+		[$host] = \explode(':', $host, 2);
+		foreach ($noProxyArray as $area) {
+			// Always match on wildcards.
+			if ($area === '*') {
+				return \true;
+			}
+			if (empty($area)) {
+				// Don't match on empty values.
+				continue;
+			}
+			if ($area === $host) {
+				// Exact matches.
+				return \true;
+			}
+			// Special match if the area when prefixed with ".". Remove any
+			// existing leading "." and add a new leading ".".
+			$area = '.' . \ltrim($area, '.');
+			if (\substr($host, -\strlen($area)) === $area) {
+				return \true;
+			}
+		}
+		return \false;
+	}
+	/**
+	 * Wrapper for json_decode that throws when an error occurs.
+	 *
+	 * @param string $json    JSON data to parse
+	 * @param bool   $assoc   When true, returned objects will be converted
+	 *                        into associative arrays.
+	 * @param int    $depth   User specified recursion depth.
+	 * @param int    $options Bitmask of JSON decode options.
+	 *
+	 * @return object|array|string|int|float|bool|null
+	 *
+	 * @throws InvalidArgumentException if the JSON cannot be decoded.
+	 *
+	 * @see https://www.php.net/manual/en/function.json-decode.php
+	 */
+	public static function jsonDecode(string $json, bool $assoc = \false, int $depth = 512, int $options = 0)
+	{
+		$data = \json_decode($json, $assoc, $depth, $options);
+		if (\JSON_ERROR_NONE !== \json_last_error()) {
+			throw new InvalidArgumentException('json_decode error: ' . \json_last_error_msg());
+		}
+		return $data;
+	}
+	/**
+	 * Wrapper for JSON encoding that throws when an error occurs.
+	 *
+	 * @param mixed $value   The value being encoded
+	 * @param int   $options JSON encode option bitmask
+	 * @param int   $depth   Set the maximum depth. Must be greater than zero.
+	 *
+	 * @throws InvalidArgumentException if the JSON cannot be encoded.
+	 *
+	 * @see https://www.php.net/manual/en/function.json-encode.php
+	 */
+	public static function jsonEncode($value, int $options = 0, int $depth = 512) : string
+	{
+		$json = \json_encode($value, $options, $depth);
+		if (\JSON_ERROR_NONE !== \json_last_error()) {
+			throw new InvalidArgumentException('json_encode error: ' . \json_last_error_msg());
+		}
+		/** @var string */
+		return $json;
+	}
+	/**
+	 * Wrapper for the hrtime() or microtime() functions
+	 * (depending on the PHP version, one of the two is used)
+	 *
+	 * @return float UNIX timestamp
+	 *
+	 * @internal
+	 */
+	public static function currentTime() : float
+	{
+		return (float) \function_exists('hrtime') ? \hrtime(\true) / 1000000000.0 : \microtime(\true);
+	}
+	/**
+	 * @throws InvalidArgumentException
+	 *
+	 * @internal
+	 */
+	public static function idnUriConvert(UriInterface $uri, int $options = 0) : UriInterface
+	{
+		if ($uri->getHost()) {
+			$asciiHost = self::idnToAsci($uri->getHost(), $options, $info);
+			if ($asciiHost === \false) {
+				$errorBitSet = $info['errors'] ?? 0;
+				$errorConstants = \array_filter(\array_keys(\get_defined_constants()), static function (string $name) : bool {
+					return \substr($name, 0, 11) === 'IDNA_ERROR_';
+				});
+				$errors = [];
+				foreach ($errorConstants as $errorConstant) {
+					if ($errorBitSet & \constant($errorConstant)) {
+						$errors[] = $errorConstant;
+					}
+				}
+				$errorMessage = 'IDN conversion failed';
+				if ($errors) {
+					$errorMessage .= ' (errors: ' . \implode(', ', $errors) . ')';
+				}
+				throw new InvalidArgumentException($errorMessage);
+			}
+			if ($uri->getHost() !== $asciiHost) {
+				// Replace URI only if the ASCII version is different
+				$uri = $uri->withHost($asciiHost);
+			}
+		}
+		return $uri;
+	}
+	/**
+	 * @internal
+	 */
+	public static function getenv(string $name) : ?string
+	{
+		if (isset($_SERVER[$name])) {
+			return (string) $_SERVER[$name];
+		}
+		if (\PHP_SAPI === 'cli' && ($value = \getenv($name)) !== \false && $value !== null) {
+			return (string) $value;
+		}
+		return null;
+	}
+	/**
+	 * @return string|false
+	 */
+	private static function idnToAsci(string $domain, int $options, ?array &$info = [])
+	{
+		if (\function_exists('idn_to_ascii') && \defined('INTL_IDNA_VARIANT_UTS46')) {
+			return \idn_to_ascii($domain, $options, \INTL_IDNA_VARIANT_UTS46, $info);
+		}
+		throw new \Error('ext-idn or symfony/polyfill-intl-idn not loaded or too old');
+	}
 }

Spacing +10 added lines, -10 removed lines

@@ -22,9 +22,9 @@ 
     {
         switch (\gettype($input)) {
             case 'object':
-                return 'object(' . \get_class($input) . ')';
+                return 'object('.\get_class($input).')';
             case 'array':
-                return 'array(' . \count($input) . ')';
+                return 'array('.\count($input).')';
             default:
                 \ob_start();
                 \var_dump($input);
@@ -218,7 +218,7 @@ 
             }
             // Special match if the area when prefixed with ".". Remove any
             // existing leading "." and add a new leading ".".
-            $area = '.' . \ltrim($area, '.');
+            $area = '.'.\ltrim($area, '.');
             if (\substr($host, -\strlen($area)) === $area) {
                 return \true;
             }
@@ -244,7 +244,7 @@ 
     {
         $data = \json_decode($json, $assoc, $depth, $options);
         if (\JSON_ERROR_NONE !== \json_last_error()) {
-            throw new InvalidArgumentException('json_decode error: ' . \json_last_error_msg());
+            throw new InvalidArgumentException('json_decode error: '.\json_last_error_msg());
         }
         return $data;
     }
@@ -263,7 +263,7 @@ 
     {
         $json = \json_encode($value, $options, $depth);
         if (\JSON_ERROR_NONE !== \json_last_error()) {
-            throw new InvalidArgumentException('json_encode error: ' . \json_last_error_msg());
+            throw new InvalidArgumentException('json_encode error: '.\json_last_error_msg());
         }
         /** @var string */
         return $json;
@@ -278,7 +278,7 @@ 
      */
     public static function currentTime() : float
     {
-        return (float) \function_exists('hrtime') ? \hrtime(\true) / 1000000000.0 : \microtime(\true);
+        return (float)\function_exists('hrtime') ? \hrtime(\true) / 1000000000.0 : \microtime(\true);
     }
     /**
      * @throws InvalidArgumentException
@@ -291,7 +291,7 @@ 
             $asciiHost = self::idnToAsci($uri->getHost(), $options, $info);
             if ($asciiHost === \false) {
                 $errorBitSet = $info['errors'] ?? 0;
-                $errorConstants = \array_filter(\array_keys(\get_defined_constants()), static function (string $name) : bool {
+                $errorConstants = \array_filter(\array_keys(\get_defined_constants()), static function(string $name) : bool {
                     return \substr($name, 0, 11) === 'IDNA_ERROR_';
                 });
                 $errors = [];
@@ -302,7 +302,7 @@ 
                 }
                 $errorMessage = 'IDN conversion failed';
                 if ($errors) {
-                    $errorMessage .= ' (errors: ' . \implode(', ', $errors) . ')';
+                    $errorMessage .= ' (errors: '.\implode(', ', $errors).')';
                 }
                 throw new InvalidArgumentException($errorMessage);
             }
@@ -319,10 +319,10 @@ 
     public static function getenv(string $name) : ?string
     {
         if (isset($_SERVER[$name])) {
-            return (string) $_SERVER[$name];
+            return (string)$_SERVER[$name];
         }
         if (\PHP_SAPI === 'cli' && ($value = \getenv($name)) !== \false && $value !== null) {
-            return (string) $value;
+            return (string)$value;
         }
         return null;
     }

Braces +1 added lines, -2 removed lines

@@ -8,8 +8,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Handler\Proxy;
 use OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Handler\StreamHandler;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\UriInterface;
-final class Utils
-{
+final class Utils {
     /**
      * Debug function used to describe the provided value type and class.
      *

lib/Vendor/Http/Discovery/Psr17Factory.php

Indentation +198 added lines, -198 removed lines

@@ -40,202 +40,202 @@
  */
 class Psr17Factory implements RequestFactoryInterface, ResponseFactoryInterface, ServerRequestFactoryInterface, StreamFactoryInterface, UploadedFileFactoryInterface, UriFactoryInterface
 {
-    private $requestFactory;
-    private $responseFactory;
-    private $serverRequestFactory;
-    private $streamFactory;
-    private $uploadedFileFactory;
-    private $uriFactory;
-    public function __construct(?RequestFactoryInterface $requestFactory = null, ?ResponseFactoryInterface $responseFactory = null, ?ServerRequestFactoryInterface $serverRequestFactory = null, ?StreamFactoryInterface $streamFactory = null, ?UploadedFileFactoryInterface $uploadedFileFactory = null, ?UriFactoryInterface $uriFactory = null)
-    {
-        $this->requestFactory = $requestFactory;
-        $this->responseFactory = $responseFactory;
-        $this->serverRequestFactory = $serverRequestFactory;
-        $this->streamFactory = $streamFactory;
-        $this->uploadedFileFactory = $uploadedFileFactory;
-        $this->uriFactory = $uriFactory;
-        $this->setFactory($requestFactory);
-        $this->setFactory($responseFactory);
-        $this->setFactory($serverRequestFactory);
-        $this->setFactory($streamFactory);
-        $this->setFactory($uploadedFileFactory);
-        $this->setFactory($uriFactory);
-    }
-    /**
-     * @param UriInterface|string $uri
-     */
-    public function createRequest(string $method, $uri) : RequestInterface
-    {
-        $factory = $this->requestFactory ?? $this->setFactory(Psr17FactoryDiscovery::findRequestFactory());
-        return $factory->createRequest(...\func_get_args());
-    }
-    public function createResponse(int $code = 200, string $reasonPhrase = '') : ResponseInterface
-    {
-        $factory = $this->responseFactory ?? $this->setFactory(Psr17FactoryDiscovery::findResponseFactory());
-        return $factory->createResponse(...\func_get_args());
-    }
-    /**
-     * @param UriInterface|string $uri
-     */
-    public function createServerRequest(string $method, $uri, array $serverParams = []) : ServerRequestInterface
-    {
-        $factory = $this->serverRequestFactory ?? $this->setFactory(Psr17FactoryDiscovery::findServerRequestFactory());
-        return $factory->createServerRequest(...\func_get_args());
-    }
-    public function createServerRequestFromGlobals(?array $server = null, ?array $get = null, ?array $post = null, ?array $cookie = null, ?array $files = null, ?StreamInterface $body = null) : ServerRequestInterface
-    {
-        $server = $server ?? $_SERVER;
-        $request = $this->createServerRequest($server['REQUEST_METHOD'] ?? 'GET', $this->createUriFromGlobals($server), $server);
-        return $this->buildServerRequestFromGlobals($request, $server, $files ?? $_FILES)->withQueryParams($get ?? $_GET)->withParsedBody($post ?? $_POST)->withCookieParams($cookie ?? $_COOKIE)->withBody($body ?? $this->createStreamFromFile('php://input', 'r+'));
-    }
-    public function createStream(string $content = '') : StreamInterface
-    {
-        $factory = $this->streamFactory ?? $this->setFactory(Psr17FactoryDiscovery::findStreamFactory());
-        return $factory->createStream($content);
-    }
-    public function createStreamFromFile(string $filename, string $mode = 'r') : StreamInterface
-    {
-        $factory = $this->streamFactory ?? $this->setFactory(Psr17FactoryDiscovery::findStreamFactory());
-        return $factory->createStreamFromFile($filename, $mode);
-    }
-    /**
-     * @param resource $resource
-     */
-    public function createStreamFromResource($resource) : StreamInterface
-    {
-        $factory = $this->streamFactory ?? $this->setFactory(Psr17FactoryDiscovery::findStreamFactory());
-        return $factory->createStreamFromResource($resource);
-    }
-    public function createUploadedFile(StreamInterface $stream, ?int $size = null, int $error = \UPLOAD_ERR_OK, ?string $clientFilename = null, ?string $clientMediaType = null) : UploadedFileInterface
-    {
-        $factory = $this->uploadedFileFactory ?? $this->setFactory(Psr17FactoryDiscovery::findUploadedFileFactory());
-        return $factory->createUploadedFile(...\func_get_args());
-    }
-    public function createUri(string $uri = '') : UriInterface
-    {
-        $factory = $this->uriFactory ?? $this->setFactory(Psr17FactoryDiscovery::findUriFactory());
-        return $factory->createUri(...\func_get_args());
-    }
-    public function createUriFromGlobals(?array $server = null) : UriInterface
-    {
-        return $this->buildUriFromGlobals($this->createUri(''), $server ?? $_SERVER);
-    }
-    private function setFactory($factory)
-    {
-        if (!$this->requestFactory && $factory instanceof RequestFactoryInterface) {
-            $this->requestFactory = $factory;
-        }
-        if (!$this->responseFactory && $factory instanceof ResponseFactoryInterface) {
-            $this->responseFactory = $factory;
-        }
-        if (!$this->serverRequestFactory && $factory instanceof ServerRequestFactoryInterface) {
-            $this->serverRequestFactory = $factory;
-        }
-        if (!$this->streamFactory && $factory instanceof StreamFactoryInterface) {
-            $this->streamFactory = $factory;
-        }
-        if (!$this->uploadedFileFactory && $factory instanceof UploadedFileFactoryInterface) {
-            $this->uploadedFileFactory = $factory;
-        }
-        if (!$this->uriFactory && $factory instanceof UriFactoryInterface) {
-            $this->uriFactory = $factory;
-        }
-        return $factory;
-    }
-    private function buildServerRequestFromGlobals(ServerRequestInterface $request, array $server, array $files) : ServerRequestInterface
-    {
-        $request = $request->withProtocolVersion(isset($server['SERVER_PROTOCOL']) ? \str_replace('HTTP/', '', $server['SERVER_PROTOCOL']) : '1.1')->withUploadedFiles($this->normalizeFiles($files));
-        $headers = [];
-        foreach ($server as $k => $v) {
-            if (0 === \strpos($k, 'HTTP_')) {
-                $k = \substr($k, 5);
-            } elseif (!\in_array($k, ['CONTENT_TYPE', 'CONTENT_LENGTH', 'CONTENT_MD5'], \true)) {
-                continue;
-            }
-            $k = \str_replace(' ', '-', \ucwords(\strtolower(\str_replace('_', ' ', $k))));
-            $headers[$k] = $v;
-        }
-        if (!isset($headers['Authorization'])) {
-            if (isset($_SERVER['REDIRECT_HTTP_AUTHORIZATION'])) {
-                $headers['Authorization'] = $_SERVER['REDIRECT_HTTP_AUTHORIZATION'];
-            } elseif (isset($_SERVER['PHP_AUTH_USER'])) {
-                $headers['Authorization'] = 'Basic ' . \base64_encode($_SERVER['PHP_AUTH_USER'] . ':' . ($_SERVER['PHP_AUTH_PW'] ?? ''));
-            } elseif (isset($_SERVER['PHP_AUTH_DIGEST'])) {
-                $headers['Authorization'] = $_SERVER['PHP_AUTH_DIGEST'];
-            }
-        }
-        foreach ($headers as $k => $v) {
-            try {
-                $request = $request->withHeader($k, $v);
-            } catch (\InvalidArgumentException $e) {
-                // ignore invalid headers
-            }
-        }
-        return $request;
-    }
-    private function buildUriFromGlobals(UriInterface $uri, array $server) : UriInterface
-    {
-        $uri = $uri->withScheme(!empty($server['HTTPS']) && 'off' !== \strtolower($server['HTTPS']) ? 'https' : 'http');
-        $hasPort = \false;
-        if (isset($server['HTTP_HOST'])) {
-            $parts = \parse_url('http://' . $server['HTTP_HOST']);
-            $uri = $uri->withHost($parts['host'] ?? 'localhost');
-            if ($parts['port'] ?? \false) {
-                $hasPort = \true;
-                $uri = $uri->withPort($parts['port']);
-            }
-        } else {
-            $uri = $uri->withHost($server['SERVER_NAME'] ?? $server['SERVER_ADDR'] ?? 'localhost');
-        }
-        if (!$hasPort && isset($server['SERVER_PORT'])) {
-            $uri = $uri->withPort($server['SERVER_PORT']);
-        }
-        $hasQuery = \false;
-        if (isset($server['REQUEST_URI'])) {
-            $requestUriParts = \explode('?', $server['REQUEST_URI'], 2);
-            $uri = $uri->withPath($requestUriParts[0]);
-            if (isset($requestUriParts[1])) {
-                $hasQuery = \true;
-                $uri = $uri->withQuery($requestUriParts[1]);
-            }
-        }
-        if (!$hasQuery && isset($server['QUERY_STRING'])) {
-            $uri = $uri->withQuery($server['QUERY_STRING']);
-        }
-        return $uri;
-    }
-    private function normalizeFiles(array $files) : array
-    {
-        foreach ($files as $k => $v) {
-            if ($v instanceof UploadedFileInterface) {
-                continue;
-            }
-            if (!\is_array($v)) {
-                unset($files[$k]);
-            } elseif (!isset($v['tmp_name'])) {
-                $files[$k] = $this->normalizeFiles($v);
-            } else {
-                $files[$k] = $this->createUploadedFileFromSpec($v);
-            }
-        }
-        return $files;
-    }
-    /**
-     * Create and return an UploadedFile instance from a $_FILES specification.
-     *
-     * @param array $value $_FILES struct
-     *
-     * @return UploadedFileInterface|UploadedFileInterface[]
-     */
-    private function createUploadedFileFromSpec(array $value)
-    {
-        if (!\is_array($tmpName = $value['tmp_name'])) {
-            $file = \is_file($tmpName) ? $this->createStreamFromFile($tmpName, 'r') : $this->createStream();
-            return $this->createUploadedFile($file, $value['size'], $value['error'], $value['name'], $value['type']);
-        }
-        foreach ($tmpName as $k => $v) {
-            $tmpName[$k] = $this->createUploadedFileFromSpec(['tmp_name' => $v, 'size' => $value['size'][$k] ?? null, 'error' => $value['error'][$k] ?? null, 'name' => $value['name'][$k] ?? null, 'type' => $value['type'][$k] ?? null]);
-        }
-        return $tmpName;
-    }
+	private $requestFactory;
+	private $responseFactory;
+	private $serverRequestFactory;
+	private $streamFactory;
+	private $uploadedFileFactory;
+	private $uriFactory;
+	public function __construct(?RequestFactoryInterface $requestFactory = null, ?ResponseFactoryInterface $responseFactory = null, ?ServerRequestFactoryInterface $serverRequestFactory = null, ?StreamFactoryInterface $streamFactory = null, ?UploadedFileFactoryInterface $uploadedFileFactory = null, ?UriFactoryInterface $uriFactory = null)
+	{
+		$this->requestFactory = $requestFactory;
+		$this->responseFactory = $responseFactory;
+		$this->serverRequestFactory = $serverRequestFactory;
+		$this->streamFactory = $streamFactory;
+		$this->uploadedFileFactory = $uploadedFileFactory;
+		$this->uriFactory = $uriFactory;
+		$this->setFactory($requestFactory);
+		$this->setFactory($responseFactory);
+		$this->setFactory($serverRequestFactory);
+		$this->setFactory($streamFactory);
+		$this->setFactory($uploadedFileFactory);
+		$this->setFactory($uriFactory);
+	}
+	/**
+	 * @param UriInterface|string $uri
+	 */
+	public function createRequest(string $method, $uri) : RequestInterface
+	{
+		$factory = $this->requestFactory ?? $this->setFactory(Psr17FactoryDiscovery::findRequestFactory());
+		return $factory->createRequest(...\func_get_args());
+	}
+	public function createResponse(int $code = 200, string $reasonPhrase = '') : ResponseInterface
+	{
+		$factory = $this->responseFactory ?? $this->setFactory(Psr17FactoryDiscovery::findResponseFactory());
+		return $factory->createResponse(...\func_get_args());
+	}
+	/**
+	 * @param UriInterface|string $uri
+	 */
+	public function createServerRequest(string $method, $uri, array $serverParams = []) : ServerRequestInterface
+	{
+		$factory = $this->serverRequestFactory ?? $this->setFactory(Psr17FactoryDiscovery::findServerRequestFactory());
+		return $factory->createServerRequest(...\func_get_args());
+	}
+	public function createServerRequestFromGlobals(?array $server = null, ?array $get = null, ?array $post = null, ?array $cookie = null, ?array $files = null, ?StreamInterface $body = null) : ServerRequestInterface
+	{
+		$server = $server ?? $_SERVER;
+		$request = $this->createServerRequest($server['REQUEST_METHOD'] ?? 'GET', $this->createUriFromGlobals($server), $server);
+		return $this->buildServerRequestFromGlobals($request, $server, $files ?? $_FILES)->withQueryParams($get ?? $_GET)->withParsedBody($post ?? $_POST)->withCookieParams($cookie ?? $_COOKIE)->withBody($body ?? $this->createStreamFromFile('php://input', 'r+'));
+	}
+	public function createStream(string $content = '') : StreamInterface
+	{
+		$factory = $this->streamFactory ?? $this->setFactory(Psr17FactoryDiscovery::findStreamFactory());
+		return $factory->createStream($content);
+	}
+	public function createStreamFromFile(string $filename, string $mode = 'r') : StreamInterface
+	{
+		$factory = $this->streamFactory ?? $this->setFactory(Psr17FactoryDiscovery::findStreamFactory());
+		return $factory->createStreamFromFile($filename, $mode);
+	}
+	/**
+	 * @param resource $resource
+	 */
+	public function createStreamFromResource($resource) : StreamInterface
+	{
+		$factory = $this->streamFactory ?? $this->setFactory(Psr17FactoryDiscovery::findStreamFactory());
+		return $factory->createStreamFromResource($resource);
+	}
+	public function createUploadedFile(StreamInterface $stream, ?int $size = null, int $error = \UPLOAD_ERR_OK, ?string $clientFilename = null, ?string $clientMediaType = null) : UploadedFileInterface
+	{
+		$factory = $this->uploadedFileFactory ?? $this->setFactory(Psr17FactoryDiscovery::findUploadedFileFactory());
+		return $factory->createUploadedFile(...\func_get_args());
+	}
+	public function createUri(string $uri = '') : UriInterface
+	{
+		$factory = $this->uriFactory ?? $this->setFactory(Psr17FactoryDiscovery::findUriFactory());
+		return $factory->createUri(...\func_get_args());
+	}
+	public function createUriFromGlobals(?array $server = null) : UriInterface
+	{
+		return $this->buildUriFromGlobals($this->createUri(''), $server ?? $_SERVER);
+	}
+	private function setFactory($factory)
+	{
+		if (!$this->requestFactory && $factory instanceof RequestFactoryInterface) {
+			$this->requestFactory = $factory;
+		}
+		if (!$this->responseFactory && $factory instanceof ResponseFactoryInterface) {
+			$this->responseFactory = $factory;
+		}
+		if (!$this->serverRequestFactory && $factory instanceof ServerRequestFactoryInterface) {
+			$this->serverRequestFactory = $factory;
+		}
+		if (!$this->streamFactory && $factory instanceof StreamFactoryInterface) {
+			$this->streamFactory = $factory;
+		}
+		if (!$this->uploadedFileFactory && $factory instanceof UploadedFileFactoryInterface) {
+			$this->uploadedFileFactory = $factory;
+		}
+		if (!$this->uriFactory && $factory instanceof UriFactoryInterface) {
+			$this->uriFactory = $factory;
+		}
+		return $factory;
+	}
+	private function buildServerRequestFromGlobals(ServerRequestInterface $request, array $server, array $files) : ServerRequestInterface
+	{
+		$request = $request->withProtocolVersion(isset($server['SERVER_PROTOCOL']) ? \str_replace('HTTP/', '', $server['SERVER_PROTOCOL']) : '1.1')->withUploadedFiles($this->normalizeFiles($files));
+		$headers = [];
+		foreach ($server as $k => $v) {
+			if (0 === \strpos($k, 'HTTP_')) {
+				$k = \substr($k, 5);
+			} elseif (!\in_array($k, ['CONTENT_TYPE', 'CONTENT_LENGTH', 'CONTENT_MD5'], \true)) {
+				continue;
+			}
+			$k = \str_replace(' ', '-', \ucwords(\strtolower(\str_replace('_', ' ', $k))));
+			$headers[$k] = $v;
+		}
+		if (!isset($headers['Authorization'])) {
+			if (isset($_SERVER['REDIRECT_HTTP_AUTHORIZATION'])) {
+				$headers['Authorization'] = $_SERVER['REDIRECT_HTTP_AUTHORIZATION'];
+			} elseif (isset($_SERVER['PHP_AUTH_USER'])) {
+				$headers['Authorization'] = 'Basic ' . \base64_encode($_SERVER['PHP_AUTH_USER'] . ':' . ($_SERVER['PHP_AUTH_PW'] ?? ''));
+			} elseif (isset($_SERVER['PHP_AUTH_DIGEST'])) {
+				$headers['Authorization'] = $_SERVER['PHP_AUTH_DIGEST'];
+			}
+		}
+		foreach ($headers as $k => $v) {
+			try {
+				$request = $request->withHeader($k, $v);
+			} catch (\InvalidArgumentException $e) {
+				// ignore invalid headers
+			}
+		}
+		return $request;
+	}
+	private function buildUriFromGlobals(UriInterface $uri, array $server) : UriInterface
+	{
+		$uri = $uri->withScheme(!empty($server['HTTPS']) && 'off' !== \strtolower($server['HTTPS']) ? 'https' : 'http');
+		$hasPort = \false;
+		if (isset($server['HTTP_HOST'])) {
+			$parts = \parse_url('http://' . $server['HTTP_HOST']);
+			$uri = $uri->withHost($parts['host'] ?? 'localhost');
+			if ($parts['port'] ?? \false) {
+				$hasPort = \true;
+				$uri = $uri->withPort($parts['port']);
+			}
+		} else {
+			$uri = $uri->withHost($server['SERVER_NAME'] ?? $server['SERVER_ADDR'] ?? 'localhost');
+		}
+		if (!$hasPort && isset($server['SERVER_PORT'])) {
+			$uri = $uri->withPort($server['SERVER_PORT']);
+		}
+		$hasQuery = \false;
+		if (isset($server['REQUEST_URI'])) {
+			$requestUriParts = \explode('?', $server['REQUEST_URI'], 2);
+			$uri = $uri->withPath($requestUriParts[0]);
+			if (isset($requestUriParts[1])) {
+				$hasQuery = \true;
+				$uri = $uri->withQuery($requestUriParts[1]);
+			}
+		}
+		if (!$hasQuery && isset($server['QUERY_STRING'])) {
+			$uri = $uri->withQuery($server['QUERY_STRING']);
+		}
+		return $uri;
+	}
+	private function normalizeFiles(array $files) : array
+	{
+		foreach ($files as $k => $v) {
+			if ($v instanceof UploadedFileInterface) {
+				continue;
+			}
+			if (!\is_array($v)) {
+				unset($files[$k]);
+			} elseif (!isset($v['tmp_name'])) {
+				$files[$k] = $this->normalizeFiles($v);
+			} else {
+				$files[$k] = $this->createUploadedFileFromSpec($v);
+			}
+		}
+		return $files;
+	}
+	/**
+	 * Create and return an UploadedFile instance from a $_FILES specification.
+	 *
+	 * @param array $value $_FILES struct
+	 *
+	 * @return UploadedFileInterface|UploadedFileInterface[]
+	 */
+	private function createUploadedFileFromSpec(array $value)
+	{
+		if (!\is_array($tmpName = $value['tmp_name'])) {
+			$file = \is_file($tmpName) ? $this->createStreamFromFile($tmpName, 'r') : $this->createStream();
+			return $this->createUploadedFile($file, $value['size'], $value['error'], $value['name'], $value['type']);
+		}
+		foreach ($tmpName as $k => $v) {
+			$tmpName[$k] = $this->createUploadedFileFromSpec(['tmp_name' => $v, 'size' => $value['size'][$k] ?? null, 'error' => $value['error'][$k] ?? null, 'name' => $value['name'][$k] ?? null, 'type' => $value['type'][$k] ?? null]);
+		}
+		return $tmpName;
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -159,7 +159,7 @@ 
             if (isset($_SERVER['REDIRECT_HTTP_AUTHORIZATION'])) {
                 $headers['Authorization'] = $_SERVER['REDIRECT_HTTP_AUTHORIZATION'];
             } elseif (isset($_SERVER['PHP_AUTH_USER'])) {
-                $headers['Authorization'] = 'Basic ' . \base64_encode($_SERVER['PHP_AUTH_USER'] . ':' . ($_SERVER['PHP_AUTH_PW'] ?? ''));
+                $headers['Authorization'] = 'Basic '.\base64_encode($_SERVER['PHP_AUTH_USER'].':'.($_SERVER['PHP_AUTH_PW'] ?? ''));
             } elseif (isset($_SERVER['PHP_AUTH_DIGEST'])) {
                 $headers['Authorization'] = $_SERVER['PHP_AUTH_DIGEST'];
             }
@@ -178,7 +178,7 @@ 
         $uri = $uri->withScheme(!empty($server['HTTPS']) && 'off' !== \strtolower($server['HTTPS']) ? 'https' : 'http');
         $hasPort = \false;
         if (isset($server['HTTP_HOST'])) {
-            $parts = \parse_url('http://' . $server['HTTP_HOST']);
+            $parts = \parse_url('http://'.$server['HTTP_HOST']);
             $uri = $uri->withHost($parts['host'] ?? 'localhost');
             if ($parts['port'] ?? \false) {
                 $hasPort = \true;

lib/Vendor/Http/Discovery/Exception/DiscoveryFailedException.php

Indentation +32 added lines, -32 removed lines

@@ -10,36 +10,36 @@
  */
 final class DiscoveryFailedException extends \Exception implements Exception
 {
-    /**
-     * @var \Exception[]
-     */
-    private $exceptions;
-    /**
-     * @param string       $message
-     * @param \Exception[] $exceptions
-     */
-    public function __construct($message, array $exceptions = [])
-    {
-        $this->exceptions = $exceptions;
-        parent::__construct($message);
-    }
-    /**
-     * @param \Exception[] $exceptions
-     */
-    public static function create($exceptions)
-    {
-        $message = 'Could not find resource using any discovery strategy. Find more information at http://docs.php-http.org/en/latest/discovery.html#common-errors';
-        foreach ($exceptions as $e) {
-            $message .= "\n - " . $e->getMessage();
-        }
-        $message .= "\n\n";
-        return new self($message, $exceptions);
-    }
-    /**
-     * @return \Exception[]
-     */
-    public function getExceptions()
-    {
-        return $this->exceptions;
-    }
+	/**
+	 * @var \Exception[]
+	 */
+	private $exceptions;
+	/**
+	 * @param string       $message
+	 * @param \Exception[] $exceptions
+	 */
+	public function __construct($message, array $exceptions = [])
+	{
+		$this->exceptions = $exceptions;
+		parent::__construct($message);
+	}
+	/**
+	 * @param \Exception[] $exceptions
+	 */
+	public static function create($exceptions)
+	{
+		$message = 'Could not find resource using any discovery strategy. Find more information at http://docs.php-http.org/en/latest/discovery.html#common-errors';
+		foreach ($exceptions as $e) {
+			$message .= "\n - " . $e->getMessage();
+		}
+		$message .= "\n\n";
+		return new self($message, $exceptions);
+	}
+	/**
+	 * @return \Exception[]
+	 */
+	public function getExceptions()
+	{
+		return $this->exceptions;
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
     {
         $message = 'Could not find resource using any discovery strategy. Find more information at http://docs.php-http.org/en/latest/discovery.html#common-errors';
         foreach ($exceptions as $e) {
-            $message .= "\n - " . $e->getMessage();
+            $message .= "\n - ".$e->getMessage();
         }
         $message .= "\n\n";
         return new self($message, $exceptions);

lib/Vendor/Http/Discovery/Exception/NoCandidateFoundException.php

Indentation +21 added lines, -21 removed lines

@@ -10,25 +10,25 @@
  */
 final class NoCandidateFoundException extends \Exception implements Exception
 {
-    /**
-     * @param string $strategy
-     */
-    public function __construct($strategy, array $candidates)
-    {
-        $classes = \array_map(function ($a) {
-            return $a['class'];
-        }, $candidates);
-        $message = \sprintf('No valid candidate found using strategy "%s". We tested the following candidates: %s.', $strategy, \implode(', ', \array_map([$this, 'stringify'], $classes)));
-        parent::__construct($message);
-    }
-    private function stringify($mixed)
-    {
-        if (\is_string($mixed)) {
-            return $mixed;
-        }
-        if (\is_array($mixed) && 2 === \count($mixed)) {
-            return \sprintf('%s::%s', $this->stringify($mixed[0]), $mixed[1]);
-        }
-        return \is_object($mixed) ? \get_class($mixed) : \gettype($mixed);
-    }
+	/**
+	 * @param string $strategy
+	 */
+	public function __construct($strategy, array $candidates)
+	{
+		$classes = \array_map(function ($a) {
+			return $a['class'];
+		}, $candidates);
+		$message = \sprintf('No valid candidate found using strategy "%s". We tested the following candidates: %s.', $strategy, \implode(', ', \array_map([$this, 'stringify'], $classes)));
+		parent::__construct($message);
+	}
+	private function stringify($mixed)
+	{
+		if (\is_string($mixed)) {
+			return $mixed;
+		}
+		if (\is_array($mixed) && 2 === \count($mixed)) {
+			return \sprintf('%s::%s', $this->stringify($mixed[0]), $mixed[1]);
+		}
+		return \is_object($mixed) ? \get_class($mixed) : \gettype($mixed);
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
      */
     public function __construct($strategy, array $candidates)
     {
-        $classes = \array_map(function ($a) {
+        $classes = \array_map(function($a) {
             return $a['class'];
         }, $candidates);
         $message = \sprintf('No valid candidate found using strategy "%s". We tested the following candidates: %s.', $strategy, \implode(', ', \array_map([$this, 'stringify'], $classes)));