feat: add Signalwire integration

packages/backend/src/apps/signalwire/triggers/index.ts

@@ -0,0 +1,3 @@
+import receiveSms from './receive-sms';
+
+export default [receiveSms];

packages/backend/src/apps/signalwire/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 = 'https://' + $.auth.data.spaceName + '.' + $.auth.data.spaceRegion + 'signalwire.com' + `/api/laml/2010-04-01/Accounts/${$.auth.data.accountSid}/Messages?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 = 'https://' + $.auth.data.spaceName + '.' + $.auth.data.spaceRegion + 'signalwire.com' + response.data.next_page_uri;
+  } while (requestPath);
+};
+
+export default fetchMessages;

packages/backend/src/apps/signalwire/triggers/receive-sms/index.ts

@@ -0,0 +1,23 @@
+import defineTrigger from '../../../../helpers/define-trigger';
+import fetchMessages from './fetch-messages';
+
+export default defineTrigger({
+  name: 'Receive SMS',
+  key: 'receiveSms',
+  pollInterval: 15,
+  description: 'Triggers when a new SMS is received.',
+  arguments: [
+    {
+      label: 'To Number',
+      key: 'toNumber',
+      type: 'string',
+      required: true,
+      description:
+        'The number to receive the SMS on. It should be a Signalwire number in your project.',
+    },
+  ],
+
+  async run($) {
+    await fetchMessages($);
+  },
+});