nextcloud / fulltextsearch_elasticsearch

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

Indentation +9 added lines, -9 removed lines

@@ -15,15 +15,15 @@
  */
 class RequestException extends TransferException implements PsrRequestException
 {
-    use RequestAwareTrait;
+	use RequestAwareTrait;
 
-    /**
-     * @param string $message
-     */
-    public function __construct($message, RequestInterface $request, \Exception $previous = null)
-    {
-        $this->setRequest($request);
+	/**
+	 * @param string $message
+	 */
+	public function __construct($message, RequestInterface $request, \Exception $previous = null)
+	{
+		$this->setRequest($request);
 
-        parent::__construct($message, 0, $previous);
-    }
+		parent::__construct($message, 0, $previous);
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -13,8 +13,7 @@
  *
  * @author Márk Sági-Kazár <mark.sagikazar@gmail.com>
  */
-class RequestException extends TransferException implements PsrRequestException
-{
+class RequestException extends TransferException implements PsrRequestException {
     use RequestAwareTrait;
 
     /**

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

Indentation +15 added lines, -15 removed lines

@@ -6,21 +6,21 @@
 
 trait RequestAwareTrait
 {
-    /**
-     * @var RequestInterface
-     */
-    private $request;
+	/**
+	 * @var RequestInterface
+	 */
+	private $request;
 
-    private function setRequest(RequestInterface $request)
-    {
-        $this->request = $request;
-    }
+	private function setRequest(RequestInterface $request)
+	{
+		$this->request = $request;
+	}
 
-    /**
-     * {@inheritdoc}
-     */
-    public function getRequest(): RequestInterface
-    {
-        return $this->request;
-    }
+	/**
+	 * {@inheritdoc}
+	 */
+	public function getRequest(): RequestInterface
+	{
+		return $this->request;
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -4,8 +4,7 @@
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\RequestInterface;
 
-trait RequestAwareTrait
-{
+trait RequestAwareTrait {
     /**
      * @var RequestInterface
      */

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

Indentation +43 added lines, -43 removed lines

@@ -8,47 +8,47 @@
 
 final class HttpFulfilledPromise implements Promise
 {
-    /**
-     * @var ResponseInterface
-     */
-    private $response;
-
-    public function __construct(ResponseInterface $response)
-    {
-        $this->response = $response;
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function then(callable $onFulfilled = null, callable $onRejected = null)
-    {
-        if (null === $onFulfilled) {
-            return $this;
-        }
-
-        try {
-            return new self($onFulfilled($this->response));
-        } catch (Exception $e) {
-            return new HttpRejectedPromise($e);
-        }
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function getState()
-    {
-        return Promise::FULFILLED;
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function wait($unwrap = true)
-    {
-        if ($unwrap) {
-            return $this->response;
-        }
-    }
+	/**
+	 * @var ResponseInterface
+	 */
+	private $response;
+
+	public function __construct(ResponseInterface $response)
+	{
+		$this->response = $response;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function then(callable $onFulfilled = null, callable $onRejected = null)
+	{
+		if (null === $onFulfilled) {
+			return $this;
+		}
+
+		try {
+			return new self($onFulfilled($this->response));
+		} catch (Exception $e) {
+			return new HttpRejectedPromise($e);
+		}
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function getState()
+	{
+		return Promise::FULFILLED;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function wait($unwrap = true)
+	{
+		if ($unwrap) {
+			return $this->response;
+		}
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -6,8 +6,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Http\Promise\Promise;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface;
 
-final class HttpFulfilledPromise implements Promise
-{
+final class HttpFulfilledPromise implements Promise {
     /**
      * @var ResponseInterface
      */

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

Indentation +48 added lines, -48 removed lines

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

Braces +1 added lines, -2 removed lines

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

lib/Vendor/Elastic/Transport/Transport.php

Indentation +413 added lines, -413 removed lines

@@ -48,420 +48,420 @@
 
 final class Transport implements ClientInterface, HttpAsyncClient
 {
-    const VERSION = "8.8.0";
-
-    private ClientInterface $client;
-    private LoggerInterface $logger;
-    private NodePoolInterface $nodePool;
-    private array $headers = [];
-    private string $user;
-    private string $password;
-    private RequestInterface $lastRequest;
-    private ResponseInterface $lastResponse;
-    private string $OSVersion;
-    private int $retries = 0;
-    private HttpAsyncClient $asyncClient;
-    private OnSuccessInterface $onAsyncSuccess;
-    private OnFailureInterface $onAsyncFailure;
-
-    public function __construct(
-        ClientInterface $client,
-        NodePoolInterface $nodePool,
-        LoggerInterface $logger
-    ) {
-        $this->client = $client;
-        $this->nodePool = $nodePool;
-        $this->logger = $logger;
-    }
-
-    public function getClient(): ClientInterface
-    {
-        return $this->client;
-    }
-
-    public function getNodePool(): NodePoolInterface
-    {
-        return $this->nodePool;
-    }
-
-    public function getLogger(): LoggerInterface
-    {
-        return $this->logger;
-    }
-
-    public function setHeader(string $name, string $value): self
-    {
-        $this->headers[$name] = $value;
-        return $this;
-    }
-
-    /**
-     * @throws InvalidArgumentException
-     */
-    public function setRetries(int $num): self
-    {
-        if ($num < 0) {
-            throw new InvalidArgumentException('The retries number must be a positive integer');
-        }
-        $this->retries = $num;
-        return $this;
-    }
-
-    public function getRetries(): int
-    {
-        return $this->retries;
-    }
-
-    public function getHeaders(): array
-    {
-        return $this->headers;
-    }
-
-    public function setUserInfo(string $user, string $password = ''): self
-    {
-        $this->user = $user;
-        $this->password = $password;
-        return $this;
-    }
-
-    public function setUserAgent(string $name, string $version): self
-    {
-        $this->headers['User-Agent'] = sprintf(
-            "%s/%s (%s %s; PHP %s)",
-            $name,
-            $version,
-            PHP_OS,
-            $this->getOSVersion(),
-            phpversion()
-        );
-        return $this;
-    }
-
-    /**
-     * Set the x-elastic-client-meta header
-     * 
-     * The header format is specified by the following regex:
-     * ^[a-z]{1,}=[a-z0-9\.\-]{1,}(?:,[a-z]{1,}=[a-z0-9\.\-]+)*$
-     */
-    public function setElasticMetaHeader(string $clientName, string $clientVersion, bool $async = false): self
-    {
-        $phpSemVersion = sprintf("%d.%d.%d", PHP_MAJOR_VERSION, PHP_MINOR_VERSION, PHP_RELEASE_VERSION);
-        $meta = sprintf(
-            "%s=%s,php=%s,t=%s,a=%d",
-            $clientName,
-            $this->purgePreReleaseTag($clientVersion),
-            $phpSemVersion,
-            $this->purgePreReleaseTag(self::VERSION),
-            $async ? 1 : 0 // 0=syncronous, 1=asynchronous
-        );
-        $lib = $this->getClientLibraryInfo();
-        if (!empty($lib)) {
-            $meta .= sprintf(",%s=%s", $lib[0], $lib[1]);
-        }
-        $this->headers['x-elastic-client-meta'] = $meta;
-        return $this;
-    }
-
-    /**
-     * Remove pre-release suffix with a single 'p' letter
-     */
-    private function purgePreReleaseTag(string $version): string
-    {
-        return str_replace(['alpha', 'beta', 'snapshot', 'rc', 'pre'], 'p', strtolower($version)); 
-    }
-
-    public function getLastRequest(): RequestInterface
-    {
-        return $this->lastRequest;
-    }
-
-    public function getLastResponse(): ResponseInterface
-    {
-        return $this->lastResponse;
-    }
-
-    /**
-     * Setup the headers, if not already present 
-     */
-    private function setupHeaders(RequestInterface $request): RequestInterface
-    {
-        foreach ($this->headers as $name => $value) {
-            if (!$request->hasHeader($name)) {
-                $request = $request->withHeader($name, $value);
-            }
-        }
-        return $request;
-    }
-
-    /**
-     * Setup the user info, if not already present
-     */
-    private function setupUserInfo(RequestInterface $request): RequestInterface
-    {
-        $uri = $request->getUri();
-        if (empty($uri->getUserInfo())) {
-            if (isset($this->user)) {
-                $request = $request->withUri($uri->withUserInfo($this->user, $this->password));
-            }
-        }
-        return $request;
-    }
-
-    /**
-     * Setup the connection Uri 
-     */
-    private function setupConnectionUri(Node $node, RequestInterface $request): RequestInterface
-    {
-        $uri = $node->getUri();
-        $path = $request->getUri()->getPath();
+	const VERSION = "8.8.0";
+
+	private ClientInterface $client;
+	private LoggerInterface $logger;
+	private NodePoolInterface $nodePool;
+	private array $headers = [];
+	private string $user;
+	private string $password;
+	private RequestInterface $lastRequest;
+	private ResponseInterface $lastResponse;
+	private string $OSVersion;
+	private int $retries = 0;
+	private HttpAsyncClient $asyncClient;
+	private OnSuccessInterface $onAsyncSuccess;
+	private OnFailureInterface $onAsyncFailure;
+
+	public function __construct(
+		ClientInterface $client,
+		NodePoolInterface $nodePool,
+		LoggerInterface $logger
+	) {
+		$this->client = $client;
+		$this->nodePool = $nodePool;
+		$this->logger = $logger;
+	}
+
+	public function getClient(): ClientInterface
+	{
+		return $this->client;
+	}
+
+	public function getNodePool(): NodePoolInterface
+	{
+		return $this->nodePool;
+	}
+
+	public function getLogger(): LoggerInterface
+	{
+		return $this->logger;
+	}
+
+	public function setHeader(string $name, string $value): self
+	{
+		$this->headers[$name] = $value;
+		return $this;
+	}
+
+	/**
+	 * @throws InvalidArgumentException
+	 */
+	public function setRetries(int $num): self
+	{
+		if ($num < 0) {
+			throw new InvalidArgumentException('The retries number must be a positive integer');
+		}
+		$this->retries = $num;
+		return $this;
+	}
+
+	public function getRetries(): int
+	{
+		return $this->retries;
+	}
+
+	public function getHeaders(): array
+	{
+		return $this->headers;
+	}
+
+	public function setUserInfo(string $user, string $password = ''): self
+	{
+		$this->user = $user;
+		$this->password = $password;
+		return $this;
+	}
+
+	public function setUserAgent(string $name, string $version): self
+	{
+		$this->headers['User-Agent'] = sprintf(
+			"%s/%s (%s %s; PHP %s)",
+			$name,
+			$version,
+			PHP_OS,
+			$this->getOSVersion(),
+			phpversion()
+		);
+		return $this;
+	}
+
+	/**
+	 * Set the x-elastic-client-meta header
+	 * 
+	 * The header format is specified by the following regex:
+	 * ^[a-z]{1,}=[a-z0-9\.\-]{1,}(?:,[a-z]{1,}=[a-z0-9\.\-]+)*$
+	 */
+	public function setElasticMetaHeader(string $clientName, string $clientVersion, bool $async = false): self
+	{
+		$phpSemVersion = sprintf("%d.%d.%d", PHP_MAJOR_VERSION, PHP_MINOR_VERSION, PHP_RELEASE_VERSION);
+		$meta = sprintf(
+			"%s=%s,php=%s,t=%s,a=%d",
+			$clientName,
+			$this->purgePreReleaseTag($clientVersion),
+			$phpSemVersion,
+			$this->purgePreReleaseTag(self::VERSION),
+			$async ? 1 : 0 // 0=syncronous, 1=asynchronous
+		);
+		$lib = $this->getClientLibraryInfo();
+		if (!empty($lib)) {
+			$meta .= sprintf(",%s=%s", $lib[0], $lib[1]);
+		}
+		$this->headers['x-elastic-client-meta'] = $meta;
+		return $this;
+	}
+
+	/**
+	 * Remove pre-release suffix with a single 'p' letter
+	 */
+	private function purgePreReleaseTag(string $version): string
+	{
+		return str_replace(['alpha', 'beta', 'snapshot', 'rc', 'pre'], 'p', strtolower($version)); 
+	}
+
+	public function getLastRequest(): RequestInterface
+	{
+		return $this->lastRequest;
+	}
+
+	public function getLastResponse(): ResponseInterface
+	{
+		return $this->lastResponse;
+	}
+
+	/**
+	 * Setup the headers, if not already present 
+	 */
+	private function setupHeaders(RequestInterface $request): RequestInterface
+	{
+		foreach ($this->headers as $name => $value) {
+			if (!$request->hasHeader($name)) {
+				$request = $request->withHeader($name, $value);
+			}
+		}
+		return $request;
+	}
+
+	/**
+	 * Setup the user info, if not already present
+	 */
+	private function setupUserInfo(RequestInterface $request): RequestInterface
+	{
+		$uri = $request->getUri();
+		if (empty($uri->getUserInfo())) {
+			if (isset($this->user)) {
+				$request = $request->withUri($uri->withUserInfo($this->user, $this->password));
+			}
+		}
+		return $request;
+	}
+
+	/**
+	 * Setup the connection Uri 
+	 */
+	private function setupConnectionUri(Node $node, RequestInterface $request): RequestInterface
+	{
+		$uri = $node->getUri();
+		$path = $request->getUri()->getPath();
         
-        $nodePath = $uri->getPath();
-        // If the node has a path we need to use it as prefix for the existing path
-        // @see https://github.com/elastic/elastic-transport-php/pull/20
-        if (!empty($nodePath)) {
-            $path = sprintf("%s/%s", rtrim($nodePath, '/'), ltrim($path,'/'));
-        }
-        // If the user information is not in the request, we check if it is present in the node uri
-        // @see https://github.com/elastic/elastic-transport-php/issues/18
-        if (empty($request->getUri()->getUserInfo()) && !empty($uri->getUserInfo())) {
-            $userInfo = explode(':', $uri->getUserInfo());
-            $request = $request->withUri(
-                $request->getUri()
-                    ->withUserInfo($userInfo[0], $userInfo[1] ?? null)
-            );
-        }
-        return $request->withUri(
-            $request->getUri()
-                ->withHost($uri->getHost())
-                ->withPort($uri->getPort())
-                ->withScheme($uri->getScheme())
-                ->withPath($path)
-        );
-    }
-
-    private function decorateRequest(RequestInterface $request): RequestInterface
-    {
-        $request = $this->setupHeaders($request);
-        return $this->setupUserInfo($request);
-    }
-
-    private function logHeaders(MessageInterface $message): void
-    {
-        $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->logHeaders($request);
-    }
-
-    private function logResponse(string $title, ResponseInterface $response, int $retry): void
-    {
-        $this->logger->info(sprintf(
-            "%s (retry %d): %d",
-            $title,
-            $retry, 
-            $response->getStatusCode()
-        ), [
-            'response' => $response,
-            'retry' => $retry
-        ]);
-        $this->logHeaders($response);
-    }
-
-    /**
-     * @throws NoNodeAvailableException
-     * @throws ClientExceptionInterface
-     */
-    public function sendRequest(RequestInterface $request): ResponseInterface
-    {   
-        if (empty($request->getUri()->getHost())) {
-            $node = $this->nodePool->nextNode();
-            $request = $this->setupConnectionUri($node, $request);
-        }
-        $request = $this->decorateRequest($request);
-        $this->lastRequest = $request;
-        $this->logRequest("Request", $request);
+		$nodePath = $uri->getPath();
+		// If the node has a path we need to use it as prefix for the existing path
+		// @see https://github.com/elastic/elastic-transport-php/pull/20
+		if (!empty($nodePath)) {
+			$path = sprintf("%s/%s", rtrim($nodePath, '/'), ltrim($path,'/'));
+		}
+		// If the user information is not in the request, we check if it is present in the node uri
+		// @see https://github.com/elastic/elastic-transport-php/issues/18
+		if (empty($request->getUri()->getUserInfo()) && !empty($uri->getUserInfo())) {
+			$userInfo = explode(':', $uri->getUserInfo());
+			$request = $request->withUri(
+				$request->getUri()
+					->withUserInfo($userInfo[0], $userInfo[1] ?? null)
+			);
+		}
+		return $request->withUri(
+			$request->getUri()
+				->withHost($uri->getHost())
+				->withPort($uri->getPort())
+				->withScheme($uri->getScheme())
+				->withPath($path)
+		);
+	}
+
+	private function decorateRequest(RequestInterface $request): RequestInterface
+	{
+		$request = $this->setupHeaders($request);
+		return $this->setupUserInfo($request);
+	}
+
+	private function logHeaders(MessageInterface $message): void
+	{
+		$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->logHeaders($request);
+	}
+
+	private function logResponse(string $title, ResponseInterface $response, int $retry): void
+	{
+		$this->logger->info(sprintf(
+			"%s (retry %d): %d",
+			$title,
+			$retry, 
+			$response->getStatusCode()
+		), [
+			'response' => $response,
+			'retry' => $retry
+		]);
+		$this->logHeaders($response);
+	}
+
+	/**
+	 * @throws NoNodeAvailableException
+	 * @throws ClientExceptionInterface
+	 */
+	public function sendRequest(RequestInterface $request): ResponseInterface
+	{   
+		if (empty($request->getUri()->getHost())) {
+			$node = $this->nodePool->nextNode();
+			$request = $this->setupConnectionUri($node, $request);
+		}
+		$request = $this->decorateRequest($request);
+		$this->lastRequest = $request;
+		$this->logRequest("Request", $request);
         
-        $count = -1;
-        while ($count < $this->getRetries()) {
-            try {
-                $count++;
-                $response = $this->client->sendRequest($request);
-
-                $this->lastResponse = $response;
-                $this->logResponse("Response", $response, $count);
-
-                return $response;
-            } catch (NetworkExceptionInterface $e) {
-                $this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
-                if (isset($node)) {
-                    $node->markAlive(false);
-                    $node = $this->nodePool->nextNode();
-                    $request = $this->setupConnectionUri($node, $request);
-                }
-            } catch (ClientExceptionInterface $e) {
-                $this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
-                throw $e;
-            }
-        }
-        $exceededMsg = sprintf("Exceeded maximum number of retries (%d)", $this->getRetries());
-        $this->logger->error($exceededMsg);
-        throw new NoNodeAvailableException($exceededMsg);
-    }
-
-    public function setAsyncClient(HttpAsyncClient $asyncClient): self
-    {
-        $this->asyncClient = $asyncClient;
-        return $this;
-    }
-
-    /**
-     * @throws NoAsyncClientException
-     */
-    public function getAsyncClient(): HttpAsyncClient
-    {
-        if (!empty($this->asyncClient)) {
-            return $this->asyncClient;
-        }
-        if ($this->client instanceof HttpAsyncClient) {
-            return $this->client;
-        }
-        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
-            ));
-        }
-        return $this->asyncClient;
-    }
-
-    public function setAsyncOnSuccess(OnSuccessInterface $success): self
-    {
-        $this->onAsyncSuccess = $success;
-        return $this;
-    }
-
-    public function getAsyncOnSuccess(): OnSuccessInterface
-    {
-        if (empty($this->onAsyncSuccess)) {
-            $this->onAsyncSuccess = new OnSuccessDefault();
-        }
-        return $this->onAsyncSuccess;
-    }
-
-    public function setAsyncOnFailure(OnFailureInterface $failure): self
-    {
-        $this->onAsyncFailure = $failure;
-        return $this;
-    }
-
-    public function getAsyncOnFailure(): OnFailureInterface
-    {
-        if (empty($this->onAsyncFailure)) {
-            $this->onAsyncFailure = new OnFailureDefault();
-        }
-        return $this->onAsyncFailure;
-    }
-
-    /**
-     * @throws Exception
-     */
-    public function sendAsyncRequest(RequestInterface $request): Promise
-    {
-        $client = $this->getAsyncClient();
-        $node = null;
-        if (empty($request->getUri()->getHost())) {
-            $node = $this->nodePool->nextNode();
-            $request = $this->setupConnectionUri($node, $request);
-        }
-        $request = $this->decorateRequest($request);
-        $this->lastRequest = $request;
-        $this->logRequest("Async Request", $request);
-
-        $count = 0;
-        $promise = $client->sendAsyncRequest($request);
-
-        // onFulfilled callable
-        $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) {
-            $this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
-            $this->getAsyncOnFailure()->failure($e, $request, $count, $node ?? null);
-            if (isset($node)) {
-                $node->markAlive(false);
-                $node = $this->nodePool->nextNode();
-                $request = $this->setupConnectionUri($node, $request);
-            }
-            $count++;
-            return $client->sendAsyncRequest($request);
-        };
+		$count = -1;
+		while ($count < $this->getRetries()) {
+			try {
+				$count++;
+				$response = $this->client->sendRequest($request);
+
+				$this->lastResponse = $response;
+				$this->logResponse("Response", $response, $count);
+
+				return $response;
+			} catch (NetworkExceptionInterface $e) {
+				$this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
+				if (isset($node)) {
+					$node->markAlive(false);
+					$node = $this->nodePool->nextNode();
+					$request = $this->setupConnectionUri($node, $request);
+				}
+			} catch (ClientExceptionInterface $e) {
+				$this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
+				throw $e;
+			}
+		}
+		$exceededMsg = sprintf("Exceeded maximum number of retries (%d)", $this->getRetries());
+		$this->logger->error($exceededMsg);
+		throw new NoNodeAvailableException($exceededMsg);
+	}
+
+	public function setAsyncClient(HttpAsyncClient $asyncClient): self
+	{
+		$this->asyncClient = $asyncClient;
+		return $this;
+	}
+
+	/**
+	 * @throws NoAsyncClientException
+	 */
+	public function getAsyncClient(): HttpAsyncClient
+	{
+		if (!empty($this->asyncClient)) {
+			return $this->asyncClient;
+		}
+		if ($this->client instanceof HttpAsyncClient) {
+			return $this->client;
+		}
+		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
+			));
+		}
+		return $this->asyncClient;
+	}
+
+	public function setAsyncOnSuccess(OnSuccessInterface $success): self
+	{
+		$this->onAsyncSuccess = $success;
+		return $this;
+	}
+
+	public function getAsyncOnSuccess(): OnSuccessInterface
+	{
+		if (empty($this->onAsyncSuccess)) {
+			$this->onAsyncSuccess = new OnSuccessDefault();
+		}
+		return $this->onAsyncSuccess;
+	}
+
+	public function setAsyncOnFailure(OnFailureInterface $failure): self
+	{
+		$this->onAsyncFailure = $failure;
+		return $this;
+	}
+
+	public function getAsyncOnFailure(): OnFailureInterface
+	{
+		if (empty($this->onAsyncFailure)) {
+			$this->onAsyncFailure = new OnFailureDefault();
+		}
+		return $this->onAsyncFailure;
+	}
+
+	/**
+	 * @throws Exception
+	 */
+	public function sendAsyncRequest(RequestInterface $request): Promise
+	{
+		$client = $this->getAsyncClient();
+		$node = null;
+		if (empty($request->getUri()->getHost())) {
+			$node = $this->nodePool->nextNode();
+			$request = $this->setupConnectionUri($node, $request);
+		}
+		$request = $this->decorateRequest($request);
+		$this->lastRequest = $request;
+		$this->logRequest("Async Request", $request);
+
+		$count = 0;
+		$promise = $client->sendAsyncRequest($request);
+
+		// onFulfilled callable
+		$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) {
+			$this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
+			$this->getAsyncOnFailure()->failure($e, $request, $count, $node ?? null);
+			if (isset($node)) {
+				$node->markAlive(false);
+				$node = $this->nodePool->nextNode();
+				$request = $this->setupConnectionUri($node, $request);
+			}
+			$count++;
+			return $client->sendAsyncRequest($request);
+		};
         
-        // Add getRetries() callables using then()
-        for ($i=0; $i < $this->getRetries(); $i++) {
-            $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) {
-            $exceededMsg = sprintf("Exceeded maximum number of retries (%d)", $this->getRetries());
-            $this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
-            $this->logger->error($exceededMsg);
-            throw new NoNodeAvailableException(sprintf("%s: %s", $exceededMsg, $e->getMessage()));
-        });
-        return $promise;
-    }
-
-    /**
-     * Get the OS version using php_uname if available
-     * otherwise it returns an empty string
-     */
-    private function getOSVersion(): string
-    {
-        if (!isset($this->OSVersion)) {
-            $disable_functions = (string) ini_get('disable_functions');
-            $this->OSVersion = strpos(strtolower($disable_functions), 'php_uname') !== false
-                ? ''
-                : php_uname("r");
-        }
-        return $this->OSVersion;
-    }
-
-    /**
-     * Returns the name and the version of the Client HTTP library used
-     * Here a list of supported libraries:
-     * gu => guzzlehttp/guzzle
-     * sy => symfony/http-client
-     */
-    private function getClientLibraryInfo(): array
-    {
-        $clientClass = get_class($this->client);
-        if (false !== strpos($clientClass, 'GuzzleHttp\Client')) {
-            return ['gu', InstalledVersions::getPrettyVersion('guzzlehttp/guzzle')]; 
-        }
-        if (false !== strpos($clientClass, 'Symfony\Component\HttpClient')) {
-            return ['sy', InstalledVersions::getPrettyVersion('symfony/http-client')];
-        }
-        return [];
-    }
+		// Add getRetries() callables using then()
+		for ($i=0; $i < $this->getRetries(); $i++) {
+			$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) {
+			$exceededMsg = sprintf("Exceeded maximum number of retries (%d)", $this->getRetries());
+			$this->logger->error(sprintf("Retry %d: %s", $count, $e->getMessage()));
+			$this->logger->error($exceededMsg);
+			throw new NoNodeAvailableException(sprintf("%s: %s", $exceededMsg, $e->getMessage()));
+		});
+		return $promise;
+	}
+
+	/**
+	 * Get the OS version using php_uname if available
+	 * otherwise it returns an empty string
+	 */
+	private function getOSVersion(): string
+	{
+		if (!isset($this->OSVersion)) {
+			$disable_functions = (string) ini_get('disable_functions');
+			$this->OSVersion = strpos(strtolower($disable_functions), 'php_uname') !== false
+				? ''
+				: php_uname("r");
+		}
+		return $this->OSVersion;
+	}
+
+	/**
+	 * Returns the name and the version of the Client HTTP library used
+	 * Here a list of supported libraries:
+	 * gu => guzzlehttp/guzzle
+	 * sy => symfony/http-client
+	 */
+	private function getClientLibraryInfo(): array
+	{
+		$clientClass = get_class($this->client);
+		if (false !== strpos($clientClass, 'GuzzleHttp\Client')) {
+			return ['gu', InstalledVersions::getPrettyVersion('guzzlehttp/guzzle')]; 
+		}
+		if (false !== strpos($clientClass, 'Symfony\Component\HttpClient')) {
+			return ['sy', InstalledVersions::getPrettyVersion('symfony/http-client')];
+		}
+		return [];
+	}
 }

Spacing +9 added lines, -9 removed lines

@@ -219,7 +219,7 @@ 
         // If the node has a path we need to use it as prefix for the existing path
         // @see https://github.com/elastic/elastic-transport-php/pull/20
         if (!empty($nodePath)) {
-            $path = sprintf("%s/%s", rtrim($nodePath, '/'), ltrim($path,'/'));
+            $path = sprintf("%s/%s", rtrim($nodePath, '/'), ltrim($path, '/'));
         }
         // If the user information is not in the request, we check if it is present in the node uri
         // @see https://github.com/elastic/elastic-transport-php/issues/18
@@ -250,7 +250,7 @@ 
         $this->logger->debug(sprintf(
             "Headers: %s\nBody: %s",
             json_encode($message->getHeaders()),
-            (string) $message->getBody()
+            (string)$message->getBody()
         ));
     }
 
@@ -260,7 +260,7 @@ 
             "%s: %s %s", 
             $title,
             $request->getMethod(),
-            (string) $request->getUri()
+            (string)$request->getUri()
         ), [
             'request' => $request
         ]);
@@ -343,8 +343,8 @@ 
             $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\". " .
+                "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
             ));
@@ -399,14 +399,14 @@ 
         $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)) {
@@ -419,7 +419,7 @@ 
         };
         
         // Add getRetries() callables using then()
