botLeiferAurik-Mod_2.0/adapter/index.js

const { getData, getReply, saveMessageMysql } = require('./mysql')
const { saveMessageJson } = require('./jsonDb')
const { getDataIa } = require('./diaglogflow')
// const  stepsInitial = require('../flow/initial.json')
const  stepsReponse = require('../flow/response.json')
// const { isUndefined } = require('util');
var ultimoStep; //MOD by CHV - 
var pasoRequerido; //MOD by CHV - 
var _vamosA = ""; //MOD by CHV - 
var VA = ""; //MOD by CHV - 
var elNum; //MOD by CHV - 
var cumplePasoPrevio = []; //MOD by CHV - 
const resps = require('../flow/response.json'); //MOD by CHV - Agregamos para traer las respuestas.
// const { appendFile, existsSync } = require('fs')
// const { traeVariables } = require(`../provider/${provider}.js`)

/**
 * Regresa un arreglo de objetos como el stepsInitial original, que se generaba desde "initial.json".
 * Contiene el nombre del paso (key) y las palabras clave correspondientes (keywords).
 */
const getStepsInitial = () => {
    let contSI = 0
    let stepsInitial0 = []
    for (const resp in stepsReponse) {
        // console.log(`${resp}: ${stepsReponse[resp]['keywords']}`);
        if(stepsReponse[resp]['keywords'] !== undefined){
            stepsInitial0[contSI]= {"keywords":stepsReponse[resp]['keywords'], "key":resp}
            contSI++
        }
    }
    return stepsInitial0
}
const stepsInitial = getStepsInitial()

/**
 * Revisa si el texto del mensaje dispara alguna regla (body == keyword)
 * @param {*} message 
 * @param {*} num 
 * @returns 
 */
