Delete documents

melohagan · Oct 18, 2022 · 5ba3fc0 · 5ba3fc0
1 parent a9a45f3
commit 5ba3fc0
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "appwrite-databases",
-  "version": "1.2.2",
+  "version": "1.2.3",
   "description": "Manage Databases, Collections, and Documents in Appwrite",
   "main": "src/index.ts",
   "license": "MIT",

diff --git a/schema.json b/schema.json
@@ -124,6 +124,10 @@
           "collectionId": {
             "type": "string",
             "required": false
+          },
+          "documentId": {
+            "type": "string",
+            "required": false
           }
         }
       }
@@ -149,7 +153,8 @@
           ],
           "delete": [
             "Databases",
-            "Collections"
+            "Collections",
+            "Documents"
           ]
         }
       }

diff --git a/src/datasource.ts b/src/datasource.ts
@@ -55,7 +55,10 @@ class CustomIntegration implements IntegrationBase {
     return await this.databases.updateDocument(query.databaseId, query.collectionId, query.documentId, query.data)
   }
 
-  async delete(query: { databaseId: string; collectionId: string; extra: { [key:string]: string; } }) {
+  async delete(query: { databaseId: string; collectionId: string; documentId: string; extra: { [key:string]: string; } }) {
+    if (query.extra.type === "Documents") {
+      return await this.databases.deleteDocument(query.databaseId, query.collectionId, query.documentId)
+    }
     if (query.extra.type === "Collections") {
       return await this.databases.deleteCollection(query.databaseId, query.collectionId)
     }