feat: update webhook behaviour

Author: joberthel

Diff for: nodes/ShopwareAdminTriggerNode/ShopwareAdminTriggerNode.node.ts

@@ -69,33 +69,37 @@ export class ShopwareAdminTriggerNode implements INodeType {
 	webhookMethods = {
 		default: {
 			async checkExists(this: IHookFunctions): Promise<boolean> {
-				const webhookData = this.getWorkflowStaticData('node');
-
-				if (webhookData.webhookId === undefined) {
-					return false;
-				}
-
-				try {
-					await axios({
-						...(await authenticate.call(this)),
-						url: `/webhook/${webhookData.webhookId}`,
-						method: 'GET',
-					});
-				} catch (error) {
+				const response = await axios({
+					...(await authenticate.call(this)),
+					url: `/search/webhook`,
+					method: 'POST',
+					data: {
+						page: 1,
+						limit: 100,
+						filter: [
+							{
+								type: 'equals',
+								field: 'name',
+								value: `n8n-${this.getNode().id}`,
+							},
+						],
+					},
+				});
+
+				if (response.data.total === 0) {
 					return false;
 				}
 
 				return true;
 			},
 			async create(this: IHookFunctions): Promise<boolean> {
 				const webhookUrl = this.getNodeWebhookUrl('default');
-				const webhookData = this.getWorkflowStaticData('node');
 
 				const eventName = this.getNodeParameter('eventName') as string;
 				const onlyLiveVersion = this.getNodeParameter('onlyLiveVersion') as boolean;
 
 				try {
-					const result = await axios({
+					await axios({
 						...(await authenticate.call(this)),
 						url: '/webhook',
 						method: 'POST',
@@ -106,29 +110,42 @@ export class ShopwareAdminTriggerNode implements INodeType {
 							onlyLiveVersion,
 						},
 					});
-
-					webhookData.webhookId = result.data.id;
 				} catch (error) {
 					return false;
 				}
 
 				return true;
 			},
 			async delete(this: IHookFunctions): Promise<boolean> {
-				const webhookData = this.getWorkflowStaticData('node');
-
-				try {
-					await axios({
-						...(await authenticate.call(this)),
-						url: `/webhook/${webhookData.webhookId}`,
-						method: 'DELETE',
-					});
-				} catch (error) {
-					return false;
+				const response = await axios({
+					...(await authenticate.call(this)),
+					url: `/search/webhook`,
+					method: 'POST',
+					data: {
+						page: 1,
+						limit: 100,
+						filter: [
+							{
+								type: 'equals',
+								field: 'name',
+								value: `n8n-${this.getNode().id}`,
+							},
+						],
+					},
+				});
+
+				for (const webhookData of response.data.data) {
+					try {
+						await axios({
+							...(await authenticate.call(this)),
+							url: `/webhook/${webhookData.id}`,
+							method: 'DELETE',
+						});
+					} catch (error) {
+						return false;
+					}
 				}
 
-				delete webhookData.webhookId;
-
 				return true;
 			},
 		},

Diff for: package-lock.json

@@ -1,6 +1,6 @@
 {
 	"name": "@c0d3bl1ck/n8n-nodes-shopware",
-	"version": "0.1.8",
+	"version": "0.1.9",
 	"description": "Community nodes to connect Shopware 6 with n8n.",
 	"keywords": [
 		"n8n-community-node-package"