diff --git a/packages/backend/src/apps/twilio/index.ts b/packages/backend/src/apps/twilio/index.ts index a15c38b1..458f88a5 100644 --- a/packages/backend/src/apps/twilio/index.ts +++ b/packages/backend/src/apps/twilio/index.ts @@ -1,6 +1,7 @@ import defineApp from '../../helpers/define-app'; import addAuthHeader from './common/add-auth-header'; import auth from './auth'; +import triggers from './triggers'; import actions from './actions'; export default defineApp({ @@ -14,5 +15,6 @@ export default defineApp({ primaryColor: 'e1000f', beforeRequest: [addAuthHeader], auth, + triggers, actions, }); diff --git a/packages/backend/src/apps/twilio/triggers/index.ts b/packages/backend/src/apps/twilio/triggers/index.ts new file mode 100644 index 00000000..04e1504d --- /dev/null +++ b/packages/backend/src/apps/twilio/triggers/index.ts @@ -0,0 +1,3 @@ +import receiveSms from './receive-sms'; + +export default [receiveSms]; diff --git a/packages/backend/src/apps/twilio/triggers/receive-sms/fetch-messages.ts b/packages/backend/src/apps/twilio/triggers/receive-sms/fetch-messages.ts new file mode 100644 index 00000000..974d3007 --- /dev/null +++ b/packages/backend/src/apps/twilio/triggers/receive-sms/fetch-messages.ts @@ -0,0 +1,27 @@ +import { IGlobalVariable, IJSONObject } from '@automatisch/types'; + +const fetchMessages = async ($: IGlobalVariable) => { + const toNumber = $.step.parameters.toNumber as string; + + let response; + let requestPath = `/2010-04-01/Accounts/${$.auth.data.accountSid}/Messages.json?To=${toNumber}`; + + do { + response = await $.http.get(requestPath); + + response.data.messages.forEach((message: IJSONObject) => { + const dataItem = { + raw: message, + meta: { + internalId: message.date_sent as string, + }, + }; + + $.pushTriggerItem(dataItem); + }); + + requestPath = response.data.next_page_uri; + } while (requestPath); +}; + +export default fetchMessages; diff --git a/packages/backend/src/apps/twilio/triggers/receive-sms/index.ts b/packages/backend/src/apps/twilio/triggers/receive-sms/index.ts new file mode 100644 index 00000000..30227cba --- /dev/null +++ b/packages/backend/src/apps/twilio/triggers/receive-sms/index.ts @@ -0,0 +1,37 @@ +import defineTrigger from '../../../../helpers/define-trigger'; +import fetchMessages from './fetch-messages'; + +export default defineTrigger({ + name: 'Receive SMS', + key: 'receiveSms', + pollInterval: 15, + description: 'Will be triggered when a new SMS is received.', + substeps: [ + { + key: 'chooseConnection', + name: 'Choose connection', + }, + { + key: 'chooseTrigger', + name: 'Set up a trigger', + arguments: [ + { + label: 'To Number', + key: 'toNumber', + type: 'string', + required: true, + description: + 'The number to receive the SMS on. It should be a Twilio number.', + }, + ], + }, + { + key: 'testStep', + name: 'Test trigger', + }, + ], + + async run($) { + await fetchMessages($); + }, +});