4268: Updated fixture loader to delete index before creating it

Author: rimi-itk

README.md

@@ -54,6 +54,9 @@ above command downloads the fixtures from
 [GitHub](https://github.com/itk-dev/event-database-imports/tree/develop/src/DataFixtures/indexes) and loads them into
 ElasticSearch.
 
+> [!TIP]
+> Use `task fixtures:load` to load all fixtures into Elasticsearch.
+
 ## Accessing the API
 
 To access the API, a valid API key must be presented in the `X-Api-Key` header, e.g.

src/Fixtures/FixtureLoader.php

@@ -39,6 +39,7 @@ public function process(string $indexName, string $url): void
     {
         $items = $this->download($url);
 
+        $this->deleteIndex($indexName);
         $this->createIndex($indexName);
         $this->indexItems($indexName, $items);
     }
@@ -131,4 +132,28 @@ private function createIndex(string $indexName): void
             ]);
         }
     }
+
+    /**
+     * Deletes an index with the given name if it exists.
+     *
+     * @param string $indexName
+     *   The name of the index
+     *
+     * @throws ClientResponseException
+     *   If an error occurs during the Elasticsearch client request
+     * @throws MissingParameterException
+     *   If the required parameter is missing
+     * @throws ServerResponseException
+     *   If the server returns an error during the Elasticsearch request
+     */
+    private function deleteIndex(string $indexName): void
+    {
+        if ($this->index->indexExists($indexName)) {
+            // This creation of the index is not in den index service as this is the only place it should be used. In
+            // production and in many cases, you should connect to the index managed by the backend (imports).
+            $this->client->indices()->delete([
+                'index' => $indexName,
+            ]);
+        }
+    }
 }

src/Service/ElasticSearch/ElasticSearchIndex.php

@@ -25,7 +25,7 @@ public function indexExists($indexName): bool
     {
         try {
             /** @var Elasticsearch $response */
-            $response = $this->client->indices()->getAlias(['name' => $indexName]);
+            $response = $this->client->indices()->get(['index' => $indexName]);
 
             return Response::HTTP_OK === $response->getStatusCode();
         } catch (ClientResponseException|ServerResponseException $e) {