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 0e502459..2fc25ba5 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,3 +1,4 @@ +import newCompanies from './new-companies/index.js'; import newContacts from './new-contacts/index.js'; -export default [newContacts]; +export default [newCompanies, newContacts]; diff --git a/packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-companies/index.js b/packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-companies/index.js new file mode 100644 index 00000000..3966d58d --- /dev/null +++ b/packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-companies/index.js @@ -0,0 +1,89 @@ +import Crypto from 'crypto'; +import defineTrigger from '../../../../helpers/define-trigger.js'; + +export default defineTrigger({ + name: 'New companies', + key: 'newCompanies', + type: 'webhook', + description: 'Triggers when a new company 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: 'Accounts', + operation: 'insert', + channel_id: organizationId, + server_time: 1708426963120, + query_params: {}, + resource_uri: `${$.auth.data.apiDomain}/bigin/v1/Accounts`, + 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: ['Accounts.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 770cdd97..0337f9fb 100644 --- a/packages/docs/pages/apps/bigin-by-zoho-crm/triggers.md +++ b/packages/docs/pages/apps/bigin-by-zoho-crm/triggers.md @@ -1,6 +1,8 @@ --- favicon: /favicons/bigin-by-zoho-crm.svg items: + - name: New companies + desc: Triggers when a new company is created. - name: New contacts desc: Triggers when a new contact is created. ---