inbound-call-status.js

import { validateTwilioSignature, twilio } from '../../../shared/twilio';
import { getBaseUrl } from '../../../shared/utils';
import { updateInboundPhoneCall } from '../phone-call-actions';
import * as qs from 'querystring';
import { twiml } from 'twilio';
import rqstbin from '../../../shared/rqstbin';

/**
 * Inbound call status webhook handler.
 *
 * @param {object} event - 8base event.
 * @param {object} ctx - 8base context.
 *
 * @returns {Promise} The webhook response.
 */
export default async function(event, ctx) {
  console.log('call: Running Inbound Call Status Webhook...');
  const body = qs.parse(event.body);
  const url = `${getBaseUrl(ctx)}/webhook/inbound-call/status`;
  const signature = event.headers['X-Twilio-Signature'];
  const options = { checkPermissions: false };
  let call = null;

  let twilioClient = await twilio(body.AccountSid);

  //rqstbin({msg: 'got here', from: "inbound-call-status"})

  if (validateTwilioSignature(signature, url, body) == false) {
    console.log('call: inbound-call-status Invalid twilio signature [' + signature + ']');

    return {
      statusCode: 401,
      body: {
        message: 'Unauthorized request',
      },
    };
  } else {
    rqstbin({ signature: 'valid', from: 'inbound-call-status' });
  }

  console.log('call: inbound-call-status CallSid', body.CallSid + ' status: ', body.CallStatus);

  if (body.CallStatus === 'completed') {
    try {
      call = await twilioClient.calls(body.CallSid).fetch();
      console.log('call: inbound-call-status', call);
    } catch (e) {
      console.error('call: inbound-call-status Error fetching call from Twilio:', e.message);

      const response = new twiml.VoiceResponse();

      response.say(`Could not fetch call from twilio: ${e.message}`);

      console.log('call: inbound-call-status Could not fetch call from twilio:', e.message);
      return {
        statusCode: 200,
        body: response.toString(),
      };
    }
  }

  try {
    let callUpdate = await updateInboundPhoneCall(
      { callSid: body.CallSid },
      {
        dialCallSid: body.DialCallSid,
        status: body.CallStatus,
        duration: Number(body.CallDuration),
        ...(call && call.price
          ? {
            price: Math.abs(parseFloat(call.price)),
            priceUnit: call.priceUnit || 'USD',
          }
          : {}),
      },
      ctx,
      options,
    );
    console.log(
      'call: inbound-call-status InboundPhoneCall was updated',
      JSON.stringify(callUpdate),
    );
  } catch (e) {
    console.error('call: inbound-call-status Error updating the call:', e.message);

    const response = new twiml.VoiceResponse();

    response.say(`Something happened updating the call: ${e.message}`);
    return {
      statusCode: 200,
      body: response.toString(),
    };
  }

  return {
    statusCode: 200,
    body: JSON.stringify({
      success: true,
    }),
  };
}