#92162 delete by query (#5)

Author: DimionX

src/Concerns/InteractsWithIndex.php

@@ -32,6 +32,14 @@ public function search(array $dsl): array
         return $this->resolveClient()->search($this->indexName(), $dsl);
     }
 
+    /**
+     * @see SearchIndex::search()
+     */
+    public function deleteByQuery(array $dsl): array
+    {
+        return $this->resolveClient()->deleteByQuery($this->indexName(), $dsl);
+    }
+
     public function isCreated(): bool
     {
         return $this->resolveClient()->indicesExists($this->indexName());

src/Contracts/SearchIndex.php

@@ -18,4 +18,12 @@ public function tiebreaker(): string;
      * @return array
      */
     public function search(array $dsl): array;
+
+    /**
+     * Perform delete by query.
+     *
+     * @param array $dsl
+     * @return array
+     */
+    public function deleteByQuery(array $dsl): array;
 }

src/ElasticClient.php

@@ -25,6 +25,16 @@ public function search(string $indexName, array $dsl): array
         ]);
     }
 
+    public function deleteByQuery(string $indexName, array $dsl): array
+    {
+        $this->queryLog?->log($indexName, $dsl);
+
+        return $this->client->deleteByQuery([
+            'index' => $indexName,
+            'body' => $dsl,
+        ]);
+    }
+
     public function get(string $indexName, $id): array
     {
         return $this->client->get([