From b5436fe7fa054182124ec9a777fff079f1a685f1 Mon Sep 17 00:00:00 2001 From: Ali BARIN Date: Wed, 30 Nov 2022 02:11:30 +0100 Subject: [PATCH] chore: add comments in update flow status --- packages/backend/src/graphql/mutations/update-flow-status.ts | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/packages/backend/src/graphql/mutations/update-flow-status.ts b/packages/backend/src/graphql/mutations/update-flow-status.ts index ccc6ac3d..83f05750 100644 --- a/packages/backend/src/graphql/mutations/update-flow-status.ts +++ b/packages/backend/src/graphql/mutations/update-flow-status.ts @@ -41,6 +41,7 @@ const updateFlowStatus = async ( }; if (flow.active) { + // add the flow job in the queue. flow = await flow.$query().patchAndFetch({ published_at: new Date().toISOString(), }); @@ -51,6 +52,7 @@ const updateFlowStatus = async ( jobName, { flowId: flow.id }, { + // do not repeat webhook job for immediate webhook registration repeat: trigger.type === 'webhook' ? null : repeatOptions, jobId: flow.id, removeOnComplete: REMOVE_AFTER_7_DAYS_OR_50_JOBS, @@ -58,6 +60,7 @@ const updateFlowStatus = async ( } ); } else if (!flow.active && trigger.type === 'webhook') { + // unregister webhook from the application const $ = await globalVariable({ flow, connection: await triggerStep.$relatedQuery('connection'), @@ -68,6 +71,7 @@ const updateFlowStatus = async ( await trigger.unregisterHook($); } else { + // remove the job out of the queue const repeatableJobs = await flowQueue.getRepeatableJobs(); const job = repeatableJobs.find((job) => job.id === flow.id);