groot/automatisch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #1139 from automatisch/update-flow-status-accordingly

Browse Source 
fix: update flow.active when remote calls succeed
This commit is contained in:
Ömer Faruk Aydın
2023-06-12 11:48:25 +02:00
committed by GitHub
parent 39620d3510 1449fb0f84
commit 8055d6555e
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
packages/backend/src/graphql/mutations/update-flow-status.ts
View File

@@ -25,14 +25,12 @@ const updateFlowStatus = async (
}) })
.throwIfNotFound(); .throwIfNotFound();
if (flow.active === params.input.active) { const newActiveValue = params.input.active;
if (flow.active === newActiveValue) {
return flow; return flow;
} }
flow = await flow.$query().withGraphFetched('steps').patchAndFetch({
active: params.input.active,
});
const triggerStep = await flow.getTriggerStep(); const triggerStep = await flow.getTriggerStep();
const trigger = await triggerStep.getTriggerCommand(); const trigger = await triggerStep.getTriggerCommand();
const interval = trigger.getInterval?.(triggerStep.parameters); const interval = trigger.getInterval?.(triggerStep.parameters);
@@ -49,13 +47,13 @@ const updateFlowStatus = async (
testRun: false, testRun: false,
}); });
if (flow.active && trigger.registerHook) { if (newActiveValue && trigger.registerHook) {
await trigger.registerHook($); await trigger.registerHook($);
} else if (!flow.active && trigger.unregisterHook) { } else if (!newActiveValue && trigger.unregisterHook) {
await trigger.unregisterHook($); await trigger.unregisterHook($);
} }
} else { } else {
if (flow.active) { if (newActiveValue) {
flow = await flow.$query().patchAndFetch({ flow = await flow.$query().patchAndFetch({
published_at: new Date().toISOString(), published_at: new Date().toISOString(),
}); });
@@ -80,6 +78,10 @@ const updateFlowStatus = async (
} }
} }
flow = await flow.$query().withGraphFetched('steps').patchAndFetch({
active: newActiveValue,
});
return flow; return flow;
}; };