[Twilio+Node.js+AWS Lambda] サーバー通知を SMS で自動配信する Web アプリケーションの作成

const twilio = require("twilio");

// 各環境変数については本記事にて後述
const accountSid = process.env.TWILIO_ACCOUNT_SID;
const authToken = process.env.TWILIO_AUTH_TOKEN;
const twilioPhoneNumber = process.env.TWILIO_PHONE_NUMBER;

const client = new twilio(accountSid, authToken);

/**
 * Twilio を使って SMS を送信するミドルウェア関数
 * @param {string} to - 送信先の電話番号
 * @param {string} message - 送信するメッセージ
 * @returns {Promise<string>} - 送信したメッセージの SID
 */
async function sendNotification(to, message) {
    if (!to || !message) {
        throw new Error("Missing 'to' or 'message' parameter");
    }

    try {
        const response = await client.messages.create({
            body: message,
            from: twilioPhoneNumber,
            to: to,
        });

        console.log(`SMS sent to ${to}: ${message}`);
        return response.sid;
    } catch (error) {
        console.error("Error sending SMS:", error);
        throw new Error("Failed to send SMS");
    }
}

module.exports = { sendNotification };

const twilioNotifications = require("./middleware/twilioNotifications");

exports.handler = async (event) => {
    let body;
    try {
        body = JSON.parse(event.body);
    } catch (error) {
        return {
            statusCode: 400,
            body: JSON.stringify({error: "Invalid JSON format"}),
        };
    }

    const {to, message} = body;

    if (!to || !message) {
        return {
            statusCode: 400,
            body: JSON.stringify({error: "Missing 'to' or 'message' in request body"}),
        };
    }

    try {
        // 何らかの処理（ここでは `message: "error"` の場合にエラーを発生）
        if (message.toLowerCase() === "error") {
            throw new Error("Intentional error for testing Twilio SMS notifications");
        }

        return {
            statusCode: 200,
            body: JSON.stringify({message: "Processing successful"}),
        };
    } catch (error) {
        console.error("Error occurred:", error.message);

        // Twilio ミドルウェアを使ってエラーメッセージを送信
        try {
            await twilioNotifications.sendNotification(to, `Lambda Error: ${error.message}`);
        } catch (twilioError) {
            console.error("Failed to send Twilio notification:", twilioError.message);
        }

        return {
            statusCode: 500,
            body: JSON.stringify({error: error.message}),
        };
    }
};

{
  "body": "{\"to\": \"****\", \"message\": \"error\"}"
}

$ curl https://****.amazonaws.com/test-twilio-notification -H "Content-Type: application/json" -d '{"to": "****", "message": "error"}'
{"error":"Intentional error for testing Twilio SMS notifications"}