mirror of
https://github.com/cheveguerra/botLeiferAurik-Mod_2.0.git
synced 2026-04-18 11:49:22 +00:00
280 lines
14 KiB
JavaScript
280 lines
14 KiB
JavaScript
/**
|
|
* ⚡⚡⚡ DECLARAMOS LAS LIBRERIAS y CONSTANTES A USAR! ⚡⚡⚡
|
|
*/
|
|
require('dotenv').config()
|
|
global.provider = process.env.PROVIDER || 'wwebjs';
|
|
const fs = require('fs');
|
|
global.siguientePaso = [{"numero":"1", "va":"XXX"}]; //MOD by CHV - Agregamos para pasar el VAMOSA a "index.js"
|
|
global.pasoAnterior = [];
|
|
global.socketioStatus = ""
|
|
global.vars = []
|
|
// const mysqlConnection = require('./config/mysql')
|
|
if( provider == 'baileys' ){ const { initBot } = require(`./provider/baileys`) }
|
|
else { const { initBot } = require(`./provider/wwebjs`) }
|
|
const { isValidNumber } = require('./controllers/handle')
|
|
const { saveMedia, saveMediaToGoogleDrive } = require('./controllers/save')
|
|
const { getMessages, responseMessages, bothResponse, waitFor } = require('./controllers/flows')
|
|
const { sendMedia, sendMessage, sendMessageButton, sendMessageList, readChat } = require(`./controllers/send`);
|
|
const { stepsInitial, vamosA, traeUltimaVisita } = require('./adapter/index');//MOD by CHV - Agregamos para utilizar remplazos y stepsInitial
|
|
const { removeDiacritics, getRandomInt, remplazos, soloNumero, agregaVars, traeVariablesFromMsg, traeVariablesFromClient } = require('./implementaciones/extraFuncs')
|
|
const appFuncs = require('./implementaciones/appFuncs')
|
|
// const { guardaXLSDatos, leeXLSDatos} = require('./Excel');
|
|
// const { ingresarDatos, leerDatos } = require('./implementaciones/sheets')
|
|
const MULTI_DEVICE = process.env.MULTI_DEVICE || 'true';
|
|
const delay = (ms) => new Promise((resolve) => setTimeout(resolve,ms))
|
|
let client
|
|
let client0
|
|
var dialogflowFilter = false;
|
|
var newBody; //MOD by CHV -
|
|
var nuevaRespuesta; //MOD by CHV - Se agrego para los remplazos
|
|
let blackList = ['346XXXX6038', '3467XXXX819', '34660XXXX89', '3464XXXX761','3463XXXX553','3464XXXX637','3463XXXX646','1417XXXX313']
|
|
|
|
// ############################################################################################################
|
|
// ########################## AQUI SE DECLARAN LAS FUNCIONES PERSONALIZADAS DESDE #########################
|
|
// ######################## EL ARCHIVO APPFUNCS.JS EN EL DIRECTORIO IMPLEMENTACIONES ######################
|
|
// ############################################################################################################
|
|
|
|
const arrayOfAppFuncs = Object.entries(appFuncs);
|
|
for(thisF = 0; thisF < arrayOfAppFuncs.length; thisF++){
|
|
// console.log(arrayOfAppFuncs[thisF][0], "|", arrayOfAppFuncs[thisF][1])
|
|
global[arrayOfAppFuncs[thisF][0]] = arrayOfAppFuncs[thisF][1]
|
|
}
|
|
|
|
/**
|
|
* Escuchamos cuando entra un mensaje.
|
|
*/
|
|
function listenMessage(client){
|
|
if(provider == 'wwebjs'){ client0 = client; messageEV = 'message' } // Usamos WWebJS.
|
|
else { client0 = client.ev; messageEV = 'messages.upsert' } // Usamos Baileys.
|
|
client0.on(messageEV, async msg => {
|
|
if(provider == 'wwebjs'){ msg.type = 'notify' }
|
|
const { from, body, name, hasMedia } = traeVariablesFromMsg(msg);
|
|
if (vars[from] === undefined) vars[from] = []
|
|
// Este bug lo reporto Lucas Aldeco Brescia para evitar que se publiquen estados.
|
|
if (from === 'status@broadcast' || msg.type !== 'notify') { console.log("++++++ status@broadcast o tipo mensaje = ", msg.type); return }
|
|
console.log("+++++++++++++++++++++++++++++++++++++ INICIO +++++++++++++++++++++++++++++++++++++++");
|
|
console.log("HORA:"+new Date().toLocaleTimeString()+" FROM:"+from+", BODY:"+body+", HASMEDIA:"+hasMedia+", DEVICETYPE:"+client.theMsg?.deviceType);
|
|
// * Numero NO válido.
|
|
if(!isValidNumber(from)){ console.log("Número invalido"); return }
|
|
const number = soloNumero(from)
|
|
newBody = removeDiacritics(body) //MOD by CHV - Agregamos para quitar acentos
|
|
message = newBody.toLowerCase();
|
|
// * Blacklist, los telefonos incluidos en este arreglo son ignorados por el bot.
|
|
if (blackList.includes(number)){ console.log('BlackListed'); return }
|
|
var { key } = stepsInitial.find(k => k.keywords.includes(message)) || { key: null }//MOD by CHV - Se agrega para obtener KEY
|
|
await readChat(number, message, key) //MOD by CHV - Agregamos key/regla para guardarla en "chats/numero.json"
|
|
client = agregaVars(client, msg, traeVariablesFromMsg(msg))
|
|
client.theMsg['key'] = key
|
|
// console.log(client)
|
|
|
|
|
|
if (body == '/bt') {
|
|
// send a buttons message with image header!
|
|
const buttons = [
|
|
{ buttonId: 'id1', buttonText: { displayText: 'Button 1' }, type: 1 },
|
|
{ buttonId: 'id2', buttonText: { displayText: 'Button 2' }, type: 1 },
|
|
{ buttonId: 'id3', buttonText: { displayText: 'Button 3' }, type: 1 }
|
|
]
|
|
|
|
const buttonMessage = {
|
|
image: { url: 'https://media2.giphy.com/media/VQJu0IeULuAmCwf5SL/giphy.gif' },
|
|
caption: "Hi it's button message",
|
|
footer: 'Hello World',
|
|
buttons: buttons,
|
|
headerType: 4
|
|
}
|
|
const sendMsg = await client.sendMessage(from, buttonMessage)
|
|
|
|
}
|
|
|
|
/**
|
|
* Si el mensaje trae un archivo multimedia, aquí lo guardamos.
|
|
*/
|
|
if (process.env.SAVE_MEDIA === 'true' && hasMedia) { const media = await msg.downloadMedia(); saveMedia(media); }
|
|
|
|
// Guardamos los mensajes entrantes en una hoja de Google Sheets
|
|
// ingresarDatos(from, body, 'Entrada', 'Bot Pruebas')
|
|
|
|
/**
|
|
* Si estas usando dialogflow solo manejamos una funcion todo es IA
|
|
*/
|
|
if (process.env.DATABASE === 'dialogflow') {
|
|
if (process.env.DIALOGFLOW_MEDIA_FOR_SLOT_FILLING === 'true' && dialogflowFilter) {
|
|
waitFor(_ => hasMedia, 30000)
|
|
.then(async _ => {
|
|
if (hasMedia) {
|
|
const media = await msg.downloadMedia();
|
|
message = await saveMediaToGoogleDrive(media);
|
|
const response = await bothResponse(message.substring(256, -1), number);
|
|
await sendMessage(client, from, response.replyMessage);
|
|
}
|
|
return
|
|
});
|
|
dialogflowFilter = false;
|
|
}
|
|
if (!message.length) return;
|
|
const response = await bothResponse(message.substring(256, -1), number);
|
|
await sendMessage(client, from, response.replyMessage);
|
|
if (response.actions) {
|
|
await sendMessageButton(client, from, null, response.actions);
|
|
return
|
|
}
|
|
if (response.media) {
|
|
sendMedia(client, from, response.media);
|
|
}
|
|
return
|
|
}
|
|
|
|
/**
|
|
* Si el texto del mensaje dispara alguna regla, entramos a esta condición.
|
|
*/
|
|
const step = await getMessages(message, from);
|
|
client.theMsg['step'] = step
|
|
if (step) {
|
|
// console.log("Entramos a STEP")
|
|
const response = await responseMessages(step);
|
|
client.theMsg['trigger'] = response.trigger
|
|
var resps = require('./flow/response.json');
|
|
nuevaRespuesta = remplazos(resps[step].replyMessage.join(''), client);
|
|
client.theMsg['replyMessage'] = nuevaRespuesta
|
|
|
|
// ####################################################################################################################
|
|
// ############################## INICIAN FUNCIONES PARA MANEJO DE PARAMETROS #####################################
|
|
// ############################## EN EL RESPONSE.JSON #####################################
|
|
// ####################################################################################################################
|
|
/*
|
|
* Si quieres ejecutar una función.
|
|
*/
|
|
if(response.hasOwnProperty('funcion')){
|
|
console.log("############# Encontramos función, ejecutamos la función '" + response.funcion + "'")
|
|
laFuncion = response.funcion + "(client)"
|
|
eval(laFuncion)
|
|
}
|
|
/**
|
|
* Si quieres enviar imagen.
|
|
*/
|
|
if (!response.delay && response.media) {
|
|
// console.log("++++++++++++++++++++++++++++ SEND MEDIA NO DELAY +++++++++++++++++++++++++++++++++++");
|
|
await sendMedia(client, from, response.media);
|
|
console.log("Enviamos imagen")
|
|
await delay(500)
|
|
}
|
|
/**
|
|
* Si quieres enviar imagen con retraso.
|
|
*/
|
|
if (response.delay && response.media) {
|
|
setTimeout(() => {
|
|
// console.log("++++++++++++++++++++++++++++ SEND MEDIA AND DELAY +++++++++++++++++++++++++++++++++++");
|
|
sendMedia(client, from, response.media);
|
|
}, response.delay)
|
|
}
|
|
/**
|
|
* Si quieres enviar mensaje con retraso.
|
|
*/
|
|
if (response.delay){
|
|
// await sendMessage(client, from, nuevaRespuesta, response.trigger, step); // Mod by CHV - Para mandar varios mensajes en el mismo response, se cambio esta linea por el forEach de abajo.
|
|
setTimeout(() => {
|
|
response.replyMessage.forEach( async messages => {
|
|
var thisMsg = messages.mensaje
|
|
if(Array.isArray(messages.mensaje)){thisMsg = messages.mensaje.join('\n')}
|
|
await sendMessage(client, from, remplazos(thisMsg, client), step);
|
|
})
|
|
}, response.delay)
|
|
await delay(500)
|
|
}
|
|
else
|
|
/**
|
|
* Si quieres enviar un mensaje.
|
|
*/
|
|
{ // await sendMessage(client, from, nuevaRespuesta, response.trigger, step); // Mod by CHV - Para mandar varios mensajes en el mismo response, se cambio esta linea por el forEach de abajo.
|
|
response.replyMessage.forEach( async messages => {
|
|
var thisMsg = messages.mensaje
|
|
if(Array.isArray(messages.mensaje)){thisMsg = messages.mensaje.join('\n')}
|
|
// console.log("Mensaje=", thisMsg)
|
|
if(thisMsg !== undefined) await sendMessage(client, from, remplazos(thisMsg, client), step);
|
|
})
|
|
await delay(500)
|
|
}
|
|
/**
|
|
* Si quieres enviar botones o listas
|
|
*/
|
|
if(response.hasOwnProperty('actions')){
|
|
const { actions } = response;
|
|
// console.log("++++++++++++++++++++++++++++ SEND MESG BUTTON/LIST +++++++++++++++++++++++++++++++++++");
|
|
if(actions['sections'] === undefined){ //Botones
|
|
console.log("Botones")
|
|
await sendMessageButton(client, from, null, actions);
|
|
}
|
|
else { //Listas
|
|
console.log("Listas")
|
|
await sendMessageList(client, from, null, actions);
|
|
}
|
|
}
|
|
return
|
|
}
|
|
/**
|
|
* Si quieres tener un mensaje por defecto
|
|
*/
|
|
if (process.env.DEFAULT_MESSAGE === 'true') {
|
|
const response = await responseMessages('DEFAULT')
|
|
// await sendMessage(client, from, response.replyMessage, response.trigger); // Mod by CHV - Para mandar varios mensajes en el mismo response, se cambio esta linea por el forEach de abajo.
|
|
response.replyMessage.forEach( async messages => {
|
|
var thisMsg = messages.mensaje
|
|
if(Array.isArray(messages.mensaje)){thisMsg = messages.mensaje.join('\n')}
|
|
await sendMessage(client, from, remplazos(thisMsg, client), step);
|
|
})
|
|
|
|
/**
|
|
* Si quieres enviar botones
|
|
*/
|
|
if(response.hasOwnProperty('actions')){
|
|
const { actions } = response;
|
|
if(actions['sections'] === undefined){ //Botones
|
|
console.log("Botones")
|
|
await sendMessageButton(client, from, null, actions);
|
|
}
|
|
else{ //Listas
|
|
console.log("Listas")
|
|
await sendMessageList(client, from, null, actions);
|
|
}
|
|
}
|
|
return
|
|
}
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Este evento es necesario para el filtro de Dialogflow
|
|
*/
|
|
function listenMessageFromBot(client0){
|
|
if(provider == 'wwebjs') {client = client0} else {client = client0.ev}
|
|
client.on('message_create', async botMsg => {
|
|
// const listenMessageFromBot = () => client.on('message_create', async botMsg => {
|
|
const { body } = botMsg;
|
|
const dialogflowFilterConfig = fs.readFileSync('./flow/dialogflow.json', 'utf8');
|
|
const keywords = JSON.parse(dialogflowFilterConfig);
|
|
|
|
for (i = 0; i < keywords.length; i++) {
|
|
key = keywords[i];
|
|
for (var j = 0; j < key.phrases.length; j++) {
|
|
let filters = key.phrases[j];
|
|
if (body.includes(filters)) {
|
|
dialogflowFilter = true;
|
|
//console.log(`El filtro de Dialogflow coincidió con el mensaje: ${filters}`);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
}
|
|
|
|
// ####################################################################################################################
|
|
// ############################## INICIAN FUNCIONES PARA LA CREACION DEL CLIENTE ####################################
|
|
// ############################## DE WHATSAPP-WEB.JS ####################################
|
|
// ####################################################################################################################
|
|
async function inicializaBot(){
|
|
const ib = await initBot()
|
|
listenMessage(ib)
|
|
// listenMessageFromBot(ib)
|
|
}
|
|
inicializaBot()
|