Add routing param

lambdaworks · Nov 30, 2022 · 3952660 · 3952660
1 parent 0279f8a
commit 3952660
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/modules/library/src/main/scala/zio/elasticsearch/ElasticRequest.scala b/modules/library/src/main/scala/zio/elasticsearch/ElasticRequest.scala
@@ -70,7 +70,8 @@ object ElasticRequest {
 
   private[elasticsearch] final case class Exists(
     index: IndexName,
-    id: DocumentId
+    id: DocumentId,
+    routing: Option[Routing] = None
   ) extends ElasticRequest[Boolean]
 
   private[elasticsearch] final case class GetById(

diff --git a/modules/library/src/main/scala/zio/elasticsearch/HttpElasticExecutor.scala b/modules/library/src/main/scala/zio/elasticsearch/HttpElasticExecutor.scala
@@ -74,12 +74,13 @@ private[elasticsearch] final class HttpElasticExecutor private (config: ElasticC
       .unit
   }
 
-  private def executeExists(r: Exists): Task[Boolean] =
+  private def executeExists(r: Exists): Task[Boolean] = {
+    val uri = uri"$basePath/${r.index}/$Doc/${r.id}".withParam("routing", r.routing.map(_.value))
     request
-      .get(uri"$basePath/${r.index}/$Doc/${r.id}")
-      .response(asJson[ElasticGetResponse])
+      .head(uri)
       .send(client)
       .map(_.code.equals(Ok))
+  }
 
 }