Add implementation to send call records to RDS

functions/statusCallback.protected.ts

@@ -1,7 +1,16 @@
 import { ServerlessFunctionSignature } from '@twilio-labs/serverless-runtime-types/types';
-import { StatusCallbackServerlessEventObject, TwilioEnvironmentVariables } from './types/interfaces';
+import { InsertParams, StatusCallbackServerlessEventObject, TwilioEnvironmentVariables } from './types/interfaces';
+import { connect, config, Request } from 'mssql';
 
-export const handler: ServerlessFunctionSignature<TwilioEnvironmentVariables, StatusCallbackServerlessEventObject> = function(
+const constructRequest = (request: Request, params: InsertParams) => {
+  const columns = Object.keys(params).join(", ")
+  const values = "@" + Object.keys(params).join(", @")
+  const builtRequest = Object.entries(params).reduce((req, [key, value]) => req.input(key, value), request)
+
+  return { columns, values, builtRequest }
+}
+
+export const handler: ServerlessFunctionSignature<TwilioEnvironmentVariables, StatusCallbackServerlessEventObject> = async function(
   context,
   event,
   callback,
@@ -12,7 +21,43 @@ export const handler: ServerlessFunctionSignature<TwilioEnvironmentVariables, St
     const callStartTimestamp = decodeURIComponent(event.request.cookies.callStartTimestamp)
     const callEndTimestamp = event.Timestamp
     const callDurationInSeconds = event.CallDuration
-    // Send into AWS RDS
+
+    const serverConfig: config = {
+      user: context.RDS_USER,
+      password: context.RDS_PASSWORD,
+      server: context.RDS_SERVER,
+      port: +context.RDS_PORT,
+      options: {
+        encrypt: false,
+        trustServerCertificate: false
+      }
+    };
+
+    const pool = await connect(serverConfig)
+
+    let insertParams: InsertParams = {
+      callerNumber,
+      callStartTimestamp,
+      callEndTimestamp,
+      callDurationInSeconds
+    }
+
+    if (logFileName !== "null") {
+      insertParams = {
+        ...insertParams,
+        logFileName
+      }
+    }
+
+    const { columns, values, builtRequest } = constructRequest(pool.request(), insertParams)
+
+    let sqlQuery = `
+    INSERT INTO CallRecords (${columns})
+    VALUES (${values})
+    `
+
+    await builtRequest.query(sqlQuery)
+    await pool.close()
   }
   const response = new Response();
   return callback(null, response)

functions/types/interfaces.d.ts

@@ -40,3 +40,11 @@ export interface TwilioEnvironmentVariables extends EnvironmentVariables {
   RDS_SERVER: string;
   RDS_PORT: string;
 }
+
+export interface InsertParams {
+  callStartTimestamp: string;
+  callEndTimestamp: string;
+  callDurationInSeconds: string;
+  callerNumber: string;
+  logFileName?: string;
+}