twilio.ts

import * as pulumi from "@pulumi/pulumi";
import * as serverless from "@pulumi/aws-serverless";
import * as url from "url";
import { Callback } from "@pulumi/aws-serverless/function";
import { APIArgs } from "@pulumi/aws-serverless/api";

const config = new pulumi.Config("twilio");
const accountSid = config.require("accountSid");
const authToken = config.require("authToken");

export class IncomingPhoneNumber extends pulumi.ComponentResource {
    public /*out*/ readonly smsUrl: pulumi.Output<string>;

    constructor(name: string, args: IncomingPhoneNumberArgs, opts? : pulumi.ResourceOptions) {
        super("twilio:rest:IncomingPhoneNumber", name, {}, opts);

        const apiArgs : APIArgs = {
            routes: [{
                path: "/sms",
                method: "POST",
                handler: (e, ctx, cb) => {
                    // Twilio passes information to POST requests as application/x-www-form-urlencoded, so we decode
                    // the body of the request to get at it.
                    const qs = require("querystring");
                    const params = qs.parse(e.isBase64Encoded ? Buffer.from(e.body, "base64").toString() : e.body);

                    // Loop over any provided media and add it to our array.
                    const allMedia: MediaInfo[] = []
                    for (let i = 0; i < params.NumMedia; i++) {
                        allMedia.push({
                            ContentType: <string>params[`MediaContentType${i}`],
                            Url: <string>params[`MediaContentUrl${i}`]
                        })
                    }

                    // Copy the payload of the request into our representation.
                    const payload: SmsPayload = {
                        MessageSid: params.MessageSid,
                        AcountSid: params.AccountSid,
                        MessagingServiceSid: params.MessagingServiceSid,
                        From: params.From,
                        To: params.To,
                        Body: params.Body,
                        Media: allMedia,
                        FromLocation: {
                            City: params.FromCity,
                            State: params.FromState,
                            Zip: params.FromZip,
                            Country: params.FromCountry,
                        },
                        ToLocation: {
                            City: params.ToCity,
                            State: params.ToState,
                            Zip: params.ToZip,
                            Country: params.ToCountry,
                        }
                    }

                    // Delegate to the user provided handler.
                    return args.handler(payload, ctx, cb);
                }
            }]
        };

        const api = new serverless.apigateway.API(`${name}-api`, apiArgs, { parent: this });
        this.smsUrl = pulumi.interpolate `${api.url}sms`;

        // Use the twilio SDK to update the handler for the SMS webhook to what we just created.
        const twilio = require("twilio")
        const client = new twilio(accountSid, authToken);

        this.smsUrl.apply(url =>{
            client.incomingPhoneNumbers(args.phoneNumberSid).update({
                smsMethod: "POST",
                smsUrl: `${url}`
            }).done();
        });

        // Register the smsUrl as an output of the component itself.
        super.registerOutputs({
            smsUrl: this.smsUrl
        });
    }
}

export interface IncomingPhoneNumberArgs {
    phoneNumberSid: string,
    handler: Callback<SmsPayload, serverless.apigateway.Response>
}

// See https://www.twilio.com/docs/sms/twiml#request-parameters for more information about
// what each parameter means.
export interface SmsPayload {
    MessageSid: string,
    AcountSid: string,
    MessagingServiceSid: string,
    From: string,
    To: string,
    Body: string,
    Media: MediaInfo[];
    FromLocation: Location,
    ToLocation: Location,
}

// Twilio attempts to look up this information and provide it, but it may not always be present.
export interface Location {
    City?: string,
    State?: string,
    Zip?: string,
    Country?: string,
}

export interface MediaInfo {
    ContentType: string,
    Url: string,
}