Merge pull request #854 from lonvia/fix-synonym-setup

Make sure to reopen the index when installation of synonym fails

Author: lonvia

app/opensearch/src/main/java/de/komoot/photon/Server.java

@@ -11,6 +11,7 @@
 import org.opensearch.client.json.jackson.JacksonJsonpMapper;
 import org.opensearch.client.opensearch.OpenSearchClient;
 import org.opensearch.client.opensearch._types.HealthStatus;
+import org.opensearch.client.opensearch._types.OpenSearchException;
 import org.opensearch.client.transport.httpclient5.ApacheHttpClient5TransportBuilder;
 import org.slf4j.Logger;
 
@@ -126,9 +127,16 @@ public DatabaseProperties recreateIndex(String[] languages, Date importDate, boo
     }
 
     public void updateIndexSettings(String synonymFile) throws IOException {
+        // This ensures we are on the right version. Do not mess with the
+        // database if the version does not fit.
         var dbProperties = loadFromDatabase();
 
-        (new IndexSettingBuilder()).setSynonymFile(synonymFile).updateIndex(client, PhotonIndex.NAME);
+        try {
+            (new IndexSettingBuilder()).setSynonymFile(synonymFile).updateIndex(client, PhotonIndex.NAME);
+        } catch (OpenSearchException ex) {
+            client.shutdown();
+            throw new UsageException("Could not install synonyms: " + ex.getMessage());
+        }
 
         if (dbProperties.getLanguages() != null) {
             (new IndexMapping(dbProperties.getSupportStructuredQueries()))

app/opensearch/src/main/java/de/komoot/photon/opensearch/IndexSettingBuilder.java

@@ -40,10 +40,13 @@ public void updateIndex(OpenSearchClient client, String indexName) throws IOExce
         addDefaultSettings();
 
         client.indices().close(req -> req.index(indexName));
-        client.indices().putSettings(req -> req
-                .index(indexName)
-                .settings(s -> s.analysis(settings.build())));
-        client.indices().open(req -> req.index(indexName));
+        try {
+            client.indices().putSettings(req -> req
+                    .index(indexName)
+                    .settings(s -> s.analysis(settings.build())));
+        } finally {
+            client.indices().open(req -> req.index(indexName));
+        }
     }
 
     public IndexSettingBuilder setSynonymFile(String synonymFile) throws IOException {