From cda36ae9e086e09cc306d02a3dcb1555ada5178d Mon Sep 17 00:00:00 2001 From: Islam Abdelfattah Date: Fri, 10 May 2024 00:32:59 +0000 Subject: [PATCH 1/2] fix: distinguish test webhooks to run when flow not published/enabled --- .../api/src/app/workers/flow-worker/consumer/webook-consumer.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts b/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts index 7f22c87f4a..2d7693c86a 100644 --- a/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts +++ b/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts @@ -17,7 +17,7 @@ export const webhookConsumer = { }) return } - const isPublishedAndEnabled = flow.status !== FlowStatus.ENABLED || isNil(flow.publishedVersionId) + const isPublishedAndEnabled = (flow.status !== FlowStatus.ENABLED || isNil(flow.publishedVersionId))&& !simulate if (isPublishedAndEnabled) { await stopAndReply(data, { status: StatusCodes.NOT_FOUND, From cb75a32f39e13c9b6524d9e10363a7d2b97ce583 Mon Sep 17 00:00:00 2001 From: Islam Abdelfattah Date: Fri, 10 May 2024 00:34:31 +0000 Subject: [PATCH 2/2] fix: add space --- .../api/src/app/workers/flow-worker/consumer/webook-consumer.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts b/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts index 2d7693c86a..5852cb8c2b 100644 --- a/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts +++ b/packages/server/api/src/app/workers/flow-worker/consumer/webook-consumer.ts @@ -17,7 +17,7 @@ export const webhookConsumer = { }) return } - const isPublishedAndEnabled = (flow.status !== FlowStatus.ENABLED || isNil(flow.publishedVersionId))&& !simulate + const isPublishedAndEnabled = (flow.status !== FlowStatus.ENABLED || isNil(flow.publishedVersionId)) && !simulate if (isPublishedAndEnabled) { await stopAndReply(data, { status: StatusCodes.NOT_FOUND,