Advanced I/O Functionの設定

const express = require("express");
const app = express();
var twilio = require('twilio');
const VoiceResponse = require("twilio").twiml.VoiceResponse;
var catalyst = require('zcatalyst-sdk-node');
var YOUR_TWILIO_NUMBER = '+15612993019'; //Twilio電話番号に置き換えてください
var accountSid = "xxxxxxxxxxxxxxx"; //Twilio Account SIDに置き換えてください
var authToken = "{{7xxxxxxxxxxxxxxxxx8}}"; //Twilio Auth Tokenに置き換えてください
var twilioClient = twilio(accountSid, authToken);
var bodyParser = require('body-parser');
app.use(bodyParser.json()); // JSONエンコードされたボディをサポート
app.use(bodyParser.urlencoded({ extended: true })); // エンコードされたボディをサポート
app.post("/makeCall", async (req, res) => {
  try {
    var salesNumber = req.body.salesNumber;
    console.log(req.body)
    const catalystApp = catalyst.initialize(req);
    let rowData =
    {
      fromNumber: req.body.phoneNumber,
      toNumber: req.body.salesNumber
    };
    console.log(rowData)
    const catalystTable = catalystApp.datastore().table('CallLog');
    const data = await catalystTable.insertRow(rowData);
    var url = 'https://' + req.headers.host + '/server/dialer/outbound/' + encodeURIComponent(salesNumber);
    var options = {
      to: req.body.phoneNumber,
      from: YOUR_TWILIO_NUMBER,
      url: url,
      method: 'post',
      statusCallbackEvent: ['answered', 'completed'],
      statusCallback: 'https://' + req.headers.host + '/server/dialer/statusCheck?ROWID=' + data.ROWID,
      statusCallbackMethod: 'POST'
    };
    twilioClient.calls.create(options).then((call) => {
      res.status(200).send({ message: 'Call Initiated' });
    }).catch((error) => {
      console.log(error);
      res.status(500).send({ "error": error });
    });
  } catch (e) {
    console.log("Exception while making a Call ::" + e);
    res.status(500).send({ "error": 'Internal Server Error Occured. Please Try again after sometime.' });
  }
});
app.post('/outbound/:salesNumber', function (req, res) {
  try {
    var salesNumber = req.params.salesNumber;
    var twimlResponse = new VoiceResponse();
    twimlResponse.say('Thanks for trying out the Catalyst Dialer App. Please hold on so that we can connect with your Customer... ', { voice: 'alice' });
    twimlResponse.dial(salesNumber);
    res.status(200).send(twimlResponse.toString());
  } catch (e) {
    console.log("Exception while making Outbound Call ::" + e);
    res.status(500).send({ "error": 'Internal Server Error Occured. Please Try again after sometime.' });
  }
});
app.post('/statusCheck', async (req, res) => {
  try {
    const catalystApp = catalyst.initialize(req);
    if (req.body.CallStatus === "completed") {
      let updatedRowData = {
        callDuration: req.body.CallDuration,
        callStatus: req.body.CallStatus,
        calledCountry: req.body.CalledCountry,
        calledState: req.body.CalledState,
        timeOfCall: req.body.Timestamp,
        ROWID: req.body.ROWID
      };
      console.log(updatedRowData)
      const catalystTable = catalystApp.datastore().table('CallLog');
      await catalystTable.updateRow(updatedRowData);
    }
    res.status(200).send(' StatusCheck Completed');
  } catch (e) {
    console.log("Exception while checking status :: " + e);
    res.status(500).send({ "error": 'Internal Server Error Occured. Please Try again after sometime.' });
  }
});
app.get('/getLogs', async function (req, res) {
  try {
    const catalystApp = catalyst.initialize(req);
    const query = 'SELECT callDuration,callStatus,calledCountry,timeOfCall,fromNumber,toNumber FROM CallLog';
    const queryResult = await catalystApp.zcql().executeZCQLQuery(query);
    res.status(200).send(queryResult);
  } catch (e) {
    console.log("Exception while getting Call Logs ::" + e);
    res.status(500).send({ "error": 'Internal Server Error Occured. Please Try again after sometime.' });
  }
});
module.exports = app;