Twilioに電話があったら、公式LINEに通知するシステムを構築してみた

exports.handler = function(context, event, callback) {
  const response = new Twilio.Response();
  response.appendHeader('Content-Type', 'application/json');
  response.setBody({ status: 'success' });


  // もし line からの JSON が event.body に文字列として入る場合:
  let parsedBody;
  if (typeof event.body === 'string') {
    try {
      parsedBody = JSON.parse(event.body);
    } catch (e) {
      console.error('JSON parse error:', e);
      parsedBody = {};
    }
  } else {
    // そもそも event.body が存在しない、またはすでにパース済みなら:
    parsedBody = event;
  }


  // ここで parsedBody.events があればユーザーIDを取得
  if (parsedBody.events && parsedBody.events.length > 0) {
    let userId = parsedBody.events[0].source.userId;
    console.log('User ID:', userId);
  } else {
    console.log('No events found in parsedBody');
  }
  callback(null, response);
};

exports.handler = function(context, event, callback) {
    const VoiceResponse = require('twilio').twiml.VoiceResponse;
    let response = new VoiceResponse();

    response.say({ language: 'ja-JP' }, 'この電話は留守番電話に接続されます。メッセージをどうぞ。');

    response.record({
        maxLength: 60, // 最大録音時間
        playBeep: true,
        recordingStatusCallback: 'https://voicemail-line-1956.twil.io/recording-complete',
        recordingStatusCallbackMethod: 'POST',
        statusCallback: 'https://voicemail-line-1956.twil.io/recording-complete',
        statusCallbackMethod: 'POST',
        statusCallbackEvent: ['ringing', 'answered', 'completed'] ,
        timeout: 5
    });

    response.hangup();
    return callback(null, response);
};

exports.handler = async function(context, event, callback) {
    const axios = require('axios');
    let recordingUrl = event.RecordingUrl + '.mp3';
    let callSid = event.CallSid;
    let recordingDuration = event.RecordingDuration;
    let callTime = new Date().toLocaleString("ja-JP", { timeZone: "Asia/Tokyo" });  // 日本時間の通話時刻

    console.log("🔍 受け取った event データ:", JSON.stringify(event, null, 2));

    // Twilio の `+81` を日本の電話番号形式（0から始まる）に変換
    let fromNumber = event.From || "不明";


    // ログ出力: Twilio から受け取った `event.From` の値を確認
    console.log(`🔍 Twilioから受け取った発信元番号 (event.From): ${fromNumber}`);

    if (fromNumber.startsWith("+81")) {
        fromNumber = "0" + fromNumber.slice(3);  // `+81` を `0` に置き換え
    }

    console.log(`📞 変換後の発信元番号: ${fromNumber}`);

    let messageText = `📞 留守電がありました。\n🕒 通話時間: ${callTime}\n📱 発信元: ${fromNumber}\n🔹 CallSID: ${callSid}\n⏳ 録音時間: ${recordingDuration}秒\n🎵 音声URL: ${recordingUrl}`;

    // 環境変数から複数のLINE IDを取得
    let userIds = context.LINE_TARGET_USER_ID.split(',');

    try {
        // 各ユーザーIDに対して通知を送る
        await Promise.all(userIds.map(async (userId) => {
            let response = await axios.post(
                'https://api.line.me/v2/bot/message/push',
                {
                    to: userId.trim(),
                    messages: [{ type: 'text', text: messageText }]
                },
                {
                    headers: {
                        'Content-Type': 'application/json',
                        'Authorization': `Bearer ${context.LINE_CHANNEL_ACCESS_TOKEN}`
                    }
                }
            );
            console.log(`✅ LINE通知送信成功 (UserID: ${userId}):`, response.data);
        }));

        return callback(null, { status: 'success' });
    } catch (error) {
        console.error('❌ エラー:', error);
        return callback(error);
    }
};