Twilio Voice

const axios = require('axios');

exports.handler = async function (context, event, callback) {
  const asappApiId = context.ASAPP_API_ID;
  const asappApiSecret = context.ASAPP_API_SECRET;
  const asappApiHost = context.ASAPP_API_HOST;

  // Authenticate with ASAPP to obtain a Twilio Media Stream URL
  const url = `${asappApiHost}/mg-genagent/v1/twilio-media-stream-url`;

  console.log('Call event:', event);

  const twiml = new Twilio.twiml.VoiceResponse();

  // Configure input parameters for the media stream
  const inputParameters = {
    "asapp_callTransferId": event.CallSid,
    "asapp_externalConversationId": event.CallSid // Use CallSid as external conversation ID for tracking
    // Add additional input parameters to be passed as inputVariables as needed:
    // "customerId": "customer123",
    // "taskName": "customer_support"
  };

  try {
    // Request streaming URL from ASAPP
    const res = await axios.get(url, {
      headers: {
        'asapp-api-id': asappApiId,
        'asapp-api-secret': asappApiSecret,
        'Content-Type': 'application/json'
      }
    });

    if (res.status === 200) {
      console.log('Streaming URL obtained:', res.data);
      
      // Configure the media stream with the obtained URL
      const connect = twiml.connect({
        action: `https://${context.DOMAIN_NAME}/call-complete?callSid=${event.CallSid}`
      });
      const stream = connect.stream({ url: res.data.streamingUrl });
      
      // Add input parameters as stream parameters
      if (inputParameters) {
        for (const name in inputParameters) {
          stream.parameter({name: name, value: inputParameters[name]});
        }
      }

      return callback(null, twiml);
    } else {
      console.error(`API request failed: ${res.status} ${res.statusText}`);
      twiml.say('We are experiencing technical difficulties. Please try again later.');
      return callback(null, twiml);
    }
  } catch (error) {
    console.error('Error:', error);
    twiml.say('We are experiencing technical difficulties. Please try again later.');
    return callback(null, twiml);
  }
};

const axios = require('axios');

exports.handler = async function (context, event, callback) {
  const asappApiId = context.ASAPP_API_ID;
  const asappApiSecret = context.ASAPP_API_SECRET;
  const asappApiHost = context.ASAPP_API_HOST;

  console.log('Call completed:', event);

  try {
    // Get call transfer state after call ends
    const callSid = event.CallSid;
    const resultUrl = `${asappApiHost}/generativeagent/v1/call-transfers/${callSid}`;
    const resultRes = await axios.get(resultUrl, {
      headers: {
        'asapp-api-id': asappApiId,
        'asapp-api-secret': asappApiSecret,
        'Content-Type': 'application/json'
      }
    });
    
    if (resultRes.status === 200) {
      const result = resultRes.data;
      console.log('Call transfer result:', result);
      
      // Handle the result based on your business logic
      if (result.outputContext) {
        const transferType = result.outputContext.transferType;
        const transferVariables = result.outputContext.transferVariables;
        
        // Process based on transfer type
        switch (transferType) {
          case 'AGENT':
            console.log('Transfer to agent required');
            // Implement your agent transfer logic here
            // Examples: Update CRM, send notification, route to queue
            break;
          case 'SYSTEM':
            console.log('System transfer with variables:', transferVariables);
            // Implement your system transfer logic here
            // Examples: Update database, trigger follow-up actions
            break;
          default:
            console.log('Conversation completed successfully');
        }
      }
    }
  } catch (error) {
    console.error('Error fetching call transfer state:', error);
  }
  
  return callback(null, 'OK');
};

const axios = require('axios');

exports.handler = async function (context, event, callback) {
  const asappApiId = context.ASAPP_API_ID;
  const asappApiSecret = context.ASAPP_API_SECRET;
  const asappApiHost = context.ASAPP_API_HOST;

  console.log('Call completed:', event);

  try {
    // Get call transfer state after call ends
    const callSid = event.CallSid;
    const resultUrl = `${asappApiHost}/generativeagent/v1/call-transfers/${callSid}`;
    const resultRes = await axios.get(resultUrl, {
      headers: {
        'asapp-api-id': asappApiId,
        'asapp-api-secret': asappApiSecret,
        'Content-Type': 'application/json'
      }
    });
    
    if (resultRes.status === 200) {
      const result = resultRes.data;
      console.log('Call transfer result:', result);
      
      // Return call transfer data for the flow to use
      const flowVariables = {
        callTransferStatus: result.status, // Call status from API
        transferType: null,
        currentTaskName: null,
        referenceVariables: null,
        transferVariables: null
      };
      
      if (result.outputContext) {
        flowVariables.transferType = result.outputContext.transferType;
        flowVariables.currentTaskName = result.outputContext.currentTaskName;
        flowVariables.referenceVariables = result.outputContext.referenceVariables;
        flowVariables.transferVariables = result.outputContext.transferVariables;
      }
      
      // Return the call transfer data to the flow
      return callback(null, flowVariables);
    } else {
      console.error(`API request failed: ${resultRes.status} ${resultRes.statusText}`);
      return callback(new Error('Failed to fetch call transfer state'));
    }
  } catch (error) {
    console.error('Error fetching call transfer state:', error);
    return callback(error);
  }
};