nextcloud / fulltextsearch_elasticsearch

lib/Vendor/Elastic/Transport/Exception/NoNodeAvailableException.php

Braces +1 added lines, -2 removed lines

@@ -15,6 +15,5 @@
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Exception;
 
 use RuntimeException;
-class NoNodeAvailableException extends RuntimeException implements TransportException
-{
+class NoNodeAvailableException extends RuntimeException implements TransportException {
 }

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\Transport\Exception;
 
 use RuntimeException;

lib/Vendor/Elastic/Transport/Exception/TransportException.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\Transport\Exception;
 
 use Throwable;

Braces +1 added lines, -2 removed lines

@@ -15,6 +15,5 @@
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Exception;
 
 use Throwable;
-interface TransportException extends Throwable
-{
+interface TransportException extends Throwable {
 }

lib/Vendor/Elastic/Transport/TransportBuilder.php

Spacing +2 added lines, -2 removed lines

@@ -11,7 +11,7 @@ 
  * Elasticsearch B.V licenses this file to you under the MIT License.
  * See the LICENSE file in the project root for more information.
  */
-declare (strict_types=1);
+declare(strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\NodePoolInterface;
@@ -99,7 +99,7 @@ 
         try {
             list($name, $encoded) = \explode(':', $cloudId);
             list($uri, $uuids) = \explode('$', \base64_decode($encoded));
-            list($es, ) = \explode(':', $uuids);
+            list($es,) = \explode(':', $uuids);
             return \sprintf("https://%s.%s", $es, $uri);
         } catch (Throwable $t) {
             throw new Exception\CloudIdParseException('Cloud ID not valid');

Braces +1 added lines, -2 removed lines

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

Indentation +80 added lines, -80 removed lines

@@ -27,84 +27,84 @@
 use Throwable;
 class TransportBuilder
 {
-    protected ClientInterface $client;
-    protected NodePoolInterface $nodePool;
-    protected LoggerInterface $logger;
-    protected array $hosts = [];
-    protected TracerInterface $OTelTracer;
-    public final 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 = [];
+	protected TracerInterface $OTelTracer;
+	public final 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');
+		}
+	}
 }

lib/Vendor/Elastic/Transport/NodePool/Node.php

Indentation +21 added lines, -21 removed lines

@@ -20,25 +20,25 @@
 use function substr;
 class Node
 {
-    protected UriInterface $uri;
-    protected bool $alive = \true;
-    public function __construct(string $host)
-    {
-        if (substr($host, 0, 5) !== 'http:' && substr($host, 0, 6) !== 'https:') {
-            $host = sprintf("http://%s", $host);
-        }
-        $this->uri = Psr17FactoryDiscovery::findUriFactory()->createUri($host);
-    }
-    public function markAlive(bool $alive) : void
-    {
-        $this->alive = $alive;
-    }
-    public function isAlive() : bool
-    {
-        return $this->alive;
-    }
-    public function getUri() : UriInterface
-    {
-        return $this->uri;
-    }
+	protected UriInterface $uri;
+	protected bool $alive = \true;
+	public function __construct(string $host)
+	{
+		if (substr($host, 0, 5) !== 'http:' && substr($host, 0, 6) !== 'https:') {
+			$host = sprintf("http://%s", $host);
+		}
+		$this->uri = Psr17FactoryDiscovery::findUriFactory()->createUri($host);
+	}
+	public function markAlive(bool $alive) : void
+	{
+		$this->alive = $alive;
+	}
+	public function isAlive() : bool
+	{
+		return $this->alive;
+	}
+	public function getUri() : UriInterface
+	{
+		return $this->uri;
+	}
 }

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\Transport\NodePool;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Http\Discovery\Psr17FactoryDiscovery;

Braces +1 added lines, -2 removed lines

@@ -18,8 +18,7 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\UriInterface;
 use function sprintf;
 use function substr;
-class Node
-{
+class Node {
     protected UriInterface $uri;
     protected bool $alive = \true;
     public function __construct(string $host)

lib/Vendor/Elastic/Transport/NodePool/NodePoolInterface.php

Indentation +5 added lines, -5 removed lines

@@ -16,9 +16,9 @@
 
 interface NodePoolInterface
 {
-    public function nextNode() : Node;
-    /**
-     * @param string[] $hosts
-     */
-    public function setHosts(array $hosts) : self;
+	public function nextNode() : Node;
+	/**
+	 * @param string[] $hosts
+	 */
+	public function setHosts(array $hosts) : self;
 }

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\Transport\NodePool;
 
 interface NodePoolInterface

Braces +1 added lines, -2 removed lines

@@ -14,8 +14,7 @@
 declare (strict_types=1);
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool;
 
-interface NodePoolInterface
-{
+interface NodePoolInterface {
     public function nextNode() : Node;
     /**
      * @param string[] $hosts

lib/Vendor/Elastic/Transport/NodePool/Selector/SelectorInterface.php

Indentation +9 added lines, -9 removed lines

@@ -17,13 +17,13 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Node;
 interface SelectorInterface
 {
-    public function nextNode() : Node;
-    /**
-     * @param Node[] $nodes
-     */
-    public function setNodes(array $nodes) : void;
-    /**
-     * @return Node[]
-     */
-    public function getNodes() : array;
+	public function nextNode() : Node;
+	/**
+	 * @param Node[] $nodes
+	 */
+	public function setNodes(array $nodes) : void;
+	/**
+	 * @return Node[]
+	 */
+	public function getNodes() : array;
 }

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\Transport\NodePool\Selector;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Node;

Braces +1 added lines, -2 removed lines

@@ -15,8 +15,7 @@
 namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Selector;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Node;
-interface SelectorInterface
-{
+interface SelectorInterface {
     public function nextNode() : Node;
     /**
      * @param Node[] $nodes

lib/Vendor/Elastic/Transport/NodePool/Selector/RoundRobin.php

Indentation +13 added lines, -13 removed lines

@@ -18,17 +18,17 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Exception\NoNodeAvailableException;
 class RoundRobin implements SelectorInterface
 {
-    use SelectorTrait;
-    public function nextNode() : Node
-    {
-        if (empty($this->getNodes())) {
-            $className = \substr(__CLASS__, \strrpos(__CLASS__, '\\') + 1);
-            throw new NoNodeAvailableException(\sprintf("No node available. Please use %s::setNodes() before calling %s::nextNode().", $className, $className));
-        }
-        $node = \current($this->nodes);
-        if (\false === \next($this->nodes)) {
-            \reset($this->nodes);
-        }
-        return $node;
-    }
+	use SelectorTrait;
+	public function nextNode() : Node
+	{
+		if (empty($this->getNodes())) {
+			$className = \substr(__CLASS__, \strrpos(__CLASS__, '\\') + 1);
+			throw new NoNodeAvailableException(\sprintf("No node available. Please use %s::setNodes() before calling %s::nextNode().", $className, $className));
+		}
+		$node = \current($this->nodes);
+		if (\false === \next($this->nodes)) {
+			\reset($this->nodes);
+		}
+		return $node;
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -16,8 +16,7 @@
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Node;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Exception\NoNodeAvailableException;
-class RoundRobin implements SelectorInterface
-{
+class RoundRobin implements SelectorInterface {
     use SelectorTrait;
     public function nextNode() : Node
     {

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\Transport\NodePool\Selector;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Node;

lib/Vendor/Elastic/Transport/NodePool/Selector/SelectorTrait.php

Indentation +14 added lines, -14 removed lines

@@ -18,18 +18,18 @@
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Exception\InvalidArrayException;
 trait SelectorTrait
 {
-    protected array $nodes = [];
-    public function setNodes(array $nodes) : void
-    {
-        foreach ($nodes as $node) {
-            if (!$node instanceof Node) {
-                throw new InvalidArrayException(\sprintf("The nodes array must contain only %s objects", Node::class));
-            }
-        }
-        $this->nodes = $nodes;
-    }
-    public function getNodes() : array
-    {
-        return $this->nodes;
-    }
+	protected array $nodes = [];
+	public function setNodes(array $nodes) : void
+	{
+		foreach ($nodes as $node) {
+			if (!$node instanceof Node) {
+				throw new InvalidArrayException(\sprintf("The nodes array must contain only %s objects", Node::class));
+			}
+		}
+		$this->nodes = $nodes;
+	}
+	public function getNodes() : array
+	{
+		return $this->nodes;
+	}
 }

Braces +1 added lines, -2 removed lines

@@ -16,8 +16,7 @@
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Node;
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Exception\InvalidArrayException;
-trait SelectorTrait
-{
+trait SelectorTrait {
     protected array $nodes = [];
     public function setNodes(array $nodes) : 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\Transport\NodePool\Selector;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Node;

lib/Vendor/Elastic/Transport/NodePool/SimpleNodePool.php

Indentation +45 added lines, -45 removed lines

@@ -22,49 +22,49 @@
 use function sprintf;
 class SimpleNodePool implements NodePoolInterface
 {
-    /**
-     * @var array
-     */
-    protected $nodes = [];
-    /**
-     * @var SelectorInterface
-     */
-    protected $selector;
-    /**
-     * @var ResurrectInterface
-     */
-    protected $resurrect;
-    public function __construct(SelectorInterface $selector, ResurrectInterface $resurrect)
-    {
-        $this->selector = $selector;
-        $this->resurrect = $resurrect;
-    }
-    public function setHosts(array $hosts) : self
-    {
-        $this->nodes = [];
-        foreach ($hosts as $host) {
-            $this->nodes[] = new Node($host);
-        }
-        shuffle($this->nodes);
-        // randomize for use different hosts on each execution
-        $this->selector->setNodes($this->nodes);
-        return $this;
-    }
-    public function nextNode() : Node
-    {
-        $totNodes = count($this->nodes);
-        $dead = 0;
-        while ($dead < $totNodes) {
-            $next = $this->selector->nextNode();
-            if ($next->isAlive()) {
-                return $next;
-            }
-            if ($this->resurrect->ping($next)) {
-                $next->markAlive(\true);
-                return $next;
-            }
-            $dead++;
-        }
-        throw new NoNodeAvailableException(sprintf('No alive nodes. All the %d nodes seem to be down.', $totNodes));
-    }
+	/**
+	 * @var array
+	 */
+	protected $nodes = [];
+	/**
+	 * @var SelectorInterface
+	 */
+	protected $selector;
+	/**
+	 * @var ResurrectInterface
+	 */
+	protected $resurrect;
+	public function __construct(SelectorInterface $selector, ResurrectInterface $resurrect)
+	{
+		$this->selector = $selector;
+		$this->resurrect = $resurrect;
+	}
+	public function setHosts(array $hosts) : self
+	{
+		$this->nodes = [];
+		foreach ($hosts as $host) {
+			$this->nodes[] = new Node($host);
+		}
+		shuffle($this->nodes);
+		// randomize for use different hosts on each execution
+		$this->selector->setNodes($this->nodes);
+		return $this;
+	}
+	public function nextNode() : Node
+	{
+		$totNodes = count($this->nodes);
+		$dead = 0;
+		while ($dead < $totNodes) {
+			$next = $this->selector->nextNode();
+			if ($next->isAlive()) {
+				return $next;
+			}
+			if ($this->resurrect->ping($next)) {
+				$next->markAlive(\true);
+				return $next;
+			}
+			$dead++;
+		}
+		throw new NoNodeAvailableException(sprintf('No alive nodes. All the %d nodes seem to be down.', $totNodes));
+	}
 }

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\Transport\NodePool;
 
 use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\NodePool\Resurrect\ResurrectInterface;

Braces +1 added lines, -2 removed lines

@@ -20,8 +20,7 @@
 use function count;
 use function shuffle;
 use function sprintf;
-class SimpleNodePool implements NodePoolInterface
-{
+class SimpleNodePool implements NodePoolInterface {
     /**
      * @var array
      */