builder flow basic

This commit is contained in:
Leifer Mendez
2022-01-18 10:09:45 +01:00
parent d3a086fc98
commit 1f9af4f7b2
5 changed files with 140 additions and 71 deletions

View File

@@ -1,5 +1,7 @@
const { getData, getReply } = require('./mysql')
const { getDataIa } = require('./diaglogflow')
const stepsInitial = require('../flow/initial.json')
const stepsReponse = require('../flow/response.json')
const get = (message) => new Promise((resolve, reject) => {
/**
@@ -7,19 +9,7 @@ const get = (message) => new Promise((resolve, reject) => {
*/
if (process.env.DATABASE === 'none') {
const steps = [
{
keywords: ['hola', 'hi', 'buen dia'],
key: 'STEP_1'
},
{
keywords: ['enviar pdf', 'pdf', 'enviarpdf'],
key: 'STEP_2'
}
]
const { key } = steps.find(k => k.keywords.includes(message)) || { key: null }
const { key } = stepsInitial.find(k => k.keywords.includes(message)) || { key: null }
const response = key || null
resolve(response)
}
@@ -34,6 +24,34 @@ const get = (message) => new Promise((resolve, reject) => {
})
const reply = (step) => new Promise((resolve, reject) => {
/**
* Si no estas usando un gesto de base de datos
*/
if (process.env.DATABASE === 'none') {
let resData = { replyMessage: '', media: null, trigger: null }
const responseFind = stepsReponse[step] || {};
console.log('Responder:',responseFind)
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
@@ -47,58 +65,4 @@ const getIA = (message) => new Promise((resolve, reject) => {
}
})
const reply = (step) => new Promise((resolve, reject) => {
/**
* Si no estas usando un gesto de base de datos
*/
if (process.env.DATABASE === 'none') {
let replyMessage = null;
let resData = { replyMessage: '', media: null, trigger: null }
switch (step) {
case 'STEP_1':
replyMessage = [
'✌️ Bienveido a este CHATBOT lo primero \n',
'Decirte que mi nombre es Leifer Mendez \n\n',
'¿Quieres que te envie mi presentación? \n',
'*enviar pdf* o *omitir* \n',
].join('');
resData = { replyMessage, media: null }
resolve(resData);
return
break;
case 'STEP_2':
replyMessage = [
'Yeah! 😎 \n',
'enviando...👌'
].join('');
resData = { replyMessage, media: 'meme-1.png', trigger: 'STEP_0' }
resolve(resData);
return
break;
case 'STEP_0':
replyMessage = [
'El flujo ha finalizado \n',
'pero puedes ver todo el codigo de este \n',
'repositorio en https://github.com/leifermendez/bot-whatsapp.git'
].join('');
resData = { replyMessage, media: null }
resolve(resData);
return
break;
}
}
/**
* Si usas MYSQL
*/
if (process.env.DATABASE === 'mysql') {
let resData = { replyMessage: '', media: null, trigger: null }
getReply(step, (dt) => {
resData = { ...resData, ...dt }
resolve(resData)
});
}
})
module.exports = { get, reply, getIA }