nextcloud / fulltextsearch_elasticsearch

lib/Vendor/Elastic/Elasticsearch/Exception/ProductCheckException.php

Braces +1 added lines, -2 removed lines

@@ -16,7 +16,6 @@
 
 use RuntimeException;
 
-class ProductCheckException extends RuntimeException implements ElasticsearchException
-{
+class ProductCheckException extends RuntimeException implements ElasticsearchException {
     
 }
\ No newline at end of file

lib/Vendor/Elastic/Elasticsearch/Exception/AuthenticationException.php

Braces +1 added lines, -2 removed lines

@@ -16,7 +16,6 @@
 
 use Exception;
 
-class AuthenticationException extends Exception implements ElasticsearchException
-{
+class AuthenticationException extends Exception implements ElasticsearchException {
 
 }
\ No newline at end of file

lib/Vendor/Elastic/Elasticsearch/Exception/ContentTypeException.php

Braces +1 added lines, -2 removed lines

@@ -16,7 +16,6 @@
 
 use Exception;
 
-class ContentTypeException extends Exception implements ElasticsearchException
-{
+class ContentTypeException extends Exception implements ElasticsearchException {
 
 }
\ No newline at end of file

lib/Vendor/Elastic/Elasticsearch/Exception/ArrayAccessException.php

Braces +1 added lines, -2 removed lines

@@ -16,7 +16,6 @@
 
 use Exception;
 
-class ArrayAccessException extends Exception implements ElasticsearchException
-{
+class ArrayAccessException extends Exception implements ElasticsearchException {
 
 }
\ No newline at end of file

lib/Vendor/Elastic/Elasticsearch/Exception/ConfigException.php

Braces +1 added lines, -2 removed lines

@@ -16,7 +16,6 @@
 
 use Exception;
 
-class ConfigException extends Exception implements ElasticsearchException
-{
+class ConfigException extends Exception implements ElasticsearchException {
 
 }
\ No newline at end of file

lib/Vendor/Elastic/Elasticsearch/Exception/InvalidArgumentException.php

Braces +1 added lines, -2 removed lines

@@ -16,7 +16,6 @@
 
 use InvalidArgumentException as InvalidArgument;
 
-class InvalidArgumentException extends InvalidArgument implements ElasticsearchException
-{
+class InvalidArgumentException extends InvalidArgument implements ElasticsearchException {
 
 }
\ No newline at end of file

lib/Vendor/Elastic/Elasticsearch/Client.php

Indentation +140 added lines, -140 removed lines

@@ -27,149 +27,149 @@
 
 final class Client implements ClientInterface
 {
-    const CLIENT_NAME = 'es';
-    const VERSION = '8.13.0';
-    const API_COMPATIBILITY_HEADER = '%s/vnd.elasticsearch+%s; compatible-with=8';
+	const CLIENT_NAME = 'es';
+	const VERSION = '8.13.0';
+	const API_COMPATIBILITY_HEADER = '%s/vnd.elasticsearch+%s; compatible-with=8';
     
-    use ClientEndpointsTrait;
-    use EndpointTrait;
-    use NamespaceTrait;
+	use ClientEndpointsTrait;
+	use EndpointTrait;
+	use NamespaceTrait;
     
-    protected Transport $transport;
-    protected LoggerInterface $logger;
+	protected Transport $transport;
+	protected LoggerInterface $logger;
 
-    /**
-     * Specify is the request is asyncronous
-     */
-    protected bool $async = false;
+	/**
+	 * Specify is the request is asyncronous
+	 */
+	protected bool $async = false;
     
-    /**
-     * Enable or disable the x-elastic-meta-header
-     */
-    protected bool $elasticMetaHeader = true;
-
-    /**
-     * Enable or disable the response Exception
-     */
-    protected bool $responseException = true;
-
-    /**
-     * The endpoint namespace storage 
-     */
-    protected array $namespace;
-
-    public function __construct(
-        Transport $transport, 
-        LoggerInterface $logger
-    ) {
-        $this->transport = $transport;
-        $this->logger = $logger;       
+	/**
+	 * Enable or disable the x-elastic-meta-header
+	 */
+	protected bool $elasticMetaHeader = true;
+
+	/**
+	 * Enable or disable the response Exception
+	 */
+	protected bool $responseException = true;
+
+	/**
+	 * The endpoint namespace storage 
+	 */
+	protected array $namespace;
+
+	public function __construct(
+		Transport $transport, 
+		LoggerInterface $logger
+	) {
+		$this->transport = $transport;
+		$this->logger = $logger;       
         
-        $this->defaultTransportSettings($this->transport);
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function getTransport(): Transport
-    {
-        return $this->transport;
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function getLogger(): LoggerInterface
-    {
-        return $this->logger;
-    }
-
-    /**
-     * Set the default settings for Elasticsearch
-     */
-    protected function defaultTransportSettings(Transport $transport): void
-    {
-        $transport->setUserAgent('elasticsearch-php', self::VERSION);
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function setAsync(bool $async): self
-    {
-        $this->async = $async;
-        return $this;
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function getAsync(): bool
-    {
-        return $this->async;
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function setElasticMetaHeader(bool $active): self
-    {
-        $this->elasticMetaHeader = $active;
-        return $this;
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function getElasticMetaHeader(): bool
-    {
-        return $this->elasticMetaHeader;
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function setResponseException(bool $active): self
-    {
-        $this->responseException = $active;
-        return $this;
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function getResponseException(): bool
-    {
-        return $this->responseException;
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function sendRequest(RequestInterface $request)
-    {   
-        // If async returns a Promise
-        if ($this->getAsync()) {
-            if ($this->getElasticMetaHeader()) {
-                $this->transport->setElasticMetaHeader(Client::CLIENT_NAME, Client::VERSION, true);
-            }
-            $this->transport->setAsyncOnSuccess(
-                $request->getMethod() === 'HEAD'
-                    ? new AsyncOnSuccessNoException
-                    : ($this->getResponseException() ? new AsyncOnSuccess : new AsyncOnSuccessNoException)
-            );
-            return $this->transport->sendAsyncRequest($request);
-        }     
-
-        if ($this->getElasticMetaHeader()) {
-            $this->transport->setElasticMetaHeader(Client::CLIENT_NAME, Client::VERSION, false);
-        }
-        $start = microtime(true);
-        $response = $this->transport->sendRequest($request);
-        $this->logger->info(sprintf("Response time in %.3f sec", microtime(true) - $start));       
-
-        $result = new Elasticsearch;
-        $result->setResponse($response, $request->getMethod() === 'HEAD' ? false : $this->getResponseException());
-        return $result;
-    }
+		$this->defaultTransportSettings($this->transport);
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function getTransport(): Transport
+	{
+		return $this->transport;
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function getLogger(): LoggerInterface
+	{
+		return $this->logger;
+	}
+
+	/**
+	 * Set the default settings for Elasticsearch
+	 */
+	protected function defaultTransportSettings(Transport $transport): void
+	{
+		$transport->setUserAgent('elasticsearch-php', self::VERSION);
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function setAsync(bool $async): self
+	{
+		$this->async = $async;
+		return $this;
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function getAsync(): bool
+	{
+		return $this->async;
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function setElasticMetaHeader(bool $active): self
+	{
+		$this->elasticMetaHeader = $active;
+		return $this;
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function getElasticMetaHeader(): bool
+	{
+		return $this->elasticMetaHeader;
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function setResponseException(bool $active): self
+	{
+		$this->responseException = $active;
+		return $this;
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function getResponseException(): bool
+	{
+		return $this->responseException;
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function sendRequest(RequestInterface $request)
+	{   
+		// If async returns a Promise
+		if ($this->getAsync()) {
+			if ($this->getElasticMetaHeader()) {
+				$this->transport->setElasticMetaHeader(Client::CLIENT_NAME, Client::VERSION, true);
+			}
+			$this->transport->setAsyncOnSuccess(
+				$request->getMethod() === 'HEAD'
+					? new AsyncOnSuccessNoException
+					: ($this->getResponseException() ? new AsyncOnSuccess : new AsyncOnSuccessNoException)
+			);
+			return $this->transport->sendAsyncRequest($request);
+		}     
+
+		if ($this->getElasticMetaHeader()) {
+			$this->transport->setElasticMetaHeader(Client::CLIENT_NAME, Client::VERSION, false);
+		}
+		$start = microtime(true);
+		$response = $this->transport->sendRequest($request);
+		$this->logger->info(sprintf("Response time in %.3f sec", microtime(true) - $start));       
+
+		$result = new Elasticsearch;
+		$result->setResponse($response, $request->getMethod() === 'HEAD' ? false : $this->getResponseException());
+		return $result;
+	}
 }
\ No newline at end of file

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,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;
 

Braces +1 added lines, -2 removed lines

@@ -25,8 +25,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\RequestInterface;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Log\LoggerInterface;
 
-final class Client implements ClientInterface
-{
+final class Client implements ClientInterface {
     const CLIENT_NAME = 'es';
     const VERSION = '8.13.0';
     const API_COMPATIBILITY_HEADER = '%s/vnd.elasticsearch+%s; compatible-with=8';

lib/Vendor/Elastic/Elasticsearch/Helper/Iterators/SearchHitIterator.php

Indentation +141 added lines, -141 removed lines

@@ -22,145 +22,145 @@
 class SearchHitIterator implements Iterator, Countable
 {
 
-    /**
-     * @var SearchResponseIterator
-     */
-    private SearchResponseIterator $searchResponses;
-
-    /**
-     * @var int
-     */
-    protected int $currentKey;
-
-    /**
-     * @var int
-     */
-    protected int $currentHitIndex;
-
-    /**
-     * @var array|null
-     */
-    protected ?array $currentHitData;
-
-    /**
-     * @var int
-     */
-    protected int $count = 0;
-
-    /**
-     * Constructor
-     *
-     * @param SearchResponseIterator $searchResponses
-     */
-    public function __construct(SearchResponseIterator $searchResponses)
-    {
-        $this->searchResponses = $searchResponses;
-    }
-
-    /**
-     * Rewinds the internal SearchResponseIterator and itself
-     *
-     * @return void
-     * @throws ClientResponseException
-     * @throws ServerResponseException
-     * @see    Iterator::rewind()
-     */
-    public function rewind(): void
-    {
-        $this->currentKey = 0;
-        $this->searchResponses->rewind();
-
-        // The first page may be empty. In that case, the next page is fetched.
-        $currentPage = $this->searchResponses->current();
-        if ($this->searchResponses->valid() && empty($currentPage['hits']['hits'])) {
-            $this->searchResponses->next();
-        }
-
-        $this->count = 0;
-        if (isset($currentPage['hits']['total']['value'], $currentPage['hits']['total'])) {
-            $this->count = $currentPage['hits']['total']['value'] ?? $currentPage['hits']['total'];
-        }
-
-        $this->readPageData();
-    }
-
-    /**
-     * Advances pointer of the current hit to the next one in the current page. If there
-     * isn't a next hit in the current page, then it advances the current page and moves the
-     * pointer to the first hit in the page.
-     *
-     * @return void
-     * @throws ClientResponseException
-     * @throws ServerResponseException
-     * @see    Iterator::next()
-     */
-    public function next(): void
-    {
-        $this->currentKey++;
-        $this->currentHitIndex++;
-        $currentPage = $this->searchResponses->current();
-        if (isset($currentPage['hits']['hits'][$this->currentHitIndex])) {
-            $this->currentHitData = $currentPage['hits']['hits'][$this->currentHitIndex];
-        } else {
-            $this->searchResponses->next();
-            $this->readPageData();
-        }
-    }
-
-    /**
-     * Returns a boolean indicating whether or not the current pointer has valid data
-     *
-     * @return bool
-     * @see    Iterator::valid()
-     */
-    public function valid(): bool
-    {
-        return is_array($this->currentHitData);
-    }
-
-    /**
-     * Returns the current hit
-     *
-     * @return array
-     * @see    Iterator::current()
-     */
-    public function current(): array
-    {
-        return $this->currentHitData;
-    }
-
-    /**
-     * Returns the current hit index. The hit index spans all pages.
-     *
-     * @return int
-     * @see    Iterator::key()
-     */
-    public function key(): int
-    {
-        return $this->currentKey;
-    }
-
-    /**
-     * Advances the internal SearchResponseIterator and resets the currentHitIndex to 0
-     *
-     * @internal
-     */
-    private function readPageData(): void
-    {
-        if ($this->searchResponses->valid()) {
-            $currentPage = $this->searchResponses->current();
-            $this->currentHitIndex = 0;
-            $this->currentHitData = $currentPage['hits']['hits'][$this->currentHitIndex];
-        } else {
-            $this->currentHitData = null;
-        }
-    }
-
-    /**
-     * {@inheritDoc}
-     */
-    public function count(): int
-    {
-        return $this->count;
-    }
+	/**
+	 * @var SearchResponseIterator
+	 */
+	private SearchResponseIterator $searchResponses;
+
+	/**
+	 * @var int
+	 */
+	protected int $currentKey;
+
+	/**
+	 * @var int
+	 */
+	protected int $currentHitIndex;
+
+	/**
+	 * @var array|null
+	 */
+	protected ?array $currentHitData;
+
+	/**
+	 * @var int
+	 */
+	protected int $count = 0;
+
+	/**
+	 * Constructor
+	 *
+	 * @param SearchResponseIterator $searchResponses
+	 */
+	public function __construct(SearchResponseIterator $searchResponses)
+	{
+		$this->searchResponses = $searchResponses;
+	}
+
+	/**
+	 * Rewinds the internal SearchResponseIterator and itself
+	 *
+	 * @return void
+	 * @throws ClientResponseException
+	 * @throws ServerResponseException
+	 * @see    Iterator::rewind()
+	 */
+	public function rewind(): void
+	{
+		$this->currentKey = 0;
+		$this->searchResponses->rewind();
+
+		// The first page may be empty. In that case, the next page is fetched.
+		$currentPage = $this->searchResponses->current();
+		if ($this->searchResponses->valid() && empty($currentPage['hits']['hits'])) {
+			$this->searchResponses->next();
+		}
+
+		$this->count = 0;
+		if (isset($currentPage['hits']['total']['value'], $currentPage['hits']['total'])) {
+			$this->count = $currentPage['hits']['total']['value'] ?? $currentPage['hits']['total'];
+		}
+
+		$this->readPageData();
+	}
+
+	/**
+	 * Advances pointer of the current hit to the next one in the current page. If there
+	 * isn't a next hit in the current page, then it advances the current page and moves the
+	 * pointer to the first hit in the page.
+	 *
+	 * @return void
+	 * @throws ClientResponseException
+	 * @throws ServerResponseException
+	 * @see    Iterator::next()
+	 */
+	public function next(): void
+	{
+		$this->currentKey++;
+		$this->currentHitIndex++;
+		$currentPage = $this->searchResponses->current();
+		if (isset($currentPage['hits']['hits'][$this->currentHitIndex])) {
+			$this->currentHitData = $currentPage['hits']['hits'][$this->currentHitIndex];
+		} else {
+			$this->searchResponses->next();
+			$this->readPageData();
+		}
+	}
+
+	/**
+	 * Returns a boolean indicating whether or not the current pointer has valid data
+	 *
+	 * @return bool
+	 * @see    Iterator::valid()
+	 */
+	public function valid(): bool
+	{
+		return is_array($this->currentHitData);
+	}
+
+	/**
+	 * Returns the current hit
+	 *
+	 * @return array
+	 * @see    Iterator::current()
+	 */
+	public function current(): array
+	{
+		return $this->currentHitData;
+	}
+
+	/**
+	 * Returns the current hit index. The hit index spans all pages.
+	 *
+	 * @return int
+	 * @see    Iterator::key()
+	 */
+	public function key(): int
+	{
+		return $this->currentKey;
+	}
+
+	/**
+	 * Advances the internal SearchResponseIterator and resets the currentHitIndex to 0
+	 *
+	 * @internal
+	 */
+	private function readPageData(): void
+	{
+		if ($this->searchResponses->valid()) {
+			$currentPage = $this->searchResponses->current();
+			$this->currentHitIndex = 0;
+			$this->currentHitData = $currentPage['hits']['hits'][$this->currentHitIndex];
+		} else {
+			$this->currentHitData = null;
+		}
+	}
+
+	/**
+	 * {@inheritDoc}
+	 */
+	public function count(): int
+	{
+		return $this->count;
+	}
 }
\ No newline at end of file

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,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\Helper\Iterators;
 

lib/Vendor/Elastic/Elasticsearch/Helper/Iterators/SearchResponseIterator.php

Indentation +167 added lines, -167 removed lines

@@ -22,171 +22,171 @@
 class SearchResponseIterator implements Iterator
 {
 
-    /**
-     * @var ClientInterface
-     */
-    private ClientInterface $client;
-
-    /**
-     * @var array
-     */
-    private array $params;
-
-    /**
-     * @var int
-     */
-    private int $currentKey = 0;
-
-    /**
-     * @var array
-     */
-    private array $currentScrolledResponse;
-
-    /**
-     * @var string|null
-     */
-    private ?string $scrollId;
-
-    /**
-     * @var string duration
-     */
-    private $scrollTtl;
-
-    /**
-     * Constructor
-     *
-     * @param ClientInterface $client
-     * @param array  $searchParams Associative array of parameters
-     * @see   ClientInterface::search()
-     */
-    public function __construct(ClientInterface $client, array $searchParams)
-    {
-        $this->client = $client;
-        $this->params = $searchParams;
-
-        if (isset($searchParams['scroll'])) {
-            $this->scrollTtl = $searchParams['scroll'];
-        }
-    }
-
-    /**
-     * Destructor
-     *
-     * @throws ClientResponseException
-     * @throws ServerResponseException
-     */
-    public function __destruct()
-    {
-        $this->clearScroll();
-    }
-
-    /**
-     * Sets the time to live duration of a scroll window
-     *
-     * @param  string $timeToLive
-     * @return $this
-     */
-    public function setScrollTimeout(string $timeToLive): SearchResponseIterator
-    {
-        $this->scrollTtl = $timeToLive;
-        return $this;
-    }
-
-    /**
-     * Clears the current scroll window if there is a scroll_id stored
-     *
-     * @return void
-     * @throws ClientResponseException
-     * @throws ServerResponseException
-     */
-    private function clearScroll(): void
-    {
-        if (!empty($this->scrollId)) {
-            /* @phpstan-ignore-next-line */
-            $this->client->clearScroll(
-                [
-                    'body' => [
-                        'scroll_id' => $this->scrollId
-                    ],
-                    'client' => [
-                        'ignore' => 404
-                    ]
-                ]
-            );
-            $this->scrollId = null;
-        }
-    }
-
-    /**
-     * Rewinds the iterator by performing the initial search.
-     *
-     * @return void
-     * @throws ClientResponseException
-     * @throws ServerResponseException
-     * @see    Iterator::rewind()
-     */
-    public function rewind(): void
-    {
-        $this->clearScroll();
-        $this->currentKey = 0;
-        /* @phpstan-ignore-next-line */
-        $this->currentScrolledResponse = $this->client->search($this->params)->asArray();
-        $this->scrollId = $this->currentScrolledResponse['_scroll_id'];
-    }
-
-    /**
-     * Fetches every "page" after the first one using the lastest "scroll_id"
-     *
-     * @return void
-     * @throws ClientResponseException
-     * @throws ServerResponseException
-     * @see    Iterator::next()
-     */
-    public function next(): void
-    {
-        /* @phpstan-ignore-next-line */
-        $this->currentScrolledResponse = $this->client->scroll(
-            [
-                'body' => [
-                    'scroll_id' => $this->scrollId,
-                    'scroll'    => $this->scrollTtl
-                ]
-            ]
-        )->asArray();
-        $this->scrollId = $this->currentScrolledResponse['_scroll_id'];
-        $this->currentKey++;
-    }
-
-    /**
-     * Returns a boolean value indicating if the current page is valid or not
-     *
-     * @return bool
-     * @see    Iterator::valid()
-     */
-    public function valid(): bool
-    {
-        return isset($this->currentScrolledResponse['hits']['hits'][0]);
-    }
-
-    /**
-     * Returns the current "page"
-     *
-     * @return array
-     * @see    Iterator::current()
-     */
-    public function current(): array
-    {
-        return $this->currentScrolledResponse;
-    }
-
-    /**
-     * Returns the current "page number" of the current "page"
-     *
-     * @return int
-     * @see    Iterator::key()
-     */
-    public function key(): int
-    {
-        return $this->currentKey;
-    }
+	/**
+	 * @var ClientInterface
+	 */
+	private ClientInterface $client;
+
+	/**
+	 * @var array
+	 */
+	private array $params;
+
+	/**
+	 * @var int
+	 */
+	private int $currentKey = 0;
+
+	/**
+	 * @var array
+	 */
+	private array $currentScrolledResponse;
+
+	/**
+	 * @var string|null
+	 */
+	private ?string $scrollId;
+
+	/**
+	 * @var string duration
+	 */
+	private $scrollTtl;
+
+	/**
+	 * Constructor
+	 *
+	 * @param ClientInterface $client
+	 * @param array  $searchParams Associative array of parameters
+	 * @see   ClientInterface::search()
+	 */
+	public function __construct(ClientInterface $client, array $searchParams)
+	{
+		$this->client = $client;
+		$this->params = $searchParams;
+
+		if (isset($searchParams['scroll'])) {
+			$this->scrollTtl = $searchParams['scroll'];
+		}
+	}
+
+	/**
+	 * Destructor
+	 *
+	 * @throws ClientResponseException
+	 * @throws ServerResponseException
+	 */
+	public function __destruct()
+	{
+		$this->clearScroll();
+	}
+
+	/**
+	 * Sets the time to live duration of a scroll window
+	 *
+	 * @param  string $timeToLive
+	 * @return $this
+	 */
+	public function setScrollTimeout(string $timeToLive): SearchResponseIterator
+	{
+		$this->scrollTtl = $timeToLive;
+		return $this;
+	}
+
+	/**
+	 * Clears the current scroll window if there is a scroll_id stored
+	 *
+	 * @return void
+	 * @throws ClientResponseException
+	 * @throws ServerResponseException
+	 */
+	private function clearScroll(): void
+	{
+		if (!empty($this->scrollId)) {
+			/* @phpstan-ignore-next-line */
+			$this->client->clearScroll(
+				[
+					'body' => [
+						'scroll_id' => $this->scrollId
+					],
+					'client' => [
+						'ignore' => 404
+					]
+				]
+			);
+			$this->scrollId = null;
+		}
+	}
+
+	/**
+	 * Rewinds the iterator by performing the initial search.
+	 *
+	 * @return void
+	 * @throws ClientResponseException
+	 * @throws ServerResponseException
+	 * @see    Iterator::rewind()
+	 */
+	public function rewind(): void
+	{
+		$this->clearScroll();
+		$this->currentKey = 0;
+		/* @phpstan-ignore-next-line */
+		$this->currentScrolledResponse = $this->client->search($this->params)->asArray();
+		$this->scrollId = $this->currentScrolledResponse['_scroll_id'];
+	}
+
+	/**
+	 * Fetches every "page" after the first one using the lastest "scroll_id"
+	 *
+	 * @return void
+	 * @throws ClientResponseException
+	 * @throws ServerResponseException
+	 * @see    Iterator::next()
+	 */
+	public function next(): void
+	{
+		/* @phpstan-ignore-next-line */
+		$this->currentScrolledResponse = $this->client->scroll(
+			[
+				'body' => [
+					'scroll_id' => $this->scrollId,
+					'scroll'    => $this->scrollTtl
+				]
+			]
+		)->asArray();
+		$this->scrollId = $this->currentScrolledResponse['_scroll_id'];
+		$this->currentKey++;
+	}
+
+	/**
+	 * Returns a boolean value indicating if the current page is valid or not
+	 *
+	 * @return bool
+	 * @see    Iterator::valid()
+	 */
+	public function valid(): bool
+	{
+		return isset($this->currentScrolledResponse['hits']['hits'][0]);
+	}
+
+	/**
+	 * Returns the current "page"
+	 *
+	 * @return array
+	 * @see    Iterator::current()
+	 */
+	public function current(): array
+	{
+		return $this->currentScrolledResponse;
+	}
+
+	/**
+	 * Returns the current "page number" of the current "page"
+	 *
+	 * @return int
+	 * @see    Iterator::key()
+	 */
+	public function key(): int
+	{
+		return $this->currentKey;
+	}
 }
\ No newline at end of file

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,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\Helper\Iterators;
 

Braces +1 added lines, -2 removed lines

@@ -19,8 +19,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Exception\ServerResponseException;
 use Iterator;
 
-class SearchResponseIterator implements Iterator
-{
+class SearchResponseIterator implements Iterator {
 
     /**
      * @var ClientInterface