From 2af04e775dfdb62086946007bc025e564f0eeef2 Mon Sep 17 00:00:00 2001
From: Jan Oberhauser <jan.oberhauser@gmail.com>
Date: Sat, 13 Jun 2020 19:22:49 +0200
Subject: [PATCH] :zap: Add delete option to MongoDb-Node

---
 .../nodes-base/nodes/MongoDb/MongoDb.node.ts  | 13 +++++++-
 .../nodes/MongoDb/mongo.node.options.ts       | 30 ++++++++++++++++++-
 2 files changed, 41 insertions(+), 2 deletions(-)

diff --git a/packages/nodes-base/nodes/MongoDb/MongoDb.node.ts b/packages/nodes-base/nodes/MongoDb/MongoDb.node.ts
index dbd7ab2929..d91a287b88 100644
--- a/packages/nodes-base/nodes/MongoDb/MongoDb.node.ts
+++ b/packages/nodes-base/nodes/MongoDb/MongoDb.node.ts
@@ -32,7 +32,18 @@ export class MongoDb implements INodeType {
 		const items = this.getInputData();
 		const operation = this.getNodeParameter('operation', 0) as string;
 
-		if (operation === 'find') {
+		if (operation === 'delete') {
+			// ----------------------------------
+			//         delete
+			// ----------------------------------
+
+			const { deletedCount } = await mdb
+				.collection(this.getNodeParameter('collection', 0) as string)
+				.deleteMany(JSON.parse(this.getNodeParameter('query', 0) as string));
+
+			returnItems = this.helpers.returnJsonArray([{ deletedCount }]);
+
+		} else if (operation === 'find') {
 			// ----------------------------------
 			//         find
 			// ----------------------------------
diff --git a/packages/nodes-base/nodes/MongoDb/mongo.node.options.ts b/packages/nodes-base/nodes/MongoDb/mongo.node.options.ts
index 190ff3de88..953a45a620 100644
--- a/packages/nodes-base/nodes/MongoDb/mongo.node.options.ts
+++ b/packages/nodes-base/nodes/MongoDb/mongo.node.options.ts
@@ -28,6 +28,11 @@ export const nodeDescription: INodeTypeDescription = {
 			name: 'operation',
 			type: 'options',
 			options: [
+				{
+					name: 'Delete',
+					value: 'delete',
+					description: 'Delete documents.'
+				},
 				{
 					name: 'Find',
 					value: 'find',
@@ -57,13 +62,36 @@ export const nodeDescription: INodeTypeDescription = {
 			description: 'MongoDB Collection'
 		},
 
+		// ----------------------------------
+		//         delete
+		// ----------------------------------
+		{
+			displayName: 'Delete Query (JSON format)',
+			name: 'query',
+			type: 'json',
+			typeOptions: {
+				rows: 5
+			},
+			displayOptions: {
+				show: {
+					operation: [
+						'delete'
+					],
+				},
+			},
+			default: '{}',
+			placeholder: `{ "birth": { "$gt": "1950-01-01" } }`,
+			required: true,
+			description: 'MongoDB Delete query.'
+		},
+
 		// ----------------------------------
 		//         find
 		// ----------------------------------
 		{
 			displayName: 'Query (JSON format)',
 			name: 'query',
-			type: 'string',
+			type: 'json',
 			typeOptions: {
 				rows: 5
 			},