const httpClient = require('https');

/* ReTell API Config */
const retell_token = "xxxxxx";
const retell_agent = "yyyyyyy";

async function httpsRequest(url, method = 'GET', headers = {}, body = null) {
    let response;

    if (method === 'POST') {
        response = await httpClient.post(url, { headers, body });
    } else if (method === 'PUT') {
        response = await httpClient.put(url, { headers, body });
    } else if (method === 'DELETE') {
        response = await httpClient.delete(url, { headers });
    } else if (method === 'GET') {
        response = await httpClient.get(url, { headers });
    } else {
        throw new Error(`Unsupported method: ${method}`);
    }

    const status = response.status || response.statusCode || 0;
    const ok = status >= 200 && status < 300;
    const responseBody = typeof response.body === 'string'
        ? response.body
        : JSON.stringify(response.body || {});

    return {
        status,
        ok,
        body: responseBody,
        headers: response.headers || {}
    };
}

async function generateReTellCall(ev) {
    const url = 'https://api.retellai.com/v2/register-phone-call';

    // SIP headers from Cloudonix
    const inboundSipHeaders = JSON.parse(ev.body).SessionData.profile['trunk-sip-headers'];

    const retellDynamicVariables = {
        cloudonix_callerid: ev.parameters.From,
        cloudonix_destination: ev.parameters.To,
        cloudonix_token: ev.parameters.Session,
        cloudonix_domain: ev.parameters.Domain
    };

    for (const key in inboundSipHeaders) {
        retellDynamicVariables[key] = inboundSipHeaders[key];
    }

    const payload = {
        agent_id: retell_agent,
        from_number: ev.parameters.From,
        to_number: ev.parameters.To,
        retell_llm_dynamic_variables: retellDynamicVariables
    };

    console.log(`Payload: ${JSON.stringify(payload)}`);

    const headers = {
        'Content-Type': 'application/json',
        'Authorization': 'Bearer ' + retell_token
    };

    try {
        const response = await httpsRequest(url, 'POST', headers, JSON.stringify(payload));

        if (!response.ok) {
            throw new Error(`ReTell call creation failed: ${response.status} - ${response.body}`);
        }

        const data = JSON.parse(response.body);

        console.log(`Success: ${data.call_id}`);
        return data.call_id;
    } catch (error) {
        console.error(`Error:`, error.message || error);
        await deleteSession(ev.parameters.Domain, ev.parameters.Session);
        return false;
    }
}


function dialToRetellScript(ev, retellCallId) {
    let  result = `<Dial callerId="${ev.parameters.From}">`;
        result += `   <Service provider="retell">${retellCallId}</Service>`;
        result += `<Dial>`;
    return result;    
}

function response(content) {
    let result  = `<?xml version="1.0"?>`;
        result += `<Response>${content}</Response>`;
    return result;
}

exports.handler = async (ev) => {
    let retellCallId = await generateReTellCall(ev);
    let cxmlResponse =  dialToRetellScript(ev, retellCallId);
    return response(cxmlResponse);
};