const get = (message, num) => new Promise((resolve, reject) => { //MOD by CHV - Agregamos parametro "num" para recibir el número de "app.js" 
    // console.log(num)
    elNum = num //MOD by CHV - 
    if(siguientePaso.find(k => k.numero.includes(elNum))){
        console.log("siguientePaso="+siguientePaso.find(k => k.numero.includes(elNum))["numero"], siguientePaso.find(k => k.numero.includes(elNum))["va"])        
        pasoAnterior[elNum] = siguientePaso.find(k => k.numero.includes(elNum))["va"] //Asignamos pasoAnterior al número.
        siguientePaso.splice(siguientePaso.indexOf(elNum), 1)
        console.log("********************   "+siguientePaso.find(k => k.numero.includes(elNum)))
    }
    if(siguientePaso.length>1){console.log(siguientePaso[1]["numero"], siguientePaso[1]["va"])}

    /**
     * Si no estas usando una base de datos
     */
    if (process.env.DATABASE === 'none') {
        //******************************************************************************** */
        var logKeysArray = false  // Poner en verdadero para ver logs de esta seccion.
        //******************************************************************************** */
        key = null
        let q = 0;
        if(logKeysArray) console.log(stepsInitial.length)
        while (key == null && q < stepsInitial.length) {
            if(Array.isArray(stepsInitial[q].keywords)){
                let r = 0
                let rFound = false
                while(!rFound && r<stepsInitial[q].keywords.length){
                    if(logKeysArray) console.log(q, "keyword=", stepsInitial[q].keywords[r], "msj=", message)
                    if(logKeysArray) console.log(q, "req=", resps[stepsInitial[q].key.toString()].pasoRequerido, "ant=", pasoAnterior[elNum])
                    if( message.toLowerCase() == stepsInitial[q].keywords[r].toLowerCase() && ( // Si el mensaje coincide con la palabra clave Y pasoRequerido es igual a pasoAnterior ...
                            resps[stepsInitial[q].key.toString()].pasoRequerido == undefined ||
                            resps[stepsInitial[q].key.toString()].pasoRequerido == pasoAnterior[elNum]
                        )
                    ){
                        key = stepsInitial[q].key
                        if(logKeysArray) console.log(key, " SI COINCIDE")
                        rFound = true
                    }
                    else
                    {
                        // key = null
                        if(logKeysArray) console.log("No coincide")
                    }
                    r++
                }
            }
           q++
        }
        if(logKeysArray) console.log("KEY = ", key)
        // var { key } = stepsInitial.find(k => k.keywords.includes(message)) || { key: null }

        /* ###############################################  *   REGEXP   *   ####################################################
            Si queremos usar RegExp, en los "keywords" de inital.json, en lugar de un arreglo usamos un string (quitamos los [])
            y en él usamos "*" para significar cualquier texto y "|" para significar "OR", esto nos permite ser mas flexibles
            con los "keywords", por ejemplo, si queremos que el mensaje pueda decir:

                "Hola quiero info del paquete" o "Requiero mas informacion"

            ponemos "*info*" y la regla se va a disparar porque los dos contienen "info", o si queremos que se dispare con:

                "Quiero info del paquete numero 3" o "Me gusto el paquete de Angular"

            ponemos "paquete*3|paquete*angular" y la regla se dispara porque contiene "paquete" Y "3" -O- "paquete" Y "angular".

           #####################################################################################################################
        */
        var {keywords} = stepsInitial.find(k => k.key.includes(key)) || { keywords: null }
        if(!Array.isArray(keywords)){key=null;}//Si "keywords" no es arreglo entonces ponemos "key" en null y usamos REGEXP para buscar reglas.
        if(key == null && message.length > 0){
            //******************************************************************************** */
            var logRegEx = false
            //******************************************************************************** */
            console.log("=======  KEY ES NULO, USAMOS REGEXP  =======");
            for (si=0; si<stepsInitial.length;si++){
                if(!Array.isArray(stepsInitial[si].keywords)){// Si "Keywords" NO es arreglo entonces ...
                    var coincideKeyword = null;
                    if(logRegEx) console.log("*** PASO=" + stepsInitial[si].key.toString() + " - REQUERIDO=" + resps[stepsInitial[si].key.toString()].pasoRequerido + " - ANTERIOR=" + pasoAnterior[elNum])
                    //Si NO hay paso requerido, o el paso requerido es IGUAL al paso anterior, entonces ...
                    if(resps[stepsInitial[si].key.toString()].pasoRequerido == undefined || resps[stepsInitial[si].key.toString()].pasoRequerido == pasoAnterior[elNum]){
                        var tempKeyword = "";
                        if(logRegEx) console.log(" - El paso requerido COINCIDE con el anterior, o NO hay paso requerido.")
                        if (stepsInitial[si].keywords == "%solo_correos%"){
                            if(logRegEx) console.log("solo_correos")
                            tempKeyword = "[a-zA-Z0-9]+[_a-zA-Z0-9\.-]*[a-zA-Z0-9]+@[a-zA-Z0-9-]+(?:\.[a-zA-Z0-9-]+[\.][a-zA-Z]{2,12})"}
                        else { 
                            tempKeyword = stepsInitial[si].keywords.toString().replaceAll("*",".*")
                        }
                        coincideKeyword = message.match(tempKeyword); // Verdadero cuando el mensaje COINCIDE con la palabre clave.
                        if (coincideKeyword != null){ //Si el mensaje COINCIDE con la palabra clave.
                            if(logRegEx) console.log(" - - El mensaje COINCIDE con el keyword")
                            key = stepsInitial[si].key;
                            //Si HAY paso requerido, y el paso requerido es DIFERENTE del paso anterior, entonces ...
                            if(resps[stepsInitial[si].key].pasoRequerido != null && resps[stepsInitial[si].key].pasoRequerido != pasoAnterior[elNum]){
                                key=null
                                if(logRegEx) console.log(" - - - Hay paso requerido y NO COINCIDE con en paso anterior")
                            }
                            if(resps[stepsInitial[si].key].replyMessage.toString().search("/URL") > -1){
                                if(logRegEx) console.log("****************    HAY URL    ****************")
                            }
                            break;
                        }
                        else {
                            coincideKeyword = null
                        }
                    }
                    else { 
                        if(logRegEx) console.log("--- NO CUMPLE PASO REQ");
                    }
                }
            }
            // console.log("<<<<<<<<<  " + key);
            // cumplePasoRequerido(key)
            // ultimoPaso = pasoRequerido;
            // ultimoStep = key;
        }
        const response = key || null
        if(resps[key]!=undefined){VA = resps[key].goto}else{VA=null}
        cumplePasoRequerido(key);
        _vamosA = VA;
        if(logRegEx) console.log("cumplePasoPrevio[elNum]=", cumplePasoPrevio[elNum], "_vamosA=", _vamosA)
        if(_vamosA != "" && _vamosA != undefined && cumplePasoPrevio[elNum] == true){
            if(logRegEx) console.log("ASIGNAMOS _VAMOSA = " + _vamosA);
            pasoAnterior[elNum] = _vamosA;
        }
        _vamosA = "";
        if(cumplePasoPrevio[elNum]) {resolve(response);}
    }

    /**
     * Si usas MYSQL
     */
    if (process.env.DATABASE === 'mysql') {
        getData(message, (dt) => {
            resolve(dt)
        });
    }
})

