feat(signalwire): add receive call

packages/backend/src/apps/signalwire/dynamic-data/index.js

@@ -1,3 +1,4 @@
-import listIncomingPhoneNumbers from './list-incoming-phone-numbers/index.js';
+import listIncomingSmsPhoneNumbers from './list-incoming-sms-phone-numbers/index.js';
+import listIncomingCallPhoneNumbers from './list-incoming-call-phone-numbers/index.js';
 
-export default [listIncomingPhoneNumbers];
+export default [listIncomingCallPhoneNumbers, listIncomingSmsPhoneNumbers];

packages/backend/src/apps/signalwire/dynamic-data/list-incoming-call-phone-numbers/index.js

@@ -0,0 +1,37 @@
+export default {
+  name: 'List incoming call phone numbers',
+  key: 'listIncomingCallPhoneNumbers',
+
+  async run($) {
+    let requestPath = `/api/laml/2010-04-01/Accounts/${$.auth.data.accountSid}/IncomingPhoneNumbers`;
+
+    const aggregatedResponse = {
+      data: [],
+    };
+
+    do {
+      const { data } = await $.http.get(requestPath);
+
+      const voiceCapableIncomingPhoneNumbers = data.incoming_phone_numbers
+        .filter((incomingPhoneNumber) => {
+          return incomingPhoneNumber.capabilities.voice;
+        })
+        .map((incomingPhoneNumber) => {
+          const friendlyName = incomingPhoneNumber.friendly_name;
+          const phoneNumber = incomingPhoneNumber.phone_number;
+          const name = [friendlyName, phoneNumber].filter(Boolean).join(' - ');
+
+          return {
+            value: incomingPhoneNumber.sid,
+            name,
+          };
+        });
+
+      aggregatedResponse.data.push(...voiceCapableIncomingPhoneNumbers);
+
+      requestPath = data.next_page_uri;
+    } while (requestPath);
+
+    return aggregatedResponse;
+  },
+};

packages/backend/src/apps/signalwire/dynamic-data/list-incoming-sms-phone-numbers/index.js

@@ -1,6 +1,6 @@
 export default {
-  name: 'List incoming phone numbers',
-  key: 'listIncomingPhoneNumbers',
+  name: 'List incoming SMS phone numbers',
+  key: 'listIncomingSmsPhoneNumbers',
 
   async run($) {
     let requestPath = `/api/laml/2010-04-01/Accounts/${$.auth.data.accountSid}/IncomingPhoneNumbers`;

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

@@ -1,3 +1,4 @@
+import receiveCall from './receive-call/index.js';
 import receiveSms from './receive-sms/index.js';
 
-export default [receiveSms];
+export default [receiveCall, receiveSms];

packages/backend/src/apps/signalwire/triggers/receive-call/index.js

@@ -0,0 +1,82 @@
+import { URLSearchParams } from 'node:url';
+import Crypto from 'node:crypto';
+import isEmpty from 'lodash/isEmpty.js';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'Receive Call',
+  key: 'receiveCall',
+  type: 'webhook',
+  description: 'Triggers when a new call is received.',
+  arguments: [
+    {
+      label: 'To Number',
+      key: 'phoneNumberSid',
+      type: 'dropdown',
+      required: true,
+      description:
+        'The number to receive the call on. It should be a SignalWire number in your project.',
+      variables: false,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listIncomingCallPhoneNumbers',
+          },
+        ],
+      },
+    },
+  ],
+
+  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 phoneNumberSid = $.step.parameters.phoneNumberSid;
+
+    const payload = new URLSearchParams({
+      VoiceUrl: $.webhookUrl,
+    }).toString();
+
+    await $.http.post(
+      `/2010-04-01/Accounts/${$.auth.data.accountSid}/IncomingPhoneNumbers/${phoneNumberSid}.json`,
+      payload
+    );
+  },
+
+  async unregisterHook($) {
+    const phoneNumberSid = $.step.parameters.phoneNumberSid;
+
+    const payload = new URLSearchParams({
+      VoiceUrl: '',
+    }).toString();
+
+    await $.http.post(
+      `/2010-04-01/Accounts/${$.auth.data.accountSid}/IncomingPhoneNumbers/${phoneNumberSid}.json`,
+      payload
+    );
+  },
+});

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

@@ -20,7 +20,7 @@ export default defineTrigger({
         arguments: [
           {
             name: 'key',
-            value: 'listIncomingPhoneNumbers',
+            value: 'listIncomingSmsPhoneNumbers',
           },
         ],
       },