diff --git a/packages/backend/src/apps/bigin-by-zoho-crm/triggers/index.js b/packages/backend/src/apps/bigin-by-zoho-crm/triggers/index.js index bd4577aa..25afceab 100644 --- a/packages/backend/src/apps/bigin-by-zoho-crm/triggers/index.js +++ b/packages/backend/src/apps/bigin-by-zoho-crm/triggers/index.js @@ -1,5 +1,6 @@ import newCalls from './new-calls/index.js'; import newCompanies from './new-companies/index.js'; import newContacts from './new-contacts/index.js'; +import newTasks from './new-tasks/index.js'; -export default [newCalls, newCompanies, newContacts]; +export default [newCalls, newCompanies, newContacts, newTasks]; diff --git a/packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-tasks/index.js b/packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-tasks/index.js new file mode 100644 index 00000000..a34b7fcd --- /dev/null +++ b/packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-tasks/index.js @@ -0,0 +1,89 @@ +import Crypto from 'crypto'; +import defineTrigger from '../../../../helpers/define-trigger.js'; + +export default defineTrigger({ + name: 'New tasks', + key: 'newTasks', + type: 'webhook', + description: 'Triggers when a new task is created.', + arguments: [ + { + label: 'Organization', + key: 'organizationId', + type: 'dropdown', + required: true, + description: '', + variables: false, + source: { + type: 'query', + name: 'getDynamicData', + arguments: [ + { + name: 'key', + value: 'listOrganizations', + }, + ], + }, + }, + ], + + async run($) { + const dataItem = { + raw: $.request.body, + meta: { + internalId: Crypto.randomUUID(), + }, + }; + + $.pushTriggerItem(dataItem); + }, + + async testRun($) { + const organizationId = $.step.parameters.organizationId; + + const sampleEventData = { + ids: ['111111111111111111'], + token: null, + module: 'Tasks', + operation: 'insert', + channel_id: organizationId, + server_time: 1708426963120, + query_params: {}, + resource_uri: `${$.auth.data.apiDomain}/bigin/v1/Tasks`, + affected_fields: [], + }; + + const dataItem = { + raw: sampleEventData, + meta: { + internalId: sampleEventData.channel_id, + }, + }; + + $.pushTriggerItem(dataItem); + }, + + async registerHook($) { + const organizationId = $.step.parameters.organizationId; + + const payload = { + watch: [ + { + channel_id: organizationId, + notify_url: $.webhookUrl, + events: ['Tasks.create'], + }, + ], + }; + + await $.http.post('/bigin/v2/actions/watch', payload); + + await $.flow.setRemoteWebhookId(organizationId); + }, + + async unregisterHook($) { + await $.http.delete( + `/bigin/v2/actions/watch?channel_ids=${$.flow.remoteWebhookId}` + ); + }, +}); diff --git a/packages/docs/pages/apps/bigin-by-zoho-crm/triggers.md b/packages/docs/pages/apps/bigin-by-zoho-crm/triggers.md index 70f625f5..fb8a36f8 100644 --- a/packages/docs/pages/apps/bigin-by-zoho-crm/triggers.md +++ b/packages/docs/pages/apps/bigin-by-zoho-crm/triggers.md @@ -7,6 +7,8 @@ items: desc: Triggers when a new company is created. - name: New contacts desc: Triggers when a new contact is created. + - name: New tasks + desc: Triggers when a new task is created. ---