const reply = (step) => new Promise((resolve, reject) => {
    /**
    * Si no estas usando una base de datos
    */
    if (process.env.DATABASE === 'none') {
        let resData = { replyMessage: '', media: null, trigger: null }
        const responseFind = stepsReponse[step] || {};
        resData = {
            ...resData, 
            ...responseFind
            // replyMessage:responseFind.replyMessage.join('')
        }
        resolve(resData);
        return 
    }
    /**
     * Si usas MYSQL
     */
    if (process.env.DATABASE === 'mysql') {
        let resData = { replyMessage: '', media: null, trigger: null }
        getReply(step, (dt) => {
            resData = { ...resData, ...dt }
            resolve(resData)
        });
    }
})

const getIA = (message) => new Promise((resolve, reject) => {
    /**
     * Si usas dialogflow
     */
     if (process.env.DATABASE === 'dialogflow') {
        let resData = { replyMessage: '', media: null, trigger: null }
        getDataIa(message,(dt) => {
            resData = { ...resData, ...dt }
            resolve(resData)
        })
    }
})

/**
 * 
 * @param {*} message 
 * @param {*} date 
 * @param {*} trigger 
 * @param {*} number
 * @returns 
 */
const saveMessage = ( message, trigger, number, regla ) => new Promise( async (resolve, reject) => { //MOD by CHV - Agregamos el partametro "regla" para poder guardarlo en "chats/numero.json"
     switch ( process.env.DATABASE ) {
         case 'mysql':
             resolve( await saveMessageMysql( message, trigger, number ) )
             break;
         case 'none':
             resolve( await saveMessageJson( message, trigger, number, regla) ) //MOD by CHV - Agregamos el parametro "regla"
             console.log("Guardamos mensaje JSON=", message)
             break;
         default:
             resolve(true)
             break;
    }
})


/**
 * Asigna el valor especificado a la variable pasoAnterior.
 * Esta hace que el flujo se redirija al paso siguente al especificado.
 * NO EJECUTA EL PASO DADO, solo espfecifica cual es el paso anterior para cuando una regla tiene el parametro "pasoRequerido".
 * @param {elNum} string - El numero del remitente.
 * @param {elPaso} string - El paso al que se va redirigir el flujo.
*/
function vamosA (elNum, elPaso){
    pasoAnterior[elNum] = elPaso;
    console.log("Asignamos pasoAnterior con " + elPaso, elNum)
}
    
