server.js

import express from 'express'
import alexa from './workflows/alexa_workflow.js'
import twilio from 'twilio'
import PatientDB from './schemas/patientDB.js'
import path from 'path'
import { fileURLToPath } from 'url'
import { relay } from '@relaypro/sdk'
import axios from 'axios'
import qs from 'qs'
import {eventEmitter} from './workflows/alexa_workflow.js'
const VoiceResponse = twilio.twiml.VoiceResponse

/*
* Express server config
*/
const port = process.env.PORT || 3000
const __dirname = path.dirname(fileURLToPath(import.meta.url))
const _server = express()
_server.set('view engine', 'ejs')
_server.use(express.urlencoded({extended: true}))
_server.use(express.json())

let ack = false

// Create a route that will handle Twilio webhook requests, sent as an
// HTTP POST to /voice in our application
_server.post('/voice', async (req, res) => {
  // Get information about the incoming call, like the city associated
  // with the phone number (if Twilio can discover it)
  ack = false
  const caller_number = req.body.From
  let data = get_patient_info(caller_number)
  // Use the Twilio Node.js SDK to build an XML response
  console.log(data)
  const twiml = new VoiceResponse()
  twiml.say(`Your request has been sent to your nurse. Please hold`)
  setTimeout(function () {
    send_notification(data.relay_id, data.relay_wf_id, data.name, data.room)
  }, 7000)
  // Render the response as XML in reply to the webhook request
  twiml.redirect('/stall')
  res.type('text/xml')
  res.send(twiml.toString())
  console.log("done processing")
})

_server.post('/stall', async  (req, res) => {
  const twiml = new VoiceResponse()
  if (ack) {
    twiml.say(`Your nurse will be coming to assist you shortly! Thank You!`)
  } else {
    twiml.redirect('/stall')
  }
  res.type('text/xml')
  res.send(twiml.toString())
})

eventEmitter.on(`ack`, async (text) => {
  setTimeout(function () {
    ack = true
  }, 5000)
})

function sleep(ms) {
  return new Promise((resolve) => {
    setTimeout(resolve, ms)
  })
}   

function get_patient_info(caller_number) {
  let patientDB = {}
  let sample_from_number = process.env.SAMPLE_NUMBER
  let data = {
    name: "Jon Doe",
    room: "231",
    relay_id: process.env.RELAY_ID,
    relay_wf_id: process.env.RELAY_WF_ID,
    nurse_name: "jo jo"
  }

  //let data = patientDB[caller_number]
  return data
}

/*
* This function initiates the workflow on the specified device_id
*/
async function send_notification(device_id, wf_id, name, room) {
  console.log("IN SEND NOTIF")
  let access_token = await get_access_token()
  console.log(name)
  console.log(room)
  console.log("IN SEND_NOTIFICATION")
  const params = qs.stringify({
      'subscriber_id': process.env.SUBSCRIBER_ID,
      'user_id': device_id
  })
  let ibot_endpoint = process.env.IBOT_ENDPOINT
  try { 
      const response = await axios.post(`${ibot_endpoint}${wf_id}?${params}`,
          {
              "action": "invoke",
              "action_args": {
                  "name": name,
                  "room": room
              }
          },
          { 
              headers : {
                  'Authorization': 'Bearer ' + access_token
              }
          })
      if (response.status == 200) {
          console.log(`Remote trigger invoked`)
          console.log(response.statusText)
          return response.statusText
      } else {
          console.log('something wrong happened within send_notification')
      }
  } catch (e) {
      console.error(e)
  }
}

/*
* This function generates an access token to hit the ibot API
*/
async function get_access_token() {
  let response = await axios({
      method: 'post',
      headers: {
          'content-type' : 'application/x-www-form-urlencoded', 
          'Authorization': `Basic ${process.env.TOKEN}`
      },
      url: process.env.OAUTH_ENDPOINT,
      data: qs.stringify({
          grant_type: 'password',
          client_id: process.env.CLIENT_ID,
          scope: 'openid',
          username: process.env.TOKEN_USERNAME,
          password: process.env.TOKEN_PASS
      }),
  })
  return response.data.access_token
}



// Create an HTTP server and listen for requests on port 3000
const server = _server.listen(port, function() {
    console.log("Web server listening on port: " + port)
})

const app = relay({server})
app.workflow(`alexa`, alexa)