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

feat($): add flow.setRemoteWebhookId

Browse Source
This commit is contained in:
Ali BARIN
2022-12-14 20:50:33 +01:00
parent 0970db3295
commit f30ac46672
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
packages/backend/src/helpers/global-variable.ts
View File

@@ -37,6 +37,7 @@ const globalVariable = async (
testRun = false, testRun = false,
} = options; } = options;
const isTrigger = step?.isTrigger;
const lastInternalId = testRun ? undefined : await flow?.lastInternalId(); const lastInternalId = testRun ? undefined : await flow?.lastInternalId();
const nextStep = await step?.getNextStep(); const nextStep = await step?.getNextStep();
@@ -123,6 +124,18 @@ const globalVariable = async (
$.webhookUrl = webhookUrl; $.webhookUrl = webhookUrl;
} }
if (isTrigger && (await step.getTriggerCommand()).type === 'webhook') {
$.flow.setRemoteWebhookId = async (remoteWebhookId) => {
await flow.$query().patchAndFetch({
remoteWebhookId,
});
$.flow.remoteWebhookId = remoteWebhookId;
};
$.flow.remoteWebhookId = flow.remoteWebhookId;
}
const lastInternalIds = const lastInternalIds =
testRun || (flow && step.isAction) ? [] : await flow?.lastInternalIds(2000); testRun || (flow && step.isAction) ? [] : await flow?.lastInternalIds(2000);