Add delete documents by filter for Meilisearch v1.2

Author: bidoubiwa

README.md

@@ -471,7 +471,7 @@ client.index('myIndex').deleteDocument(documentId: string | number): Promise<Enq
 #### [Delete multiple documents](https://docs.meilisearch.com/reference/api/documents.html#delete-documents)
 
 ```ts
-client.index('myIndex').deleteDocuments(documentsIds: string[] | number[]): Promise<EnqueuedTask>
+client.index('myIndex').deleteDocuments(params: DocumentsDeletionQuery | DocumentsIds): Promise<EnqueuedTask>
 ```
 
 #### [Delete all documents](https://docs.meilisearch.com/reference/api/documents.html#delete-all-documents)

src/indexes.ts

@@ -42,6 +42,8 @@ import {
   ResourceResults,
   RawDocumentAdditionOptions,
   ContentType,
+  DocumentsIds,
+  DocumentsDeletionQuery,
 } from './types'
 import { removeUndefinedFromObject } from './utils'
 import { HttpRequests } from './http-requests'
@@ -523,19 +525,41 @@ class Index<T extends Record<string, any> = Record<string, any>> {
   }
 
   /**
-   * Delete multiples documents of an index
+   * Delete multiples documents of an index.
+   *
+   * @param params - Params value can be:
+   *
+   *   - DocumentsDeletionQuery: An object containing the parameters to customize
+   *       your document deletion. Only available in Meilisearch v1.2 and newer
+   *   - DocumentsIds: An array of document ids to delete
    *
-   * @param documentsIds - Array of Document Ids to delete
    * @returns Promise containing an EnqueuedTask
    */
   async deleteDocuments(
-    documentsIds: string[] | number[]
+    params: DocumentsDeletionQuery | DocumentsIds
   ): Promise<EnqueuedTask> {
-    const url = `indexes/${this.uid}/documents/delete-batch`
-
-    const task = await this.httpRequest.post(url, documentsIds)
+    // If params is of type DocumentsDeletionQuery
+    const isDocumentsDeletionQuery =
+      !Array.isArray(params) && typeof params === 'object'
+    const endpoint = isDocumentsDeletionQuery
+      ? 'documents/delete'
+      : 'documents/delete-batch'
+    const url = `indexes/${this.uid}/${endpoint}`
+
+    try {
+      const task = await this.httpRequest.post(url, params)
+
+      return new EnqueuedTask(task)
+    } catch (e) {
+      if (
+        e instanceof MeiliSearchCommunicationError &&
+        isDocumentsDeletionQuery
+      ) {
+        e.message = versionErrorHintMessage(e.message, 'deleteDocuments')
+      }
 
-    return new EnqueuedTask(task)
+      throw e
+    }
   }
 
   /**

src/types/types.ts

@@ -225,6 +225,12 @@ export type DocumentQuery<T = Record<string, any>> = {
   fields?: Fields<T>
 }
 
+export type DocumentsDeletionQuery = {
+  filter: Filter
+}
+
+export type DocumentsIds = string[] | number[]
+
 /*
  ** Settings
  */

tests/documents.test.ts

@@ -451,6 +451,48 @@ describe('Documents tests', () => {
         expect(response.results.length).toEqual(dataset.length)
       })
 
+      test(`${permission} key: Delete some documents with string filters`, async () => {
+        const client = await getClient(permission)
+        await client.index(indexPk.uid).updateFilterableAttributes(['id'])
+        const { taskUid: addDocTask } = await client
+          .index(indexPk.uid)
+          .addDocuments(dataset)
+        await client.index(indexPk.uid).waitForTask(addDocTask)
+
+        const task = await client
+          .index(indexPk.uid)
+          .deleteDocuments({ filter: 'id IN [1, 2]' })
+
+        const resolvedTask = await client
+          .index(indexPk.uid)
+          .waitForTask(task.taskUid)
+        const documents = await client.index(indexPk.uid).getDocuments<Book>()
+
+        expect(resolvedTask.details.deletedDocuments).toEqual(2)
+        expect(documents.results.length).toEqual(dataset.length - 2)
+      })
+
+      test(`${permission} key: Delete some documents with array filters`, async () => {
+        const client = await getClient(permission)
+        await client.index(indexPk.uid).updateFilterableAttributes(['id'])
+        const { taskUid: addDocTask } = await client
+          .index(indexPk.uid)
+          .addDocuments(dataset)
+        await client.index(indexPk.uid).waitForTask(addDocTask)
+
+        const task = await client
+          .index(indexPk.uid)
+          .deleteDocuments({ filter: [['id = 1', 'id = 2']] })
+
+        const resolvedTask = await client
+          .index(indexPk.uid)
+          .waitForTask(task.taskUid)
+        const documents = await client.index(indexPk.uid).getDocuments<Book>()
+
+        expect(resolvedTask.details.deletedDocuments).toEqual(2)
+        expect(documents.results.length).toEqual(dataset.length - 2)
+      })
+
       test(`${permission} key: Delete some documents from index that has NO primary key`, async () => {
         const client = await getClient(permission)
         const { taskUid: addDocTask } = await client
@@ -492,6 +534,23 @@ describe('Documents tests', () => {
         expect(returnedIds).not.toContain(ids[1])
       })
 
+      test(`${permission} key: Delete some documents should trigger error with a hint on unknown route`, async () => {
+        const apiKey = await getKey(permission)
+        const client = new MeiliSearch({ host: `${HOST}/indexes`, apiKey })
+
+        try {
+          await client.index(indexPk.uid).deleteDocuments({ filter: 'id = 1' })
+
+          fail(
+            'deleteDocuments should have raised an error when the route does not exist'
+          )
+        } catch (e: any) {
+          expect(e.message).toEqual(
+            "Not Found\nHint: It might not be working because maybe you're not up to date with the Meilisearch version that deleteDocuments call requires."
+          )
+        }
+      })
+
       test(`${permission} key: Delete all document from index that has NO primary key`, async () => {
         const client = await getClient(permission)
         const task = await client.index(indexNoPk.uid).deleteAllDocuments()