File size: 1,210 Bytes
3206347 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 |
import Crypto from 'crypto';
import isEmpty from 'lodash/isEmpty.js';
import defineTrigger from '../../../../helpers/define-trigger.js';
export default defineTrigger({
name: 'New clients',
key: 'newClients',
type: 'webhook',
description: 'Triggers when a new client is added.',
arguments: [],
async run($) {
const dataItem = {
raw: $.request.body,
meta: {
internalId: Crypto.randomUUID(),
},
};
$.pushTriggerItem(dataItem);
},
async testRun($) {
const lastExecutionStep = await $.getLastExecutionStep();
if (!isEmpty(lastExecutionStep?.dataOut)) {
$.pushTriggerItem({
raw: lastExecutionStep.dataOut,
meta: {
internalId: '',
},
});
}
},
async registerHook($) {
const CREATE_CLIENT_EVENT_ID = '1';
const payload = {
target_url: $.webhookUrl,
event_id: CREATE_CLIENT_EVENT_ID,
format: 'JSON',
rest_method: 'post',
};
const response = await $.http.post('/v1/webhooks', payload);
await $.flow.setRemoteWebhookId(response.data.data.id);
},
async unregisterHook($) {
await $.http.delete(`/v1/webhooks/${$.flow.remoteWebhookId}`);
},
});
|