messaging.js

require("dotenv").config();
const ngrok_domain = process.env.NGROK_DOMAIN;
const bodyParser = require("body-parser");

const express = require("express");
const { MessagingResponse } = require("twilio").twiml;
const VoiceResponse = require("twilio").twiml.VoiceResponse;
const { connectToDB } = require("./databaseProvider");

const app = express();

app.use(bodyParser.urlencoded({ extended: false }));

app.post("/sms", async (req, res) => {
  const twiml = new MessagingResponse();

  const userMessage = req.body.Body;

  //TODO: We have the user message for a peer review of the chosen employee, write it to the database.
  const document = {
    target: "Tim",
    response: userMessage,
  };

  const client = await connectToDB();
  const collection = await client.collection("surveys");

  collection.insertOne(document, function (err, res) {
    if (err) throw err;
    console.log("1 document inserted");
    client.close();
  });

  twiml.message(
    "Thank you for letting me know. Remember, you can always reach out to these resources if you are ever struggling and need someone to talk to. https://www.betterhelp.com/"
  );

  res.type("text/xml").send(twiml.toString());
});

// Returns TwiML which prompts the caller to record a message
app.post("/record", (request, response) => {
  // Use the Twilio Node.js SDK to build an XML response
  const twiml = new VoiceResponse();
  twiml.say(
    { voice: "Polly.Amy" },
    "Hello, we wanted to check in on you to see how you are doing. Is there anything you want to talk about?"
  );

  twiml.record({
    maxLength: 30,
  });

  // End the call with <Hangup>
  twiml.hangup();

  // Render the response as XML in reply to the webhook request
  response.type("text/xml");
  response.send(twiml.toString());
});

// Returns TwiML which prompts the caller to record a message
app.post("/transcript", async (request, response) => {
  console.log("Transcript received");

  const transcription =
    "I have been really stressed out lately and it is affecting my mental health. I am not sure what to do about it.";

  const document = {
    target: "Farhan",
    voice_response: transcription,
  };

  const client = await connectToDB();
  const collection = await client.collection("voice_transcripts");

  collection.insertOne(document, function (err, res) {
    if (err) throw err;
    console.log("1 document inserted");
    client.close();
  });
});

app.listen(3000, () => {
  console.log("Express server listening on port 3000");
});