fix: delete by query

Author: samuelgja

src/__tests__/elastic-client.test.ts

@@ -1,5 +1,6 @@
 import { ElasticClient } from '../elastic-client'
 import 'isomorphic-fetch'
+
 describe('elastic-client', () => {
   it('should create and delete elastic index', async () => {
     const client = new ElasticClient({ hosts: ['http://localhost:9200'] })
@@ -129,6 +130,37 @@ describe('elastic-client', () => {
     expect(result.code).toBe(200)
   })
 
+  it('should delete document', async () => {
+    const client = new ElasticClient({ hosts: ['http://localhost:9200'] })
+
+    await client.index({
+      index: 'hello-world2',
+      document: { hello: true },
+      id: '21',
+    })
+
+    await client.refreshIndex({ index: 'hello-world2' })
+    await client.deleteByQuery({
+      index: 'hello-world2',
+      query: {
+        match: {
+          hello: true,
+        },
+      },
+    })
+    await client.refreshIndex({ index: 'hello-world2' })
+    const search = await client.search({
+      index: 'hello-world2',
+      query: {
+        match: {
+          hello: true,
+        },
+      },
+    })
+
+    expect(search.data.hits.hits.length).toBe(0)
+  })
+
   it('should bulk index', async () => {
     const client = new ElasticClient({ hosts: ['http://localhost:9200'] })
     const result = await client.bulk({

src/elastic-client.ts

@@ -333,7 +333,7 @@ export class ElasticClient {
   }
 
   async deleteByQuery(params: DeleteByQueryRequest): Promise<Response<DeleteByQueryResponse>> {
-    let url = `/${params.index}_delete_by_query`
+    let url = `/${params.index}/_delete_by_query`
 
     const queryParams = queryParametersGenerator(
       {