nextcloud / fulltextsearch_elasticsearch

lib/Vendor/Psr/EventDispatcher/ListenerProviderInterface.php

Indentation +8 added lines, -8 removed lines

@@ -8,12 +8,12 @@
  */
 interface ListenerProviderInterface
 {
-    /**
-     * @param object $event
-     *   An event for which to return the relevant listeners.
-     * @return iterable[callable]
-     *   An iterable (array, iterator, or generator) of callables.  Each
-     *   callable MUST be type-compatible with $event.
-     */
-    public function getListenersForEvent(object $event) : iterable;
+	/**
+	 * @param object $event
+	 *   An event for which to return the relevant listeners.
+	 * @return iterable[callable]
+	 *   An iterable (array, iterator, or generator) of callables.  Each
+	 *   callable MUST be type-compatible with $event.
+	 */
+	public function getListenersForEvent(object $event) : iterable;
 }

Spacing +1 added lines, -1 removed lines

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

Braces +1 added lines, -2 removed lines

@@ -6,8 +6,7 @@
 /**
  * Mapper from an event to the listeners that are applicable to that event.
  */
-interface ListenerProviderInterface
-{
+interface ListenerProviderInterface {
     /**
      * @param object $event
      *   An event for which to return the relevant listeners.

lib/Vendor/Psr/EventDispatcher/EventDispatcherInterface.php

Indentation +10 added lines, -10 removed lines

@@ -8,14 +8,14 @@
  */
 interface EventDispatcherInterface
 {
-    /**
-     * Provide all relevant listeners with an event to process.
-     *
-     * @param object $event
-     *   The object to process.
-     *
-     * @return object
-     *   The Event that was passed, now modified by listeners.
-     */
-    public function dispatch(object $event);
+	/**
+	 * Provide all relevant listeners with an event to process.
+	 *
+	 * @param object $event
+	 *   The object to process.
+	 *
+	 * @return object
+	 *   The Event that was passed, now modified by listeners.
+	 */
+	public function dispatch(object $event);
 }

Braces +1 added lines, -2 removed lines

@@ -6,8 +6,7 @@
 /**
  * Defines a dispatcher for events.
  */
-interface EventDispatcherInterface
-{
+interface EventDispatcherInterface {
     /**
      * Provide all relevant listeners with an event to process.
      *

Spacing +1 added lines, -1 removed lines

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

lib/Vendor/Psr/EventDispatcher/StoppableEventInterface.php

Indentation +11 added lines, -11 removed lines

@@ -12,15 +12,15 @@
  */
 interface StoppableEventInterface
 {
-    /**
-     * Is propagation stopped?
-     *
-     * This will typically only be used by the Dispatcher to determine if the
-     * previous listener halted propagation.
-     *
-     * @return bool
-     *   True if the Event is complete and no further listeners should be called.
-     *   False to continue calling listeners.
-     */
-    public function isPropagationStopped() : bool;
+	/**
+	 * Is propagation stopped?
+	 *
+	 * This will typically only be used by the Dispatcher to determine if the
+	 * previous listener halted propagation.
+	 *
+	 * @return bool
+	 *   True if the Event is complete and no further listeners should be called.
+	 *   False to continue calling listeners.
+	 */
+	public function isPropagationStopped() : bool;
 }

Braces +1 added lines, -2 removed lines

@@ -10,8 +10,7 @@
  * is marked as stopped after each listener is called.  If it is then it should
  * return immediately without calling any further Listeners.
  */
-interface StoppableEventInterface
-{
+interface StoppableEventInterface {
     /**
      * Is propagation stopped?
      *

Spacing +1 added lines, -1 removed lines

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

lib/Vendor/Psr/Container/ContainerExceptionInterface.php

Braces +1 added lines, -2 removed lines

@@ -6,6 +6,5 @@
 /**
  * Base interface representing a generic exception in a container.
  */
-interface ContainerExceptionInterface extends Throwable
-{
+interface ContainerExceptionInterface extends Throwable {
 }

lib/Vendor/Psr/Container/ContainerInterface.php

Indentation +23 added lines, -23 removed lines

@@ -8,27 +8,27 @@
  */
 interface ContainerInterface
 {
-    /**
-     * Finds an entry of the container by its identifier and returns it.
-     *
-     * @param string $id Identifier of the entry to look for.
-     *
-     * @throws NotFoundExceptionInterface  No entry was found for **this** identifier.
-     * @throws ContainerExceptionInterface Error while retrieving the entry.
-     *
-     * @return mixed Entry.
-     */
-    public function get(string $id);
-    /**
-     * Returns true if the container can return an entry for the given identifier.
-     * Returns false otherwise.
-     *
-     * `has($id)` returning true does not mean that `get($id)` will not throw an exception.
-     * It does however mean that `get($id)` will not throw a `NotFoundExceptionInterface`.
-     *
-     * @param string $id Identifier of the entry to look for.
-     *
-     * @return bool
-     */
-    public function has(string $id) : bool;
+	/**
+	 * Finds an entry of the container by its identifier and returns it.
+	 *
+	 * @param string $id Identifier of the entry to look for.
+	 *
+	 * @throws NotFoundExceptionInterface  No entry was found for **this** identifier.
+	 * @throws ContainerExceptionInterface Error while retrieving the entry.
+	 *
+	 * @return mixed Entry.
+	 */
+	public function get(string $id);
+	/**
+	 * Returns true if the container can return an entry for the given identifier.
+	 * Returns false otherwise.
+	 *
+	 * `has($id)` returning true does not mean that `get($id)` will not throw an exception.
+	 * It does however mean that `get($id)` will not throw a `NotFoundExceptionInterface`.
+	 *
+	 * @param string $id Identifier of the entry to look for.
+	 *
+	 * @return bool
+	 */
+	public function has(string $id) : bool;
 }

Spacing +1 added lines, -1 removed lines

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

Braces +1 added lines, -2 removed lines

@@ -6,8 +6,7 @@
 /**
  * Describes the interface of a container that exposes methods to read its entries.
  */
-interface ContainerInterface
-{
+interface ContainerInterface {
     /**
      * Finds an entry of the container by its identifier and returns it.
      *

lib/Vendor/Psr/Container/NotFoundExceptionInterface.php

Braces +1 added lines, -2 removed lines

@@ -5,6 +5,5 @@
 /**
  * No entry was found in the container.
  */
-interface NotFoundExceptionInterface extends ContainerExceptionInterface
-{
+interface NotFoundExceptionInterface extends ContainerExceptionInterface {
 }

lib/Vendor/Elastic/Elasticsearch/Client.php

Spacing +1 added lines, -1 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;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Response\Elasticsearch;

Indentation +119 added lines, -119 removed lines

@@ -26,123 +26,123 @@
 use Psr\Log\LoggerInterface;
 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';
-    use ClientEndpointsTrait;
-    use EndpointTrait;
-    use NamespaceTrait;
-    protected Transport $transport;
-    protected LoggerInterface $logger;
-    /**
-     * 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;
-        $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;
-    }
+	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;
+	protected Transport $transport;
+	protected LoggerInterface $logger;
+	/**
+	 * 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;
+		$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;
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -24,8 +24,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Http\Promise\Promise;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\RequestInterface;
 use 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/Response/ElasticsearchInterface.php

Indentation +4 added lines, -4 removed lines

@@ -17,8 +17,8 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface;
 interface ElasticsearchInterface
 {
-    /**
-     * Set the HTTP PSR-7 response 
-     */
-    public function setResponse(ResponseInterface $response, bool $throwException = \true) : void;
+	/**
+	 * Set the HTTP PSR-7 response 
+	 */
+	public function setResponse(ResponseInterface $response, bool $throwException = \true) : void;
 }

Spacing +1 added lines, -1 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\Response;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface;

Braces +1 added lines, -2 removed lines

@@ -15,8 +15,7 @@
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Response;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface;
-interface ElasticsearchInterface
-{
+interface ElasticsearchInterface {
     /**
      * Set the HTTP PSR-7 response 
      */

lib/Vendor/Elastic/Elasticsearch/Response/Elasticsearch.php

Indentation +216 added lines, -216 removed lines

@@ -34,220 +34,220 @@
  */
 class Elasticsearch implements ElasticsearchInterface, ResponseInterface, ArrayAccess
 {
-    const HEADER_CHECK = 'X-Elastic-Product';
-    const PRODUCT_NAME = 'Elasticsearch';
-    use ProductCheckTrait;
-    use MessageResponseTrait;
-    protected array $asArray;
-    protected object $asObject;
-    protected string $asString;
-    /**
-     * The PSR-7 response
-     */
-    protected ResponseInterface $response;
-    /**
-     * Enable or disable the response Exception
-     */
-    protected bool $responseException;
-    /**
-     * @throws ClientResponseException if status code 4xx
-     * @throws ServerResponseException if status code 5xx
-     */
-    public function setResponse(ResponseInterface $response, bool $throwException = \true) : void
-    {
-        $this->productCheck($response);
-        $this->response = $response;
-        $status = $response->getStatusCode();
-        if ($throwException && $status > 399 && $status < 500) {
-            $error = new ClientResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string) $response->getBody()), $status);
-            throw $error->setResponse($response);
-        } elseif ($throwException && $status > 499 && $status < 600) {
-            $error = new ServerResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string) $response->getBody()), $status);
-            throw $error->setResponse($response);
-        }
-    }
-    /**
-     * Return true if status code is 2xx
-     */
-    public function asBool() : bool
-    {
-        return $this->response->getStatusCode() >= 200 && $this->response->getStatusCode() < 300;
-    }
-    /**
-     * Converts the body content to array, if possible.
-     * Otherwise, it throws an UnknownContentTypeException
-     * if Content-Type is not specified or unknown.
-     * 
-     * @throws UnknownContentTypeException
-     */
-    public function asArray() : array
-    {
-        if (isset($this->asArray)) {
-            return $this->asArray;
-        }
-        if (!$this->response->hasHeader('Content-Type')) {
-            throw new UnknownContentTypeException('No Content-Type specified in the response');
-        }
-        $contentType = $this->response->getHeaderLine('Content-Type');
-        if (\strpos($contentType, 'application/json') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+json') !== \false) {
-            $this->asArray = JsonSerializer::unserialize($this->asString());
-            return $this->asArray;
-        }
-        if (\strpos($contentType, 'application/x-ndjson') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+x-ndjson') !== \false) {
-            $this->asArray = NDJsonSerializer::unserialize($this->asString());
-            return $this->asArray;
-        }
-        if (\strpos($contentType, 'text/csv') !== \false) {
-            $this->asArray = CsvSerializer::unserialize($this->asString());
-            return $this->asArray;
-        }
-        throw new UnknownContentTypeException(\sprintf("Cannot deserialize the reponse as array with Content-Type: %s", $contentType));
-    }
-    /**
-     * Converts the body content to object, if possible.
-     * Otherwise, it throws an UnknownContentTypeException
-     * if Content-Type is not specified or unknown.
-     * 
-     * @throws UnknownContentTypeException
-     */
-    public function asObject() : object
-    {
-        if (isset($this->asObject)) {
-            return $this->asObject;
-        }
-        $contentType = $this->response->getHeaderLine('Content-Type');
-        if (\strpos($contentType, 'application/json') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+json') !== \false) {
-            $this->asObject = JsonSerializer::unserialize($this->asString(), ['type' => 'object']);
-            return $this->asObject;
-        }
-        if (\strpos($contentType, 'application/x-ndjson') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+x-ndjson') !== \false) {
-            $this->asObject = NDJsonSerializer::unserialize($this->asString(), ['type' => 'object']);
-            return $this->asObject;
-        }
-        if (\strpos($contentType, 'text/xml') !== \false || \strpos($contentType, 'application/xml') !== \false) {
-            $this->asObject = XmlSerializer::unserialize($this->asString());
-            return $this->asObject;
-        }
-        throw new UnknownContentTypeException(\sprintf("Cannot deserialize the reponse as object with Content-Type: %s", $contentType));
-    }
-    /**
-     * Converts the body content to string
-     */
-    public function asString() : string
-    {
-        if (empty($this->asString)) {
-            $this->asString = (string) $this->response->getBody();
-        }
-        return $this->asString;
-    }
-    /**
-     * Converts the body content to string
-     */
-    public function __toString() : string
-    {
-        return $this->asString();
-    }
-    /**
-     * Access the body content as object properties
-     * 
-     * @see https://www.php.net/manual/en/language.oop5.overloading.php#object.get
-     */
-    public function __get($name)
-    {
-        return $this->asObject()->{$name} ?? null;
-    }
-    /**
-     * ArrayAccess interface
-     * 
-     * @see https://www.php.net/manual/en/class.arrayaccess.php
-     */
-    public function offsetExists($offset) : bool
-    {
-        return isset($this->asArray()[$offset]);
-    }
-    /**
-     * ArrayAccess interface
-     * 
-     * @see https://www.php.net/manual/en/class.arrayaccess.php
-     *
-     * @return mixed
-     */
-    #[\ReturnTypeWillChange]
-    public function offsetGet($offset)
-    {
-        return $this->asArray()[$offset];
-    }
-    /**
-     * ArrayAccess interface
-     * 
-     * @see https://www.php.net/manual/en/class.arrayaccess.php
-     */
-    public function offsetSet($offset, $value) : void
-    {
-        throw new ArrayAccessException('The array is reading only');
-    }
-    /**
-     * ArrayAccess interface
-     * 
-     * @see https://www.php.net/manual/en/class.arrayaccess.php
-     */
-    public function offsetUnset($offset) : void
-    {
-        throw new ArrayAccessException('The array is reading only');
-    }
-    /**
-     * Map the response body to an object of a specific class
-     * by default the class is the PHP standard one (stdClass)
-     * 
-     * This mapping works only for ES|QL results (with columns and values)
-     * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/esql.html
-     * 
-     * @return object[] 
-     */
-    public function mapTo(string $class = stdClass::class) : array
-    {
-        $response = $this->asArray();
-        if (!isset($response['columns']) || !isset($response['values'])) {
-            throw new UnknownContentTypeException(\sprintf("The response is not a valid ES|QL result. I cannot mapTo(\"%s\")", $class));
-        }
-        $iterator = [];
-        $ncol = \count($response['columns']);
-        foreach ($response['values'] as $value) {
-            $obj = new $class();
-            for ($i = 0; $i < $ncol; $i++) {
-                $field = Utility::formatVariableName($response['columns'][$i]['name']);
-                if ($class !== stdClass::class && !\property_exists($obj, $field)) {
-                    continue;
-                }
-                switch ($response['columns'][$i]['type']) {
-                    case 'boolean':
-                        $obj->{$field} = (bool) $value[$i];
-                        break;
-                    case 'date':
-                        $obj->{$field} = new DateTime($value[$i]);
-                        break;
-                    case 'alias':
-                    case 'text':
-                    case 'keyword':
-                    case 'ip':
-                        $obj->{$field} = (string) $value[$i];
-                        break;
-                    case 'integer':
-                        $obj->{$field} = (int) $value[$i];
-                        break;
-                    case 'long':
-                    case 'double':
-                        $obj->{$field} = (float) $value[$i];
-                        break;
-                    case 'null':
-                        $obj->{$field} = null;
-                        break;
-                    default:
-                        $obj->{$field} = $value[$i];
-                }
-            }
-            $iterator[] = $obj;
-        }
-        return $iterator;
-    }
+	const HEADER_CHECK = 'X-Elastic-Product';
+	const PRODUCT_NAME = 'Elasticsearch';
+	use ProductCheckTrait;
+	use MessageResponseTrait;
+	protected array $asArray;
+	protected object $asObject;
+	protected string $asString;
+	/**
+	 * The PSR-7 response
+	 */
+	protected ResponseInterface $response;
+	/**
+	 * Enable or disable the response Exception
+	 */
+	protected bool $responseException;
+	/**
+	 * @throws ClientResponseException if status code 4xx
+	 * @throws ServerResponseException if status code 5xx
+	 */
+	public function setResponse(ResponseInterface $response, bool $throwException = \true) : void
+	{
+		$this->productCheck($response);
+		$this->response = $response;
+		$status = $response->getStatusCode();
+		if ($throwException && $status > 399 && $status < 500) {
+			$error = new ClientResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string) $response->getBody()), $status);
+			throw $error->setResponse($response);
+		} elseif ($throwException && $status > 499 && $status < 600) {
+			$error = new ServerResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string) $response->getBody()), $status);
+			throw $error->setResponse($response);
+		}
+	}
+	/**
+	 * Return true if status code is 2xx
+	 */
+	public function asBool() : bool
+	{
+		return $this->response->getStatusCode() >= 200 && $this->response->getStatusCode() < 300;
+	}
+	/**
+	 * Converts the body content to array, if possible.
+	 * Otherwise, it throws an UnknownContentTypeException
+	 * if Content-Type is not specified or unknown.
+	 * 
+	 * @throws UnknownContentTypeException
+	 */
+	public function asArray() : array
+	{
+		if (isset($this->asArray)) {
+			return $this->asArray;
+		}
+		if (!$this->response->hasHeader('Content-Type')) {
+			throw new UnknownContentTypeException('No Content-Type specified in the response');
+		}
+		$contentType = $this->response->getHeaderLine('Content-Type');
+		if (\strpos($contentType, 'application/json') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+json') !== \false) {
+			$this->asArray = JsonSerializer::unserialize($this->asString());
+			return $this->asArray;
+		}
+		if (\strpos($contentType, 'application/x-ndjson') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+x-ndjson') !== \false) {
+			$this->asArray = NDJsonSerializer::unserialize($this->asString());
+			return $this->asArray;
+		}
+		if (\strpos($contentType, 'text/csv') !== \false) {
+			$this->asArray = CsvSerializer::unserialize($this->asString());
+			return $this->asArray;
+		}
+		throw new UnknownContentTypeException(\sprintf("Cannot deserialize the reponse as array with Content-Type: %s", $contentType));
+	}
+	/**
+	 * Converts the body content to object, if possible.
+	 * Otherwise, it throws an UnknownContentTypeException
+	 * if Content-Type is not specified or unknown.
+	 * 
+	 * @throws UnknownContentTypeException
+	 */
+	public function asObject() : object
+	{
+		if (isset($this->asObject)) {
+			return $this->asObject;
+		}
+		$contentType = $this->response->getHeaderLine('Content-Type');
+		if (\strpos($contentType, 'application/json') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+json') !== \false) {
+			$this->asObject = JsonSerializer::unserialize($this->asString(), ['type' => 'object']);
+			return $this->asObject;
+		}
+		if (\strpos($contentType, 'application/x-ndjson') !== \false || \strpos($contentType, 'application/vnd.elasticsearch+x-ndjson') !== \false) {
+			$this->asObject = NDJsonSerializer::unserialize($this->asString(), ['type' => 'object']);
+			return $this->asObject;
+		}
+		if (\strpos($contentType, 'text/xml') !== \false || \strpos($contentType, 'application/xml') !== \false) {
+			$this->asObject = XmlSerializer::unserialize($this->asString());
+			return $this->asObject;
+		}
+		throw new UnknownContentTypeException(\sprintf("Cannot deserialize the reponse as object with Content-Type: %s", $contentType));
+	}
+	/**
+	 * Converts the body content to string
+	 */
+	public function asString() : string
+	{
+		if (empty($this->asString)) {
+			$this->asString = (string) $this->response->getBody();
+		}
+		return $this->asString;
+	}
+	/**
+	 * Converts the body content to string
+	 */
+	public function __toString() : string
+	{
+		return $this->asString();
+	}
+	/**
+	 * Access the body content as object properties
+	 * 
+	 * @see https://www.php.net/manual/en/language.oop5.overloading.php#object.get
+	 */
+	public function __get($name)
+	{
+		return $this->asObject()->{$name} ?? null;
+	}
+	/**
+	 * ArrayAccess interface
+	 * 
+	 * @see https://www.php.net/manual/en/class.arrayaccess.php
+	 */
+	public function offsetExists($offset) : bool
+	{
+		return isset($this->asArray()[$offset]);
+	}
+	/**
+	 * ArrayAccess interface
+	 * 
+	 * @see https://www.php.net/manual/en/class.arrayaccess.php
+	 *
+	 * @return mixed
+	 */
+	#[\ReturnTypeWillChange]
+	public function offsetGet($offset)
+	{
+		return $this->asArray()[$offset];
+	}
+	/**
+	 * ArrayAccess interface
+	 * 
+	 * @see https://www.php.net/manual/en/class.arrayaccess.php
+	 */
+	public function offsetSet($offset, $value) : void
+	{
+		throw new ArrayAccessException('The array is reading only');
+	}
+	/**
+	 * ArrayAccess interface
+	 * 
+	 * @see https://www.php.net/manual/en/class.arrayaccess.php
+	 */
+	public function offsetUnset($offset) : void
+	{
+		throw new ArrayAccessException('The array is reading only');
+	}
+	/**
+	 * Map the response body to an object of a specific class
+	 * by default the class is the PHP standard one (stdClass)
+	 * 
+	 * This mapping works only for ES|QL results (with columns and values)
+	 * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/esql.html
+	 * 
+	 * @return object[] 
+	 */
+	public function mapTo(string $class = stdClass::class) : array
+	{
+		$response = $this->asArray();
+		if (!isset($response['columns']) || !isset($response['values'])) {
+			throw new UnknownContentTypeException(\sprintf("The response is not a valid ES|QL result. I cannot mapTo(\"%s\")", $class));
+		}
+		$iterator = [];
+		$ncol = \count($response['columns']);
+		foreach ($response['values'] as $value) {
+			$obj = new $class();
+			for ($i = 0; $i < $ncol; $i++) {
+				$field = Utility::formatVariableName($response['columns'][$i]['name']);
+				if ($class !== stdClass::class && !\property_exists($obj, $field)) {
+					continue;
+				}
+				switch ($response['columns'][$i]['type']) {
+					case 'boolean':
+						$obj->{$field} = (bool) $value[$i];
+						break;
+					case 'date':
+						$obj->{$field} = new DateTime($value[$i]);
+						break;
+					case 'alias':
+					case 'text':
+					case 'keyword':
+					case 'ip':
+						$obj->{$field} = (string) $value[$i];
+						break;
+					case 'integer':
+						$obj->{$field} = (int) $value[$i];
+						break;
+					case 'long':
+					case 'double':
+						$obj->{$field} = (float) $value[$i];
+						break;
+					case 'null':
+						$obj->{$field} = null;
+						break;
+					default:
+						$obj->{$field} = $value[$i];
+				}
+			}
+			$iterator[] = $obj;
+		}
+		return $iterator;
+	}
 }

