Add endpoint to recreate the index

Now free from manual `curl` commands!

Author: Tristan-WorkGH

src/main/java/org/gridsuite/directory/server/SupervisionController.java

@@ -12,17 +12,19 @@
 import io.swagger.v3.oas.annotations.tags.Tag;
 import org.gridsuite.directory.server.dto.ElementAttributes;
 import org.gridsuite.directory.server.services.SupervisionService;
+import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
+import java.util.Optional;
 import java.util.UUID;
 
 /**
  * @author Kevin Le Saulnier <kevin.lesaulnier at rte-france.com>
  */
 @RestController
-@RequestMapping(value = "/" + DirectoryApi.API_VERSION + "/supervision")
+@RequestMapping(value = "/" + DirectoryApi.API_VERSION + "/supervision", consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
 @Tag(name = "directory-server - Supervision")
 public class SupervisionController {
     private final SupervisionService service;
@@ -47,4 +49,17 @@ public ResponseEntity<Void> deleteElements(@RequestParam("ids") List<UUID> eleme
         service.deleteElementsByIds(elementsUuid);
         return ResponseEntity.ok().build();
     }
+
+    @PostMapping(value = "/elements/recreate-index", produces = MediaType.TEXT_PLAIN_VALUE)
+    @Operation(summary = "Recreate the index then reindex data")
+    @ApiResponse(responseCode = "200", description = "Success of the index recreation & reindexing of elements")
+    @ApiResponse(responseCode = "500", description = "An error happen while recreating the index.\nAn manual intervention is needing as no details of the error is available.")
+    public ResponseEntity<Optional<String>> deleteElements() {
+        if (service.recreateIndexDirectoryElementInfos()) {
+            return ResponseEntity.ok().build();
+        } else {
+            return ResponseEntity.internalServerError().contentType(MediaType.TEXT_PLAIN)
+                    .body(Optional.of("An error happen while re-creating the index. As no details is available an manual intervention is required."));
+        }
+    }
 }

src/main/java/org/gridsuite/directory/server/services/SupervisionService.java

@@ -1,8 +1,12 @@
 package org.gridsuite.directory.server.services;
 
+import lombok.extern.slf4j.Slf4j;
 import org.gridsuite.directory.server.dto.ElementAttributes;
+import org.gridsuite.directory.server.dto.elasticsearch.DirectoryElementInfos;
 import org.gridsuite.directory.server.repository.DirectoryElementEntity;
 import org.gridsuite.directory.server.repository.DirectoryElementRepository;
+import org.springframework.data.elasticsearch.client.elc.ElasticsearchTemplate;
+import org.springframework.data.elasticsearch.core.IndexOperations;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
@@ -11,13 +15,17 @@
 import static org.gridsuite.directory.server.dto.ElementAttributes.toElementAttributes;
 
 @Service
+@Slf4j
 public class SupervisionService {
     private final DirectoryElementRepository directoryElementRepository;
     private final DirectoryRepositoryService repositoryService;
+    private final ElasticsearchTemplate esTemplate;
 
-    public SupervisionService(DirectoryRepositoryService repositoryService, DirectoryElementRepository directoryElementRepository) {
+    public SupervisionService(DirectoryRepositoryService repositoryService, DirectoryElementRepository directoryElementRepository,
+                              ElasticsearchTemplate esTemplate) {
         this.repositoryService = repositoryService;
         this.directoryElementRepository = directoryElementRepository;
+        this.esTemplate = esTemplate;
     }
 
     public List<ElementAttributes> getStashedElementsAttributes() {
@@ -35,4 +43,28 @@ public void deleteElementsByIds(List<UUID> uuids) {
     public List<DirectoryElementEntity> getStashedElements() {
         return directoryElementRepository.findAllByStashed(true);
     }
+
+    public boolean recreateIndexDirectoryElementInfos() {
+        final IndexOperations idxDirectoryElementInfos = esTemplate.indexOps(DirectoryElementInfos.class);
+        final String idxDirectoryElementInfosName = idxDirectoryElementInfos.getIndexCoordinates().getIndexName();
+        log.warn("Recreating ElasticSearch index {}", idxDirectoryElementInfosName);
+        if (idxDirectoryElementInfos.exists()) {
+            log.info("Index {} found, delete it.", idxDirectoryElementInfosName);
+            if (idxDirectoryElementInfos.delete()) {
+                log.info("Successfully delete index {}", idxDirectoryElementInfosName);
+            } else {
+                log.error("A problem seems to happen when deleting index {}...", idxDirectoryElementInfosName);
+                return false;
+            }
+        }
+        if (idxDirectoryElementInfos.createWithMapping()) {
+            log.info("Index {} successfully recreated!", idxDirectoryElementInfosName);
+        } else {
+            log.info("An error happen while re-creating index {}...", idxDirectoryElementInfosName);
+            return false;
+        }
+        log.info("Re-indexing all elements of {}", idxDirectoryElementInfosName);
+        repositoryService.reindexAllElements();
+        return true;
+    }
 }