fix: update alias creation method and url for compatibility

Updated the REST API method for creating aliases from PUT to POST and changed the URL from `_aliases/<alias_name>` to `_aliases` to align with OpenSearch v2.17 requirements.
SRGSSR · Nov 28, 2024 · b2e20f0 · b2e20f0
1 parent b67f462
commit b2e20f0
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/main/kotlin/ch/srgssr/pillarbox/monitoring/event/setup/AliasSetupTask.kt b/src/main/kotlin/ch/srgssr/pillarbox/monitoring/event/setup/AliasSetupTask.kt
@@ -48,7 +48,7 @@ class AliasSetupTask(
     /**
      * Path to create the alias in OpenSearch.
      */
-    private const val ALIAS_CREATION_PATH = "/_aliases/${ALIAS_NAME}"
+    private const val ALIAS_CREATION_PATH = "/_aliases"
   }
 
   /**
@@ -76,7 +76,7 @@ class AliasSetupTask(
   private fun createAlias(): Mono<*> {
     val indexTemplateJson = resourceLoader.loadResourceContent("classpath:opensearch/alias.json")
     return webClient
-      .put()
+      .post()
       .uri(ALIAS_CREATION_PATH)
       .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
       .bodyValue(indexTemplateJson)

diff --git a/src/test/kotlin/ch/srgssr/pillarbox/monitoring/event/setup/AliasSetupTaskTest.kt b/src/test/kotlin/ch/srgssr/pillarbox/monitoring/event/setup/AliasSetupTaskTest.kt
@@ -60,7 +60,7 @@ class AliasSetupTaskTest(
         createDispatcher(
           mapOf(
             "GET" to "/_alias/user_events" to MockResponse().setResponseCode(404),
-            "PUT" to "/_aliases/user_events" to MockResponse().setResponseCode(201),
+            "POST" to "/_aliases" to MockResponse().setResponseCode(201),
           ),
         )
 
@@ -76,8 +76,8 @@ class AliasSetupTaskTest(
       }
 
       mockWebServer.takeRequest().apply {
-        path shouldBe "/_aliases/user_events"
-        method shouldBe "PUT"
+        path shouldBe "/_aliases"
+        method shouldBe "POST"
         shouldNotThrow<Exception> { objectMapper.readTree(body.readUtf8()) }
       }
     }