BUGFIX: Set up missing alias during nodeindex:build

The command `nodeindex:build` does not set up aliases after creating
fresh indexes until it considers the indexing complete. This is good,
usually, since it allows for indexing "in the background". But if no
aliases exist at all, this is going to break.

This change fixes that by setting up aliases after creating (fresh)
indexes, if no aliases exist.

Fixes #370

Author: kdambekalns

Classes/Command/NodeIndexCommandController.php

@@ -14,7 +14,9 @@
  */
 
 use Doctrine\Common\Collections\ArrayCollection;
+use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Driver\IndexDriverInterface;
 use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Driver\NodeTypeMappingBuilderInterface;
+use Flowpack\ElasticSearch\ContentRepositoryAdaptor\ElasticSearchClient;
 use Flowpack\ElasticSearch\ContentRepositoryAdaptor\ErrorHandling\ErrorHandlingService;
 use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Exception;
 use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Exception\ConfigurationException;
@@ -131,6 +133,18 @@ class NodeIndexCommandController extends CommandController
      */
     protected $workspaceIndexer;
 
+    /**
+     * @Flow\Inject
+     * @var ElasticSearchClient
+     */
+    protected $searchClient;
+
+    /**
+     * @var IndexDriverInterface
+     * @Flow\Inject
+     */
+    protected $indexDriver;
+
     /**
      * Index a single node by the given identifier and workspace name
      *
@@ -213,6 +227,7 @@ public function indexNodeCommand(string $identifier, string $workspace = null, s
      * @throws StopCommandException
      * @throws Exception
      * @throws ConfigurationException
+     * @throws ApiException
      */
     public function buildCommand(int $limit = null, bool $update = false, string $workspace = null, string $postfix = null): void
     {
@@ -264,6 +279,10 @@ public function buildCommand(int $limit = null, bool $update = false, string $wo
 
         $runAndLog($createIndicesAndApplyMapping, 'Creating indices and apply mapping');
 
+        if ($this->aliasesExist() === false) {
+            $runAndLog($updateAliases, 'Set up aliases');
+        }
+
         $runAndLog($buildIndex, 'Indexing nodes');
 
         $runAndLog($refresh, 'Refresh indicies');
@@ -276,6 +295,28 @@ public function buildCommand(int $limit = null, bool $update = false, string $wo
         $this->outputMemoryUsage();
     }
 
+    /**
+     * @return bool
+     * @throws ApiException
+     * @throws ConfigurationException
+     * @throws Exception
+     */
+    private function aliasesExist(): bool
+    {
+        $aliasName = $this->searchClient->getIndexName();
+        $aliasesExist = false;
+        try {
+            $aliasesExist = $this->indexDriver->getIndexNamesByAlias($aliasName) !== [];
+        } catch (ApiException $exception) {
+            // in case of 404, do not throw an error...
+            if ($exception->getResponse()->getStatusCode() !== 404) {
+                throw $exception;
+            }
+        }
+
+        return $aliasesExist;
+    }
+
     /**
      * Build up the node index
      *