Spacing +8 added lines, -8 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\Response;
 
 use ArrayAccess;
@@ -59,10 +59,10 @@ 
         $this->response = $response;
         $status = $response->getStatusCode();
         if ($throwException && $status > 399 && $status < 500) {
-            $error = new ClientResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string) $response->getBody()), $status);
+            $error = new ClientResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string)$response->getBody()), $status);
             throw $error->setResponse($response);
         } elseif ($throwException && $status > 499 && $status < 600) {
-            $error = new ServerResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string) $response->getBody()), $status);
+            $error = new ServerResponseException(\sprintf("%s %s: %s", $status, $response->getReasonPhrase(), (string)$response->getBody()), $status);
             throw $error->setResponse($response);
         }
     }
@@ -136,7 +136,7 @@ 
     public function asString() : string
     {
         if (empty($this->asString)) {
-            $this->asString = (string) $this->response->getBody();
+            $this->asString = (string)$this->response->getBody();
         }
         return $this->asString;
     }
@@ -221,7 +221,7 @@ 
                 }
                 switch ($response['columns'][$i]['type']) {
                     case 'boolean':
-                        $obj->{$field} = (bool) $value[$i];
+                        $obj->{$field} = (bool)$value[$i];
                         break;
                     case 'date':
                         $obj->{$field} = new DateTime($value[$i]);
@@ -230,14 +230,14 @@ 
                     case 'text':
                     case 'keyword':
                     case 'ip':
-                        $obj->{$field} = (string) $value[$i];
+                        $obj->{$field} = (string)$value[$i];
                         break;
                     case 'integer':
-                        $obj->{$field} = (int) $value[$i];
+                        $obj->{$field} = (int)$value[$i];
                         break;
                     case 'long':
                     case 'double':
-                        $obj->{$field} = (float) $value[$i];
+                        $obj->{$field} = (float)$value[$i];
                         break;
                     case 'null':
                         $obj->{$field} = null;