nextcloud / fulltextsearch_elasticsearch

lib/Vendor/Http/Discovery/Composer/Plugin.php

Spacing +7 added lines, -7 removed lines

@@ -97,7 +97,7 @@ 
         }
         $event->stopPropagation();
         $dispatcher = $composer->getEventDispatcher();
-        $disableScripts = !\method_exists($dispatcher, 'setRunScripts') || !((array) $dispatcher)["\x00*\x00runScripts"];
+        $disableScripts = !\method_exists($dispatcher, 'setRunScripts') || !((array)$dispatcher)["\x00*\x00runScripts"];
         $composer = Factory::create($event->getIO(), null, \false, $disableScripts);
         /** @var Installer $installer */
         $installer = clone $installer;
@@ -107,7 +107,7 @@ 
         // we need a clone of the installer to preserve its configuration state but with our own service objects
         $installer->__construct($event->getIO(), $composer->getConfig(), $composer->getPackage(), $composer->getDownloadManager(), $composer->getRepositoryManager(), $composer->getLocker(), $composer->getInstallationManager(), $composer->getEventDispatcher(), $composer->getAutoloadGenerator());
         if (\method_exists($installer, 'setPlatformRequirementFilter')) {
-            $installer->setPlatformRequirementFilter(((array) $trace['object'])["\x00*\x00platformRequirementFilter"]);
+            $installer->setPlatformRequirementFilter(((array)$trace['object'])["\x00*\x00platformRequirementFilter"]);
         }
         if (0 !== $installer->run()) {
             \file_put_contents(Factory::getComposerFile(), $composerJsonContents);
@@ -147,7 +147,7 @@ 
                 }
             }
             if (isset($package->getRequires()['php-http/discovery'])) {
-                $requires[(int) isset($devPackages[$package->getName()])] += $package->getRequires();
+                $requires[(int)isset($devPackages[$package->getName()])] += $package->getRequires();
             }
         }
         $missingRequires = [[], [], []];
@@ -235,7 +235,7 @@ 
         $filesystem = new Filesystem();
         // Double realpath() on purpose, see https://bugs.php.net/72738
         $vendorDir = $filesystem->normalizePath(\realpath(\realpath($event->getComposer()->getConfig()->get('vendor-dir'))));
-        $filesystem->ensureDirectoryExists($vendorDir . '/composer');
+        $filesystem->ensureDirectoryExists($vendorDir.'/composer');
         $pinned = $event->getComposer()->getPackage()->getExtra()['discovery'] ?? [];
         $candidates = [];
         $allInterfaces = \array_merge(...\array_values(self::INTERFACE_MAP));
@@ -251,7 +251,7 @@ 
                 $candidates[] = \sprintf("case %s: return [['class' => %s]];\n", \var_export($interface, \true), \var_export($class, \true));
             }
         }
-        $file = $vendorDir . '/composer/GeneratedDiscoveryStrategy.php';
+        $file = $vendorDir.'/composer/GeneratedDiscoveryStrategy.php';
         if (!$candidates) {
             if (\file_exists($file)) {
                 \unlink($file);
@@ -281,7 +281,7 @@ 
         }
         $rootPackage = $event->getComposer()->getPackage();
         $autoload = $rootPackage->getAutoload();
-        $autoload['classmap'][] = $vendorDir . '/composer/GeneratedDiscoveryStrategy.php';
+        $autoload['classmap'][] = $vendorDir.'/composer/GeneratedDiscoveryStrategy.php';
         $rootPackage->setAutoload($autoload);
     }
     private function updateComposerJson(array $missingRequires, bool $sortPackages)
@@ -305,7 +305,7 @@ 
         if (\false === $composer->getConfig()->get('lock')) {
             return;
         }
-        $lock = \substr(Factory::getComposerFile(), 0, -4) . 'lock';
+        $lock = \substr(Factory::getComposerFile(), 0, -4).'lock';
         $composerJson = \file_get_contents(Factory::getComposerFile());
         $lockFile = new JsonFile($lock, null, $io);
         $locker = ClassDiscovery::safeClassExists(RepositorySet::class) ? new Locker($io, $lockFile, $composer->getInstallationManager(), $composerJson) : new Locker($io, $lockFile, $composer->getRepositoryManager(), $composer->getInstallationManager(), $composerJson);

lib/Vendor/GuzzleHttp/Psr7/Query.php

Spacing +12 added lines, -12 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\Psr7;
 
 final class Query
@@ -23,15 +23,15 @@ 
             return $result;
         }
         if ($urlEncoding === \true) {
-            $decoder = function ($value) {
-                return \rawurldecode(\str_replace('+', ' ', (string) $value));
+            $decoder = function($value) {
+                return \rawurldecode(\str_replace('+', ' ', (string)$value));
             };
         } elseif ($urlEncoding === \PHP_QUERY_RFC3986) {
             $decoder = 'rawurldecode';
         } elseif ($urlEncoding === \PHP_QUERY_RFC1738) {
             $decoder = 'urldecode';
         } else {
-            $decoder = function ($str) {
+            $decoder = function($str) {
                 return $str;
             };
         }
@@ -71,7 +71,7 @@ 
             return '';
         }
         if ($encoding === \false) {
-            $encoder = function (string $str) : string {
+            $encoder = function(string $str) : string {
                 return $str;
             };
         } elseif ($encoding === \PHP_QUERY_RFC3986) {
@@ -81,19 +81,19 @@ 
         } else {
             throw new \InvalidArgumentException('Invalid type');
         }
-        $castBool = $treatBoolsAsInts ? static function ($v) {
-            return (int) $v;
-        } : static function ($v) {
+        $castBool = $treatBoolsAsInts ? static function($v) {
+            return (int)$v;
+        } : static function($v) {
             return $v ? 'true' : 'false';
         };
         $qs = '';
         foreach ($params as $k => $v) {
-            $k = $encoder((string) $k);
+            $k = $encoder((string)$k);
             if (!\is_array($v)) {
                 $qs .= $k;
                 $v = \is_bool($v) ? $castBool($v) : $v;
                 if ($v !== null) {
-                    $qs .= '=' . $encoder((string) $v);
+                    $qs .= '='.$encoder((string)$v);
                 }
                 $qs .= '&';
             } else {
@@ -101,12 +101,12 @@ 
                     $qs .= $k;
                     $vv = \is_bool($vv) ? $castBool($vv) : $vv;
                     if ($vv !== null) {
-                        $qs .= '=' . $encoder((string) $vv);
+                        $qs .= '='.$encoder((string)$vv);
                     }
                     $qs .= '&';
                 }
             }
         }
-        return $qs ? (string) \substr($qs, 0, -1) : '';
+        return $qs ? (string)\substr($qs, 0, -1) : '';
     }
 }