/**
 * Revisa si la regla especificada depende (es submenu) de otra regla, y cambia la variable "cumplePasoPrevio" a verdadero o falso.
*/
function cumplePasoRequerido(step){
    //Traemos las respuestas para obtener el "pasoRequerido".
    if(resps[step]!=undefined){pasoRequerido=resps[step].pasoRequerido}else{pasoRequerido=null}
    if((pasoRequerido != null && pasoRequerido == ultimoStep)){
        // console.log("REQUIERE PASO PREVIO Y CUMPLE");
        cumplePasoPrevio[elNum] = true;
    }
    else if((pasoRequerido != null && pasoRequerido != pasoAnterior[elNum])){
        // console.log("REQUIERE PASO PREVIO Y NO LO CUMPLE");
        cumplePasoPrevio[elNum] = false;
    }
    else{
        // console.log("NO REQUIERE PASO PREVIO")
        cumplePasoPrevio[elNum] = true;
    }
    pasoAnterior[elNum] = step
    // ultimoPaso = pasoRequerido;
}

/**
 * Revisa que exista el archivo "chats/numero.json"
 * @param {*} theFile 
 * @returns 
*/
function chkFile(theFile){ //MOD by CHV - Agregamos para revisar que exista el archivo "chats/numero.json"
    const fs = require('fs');
    if (fs.existsSync(theFile)) {
        // console.log("Si existe el archivo "+ theFile);
        var h = true;
    }
    else{
        // console.log("No existe el archivo "+ theFile);
        var h = false;
    }
    return h;
}

/**
 * Regresa el tiempo tanscurrido en (datepart) desde la ultima visita.\n
 * datepart: 'y', 'm', 'w', 'd', 'h', 'n', 's' (default = n)
 * @param {*} file 
 * @param {*} datepart
*/
function traeUltimaVisita(file, datepart = 'n'){
    // Node.js program to demonstrate the
    // fs.futimes() method
    let thisLog = false
    const fs = require('fs');
    let theFile = `${__dirname}/../chats/`+file+".json"
    if(thisLog) console.log("chkFile=", chkFile(theFile), datepart)
    if(chkFile(theFile)){
        // Get the file descriptor of the file
        const fd = fs.openSync(theFile);
        // console.log("Details before changing time:");
        // Get the stats object of the file
        if(thisLog) console.log(new Date())
        prevStats = fs.statSync(theFile);
        // Access the modified and access time of the file
        if(thisLog) console.log("Modification Time:", prevStats.mtime);
        if(thisLog) console.log("Access Time:", prevStats.atime);
        // Get the current time to change the timestamps
        let changedModifiedTime = new Date();
        let changedAccessTime = new Date();
        // Use the futimes() function to assign
        // the new timestamps to the file descriptor
        fs.futimes(fd, changedAccessTime, changedModifiedTime, ()=>{})
        if(thisLog) console.log("dd=", dateDiff(datepart, prevStats.atime, changedAccessTime))
        if(thisLog) console.log(new Date())
        return dateDiff(datepart, prevStats.atime, changedAccessTime)
    }
    else { return 0 }
}
/**
 * Regresa el tiempo transcurrido en (datepart) entre las fechas dadas.
 * datepart: 'y', 'm', 'w', 'd', 'h', 'n', 's'
 * @param {*} datepart 
 * @param {*} fromdate 
 * @param {*} todate 
 * @returns 
 */
function dateDiff(datepart, fromdate, todate){
    datepart = datepart.toLowerCase();	
    var diff = todate - fromdate;	
    var divideBy = { w:604800000, 
        d:86400000, 
        h:3600000, 
        n:60000, 
        s:1000
    };	
    return Math.floor( diff/divideBy[datepart]);
}

module.exports = { get, reply, getIA, saveMessage, stepsInitial, vamosA, traeUltimaVisita } //MOD by CHV - Agregamos "stepsInitial" para usarlos en "apps.js"