-        for ($i=0; $i < $this->getRetries(); $i++) {
+        for ($i = 0; $i < $this->getRetries(); $i++) {
             $promise = $promise->then($onFulfilled, $onRejected);
         }
         // Add the last getRetries()+1 callable for managing the exceeded error
@@ -439,7 +439,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");

lib/Vendor/Elastic/Transport/TransportBuilder.php

Indentation +102 added lines, -102 removed lines

@@ -27,106 +27,106 @@
 
 class TransportBuilder
 {
-    protected ClientInterface $client;
-    protected NodePoolInterface $nodePool;
-    protected LoggerInterface $logger;
-    protected array $hosts = [];
-
-    final public function __construct()
-    {
-    }
-
-    public static function create(): TransportBuilder
-    {
-        return new static();
-    }
-
-    public function setClient(ClientInterface $client): self
-    {
-        $this->client = $client;
-        return $this;
-    }
-
-    public function getClient(): ClientInterface
-    {
-        if (empty($this->client)) {
-            $this->client = Psr18ClientDiscovery::find();
-        }
-        return $this->client;
-    }
-
-    public function setNodePool(NodePoolInterface $nodePool): self
-    {
-        $this->nodePool = $nodePool;
-        return $this;
-    }
-
-    public function getNodePool(): NodePoolInterface
-    {
-        if (empty($this->nodePool)) {
-            $this->nodePool = new SimpleNodePool(
-                new RoundRobin(),
-                new NoResurrect()
-            );
-        }
-        return $this->nodePool;
-    }
-
-    public function setLogger(LoggerInterface $logger): self
-    {
-        $this->logger = $logger;
-        return $this;
-    }
-
-    public function getLogger(): LoggerInterface
-    {
-        if (empty($this->logger)) {
-            $this->logger = new NullLogger();
-        }
-        return $this->logger;
-    }
-
-    public function setHosts(array $hosts): self
-    {
-        $this->hosts = $hosts;
-        return $this;
-    }
-
-    public function getHosts(): array
-    {
-        return $this->hosts;
-    }
-
-    public function setCloudId(string $cloudId): self
-    {
-        $this->hosts = [$this->parseElasticCloudId($cloudId)];
-        return $this;
-    }
-
-    public function build(): Transport
-    {
-        return new Transport(
-            $this->getClient(),
-            $this->getNodePool()->setHosts($this->hosts),
-            $this->getLogger()
-        );
-    }
-
-    /**
-     * Return the URL of Elastic Cloud from the Cloud ID
-     */
-    private function parseElasticCloudId(string $cloudId): string
-    {
-        try {
-            list($name, $encoded) = explode(':', $cloudId);
-            list($uri, $uuids)    = explode('$', base64_decode($encoded));
-            list($es,)            = explode(':', $uuids);
-
-            return sprintf("https://%s.%s", $es, $uri);
-        } catch (Throwable $t) {
-            throw new Exception\CloudIdParseException(
-                'Cloud ID not valid'
-            );
-        }
-    }
+	protected ClientInterface $client;
+	protected NodePoolInterface $nodePool;
+	protected LoggerInterface $logger;
+	protected array $hosts = [];
+
+	final public function __construct()
+	{
+	}
+
+	public static function create(): TransportBuilder
+	{
+		return new static();
+	}
+
+	public function setClient(ClientInterface $client): self
+	{
+		$this->client = $client;
+		return $this;
+	}
+
+	public function getClient(): ClientInterface
+	{
+		if (empty($this->client)) {
+			$this->client = Psr18ClientDiscovery::find();
+		}
+		return $this->client;
+	}
+
+	public function setNodePool(NodePoolInterface $nodePool): self
+	{
+		$this->nodePool = $nodePool;
+		return $this;
+	}
+
+	public function getNodePool(): NodePoolInterface
+	{
+		if (empty($this->nodePool)) {
+			$this->nodePool = new SimpleNodePool(
+				new RoundRobin(),
+				new NoResurrect()
+			);
+		}
+		return $this->nodePool;
+	}
+
+	public function setLogger(LoggerInterface $logger): self
+	{
+		$this->logger = $logger;
+		return $this;
+	}
+
+	public function getLogger(): LoggerInterface
+	{
+		if (empty($this->logger)) {
+			$this->logger = new NullLogger();
+		}
+		return $this->logger;
+	}
+
+	public function setHosts(array $hosts): self
+	{
+		$this->hosts = $hosts;
+		return $this;
+	}
+
+	public function getHosts(): array
+	{
+		return $this->hosts;
+	}
+
+	public function setCloudId(string $cloudId): self
+	{
+		$this->hosts = [$this->parseElasticCloudId($cloudId)];
+		return $this;
+	}
+
+	public function build(): Transport
+	{
+		return new Transport(
+			$this->getClient(),
+			$this->getNodePool()->setHosts($this->hosts),
+			$this->getLogger()
+		);
+	}
+
+	/**
+	 * Return the URL of Elastic Cloud from the Cloud ID
+	 */
+	private function parseElasticCloudId(string $cloudId): string
+	{
+		try {
+			list($name, $encoded) = explode(':', $cloudId);
+			list($uri, $uuids)    = explode('$', base64_decode($encoded));
+			list($es,)            = explode(':', $uuids);
+
+			return sprintf("https://%s.%s", $es, $uri);
+		} catch (Throwable $t) {
+			throw new Exception\CloudIdParseException(
+				'Cloud ID not valid'
+			);
+		}
+	}
 }
\ No newline at end of file

Braces +1 added lines, -2 removed lines

@@ -25,8 +25,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Log\NullLogger;
 use Throwable;
 
-class TransportBuilder
-{
+class TransportBuilder {
     protected ClientInterface $client;
     protected NodePoolInterface $nodePool;
     protected LoggerInterface $logger;

lib/Vendor/Elastic/Transport/Serializer/XmlSerializer.php

Indentation +27 added lines, -27 removed lines

@@ -25,32 +25,32 @@
 
 class XmlSerializer implements SerializerInterface
 {
-    public static function serialize($data, array $options = []): string
-    {
-        if ($data instanceof SimpleXMLElement) {
-            $xml = $data->asXML();
-            return false === $xml ? '' : $xml;
-        }
-        throw new InvalidXmlException(sprintf(
-            "Not a valid SimpleXMLElement: %s", 
-            serialize($data)
-        ));
-    }
+	public static function serialize($data, array $options = []): string
+	{
+		if ($data instanceof SimpleXMLElement) {
+			$xml = $data->asXML();
+			return false === $xml ? '' : $xml;
+		}
+		throw new InvalidXmlException(sprintf(
+			"Not a valid SimpleXMLElement: %s", 
+			serialize($data)
+		));
+	}
 
-    /**
-     * @return SimpleXMLElement
-     */
-    public static function unserialize(string $data, array $options = []): SimpleXMLElement
-    {
-        $result = simplexml_load_string($data);
-        if (false === $result) {
-            $errors = libxml_get_errors();
-            libxml_clear_errors();
-            throw new InvalidXmlException(sprintf(
-                "Not a valid XML: %s", 
-                serialize($errors)
-            ));
-        }
-        return $result;
-    }
+	/**
+	 * @return SimpleXMLElement
+	 */
+	public static function unserialize(string $data, array $options = []): SimpleXMLElement
+	{
+		$result = simplexml_load_string($data);
+		if (false === $result) {
+			$errors = libxml_get_errors();
+			libxml_clear_errors();
+			throw new InvalidXmlException(sprintf(
+				"Not a valid XML: %s", 
+				serialize($errors)
+			));
+		}
+		return $result;
+	}
 }
\ No newline at end of file

Braces +1 added lines, -2 removed lines

@@ -23,8 +23,7 @@
 use function simplexml_load_string;
 use function sprintf;
 
-class XmlSerializer implements SerializerInterface
-{
+class XmlSerializer implements SerializerInterface {
     public static function serialize($data, array $options = []): string
     {
         if ($data instanceof SimpleXMLElement) {

lib/Vendor/Elastic/Transport/Serializer/JsonSerializer.php

Indentation +49 added lines, -49 removed lines

@@ -26,54 +26,54 @@
 class JsonSerializer implements SerializerInterface
 {
    /**
-     * The available $options are: 
-     * 'remove_null'  => (bool) enable/disable the removing of
-     *                   null values (default is true)
-     * 
-     * @param mixed $data
-     */
-    public static function serialize($data, array $options = []): string
-    {
-        if (empty($data)) {
-            return '{}';
-        }
-        if (is_string($data)) {
-            return $data;
-        }
-        try {
-            $removeNull = $options['remove_null'] ?? true;
-            if ($removeNull) {
-                Utility::removeNullValue($data);
-            }
-            return json_encode($data, JSON_PRESERVE_ZERO_FRACTION + JSON_INVALID_UTF8_SUBSTITUTE + JSON_THROW_ON_ERROR);
-        } catch (JsonException $e) {
-            throw new InvalidJsonException(sprintf(
-                "I cannot serialize to Json: %s", 
-                $e->getMessage()
-            ));
-        }
-    }
+    * The available $options are: 
+    * 'remove_null'  => (bool) enable/disable the removing of
+    *                   null values (default is true)
+    * 
+    * @param mixed $data
+    */
+	public static function serialize($data, array $options = []): string
+	{
+		if (empty($data)) {
+			return '{}';
+		}
+		if (is_string($data)) {
+			return $data;
+		}
+		try {
+			$removeNull = $options['remove_null'] ?? true;
+			if ($removeNull) {
+				Utility::removeNullValue($data);
+			}
+			return json_encode($data, JSON_PRESERVE_ZERO_FRACTION + JSON_INVALID_UTF8_SUBSTITUTE + JSON_THROW_ON_ERROR);
+		} catch (JsonException $e) {
+			throw new InvalidJsonException(sprintf(
+				"I cannot serialize to Json: %s", 
+				$e->getMessage()
+			));
+		}
+	}
 
-    /**
-     * The available options are:
-     * 'type' => (string) specify if the output should be an array
-     *           or an object (default is array)
-     * 
-     * @inheritdoc
-     */
-    public static function unserialize(string $data, array $options = [])
-    {
-        try {
-            $type = $options['type'] ?? 'array';
-            if (!in_array($type, ['object', 'array'])) {
-                throw new UndefinedPropertyException("The unserialize 'type' option must be object or array");
-            }
-            return json_decode($data, $type === 'array', 512, JSON_THROW_ON_ERROR);
-        } catch (JsonException $e) {
-            throw new InvalidJsonException(sprintf(
-                "Not a valid Json: %s", 
-                $e->getMessage()
-            ));
-        }
-    }
+	/**
+	 * The available options are:
+	 * 'type' => (string) specify if the output should be an array
+	 *           or an object (default is array)
+	 * 
+	 * @inheritdoc
+	 */
+	public static function unserialize(string $data, array $options = [])
+	{
+		try {
+			$type = $options['type'] ?? 'array';
+			if (!in_array($type, ['object', 'array'])) {
+				throw new UndefinedPropertyException("The unserialize 'type' option must be object or array");
+			}
+			return json_decode($data, $type === 'array', 512, JSON_THROW_ON_ERROR);
+		} catch (JsonException $e) {
+			throw new InvalidJsonException(sprintf(
+				"Not a valid Json: %s", 
+				$e->getMessage()
+			));
+		}
+	}
 }
\ No newline at end of file

Braces +1 added lines, -2 removed lines

@@ -23,8 +23,7 @@
 use function json_encode;
 use function sprintf;
 
-class JsonSerializer implements SerializerInterface
-{
+class JsonSerializer implements SerializerInterface {
    /**
      * The available $options are: 
      * 'remove_null'  => (bool) enable/disable the removing of

lib/Vendor/Elastic/Transport/Serializer/TextSerializer.php

Indentation +19 added lines, -19 removed lines

@@ -20,24 +20,24 @@
 
 class TextSerializer implements SerializerInterface
 {
-    /**
-     * @throws SerializeException
-     */
-    public static function serialize($data, array $options = []): string
-    {
-        if (is_string($data) || is_numeric($data) || (is_object($data) && method_exists($data, '__toString'))) {
-            return (string) $data;
-        }
-        throw new SerializeException(
-            sprintf("I cannot serialize %s in a text", serialize($data))
-        );
-    }
+	/**
+	 * @throws SerializeException
+	 */
+	public static function serialize($data, array $options = []): string
+	{
+		if (is_string($data) || is_numeric($data) || (is_object($data) && method_exists($data, '__toString'))) {
+			return (string) $data;
+		}
+		throw new SerializeException(
+			sprintf("I cannot serialize %s in a text", serialize($data))
+		);
+	}
 
-    /**
-     * @return string
-     */
-    public static function unserialize(string $data, array $options = []): string
-    {
-        return $data;
-    }
+	/**
+	 * @return string
+	 */
+	public static function unserialize(string $data, array $options = []): string
+	{
+		return $data;
+	}
 }
\ No newline at end of file

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
     public static function serialize($data, array $options = []): string
     {
         if (is_string($data) || is_numeric($data) || (is_object($data) && method_exists($data, '__toString'))) {
-            return (string) $data;
+            return (string)$data;
         }
         throw new SerializeException(
             sprintf("I cannot serialize %s in a text", serialize($data))

Braces +1 added lines, -2 removed lines

@@ -18,8 +18,7 @@
 
 use function serialize;
 
-class TextSerializer implements SerializerInterface
-{
+class TextSerializer implements SerializerInterface {
     /**
      * @throws SerializeException
      */