shellphone.app/app/phone-calls/api/webhook/call.ts

162 lines
4.6 KiB
TypeScript
Raw Normal View History

import type { BlitzApiRequest, BlitzApiResponse } from "blitz";
2021-08-13 17:16:27 +00:00
import twilio from "twilio";
2021-07-31 14:33:18 +00:00
import db, { Direction } from "../../../../db";
2021-08-13 17:16:27 +00:00
import appLogger from "../../../../integrations/logger";
import { translateCallStatus, voiceUrl } from "../../../../integrations/twilio";
import updateCallDurationQueue from "../queue/update-call-duration";
2021-09-26 22:08:02 +00:00
import type { ApiError } from "../../../core/types";
2021-08-13 17:16:27 +00:00
const logger = appLogger.child({ route: "/api/webhook/call" });
export default async function incomingCallHandler(req: BlitzApiRequest, res: BlitzApiResponse) {
console.log("req.body", req.body);
2021-08-13 17:16:27 +00:00
const twilioSignature = req.headers["X-Twilio-Signature"] || req.headers["x-twilio-signature"];
if (!twilioSignature || Array.isArray(twilioSignature)) {
const statusCode = 400;
const apiError: ApiError = {
statusCode,
errorMessage: "Invalid header X-Twilio-Signature",
};
logger.error(apiError);
res.status(statusCode).send(apiError);
return;
}
const isOutgoingCall = req.body.From.startsWith("client:");
if (isOutgoingCall) {
const recipient = req.body.To;
const organizationId = req.body.From.slice("client:".length).split("__")[0];
const phoneNumber = await db.phoneNumber.findFirst({
where: { organizationId },
2021-08-13 17:16:27 +00:00
include: { organization: true },
});
if (
!phoneNumber ||
!phoneNumber.organization.twilioAuthToken ||
!twilio.validateRequest(phoneNumber.organization.twilioAuthToken, twilioSignature, voiceUrl, req.body)
2021-08-13 17:16:27 +00:00
) {
const statusCode = 400;
const apiError: ApiError = {
statusCode,
errorMessage: "Invalid webhook",
};
logger.error(apiError);
res.status(statusCode).send(apiError);
return;
}
await db.phoneCall.create({
data: {
id: req.body.CallSid,
from: phoneNumber.number,
to: req.body.To,
status: translateCallStatus(req.body.CallStatus),
2021-08-13 17:16:27 +00:00
direction: Direction.Outbound,
duration: "0",
2021-08-13 17:16:27 +00:00
organizationId: phoneNumber.organization.id,
phoneNumberId: phoneNumber.id,
},
});
await updateCallDurationQueue.enqueue(
{
organizationId: phoneNumber.organization.id,
callId: req.body.CallSid,
},
{ delay: "30s" },
);
2021-08-13 17:16:27 +00:00
const twiml = new twilio.twiml.VoiceResponse();
const dial = twiml.dial({
answerOnBridge: true,
callerId: phoneNumber!.number,
});
dial.number(recipient);
console.log("twiml", twiml.toString());
res.setHeader("content-type", "text/xml");
return res.status(200).send(twiml.toString());
2021-08-13 17:16:27 +00:00
} else {
const phoneNumbers = await db.phoneNumber.findMany({
where: { number: req.body.To },
include: { organization: true },
});
if (phoneNumbers.length === 0) {
// phone number is not registered by any organization
res.status(500).end();
return;
}
const phoneNumber = phoneNumbers.find((phoneNumber) => {
// if multiple organizations have the same number
// find the organization currently using that phone number
// maybe we shouldn't let multiple organizations use the same phone number
const authToken = phoneNumber.organization.twilioAuthToken ?? "";
return twilio.validateRequest(authToken, twilioSignature, voiceUrl, req.body);
2021-08-13 17:16:27 +00:00
});
if (!phoneNumber) {
const statusCode = 400;
const apiError: ApiError = {
statusCode,
errorMessage: "Invalid webhook",
};
logger.error(apiError);
res.status(statusCode).send(apiError);
return;
}
// TODO dial.client("unique id of device user is picking up with");
2021-08-13 17:16:27 +00:00
// TODO send notification
// TODO db.phoneCall.create(...);
2021-08-30 20:13:40 +00:00
// TODO subscribe to status updates to update duration when call ends
}
res.status(500).end();
}
const outgoingBody = {
AccountSid: "ACa886d066be0832990d1cf43fb1d53362",
ApiVersion: "2010-04-01",
ApplicationSid: "AP6334c6dd54f5808717b37822de4e4e14",
CallSid: "CA3b639875693fd8f563e07937780c9f5f",
CallStatus: "ringing",
Called: "",
Caller: "client:95267d60-3d35-4c36-9905-8543ecb4f174__673b461a-11ba-43a4-89d7-9e29403053d4",
Direction: "inbound",
From: "client:95267d60-3d35-4c36-9905-8543ecb4f174__673b461a-11ba-43a4-89d7-9e29403053d4",
To: "+33613370787",
};
2021-08-30 20:13:40 +00:00
const incomingBody = {
AccountSid: "ACa886d066be0832990d1cf43fb1d53362",
ApiVersion: "2010-04-01",
ApplicationSid: "APa43d85150ad6f6cf9869fbe1c1e36a66",
CallSid: "CA09a5d9a4cfacf2b56d66f8f743d2881a",
CallStatus: "ringing",
Called: "+33757592025",
CalledCity: "",
CalledCountry: "FR",
CalledState: "",
CalledZip: "",
Caller: "+33613370787",
CallerCity: "",
CallerCountry: "FR",
CallerState: "",
CallerZip: "",
Direction: "inbound",
From: "+33613370787",
FromCity: "",
FromCountry: "FR",
FromState: "",
FromZip: "",
To: "+33757592025",
ToCity: "",
ToCountry: "FR",
ToState: "",
ToZip: "",
};