MSEARCH-794: enable async processing

folio-org · Aug 19, 2024 · 0aea7f6 · 0aea7f6
1 parent 69aae17
commit 0aea7f6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/main/java/org/folio/search/service/reindex/ReindexService.java b/src/main/java/org/folio/search/service/reindex/ReindexService.java
@@ -55,6 +55,7 @@ public CompletableFuture<Void> initFullReindex(String tenantId) {
       .thenRun(this::publishRecordsRange)
       .handle((unused, throwable) -> {
         if (throwable != null) {
+          log.error("full reindex process failed: {}", throwable.getMessage());
           statusService.updateMergeRangesFailed();
         }
         return unused;

diff --git a/src/test/java/org/folio/search/controller/IndexManagementControllerTest.java b/src/test/java/org/folio/search/controller/IndexManagementControllerTest.java
@@ -10,7 +10,6 @@
 import static org.folio.search.utils.TestUtils.randomId;
 import static org.folio.search.utils.TestUtils.resourceEvent;
 import static org.hamcrest.Matchers.is;
-import static org.mockito.Mockito.doNothing;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 import static org.springframework.http.MediaType.APPLICATION_JSON;
@@ -24,6 +23,7 @@
 import java.io.IOException;
 import java.util.List;
 import java.util.Set;
+import java.util.concurrent.CompletableFuture;
 import org.folio.search.domain.dto.CreateIndexRequest;
 import org.folio.search.domain.dto.IndexDynamicSettings;
 import org.folio.search.domain.dto.ReindexJob;
@@ -68,7 +68,7 @@ class IndexManagementControllerTest {
 
   @Test
   void runFullReindex_positive() throws Exception {
-    doNothing().when(reindexService).initFullReindex(TENANT_ID);
+    when(reindexService.initFullReindex(TENANT_ID)).thenReturn(new CompletableFuture<>());
 
     mockMvc.perform(post(reindexFullPath()).header(XOkapiHeaders.TENANT, TENANT_ID))
       .andExpect(status().isOk());