Add reload_search_analyzers call (#3067)

elastic4s-core/src/main/scala/com/sksamuel/elastic4s/ElasticApi.scala

@@ -1,7 +1,6 @@
 package com.sksamuel.elastic4s
 
-import com.sksamuel.elastic4s.api.{AggregationApi, AliasesApi, AnalyzeApi, AnalyzerApi, BulkApi, CatsApi, ClearRolesCacheApi, ClusterApi, CollapseApi, CountApi, CreateIndexApi, CreateRoleApi, CreateUserApi, DeleteApi, DeleteIndexApi, DeleteRoleApi, DeleteUserApi, ExistsApi, ExplainApi, ForceMergeApi, GetApi, HighlightApi, IndexAdminApi, IndexApi, IndexRecoveryApi, IndexTemplateApi, IngestApi, KnnApi, LocksApi, MappingApi, NodesApi, NormalizerApi, PipelineAggregationApi, PitApi, QueryApi, ReindexApi, RoleApi, ScoreApi, ScriptApi, ScrollApi, SearchApi, SearchTemplateApi, SettingsApi, SnapshotApi, SortApi, StoredScriptApi, SuggestionApi, TaskApi, TermVectorApi, TokenFilterApi, TokenizerApi, TypesApi, UpdateApi, UserAdminApi, UserApi, ValidateApi}
-
+import com.sksamuel.elastic4s.api.{AggregationApi, AliasesApi, AnalyzeApi, AnalyzerApi, BulkApi, CatsApi, ClearRolesCacheApi, ClusterApi, CollapseApi, CountApi, CreateIndexApi, CreateRoleApi, CreateUserApi, DeleteApi, DeleteIndexApi, DeleteRoleApi, DeleteUserApi, ExistsApi, ExplainApi, ForceMergeApi, GetApi, HighlightApi, IndexAdminApi, IndexApi, IndexRecoveryApi, IndexTemplateApi, IngestApi, KnnApi, LocksApi, MappingApi, NodesApi, NormalizerApi, PipelineAggregationApi, PitApi, QueryApi, ReindexApi, ReloadSearchAnalyzersApi, RoleApi, ScoreApi, ScriptApi, ScrollApi, SearchApi, SearchTemplateApi, SettingsApi, SnapshotApi, SortApi, StoredScriptApi, SuggestionApi, TaskApi, TermVectorApi, TokenFilterApi, TokenizerApi, TypesApi, UpdateApi, UserAdminApi, UserApi, ValidateApi}
 import scala.concurrent.duration._
 import scala.concurrent.{Await, Future}
 
@@ -41,6 +40,7 @@ trait ElasticApi
     with QueryApi
     with PipelineAggregationApi
     with ReindexApi
+    with ReloadSearchAnalyzersApi
     with RoleApi
     with ScriptApi
     with ScoreApi

elastic4s-core/src/main/scala/com/sksamuel/elastic4s/ElasticDsl.scala

@@ -15,6 +15,7 @@ import com.sksamuel.elastic4s.handlers.locks.LocksHandlers
 import com.sksamuel.elastic4s.handlers.nodes.NodesHandlers
 import com.sksamuel.elastic4s.handlers.pit.PitHandlers
 import com.sksamuel.elastic4s.handlers.reindex.ReindexHandlers
+import com.sksamuel.elastic4s.handlers.reloadsearchanalyzers.ReloadSearchAnalyzersHandlers
 import com.sksamuel.elastic4s.handlers.script.StoredScriptHandlers
 import com.sksamuel.elastic4s.handlers.security.roles.{RoleAdminHandlers, RoleHandlers}
 import com.sksamuel.elastic4s.handlers.security.users.{UserAdminHandlers, UserHandlers}
@@ -51,6 +52,7 @@ with LocksHandlers
 with MappingHandlers
 with NodesHandlers
 with ReindexHandlers
+with ReloadSearchAnalyzersHandlers
 with RoleAdminHandlers
 with RoleHandlers
 with RolloverHandlers

elastic4s-core/src/main/scala/com/sksamuel/elastic4s/api/ReloadSearchAnalyzersApi.scala

@@ -0,0 +1,10 @@
+package com.sksamuel.elastic4s.api
+
+import com.sksamuel.elastic4s.Indexes
+import com.sksamuel.elastic4s.requests.reloadsearchanalyzers.ReloadSearchAnalyzersRequest
+
+trait ReloadSearchAnalyzersApi {
+  def reloadSearchAnalyzers(index: String): ReloadSearchAnalyzersRequest = ReloadSearchAnalyzersRequest(Indexes(index))
+  def reloadSearchAnalyzers(indexes: Indexes): ReloadSearchAnalyzersRequest = ReloadSearchAnalyzersRequest(indexes)
+  def reloadSearchAnalyzers(indexes: Seq[String]): ReloadSearchAnalyzersRequest = ReloadSearchAnalyzersRequest(Indexes(indexes))
+}

elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/reloadsearchanalyzers/ReloadSearchAnalyzersRequest.scala

@@ -0,0 +1,5 @@
+package com.sksamuel.elastic4s.requests.reloadsearchanalyzers
+
+import com.sksamuel.elastic4s.Indexes
+
+case class ReloadSearchAnalyzersRequest(indexes: Indexes) extends Serializable

elastic4s-domain/src/main/scala/com/sksamuel/elastic4s/requests/reloadsearchanalyzers/ReloadSearchAnalyzersResponse.scala

@@ -0,0 +1,9 @@
+package com.sksamuel.elastic4s.requests.reloadsearchanalyzers
+
+import com.fasterxml.jackson.annotation.JsonProperty
+import com.sksamuel.elastic4s.requests.common.Shards
+
+case class ReloadDetails(index: String, @JsonProperty("reloaded_analyzers") reloadedAnalyzers: Seq[String], @JsonProperty("reloaded_node_ids") reloadedNodeIds: Seq[String])
+
+case class ReloadSearchAnalyzersResponse(@JsonProperty("reload_details") reloadDetails: Seq[ReloadDetails],
+                                         @JsonProperty("_shards") shards: Option[Shards])

elastic4s-handlers/src/main/scala/com/sksamuel/elastic4s/handlers/reloadsearchanalyzers/ReloadSearchAnalyzersHandlers.scala

@@ -0,0 +1,23 @@
+package com.sksamuel.elastic4s.handlers.reloadsearchanalyzers
+
+import com.sksamuel.elastic4s.requests.reloadsearchanalyzers._
+import com.sksamuel.elastic4s.{ElasticRequest, Handler, HttpResponse, ResponseHandler}
+
+trait ReloadSearchAnalyzersHandlers {
+  implicit object ReloadSearchAnalyzersHandler extends Handler[ReloadSearchAnalyzersRequest, ReloadSearchAnalyzersResponse] {
+
+    override def responseHandler: ResponseHandler[ReloadSearchAnalyzersResponse] = new ResponseHandler[ReloadSearchAnalyzersResponse] {
+      override def handle(response: HttpResponse): Right[Nothing, ReloadSearchAnalyzersResponse] =
+        response.statusCode match {
+          case 404 | 200 => Right(ResponseHandler.fromResponse[ReloadSearchAnalyzersResponse](response))
+          case _ => sys.error("Invalid response")
+        }
+    }
+
+    override def build(request: ReloadSearchAnalyzersRequest): ElasticRequest = {
+      val endpoint = s"/${request.indexes.string(true)}/_reload_search_analyzers"
+
+      ElasticRequest("POST", endpoint)
+    }
+  }
+}