lib/Vendor/GuzzleHttp/Middleware.php

Spacing +23 added lines, -23 removed lines

@@ -24,8 +24,8 @@ 
      */
     public static function cookies() : callable
     {
-        return static function (callable $handler) : callable {
-            return static function ($request, array $options) use($handler) {
+        return static function(callable $handler) : callable {
+            return static function($request, array $options) use($handler) {
                 if (empty($options['cookies'])) {
                     return $handler($request, $options);
                 } elseif (!$options['cookies'] instanceof CookieJarInterface) {
@@ -33,7 +33,7 @@ 
                 }
                 $cookieJar = $options['cookies'];
                 $request = $cookieJar->withCookieHeader($request);
-                return $handler($request, $options)->then(static function (ResponseInterface $response) use($cookieJar, $request) : ResponseInterface {
+                return $handler($request, $options)->then(static function(ResponseInterface $response) use($cookieJar, $request) : ResponseInterface {
                     $cookieJar->extractCookies($request, $response);
                     return $response;
                 });
@@ -50,12 +50,12 @@ 
      */
     public static function httpErrors(?BodySummarizerInterface $bodySummarizer = null) : callable
     {
-        return static function (callable $handler) use($bodySummarizer) : callable {
-            return static function ($request, array $options) use($handler, $bodySummarizer) {
+        return static function(callable $handler) use($bodySummarizer) : callable {
+            return static function($request, array $options) use($handler, $bodySummarizer) {
                 if (empty($options['http_errors'])) {
                     return $handler($request, $options);
                 }
-                return $handler($request, $options)->then(static function (ResponseInterface $response) use($request, $bodySummarizer) {
+                return $handler($request, $options)->then(static function(ResponseInterface $response) use($request, $bodySummarizer) {
                     $code = $response->getStatusCode();
                     if ($code < 400) {
                         return $response;
@@ -79,12 +79,12 @@ 
         if (!\is_array($container) && !$container instanceof \ArrayAccess) {
             throw new \InvalidArgumentException('history container must be an array or object implementing ArrayAccess');
         }
-        return static function (callable $handler) use(&$container) : callable {
-            return static function (RequestInterface $request, array $options) use($handler, &$container) {
-                return $handler($request, $options)->then(static function ($value) use($request, &$container, $options) {
+        return static function(callable $handler) use(&$container) : callable {
+            return static function(RequestInterface $request, array $options) use($handler, &$container) {
+                return $handler($request, $options)->then(static function($value) use($request, &$container, $options) {
                     $container[] = ['request' => $request, 'response' => $value, 'error' => null, 'options' => $options];
                     return $value;
-                }, static function ($reason) use($request, &$container, $options) {
+                }, static function($reason) use($request, &$container, $options) {
                     $container[] = ['request' => $request, 'response' => null, 'error' => $reason, 'options' => $options];
                     return P\Create::rejectionFor($reason);
                 });
@@ -106,8 +106,8 @@ 
      */
     public static function tap(?callable $before = null, ?callable $after = null) : callable
     {
-        return static function (callable $handler) use($before, $after) : callable {
-            return static function (RequestInterface $request, array $options) use($handler, $before, $after) {
+        return static function(callable $handler) use($before, $after) : callable {
+            return static function(RequestInterface $request, array $options) use($handler, $before, $after) {
                 if ($before) {
                     $before($request, $options);
                 }
@@ -126,7 +126,7 @@ 
      */
     public static function redirect() : callable
     {
-        return static function (callable $handler) : RedirectMiddleware {
+        return static function(callable $handler) : RedirectMiddleware {
             return new RedirectMiddleware($handler);
         };
     }
@@ -147,7 +147,7 @@ 
      */
     public static function retry(callable $decider, ?callable $delay = null) : callable
     {
-        return static function (callable $handler) use($decider, $delay) : RetryMiddleware {
+        return static function(callable $handler) use($decider, $delay) : RetryMiddleware {
             return new RetryMiddleware($decider, $handler, $delay);
         };
     }
@@ -169,13 +169,13 @@ 
         if (!$formatter instanceof MessageFormatter && !$formatter instanceof MessageFormatterInterface) {
             throw new \LogicException(\sprintf('Argument 2 to %s::log() must be of type %s', self::class, MessageFormatterInterface::class));
         }
-        return static function (callable $handler) use($logger, $formatter, $logLevel) : callable {
-            return static function (RequestInterface $request, array $options = []) use($handler, $logger, $formatter, $logLevel) {
-                return $handler($request, $options)->then(static function ($response) use($logger, $request, $formatter, $logLevel) : ResponseInterface {
+        return static function(callable $handler) use($logger, $formatter, $logLevel) : callable {
+            return static function(RequestInterface $request, array $options = []) use($handler, $logger, $formatter, $logLevel) {
+                return $handler($request, $options)->then(static function($response) use($logger, $request, $formatter, $logLevel) : ResponseInterface {
                     $message = $formatter->format($request, $response);
                     $logger->log($logLevel, $message);
                     return $response;
-                }, static function ($reason) use($logger, $request, $formatter) : PromiseInterface {
+                }, static function($reason) use($logger, $request, $formatter) : PromiseInterface {
                     $response = $reason instanceof RequestException ? $reason->getResponse() : null;
                     $message = $formatter->format($request, $response, P\Create::exceptionFor($reason));
                     $logger->error($message);
@@ -190,7 +190,7 @@ 
      */
     public static function prepareBody() : callable
     {
-        return static function (callable $handler) : PrepareBodyMiddleware {
+        return static function(callable $handler) : PrepareBodyMiddleware {
             return new PrepareBodyMiddleware($handler);
         };
     }
@@ -203,8 +203,8 @@ 
      */
     public static function mapRequest(callable $fn) : callable
     {
-        return static function (callable $handler) use($fn) : callable {
-            return static function (RequestInterface $request, array $options) use($handler, $fn) {
+        return static function(callable $handler) use($fn) : callable {
+            return static function(RequestInterface $request, array $options) use($handler, $fn) {
                 return $handler($fn($request), $options);
             };
         };
@@ -218,8 +218,8 @@ 
      */
     public static function mapResponse(callable $fn) : callable
     {
-        return static function (callable $handler) use($fn) : callable {
-            return static function (RequestInterface $request, array $options) use($handler, $fn) {
+        return static function(callable $handler) use($fn) : callable {
+            return static function(RequestInterface $request, array $options) use($handler, $fn) {
                 return $handler($request, $options)->then($fn);
             };
         };

lib/Vendor/GuzzleHttp/Handler/CurlFactory.php

Spacing +10 added lines, -10 removed lines

@@ -209,7 +209,7 @@ 
      */
     private function getDefaultConf(EasyHandle $easy) : array
     {
-        $conf = ['_headers' => $easy->request->getHeaders(), \CURLOPT_CUSTOMREQUEST => $easy->request->getMethod(), \CURLOPT_URL => (string) $easy->request->getUri()->withFragment(''), \CURLOPT_RETURNTRANSFER => \false, \CURLOPT_HEADER => \false, \CURLOPT_CONNECTTIMEOUT => 300];
+        $conf = ['_headers' => $easy->request->getHeaders(), \CURLOPT_CUSTOMREQUEST => $easy->request->getMethod(), \CURLOPT_URL => (string)$easy->request->getUri()->withFragment(''), \CURLOPT_RETURNTRANSFER => \false, \CURLOPT_HEADER => \false, \CURLOPT_CONNECTTIMEOUT => 300];
         if (\defined('CURLOPT_PROTOCOLS')) {
             $conf[\CURLOPT_PROTOCOLS] = \CURLPROTO_HTTP | \CURLPROTO_HTTPS;
         }
@@ -244,11 +244,11 @@ 
     }
     private function applyBody(RequestInterface $request, array $options, array &$conf) : void
     {
-        $size = $request->hasHeader('Content-Length') ? (int) $request->getHeaderLine('Content-Length') : null;
+        $size = $request->hasHeader('Content-Length') ? (int)$request->getHeaderLine('Content-Length') : null;
         // Send the body as a string if the size is less than 1MB OR if the
         // [curl][body_as_string] request value is set.
         if ($size !== null && $size < 1000000 || !empty($options['_body_as_string'])) {
-            $conf[\CURLOPT_POSTFIELDS] = (string) $request->getBody();
+            $conf[\CURLOPT_POSTFIELDS] = (string)$request->getBody();
             // Don't duplicate the Content-Length header
             $this->removeHeader('Content-Length', $conf);
             $this->removeHeader('Transfer-Encoding', $conf);
@@ -262,7 +262,7 @@ 
             if ($body->isSeekable()) {
                 $body->rewind();
             }
-            $conf[\CURLOPT_READFUNCTION] = static function ($ch, $fd, $length) use($body) {
+            $conf[\CURLOPT_READFUNCTION] = static function($ch, $fd, $length) use($body) {
                 return $body->read($length);
             };
         }
@@ -279,7 +279,7 @@ 
     {
         foreach ($conf['_headers'] as $name => $values) {
             foreach ($values as $value) {
-                $value = (string) $value;
+                $value = (string)$value;
                 if ($value === '') {
                     // cURL requires a special format for empty headers.
                     // See https://github.com/guzzle/guzzle/issues/1882 for more details.
@@ -364,7 +364,7 @@ 
             $sink = new LazyOpenStream($sink, 'w+');
         }
         $easy->sink = $sink;
-        $conf[\CURLOPT_WRITEFUNCTION] = static function ($ch, $write) use($sink) : int {
+        $conf[\CURLOPT_WRITEFUNCTION] = static function($ch, $write) use($sink) : int {
             return $sink->write($write);
         };
         $timeoutRequiresNoSignal = \false;
@@ -471,7 +471,7 @@ 
                 throw new \InvalidArgumentException('progress client option must be callable');
             }
             $conf[\CURLOPT_NOPROGRESS] = \false;
-            $conf[\CURLOPT_PROGRESSFUNCTION] = static function ($resource, int $downloadSize, int $downloaded, int $uploadSize, int $uploaded) use($progress) {
+            $conf[\CURLOPT_PROGRESSFUNCTION] = static function($resource, int $downloadSize, int $downloaded, int $uploadSize, int $uploaded) use($progress) {
                 $progress($downloadSize, $downloaded, $uploadSize, $uploaded);
             };
         }
@@ -500,14 +500,14 @@ 
                 $body->rewind();
             }
         } catch (\RuntimeException $e) {
-            $ctx['error'] = 'The connection unexpectedly failed without ' . 'providing an error. The request would have been retried, ' . 'but attempting to rewind the request body failed. ' . 'Exception: ' . $e;
+            $ctx['error'] = 'The connection unexpectedly failed without '.'providing an error. The request would have been retried, '.'but attempting to rewind the request body failed. '.'Exception: '.$e;
             return self::createRejection($easy, $ctx);
         }
         // Retry no more than 3 times before giving up.
         if (!isset($easy->options['_curl_retries'])) {
             $easy->options['_curl_retries'] = 1;
         } elseif ($easy->options['_curl_retries'] == 2) {
-            $ctx['error'] = 'The cURL request was retried 3 times ' . 'and did not succeed. The most likely reason for the failure ' . 'is that cURL was unable to rewind the body of the request ' . 'and subsequent retries resulted in the same error. Turn on ' . 'the debug option to see what went wrong. See ' . 'https://bugs.php.net/bug.php?id=47204 for more information.';
+            $ctx['error'] = 'The cURL request was retried 3 times '.'and did not succeed. The most likely reason for the failure '.'is that cURL was unable to rewind the body of the request '.'and subsequent retries resulted in the same error. Turn on '.'the debug option to see what went wrong. See '.'https://bugs.php.net/bug.php?id=47204 for more information.';
             return self::createRejection($easy, $ctx);
         } else {
             ++$easy->options['_curl_retries'];
@@ -524,7 +524,7 @@ 
         } else {
             $onHeaders = null;
         }
-        return static function ($ch, $h) use($onHeaders, $easy, &$startingResponse) {
+        return static function($ch, $h) use($onHeaders, $easy, &$startingResponse) {
             $value = \trim($h);
             if ($value === '') {
                 $startingResponse = \true;

lib/Vendor/GuzzleHttp/Promise/Utils.php

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,18 +124,18 @@ 
     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 {
             if (Is::pending($aggregate)) {
                 $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);
@@ -164,7 +164,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;
             }
@@ -172,9 +172,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);
             }
@@ -190,7 +190,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];
         });
     }
@@ -207,11 +207,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;
         });

lib/Vendor/GuzzleHttp/Promise/Each.php

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);
         });
     }

lib/Vendor/Elastic/Transport/Transport.php

Spacing +9 added lines, -9 removed lines

@@ -11,7 +11,7 @@ 
  * Elasticsearch B.V licenses this file to you under the MIT License.
  * See the LICENSE file in the project root for more information.
  */
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport;
 
 use Composer\InstalledVersions;
@@ -214,11 +214,11 @@ 
     }
     private function logHeaders(MessageInterface $message) : void
     {
-        $this->logger->debug(sprintf("Headers: %s\nBody: %s", json_encode($message->getHeaders()), (string) $message->getBody()));
+        $this->logger->debug(sprintf("Headers: %s\nBody: %s", json_encode($message->getHeaders()), (string)$message->getBody()));
     }
     private function logRequest(string $title, RequestInterface $request) : void
     {
-        $this->logger->info(sprintf("%s: %s %s", $title, $request->getMethod(), (string) $request->getUri()), ['request' => $request]);
+        $this->logger->info(sprintf("%s: %s %s", $title, $request->getMethod(), (string)$request->getUri()), ['request' => $request]);
         $this->logHeaders($request);
     }
     private function logResponse(string $title, ResponseInterface $response, int $retry) : void
@@ -312,7 +312,7 @@ 
         try {
             $this->asyncClient = HttpAsyncClientDiscovery::find();
         } catch (Exception $e) {
-            throw new NoAsyncClientException(sprintf("I did not find any HTTP library with HttpAsyncClient interface. " . "Make sure to install a package providing \"php-http/async-client-implementation\". " . "You can also set a specific async library using %s::setAsyncClient()", self::class));
+            throw new NoAsyncClientException(sprintf("I did not find any HTTP library with HttpAsyncClient interface. "."Make sure to install a package providing \"php-http/async-client-implementation\". "."You can also set a specific async library using %s::setAsyncClient()", self::class));
         }
         return $this->asyncClient;
     }
@@ -357,13 +357,13 @@ 
         $count = 0;
         $promise = $client->sendAsyncRequest($request);
         // onFulfilled callable
-        $onFulfilled = function (ResponseInterface $response) use(&$count) {
+        $onFulfilled = function(ResponseInterface $response) use(&$count) {
             $this->lastResponse = $response;
             $this->logResponse("Async Response", $response, $count);
             return $this->getAsyncOnSuccess()->success($response, $count);
         };
         // onRejected callable
-        $onRejected = function (Exception $e) use($client, $request, &$count, $node) {
+        $onRejected = function(Exception $e) use($client, $request, &$count, $node) {
             $this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
             $this->getAsyncOnFailure()->failure($e, $request, $count, $node ?? null);
             if (isset($node)) {
@@ -379,7 +379,7 @@ 
             $promise = $promise->then($onFulfilled, $onRejected);
         }
         // Add the last getRetries()+1 callable for managing the exceeded error
-        $promise = $promise->then($onFulfilled, function (Exception $e) use(&$count) {
+        $promise = $promise->then($onFulfilled, function(Exception $e) use(&$count) {
             $exceededMsg = sprintf("Exceeded maximum number of retries (%d)", $this->getRetries());
             $this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
             $this->logger->error($exceededMsg);
@@ -394,7 +394,7 @@ 
     private function getOSVersion() : string
     {
         if (!isset($this->OSVersion)) {
-            $disable_functions = (string) ini_get('disable_functions');
+            $disable_functions = (string)ini_get('disable_functions');
             $this->OSVersion = strpos(strtolower($disable_functions), 'php_uname') !== \false ? '' : php_uname("r");
         }
         return $this->OSVersion;
@@ -425,7 +425,7 @@ 
         $fullUrl = sprintf("%s://%s:%s%s", $request->getUri()->getScheme(), $request->getUri()->getHost(), $request->getUri()->getPort(), $request->getUri()->getPath());
         $queryString = $request->getUri()->getQuery();
         if (!empty($queryString)) {
-            $fullUrl .= '?' . $queryString;
+            $fullUrl .= '?'.$queryString;
         }
         return $fullUrl;
     }

lib/Vendor/Elastic/Transport/OpenTelemetry.php

Spacing +2 added lines, -2 removed lines

@@ -11,7 +11,7 @@ 
  * Elasticsearch B.V licenses this file to you under the MIT License.
  * See the LICENSE file in the project root for more information.
  */
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Exception\InvalidArgumentException;
@@ -81,7 +81,7 @@ 
         // Convert the patterns array into a regex
         $regex = \sprintf('/%s/', \implode('|', $patterns));
         // Recursively traverse the array and redact the specified keys
-        \array_walk_recursive($json, function (&$value, $key) use($regex) {
+        \array_walk_recursive($json, function(&$value, $key) use($regex) {
             if (\preg_match($regex, $key, $matches)) {
                 $value = self::REDACTED_STRING;
             }

lib/Vendor/Elastic/Elasticsearch/Endpoints/Ml.php

Spacing +72 added lines, -72 removed lines

@@ -11,7 +11,7 @@ 
  * Elasticsearch B.V licenses this file to you under the MIT License.
  * See the LICENSE file in the project root for more information.
  */
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Endpoints;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Exception\ClientResponseException;
@@ -49,7 +49,7 @@ 
     public function clearTrainedModelDeploymentCache(array $params = [])
     {
         $this->checkRequiredParameters(['model_id'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/deployment/cache/_clear';
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/deployment/cache/_clear';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -85,7 +85,7 @@ 
     public function closeJob(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_close';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_close';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['allow_no_match', 'force', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -117,7 +117,7 @@ 
     public function deleteCalendar(array $params = [])
     {
         $this->checkRequiredParameters(['calendar_id'], $params);
-        $url = '/_ml/calendars/' . $this->encode($params['calendar_id']);
+        $url = '/_ml/calendars/'.$this->encode($params['calendar_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -150,7 +150,7 @@ 
     public function deleteCalendarEvent(array $params = [])
     {
         $this->checkRequiredParameters(['calendar_id', 'event_id'], $params);
-        $url = '/_ml/calendars/' . $this->encode($params['calendar_id']) . '/events/' . $this->encode($params['event_id']);
+        $url = '/_ml/calendars/'.$this->encode($params['calendar_id']).'/events/'.$this->encode($params['event_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -183,7 +183,7 @@ 
     public function deleteCalendarJob(array $params = [])
     {
         $this->checkRequiredParameters(['calendar_id', 'job_id'], $params);
-        $url = '/_ml/calendars/' . $this->encode($params['calendar_id']) . '/jobs/' . $this->encode($params['job_id']);
+        $url = '/_ml/calendars/'.$this->encode($params['calendar_id']).'/jobs/'.$this->encode($params['job_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -217,7 +217,7 @@ 
     public function deleteDataFrameAnalytics(array $params = [])
     {
         $this->checkRequiredParameters(['id'], $params);
-        $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']);
+        $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['force', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -250,7 +250,7 @@ 
     public function deleteDatafeed(array $params = [])
     {
         $this->checkRequiredParameters(['datafeed_id'], $params);
-        $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']);
+        $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['force', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -284,7 +284,7 @@ 
     public function deleteExpiredData(array $params = [])
     {
         if (isset($params['job_id'])) {
-            $url = '/_ml/_delete_expired_data/' . $this->encode($params['job_id']);
+            $url = '/_ml/_delete_expired_data/'.$this->encode($params['job_id']);
             $method = 'DELETE';
         } else {
             $url = '/_ml/_delete_expired_data';
@@ -320,7 +320,7 @@ 
     public function deleteFilter(array $params = [])
     {
         $this->checkRequiredParameters(['filter_id'], $params);
-        $url = '/_ml/filters/' . $this->encode($params['filter_id']);
+        $url = '/_ml/filters/'.$this->encode($params['filter_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -356,10 +356,10 @@ 
     {
         $this->checkRequiredParameters(['job_id'], $params);
         if (isset($params['forecast_id'])) {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_forecast/' . $this->encode($params['forecast_id']);
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_forecast/'.$this->encode($params['forecast_id']);
             $method = 'DELETE';
         } else {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_forecast';
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_forecast';
             $method = 'DELETE';
         }
         $url = $this->addQueryString($url, $params, ['allow_no_forecasts', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
@@ -395,7 +395,7 @@ 
     public function deleteJob(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']);
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['force', 'wait_for_completion', 'delete_user_annotations', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -428,7 +428,7 @@ 
     public function deleteModelSnapshot(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'snapshot_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/model_snapshots/' . $this->encode($params['snapshot_id']);
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/model_snapshots/'.$this->encode($params['snapshot_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -462,7 +462,7 @@ 
     public function deleteTrainedModel(array $params = [])
     {
         $this->checkRequiredParameters(['model_id'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']);
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['timeout', 'force', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -495,7 +495,7 @@ 
     public function deleteTrainedModelAlias(array $params = [])
     {
         $this->checkRequiredParameters(['model_alias', 'model_id'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/model_aliases/' . $this->encode($params['model_alias']);
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/model_aliases/'.$this->encode($params['model_alias']);
         $method = 'DELETE';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -589,7 +589,7 @@ 
     public function explainDataFrameAnalytics(array $params = [])
     {
         if (isset($params['id'])) {
-            $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']) . '/_explain';
+            $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']).'/_explain';
             $method = empty($params['body']) ? 'GET' : 'POST';
         } else {
             $url = '/_ml/data_frame/analytics/_explain';
@@ -631,7 +631,7 @@ 
     public function flushJob(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_flush';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_flush';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['calc_interim', 'start', 'end', 'advance_time', 'skip_time', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -667,7 +667,7 @@ 
     public function forecast(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_forecast';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_forecast';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['duration', 'expires_in', 'max_model_memory', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -711,10 +711,10 @@ 
     {
         $this->checkRequiredParameters(['job_id'], $params);
         if (isset($params['timestamp'])) {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/results/buckets/' . $this->encode($params['timestamp']);
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/results/buckets/'.$this->encode($params['timestamp']);
             $method = empty($params['body']) ? 'GET' : 'POST';
         } else {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/results/buckets';
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/results/buckets';
             $method = empty($params['body']) ? 'GET' : 'POST';
         }
         $url = $this->addQueryString($url, $params, ['expand', 'exclude_interim', 'from', 'size', 'start', 'end', 'anomaly_score', 'sort', 'desc', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
@@ -752,7 +752,7 @@ 
     public function getCalendarEvents(array $params = [])
     {
         $this->checkRequiredParameters(['calendar_id'], $params);
-        $url = '/_ml/calendars/' . $this->encode($params['calendar_id']) . '/events';
+        $url = '/_ml/calendars/'.$this->encode($params['calendar_id']).'/events';
         $method = 'GET';
         $url = $this->addQueryString($url, $params, ['job_id', 'start', 'end', 'from', 'size', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -786,7 +786,7 @@ 
     public function getCalendars(array $params = [])
     {
         if (isset($params['calendar_id'])) {
-            $url = '/_ml/calendars/' . $this->encode($params['calendar_id']);
+            $url = '/_ml/calendars/'.$this->encode($params['calendar_id']);
             $method = empty($params['body']) ? 'GET' : 'POST';
         } else {
             $url = '/_ml/calendars';
@@ -828,10 +828,10 @@ 
     {
         $this->checkRequiredParameters(['job_id'], $params);
         if (isset($params['category_id'])) {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/results/categories/' . $this->encode($params['category_id']);
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/results/categories/'.$this->encode($params['category_id']);
             $method = empty($params['body']) ? 'GET' : 'POST';
         } else {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/results/categories';
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/results/categories';
             $method = empty($params['body']) ? 'GET' : 'POST';
         }
         $url = $this->addQueryString($url, $params, ['from', 'size', 'partition_field_value', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
@@ -867,7 +867,7 @@ 
     public function getDataFrameAnalytics(array $params = [])
     {
         if (isset($params['id'])) {
-            $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']);
+            $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']);
             $method = 'GET';
         } else {
             $url = '/_ml/data_frame/analytics';
@@ -906,7 +906,7 @@ 
     public function getDataFrameAnalyticsStats(array $params = [])
     {
         if (isset($params['id'])) {
-            $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']) . '/_stats';
+            $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']).'/_stats';
             $method = 'GET';
         } else {
             $url = '/_ml/data_frame/analytics/_stats';
@@ -942,7 +942,7 @@ 
     public function getDatafeedStats(array $params = [])
     {
         if (isset($params['datafeed_id'])) {
-            $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']) . '/_stats';
+            $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']).'/_stats';
             $method = 'GET';
         } else {
             $url = '/_ml/datafeeds/_stats';
@@ -979,7 +979,7 @@ 
     public function getDatafeeds(array $params = [])
     {
         if (isset($params['datafeed_id'])) {
-            $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']);
+            $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']);
             $method = 'GET';
         } else {
             $url = '/_ml/datafeeds';
@@ -1016,7 +1016,7 @@ 
     public function getFilters(array $params = [])
     {
         if (isset($params['filter_id'])) {
-            $url = '/_ml/filters/' . $this->encode($params['filter_id']);
+            $url = '/_ml/filters/'.$this->encode($params['filter_id']);
             $method = 'GET';
         } else {
             $url = '/_ml/filters';
@@ -1061,7 +1061,7 @@ 
     public function getInfluencers(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/results/influencers';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/results/influencers';
         $method = empty($params['body']) ? 'GET' : 'POST';
         $url = $this->addQueryString($url, $params, ['exclude_interim', 'from', 'size', 'start', 'end', 'influencer_score', 'sort', 'desc', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1093,7 +1093,7 @@ 
     public function getJobStats(array $params = [])
     {
         if (isset($params['job_id'])) {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_stats';
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_stats';
             $method = 'GET';
         } else {
             $url = '/_ml/anomaly_detectors/_stats';
@@ -1130,7 +1130,7 @@ 
     public function getJobs(array $params = [])
     {
         if (isset($params['job_id'])) {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']);
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']);
             $method = 'GET';
         } else {
             $url = '/_ml/anomaly_detectors';
@@ -1167,7 +1167,7 @@ 
     public function getMemoryStats(array $params = [])
     {
         if (isset($params['node_id'])) {
-            $url = '/_ml/memory/' . $this->encode($params['node_id']) . '/_stats';
+            $url = '/_ml/memory/'.$this->encode($params['node_id']).'/_stats';
             $method = 'GET';
         } else {
             $url = '/_ml/memory/_stats';
@@ -1205,7 +1205,7 @@ 
     public function getModelSnapshotUpgradeStats(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'snapshot_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/model_snapshots/' . $this->encode($params['snapshot_id']) . '/_upgrade/_stats';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/model_snapshots/'.$this->encode($params['snapshot_id']).'/_upgrade/_stats';
         $method = 'GET';
         $url = $this->addQueryString($url, $params, ['allow_no_match', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -1246,10 +1246,10 @@ 
     {
         $this->checkRequiredParameters(['job_id'], $params);
         if (isset($params['snapshot_id'])) {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/model_snapshots/' . $this->encode($params['snapshot_id']);
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/model_snapshots/'.$this->encode($params['snapshot_id']);
             $method = empty($params['body']) ? 'GET' : 'POST';
         } else {
-            $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/model_snapshots';
+            $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/model_snapshots';
             $method = empty($params['body']) ? 'GET' : 'POST';
         }
         $url = $this->addQueryString($url, $params, ['from', 'size', 'start', 'end', 'sort', 'desc', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
@@ -1290,7 +1290,7 @@ 
     public function getOverallBuckets(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/results/overall_buckets';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/results/overall_buckets';
         $method = empty($params['body']) ? 'GET' : 'POST';
         $url = $this->addQueryString($url, $params, ['top_n', 'bucket_span', 'overall_score', 'exclude_interim', 'start', 'end', 'allow_no_match', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1331,7 +1331,7 @@ 
     public function getRecords(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/results/records';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/results/records';
         $method = empty($params['body']) ? 'GET' : 'POST';
         $url = $this->addQueryString($url, $params, ['exclude_interim', 'from', 'size', 'start', 'end', 'record_score', 'sort', 'desc', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1370,7 +1370,7 @@ 
     public function getTrainedModels(array $params = [])
     {
         if (isset($params['model_id'])) {
-            $url = '/_ml/trained_models/' . $this->encode($params['model_id']);
+            $url = '/_ml/trained_models/'.$this->encode($params['model_id']);
             $method = 'GET';
         } else {
             $url = '/_ml/trained_models';
@@ -1408,7 +1408,7 @@ 
     public function getTrainedModelsStats(array $params = [])
     {
         if (isset($params['model_id'])) {
-            $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/_stats';
+            $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/_stats';
             $method = 'GET';
         } else {
             $url = '/_ml/trained_models/_stats';
@@ -1446,7 +1446,7 @@ 
     public function inferTrainedModel(array $params = [])
     {
         $this->checkRequiredParameters(['model_id', 'body'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/_infer';
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/_infer';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1508,7 +1508,7 @@ 
     public function openJob(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_open';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_open';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1541,7 +1541,7 @@ 
     public function postCalendarEvents(array $params = [])
     {
         $this->checkRequiredParameters(['calendar_id', 'body'], $params);
-        $url = '/_ml/calendars/' . $this->encode($params['calendar_id']) . '/events';
+        $url = '/_ml/calendars/'.$this->encode($params['calendar_id']).'/events';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1576,7 +1576,7 @@ 
     public function postData(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'body'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_data';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_data';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['reset_start', 'reset_end', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => isset($params['body']) && (\is_string($params['body']) || $this->isAssociativeArray($params['body'])) ? 'application/json' : 'application/x-ndjson'];
@@ -1608,7 +1608,7 @@ 
     public function previewDataFrameAnalytics(array $params = [])
     {
         if (isset($params['id'])) {
-            $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']) . '/_preview';
+            $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']).'/_preview';
             $method = empty($params['body']) ? 'GET' : 'POST';
         } else {
             $url = '/_ml/data_frame/analytics/_preview';
@@ -1646,7 +1646,7 @@ 
     public function previewDatafeed(array $params = [])
     {
         if (isset($params['datafeed_id'])) {
-            $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']) . '/_preview';
+            $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']).'/_preview';
             $method = empty($params['body']) ? 'GET' : 'POST';
         } else {
             $url = '/_ml/datafeeds/_preview';
@@ -1683,7 +1683,7 @@ 
     public function putCalendar(array $params = [])
     {
         $this->checkRequiredParameters(['calendar_id'], $params);
-        $url = '/_ml/calendars/' . $this->encode($params['calendar_id']);
+        $url = '/_ml/calendars/'.$this->encode($params['calendar_id']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1716,7 +1716,7 @@ 
     public function putCalendarJob(array $params = [])
     {
         $this->checkRequiredParameters(['calendar_id', 'job_id'], $params);
-        $url = '/_ml/calendars/' . $this->encode($params['calendar_id']) . '/jobs/' . $this->encode($params['job_id']);
+        $url = '/_ml/calendars/'.$this->encode($params['calendar_id']).'/jobs/'.$this->encode($params['job_id']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -1749,7 +1749,7 @@ 
     public function putDataFrameAnalytics(array $params = [])
     {
         $this->checkRequiredParameters(['id', 'body'], $params);
-        $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']);
+        $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1786,7 +1786,7 @@ 
     public function putDatafeed(array $params = [])
     {
         $this->checkRequiredParameters(['datafeed_id', 'body'], $params);
-        $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']);
+        $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['ignore_unavailable', 'allow_no_indices', 'ignore_throttled', 'expand_wildcards', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1819,7 +1819,7 @@ 
     public function putFilter(array $params = [])
     {
         $this->checkRequiredParameters(['filter_id', 'body'], $params);
-        $url = '/_ml/filters/' . $this->encode($params['filter_id']);
+        $url = '/_ml/filters/'.$this->encode($params['filter_id']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1856,7 +1856,7 @@ 
     public function putJob(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'body'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']);
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['ignore_unavailable', 'allow_no_indices', 'ignore_throttled', 'expand_wildcards', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1891,7 +1891,7 @@ 
     public function putTrainedModel(array $params = [])
     {
         $this->checkRequiredParameters(['model_id', 'body'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']);
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['defer_definition_decompression', 'wait_for_completion', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1925,7 +1925,7 @@ 
     public function putTrainedModelAlias(array $params = [])
     {
         $this->checkRequiredParameters(['model_alias', 'model_id'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/model_aliases/' . $this->encode($params['model_alias']);
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/model_aliases/'.$this->encode($params['model_alias']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['reassign', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1959,7 +1959,7 @@ 
     public function putTrainedModelDefinitionPart(array $params = [])
     {
         $this->checkRequiredParameters(['model_id', 'part', 'body'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/definition/' . $this->encode($params['part']);
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/definition/'.$this->encode($params['part']);
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -1992,7 +1992,7 @@ 
     public function putTrainedModelVocabulary(array $params = [])
     {
         $this->checkRequiredParameters(['model_id', 'body'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/vocabulary';
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/vocabulary';
         $method = 'PUT';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2026,7 +2026,7 @@ 
     public function resetJob(array $params = [])
     {
         $this->checkRequiredParameters(['job_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_reset';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_reset';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['wait_for_completion', 'delete_user_annotations', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];
@@ -2061,7 +2061,7 @@ 
     public function revertModelSnapshot(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'snapshot_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/model_snapshots/' . $this->encode($params['snapshot_id']) . '/_revert';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/model_snapshots/'.$this->encode($params['snapshot_id']).'/_revert';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['delete_intervening_results', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2126,7 +2126,7 @@ 
     public function startDataFrameAnalytics(array $params = [])
     {
         $this->checkRequiredParameters(['id'], $params);
-        $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']) . '/_start';
+        $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']).'/_start';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2162,7 +2162,7 @@ 
     public function startDatafeed(array $params = [])
     {
         $this->checkRequiredParameters(['datafeed_id'], $params);
-        $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']) . '/_start';
+        $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']).'/_start';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['start', 'end', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2202,7 +2202,7 @@ 
     public function startTrainedModelDeployment(array $params = [])
     {
         $this->checkRequiredParameters(['model_id'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/deployment/_start';
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/deployment/_start';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['cache_size', 'deployment_id', 'number_of_allocations', 'threads_per_allocation', 'priority', 'queue_capacity', 'timeout', 'wait_for', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2238,7 +2238,7 @@ 
     public function stopDataFrameAnalytics(array $params = [])
     {
         $this->checkRequiredParameters(['id'], $params);
-        $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']) . '/_stop';
+        $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']).'/_stop';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['allow_no_match', 'force', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2275,7 +2275,7 @@ 
     public function stopDatafeed(array $params = [])
     {
         $this->checkRequiredParameters(['datafeed_id'], $params);
-        $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']) . '/_stop';
+        $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']).'/_stop';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['allow_no_match', 'allow_no_datafeeds', 'force', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2310,7 +2310,7 @@ 
     public function stopTrainedModelDeployment(array $params = [])
     {
         $this->checkRequiredParameters(['model_id'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/deployment/_stop';
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/deployment/_stop';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['allow_no_match', 'force', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2343,7 +2343,7 @@ 
     public function updateDataFrameAnalytics(array $params = [])
     {
         $this->checkRequiredParameters(['id', 'body'], $params);
-        $url = '/_ml/data_frame/analytics/' . $this->encode($params['id']) . '/_update';
+        $url = '/_ml/data_frame/analytics/'.$this->encode($params['id']).'/_update';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2380,7 +2380,7 @@ 
     public function updateDatafeed(array $params = [])
     {
         $this->checkRequiredParameters(['datafeed_id', 'body'], $params);
-        $url = '/_ml/datafeeds/' . $this->encode($params['datafeed_id']) . '/_update';
+        $url = '/_ml/datafeeds/'.$this->encode($params['datafeed_id']).'/_update';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['ignore_unavailable', 'allow_no_indices', 'ignore_throttled', 'expand_wildcards', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2413,7 +2413,7 @@ 
     public function updateFilter(array $params = [])
     {
         $this->checkRequiredParameters(['filter_id', 'body'], $params);
-        $url = '/_ml/filters/' . $this->encode($params['filter_id']) . '/_update';
+        $url = '/_ml/filters/'.$this->encode($params['filter_id']).'/_update';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2446,7 +2446,7 @@ 
     public function updateJob(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'body'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/_update';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/_update';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2480,7 +2480,7 @@ 
     public function updateModelSnapshot(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'snapshot_id', 'body'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/model_snapshots/' . $this->encode($params['snapshot_id']) . '/_update';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/model_snapshots/'.$this->encode($params['snapshot_id']).'/_update';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2514,7 +2514,7 @@ 
     public function updateTrainedModelDeployment(array $params = [])
     {
         $this->checkRequiredParameters(['model_id'], $params);
-        $url = '/_ml/trained_models/' . $this->encode($params['model_id']) . '/deployment/_update';
+        $url = '/_ml/trained_models/'.$this->encode($params['model_id']).'/deployment/_update';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['number_of_allocations', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json', 'Content-Type' => 'application/json'];
@@ -2549,7 +2549,7 @@ 
     public function upgradeJobSnapshot(array $params = [])
     {
         $this->checkRequiredParameters(['job_id', 'snapshot_id'], $params);
-        $url = '/_ml/anomaly_detectors/' . $this->encode($params['job_id']) . '/model_snapshots/' . $this->encode($params['snapshot_id']) . '/_upgrade';
+        $url = '/_ml/anomaly_detectors/'.$this->encode($params['job_id']).'/model_snapshots/'.$this->encode($params['snapshot_id']).'/_upgrade';
         $method = 'POST';
         $url = $this->addQueryString($url, $params, ['timeout', 'wait_for_completion', 'pretty', 'human', 'error_trace', 'source', 'filter_path']);
         $headers = ['Accept' => 'application/json'];