Twilio Studio と Functions で留守番電話検出付き一次・二次発信フローを作る

{
  "description": "A New Flow",
  "states": [
    {
      "name": "Trigger",
      "type": "trigger",
      "transitions": [
        {
          "event": "incomingMessage"
        },
        {
          "event": "incomingCall"
        },
        {
          "event": "incomingConversationMessage"
        },
        {
          "next": "call_primary",
          "event": "incomingRequest"
        },
        {
          "event": "incomingParent"
        }
      ],
      "properties": {
        "offset": {
          "x": 0,
          "y": 0
        }
      }
    },
    {
      "name": "call_primary",
      "type": "make-outgoing-call-v2",
      "transitions": [
        {
          "next": "branch_answered_by",
          "event": "answered"
        },
        {
          "next": "notify_secondary",
          "event": "busy"
        },
        {
          "next": "notify_secondary",
          "event": "noAnswer"
        },
        {
          "next": "notify_secondary",
          "event": "failed"
        }
      ],
      "properties": {
        "machine_detection_speech_threshold": "2400",
        "detect_answering_machine": true,
        "offset": {
          "x": 630,
          "y": 240
        },
        "recording_channels": "mono",
        "timeout": 60,
        "machine_detection": "Enable",
        "trim": "do-not-trim",
        "record": false,
        "machine_detection_speech_end_threshold": "1200",
        "machine_detection_timeout": "30",
        "from": "{{flow.channel.address}}",
        "to": "{{contact.channel.address}}",
        "machine_detection_silence_timeout": "5000"
      }
    },
    {
      "name": "branch_answered_by",
      "type": "split-based-on",
      "transitions": [
        {
          "next": "notify_secondary",
          "event": "noMatch"
        },
        {
          "next": "say_message_primary",
          "event": "match",
          "conditions": [
            {
              "friendly_name": "If value equal_to human",
              "arguments": [
                "{{widgets.call_primary.AnsweredBy}}"
              ],
              "type": "equal_to",
              "value": "human"
            }
          ]
        }
      ],
      "properties": {
        "input": "{{widgets.call_primary.AnsweredBy}}",
        "offset": {
          "x": 950,
          "y": 530
        }
      }
    },
    {
      "name": "say_message_primary",
      "type": "say-play",
      "transitions": [
        {
          "event": "audioComplete"
        }
      ],
      "properties": {
        "voice": "Polly.Takumi",
        "offset": {
          "x": 1190,
          "y": 790
        },
        "loop": 1,
        "say": "システムからのお知らせです。",
        "language": "ja-JP"
      }
    },
    {
      "name": "notify_secondary",
      "type": "run-function",
      "transitions": [
        {
          "event": "success"
        },
        {
          "event": "fail"
        }
      ],
      "properties": {
        "service_sid": "ZSXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
        "environment_sid": "ZEXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
        "offset": {
          "x": 250,
          "y": 790
        },
        "function_sid": "ZHXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
        "parameters": [
          {
            "value": "{{widgets.call_primary.CallSid}}",
            "key": "callSid"
          },
          {
            "value": "{{widgets.call_primary.AnsweredBy}}",
            "key": "answeredBy"
          },
          {
            "value": "{{flow.flow_sid}}",
            "key": "executionSid"
          }
        ],
        "url": "https://{your-function-service-domain}.twil.io/call-secondary"
      }
    }
  ],
  "initial_state": "Trigger",
  "flags": {
    "allow_concurrent_calls": true
  }
}

exports.handler = async function (context, event, callback) {
  const client = context.getTwilioClient();

  const flowSid = context.FLOW_SID;
  const to = context.PRIMARY_NUMBER;   // 一次番号
  const from = context.CALLER_ID;      // Twilio 発信元番号

  try {
    await client.studio.v2.flows(flowSid)
      .executions
      .create({
        to,
        from,
        parameters: { requestId: event.requestId || null }
      });

    const response = new Twilio.Response();
    response.setStatusCode(200);
    response.setBody({ status: 'ok' });
    callback(null, response);
  } catch (err) {
    console.error(err);
    const response = new Twilio.Response();
    response.setStatusCode(500);
    response.setBody({ error: err.message });
    callback(null, response);
  }
};

exports.handler = async function (context, event, callback) {
  const client = context.getTwilioClient();

  const to = context.SECONDARY_NUMBER;
  const from = context.CALLER_ID;

  // AMD の結果をログ出力
  console.log('Primary AnsweredBy:', event.answeredBy);
  console.log('Primary CallSid:', event.callSid);

  // 二次側に読み上げるメッセージ
  const twiml = new Twilio.twiml.VoiceResponse();
  twiml.say(
    {
      language: 'ja-JP'
    },
    '一次の連絡先に接続できなかったため、この番号にご連絡しています。システムからのお知らせです。'
  );

  try {
    await client.calls.create({
      to,
      from,
      twiml: twiml.toString()
      // 必要に応じて二次発信にも AMD を付けられます
      // machineDetection: 'Enable'
    });

    const response = new Twilio.Response();
    response.setStatusCode(200);
    response.setBody({ status: 'secondary call started' });
    callback(null, response);
  } catch (err) {
    console.error(err);
    const response = new Twilio.Response();
    response.setStatusCode(500);
    response.setBody({ error: err.message });
    callback(null, response);
  }
};