Compare commits

..

40 Commits

Author SHA1 Message Date
Leifer Mendez
2858e910dc Create LICENSE.md 2022-12-11 22:20:49 +01:00
Leifer Mendez
ee87e9e875 Merge pull request #140 from jzvi12/main
Use WhatsApp Number as an Unique Dialogflow Session ID
2022-12-06 09:57:10 +01:00
jzvi12
1884832192 fixed dialogflow session id 2022-12-05 19:10:41 -05:00
jzvi12
f21a58b6ff Update README.md 2022-12-02 10:16:16 -05:00
Leifer Mendez
8a4f134327 Update latest 2022-11-19 11:08:51 +01:00
Leifer Mendez
9b6ce92612 Update diaglogflow.js 2022-10-31 09:51:18 +01:00
Leifer
663fcafc9c update 2022-10-24 09:39:38 +02:00
Leifer
f36ddd3014 update 2022-10-20 13:51:43 +02:00
Leifer Mendez
3fadaaaf13 Merge pull request #82 from Gonzalito87/patch-7
Update de librerias
2022-08-09 20:57:57 +02:00
Leifer Mendez
dfa569f29d Merge pull request #83 from aurik3/dev-pull
coreccion nanoid y send.js
2022-08-09 20:57:41 +02:00
Leifer Mendez
601508f379 Merge branch 'main' into dev-pull 2022-08-09 20:57:29 +02:00
aurik3
e7ad205268 coreccion nanoid y send.js
se corrigen errores en el codigo
2022-08-09 13:43:28 -05:00
Gonzalito87
f62ba0a076 Update de librerias 2022-08-08 15:19:13 -03:00
Leifer Mendez
a9efa0aa58 Merge pull request #71 from ulisesvina/main
Arreglado: comprobación de parámetros en funciones y problemas de inconsistencia.
2022-08-08 14:47:33 +02:00
Leifer Mendez
3276c21bc3 Merge pull request #75 from aurik3/dev-pull
Update Julio 2022
2022-07-22 12:57:14 +02:00
aurik3
1114f25a71 Update Julio 2022
Se añade localAuth para mantener la session despues de escanear el codigo y se hace un code fix al api rest

Co-Authored-By: Leifer Mendez <15802366+leifermendez@users.noreply.github.com>
2022-07-19 18:15:12 -05:00
Ulises Viña
f13a34ff75 Update send.js 2022-07-05 20:59:06 -05:00
Leifer Mendez
d45ea85e7d Merge pull request #57 from leifermendez/rev-global
rex
2022-04-27 21:33:51 +02:00
Leifer Mendez
10e2b138d3 rex 2022-04-27 21:32:29 +02:00
Leifer Mendez
a1bf5ba5c2 Merge pull request #55 from Gonzalito87/patch-3
Update package.json
2022-04-27 21:03:06 +02:00
Gonzalito87
19102b7b3a Update package.json
actualizacion de repositorio de whats app
2022-04-26 11:12:35 -03:00
Leifer Mendez
5efcc2a9a6 Merge pull request #54 from Gonzalito87/patch-1
Update diaglogflow.js
2022-04-25 19:33:28 +02:00
Gonzalito87
8279c07a88 Update diaglogflow.js 2022-04-25 13:42:12 -03:00
Leifer Mendez
02d7b3bd98 Merge pull request #50 from leifermendez/update
Update
2022-04-20 14:17:02 +02:00
Leifer Mendez
f8f6a3000d Merge branch 'update' of github.com:leifermendez/bot-whatsapp into update 2022-04-20 14:16:46 +02:00
Leifer Mendez
9a92b152a4 fix 2022-04-20 14:16:42 +02:00
Leifer Mendez
f86700deaf Update README.md 2022-04-15 12:03:22 +02:00
Leifer Mendez
4ba259b46c Update README.md 2022-04-15 12:02:59 +02:00
Leifer Mendez
cf459e94d2 Update README.md 2022-04-15 12:01:29 +02:00
Leifer Mendez
4f8ed1361c Merge pull request #47 from leifermendez/update
Update
2022-04-15 12:00:43 +02:00
Leifer Mendez
bad8802241 Merge branch 'main' into update 2022-04-15 12:00:37 +02:00
Leifer Mendez
f09ac862d5 clean credentials 2022-04-15 11:58:09 +02:00
Leifer Mendez
fe7567e1a9 update many stuff 2022-04-15 11:57:32 +02:00
Leifer Mendez
9b0b7f4d54 befor update 2022-04-15 11:02:12 +02:00
Leifer Mendez
3ddbf462a8 Update package.json 2022-03-29 17:02:09 +02:00
Leifer Mendez
e6043c99a7 Merge pull request #35 from leifermendez/dev
update
2022-03-23 09:41:38 +01:00
Leifer Mendez
b1daa0020e update 2022-03-23 09:41:18 +01:00
Leifer Mendez
190d35c9a5 Merge pull request #30 from leifermendez/dev
Dev
2022-03-16 10:05:54 +01:00
Leifer Mendez
e4378fe848 se agego multi-device .env 2022-03-16 10:05:13 +01:00
Leifer Mendez
676e48021f Merge pull request #28 from leifermendez/dev
Dev
2022-03-15 10:22:38 +01:00
17 changed files with 6719 additions and 932 deletions

View File

@@ -8,4 +8,6 @@ LANGUAGE=es
SQL_HOST= SQL_HOST=
SQL_USER= SQL_USER=
SQL_PASS= SQL_PASS=
SQL_DATABASE= SQL_DATABASE=
KEEP_DIALOG_FLOW=false
MULTI_DEVICE=true

21
LICENSE.md Normal file
View File

@@ -0,0 +1,21 @@
MIT License
Copyright (c) 2022 Leifer Mendez
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in all
copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
SOFTWARE.

View File

@@ -1,26 +1,4 @@
## Chatbot Whatsapp (OpenSource) ## Chatbot Whatsapp (OpenSource)
#### Actualizado Enero 2022
El siguiente proyecto se realizó con fines educativos para el canal de [Youtube (Leifer Mendez)](https://www.youtube.com/channel/UCgrIGp5QAnC0J8LfNJxDRDw?sub_confirmation=1) donde aprendemos a crear y implementar un chatbot increíble usando [node.js](https://codigoencasa.com/tag/nodejs/) además le agregamos inteligencia artificial gracias al servicio de __dialogflow__.
[![Video](https://i.giphy.com/media/OBDi3CXC83WkNeLEZP/giphy.webp)](https://youtu.be/5lEMCeWEJ8o)
### ATENCION 1 🔴
> 💥💥 Si te aparece el Error Multi-device es porque tienes la cuenta de whatsapp afiliada al modo "BETA de Multi dispositivo" por el momento no se tiene soporte para esas personas si tu quieres hacer uso de este __BOT__ debes de salir del modo BETA y intentarlo de la manera tradicional
### ATENCION 2 🔴
> El core de whatsapp esta en constante actualizaciones por lo cual siempre revisa la ultima fecha de la actualizacion
> [VER](https://github.com/leifermendez/bot-whatsapp/commits/main)
#### Acceso rápido
> Si tienes una cuenta en __heroku__ puedes desplegar este proyecto con (1 click)
[![Deploy](https://www.herokucdn.com/deploy/button.svg)](https://heroku.com/deploy?template=https://github.com/leifermendez/bot-whatsapp)
> Comprarme un cafe!
[![Comprar](https://www.buymeacoffee.com/assets/img/custom_images/orange_img.png)](https://www.buymeacoffee.com/leifermendez)
#### Actualización #### Actualización
@@ -31,7 +9,7 @@ El siguiente proyecto se realizó con fines educativos para el canal de [Youtube
| JSON File | ✅ | | JSON File | ✅ |
| QR Scan (route) | ✅ | | QR Scan (route) | ✅ |
| Easy deploy heroku | ✅ | | Easy deploy heroku | ✅ |
| Buttons | ✅ | | Buttons | ✅ (No funciona en multi-device)|
| Send Voice Note | ✅ | | Send Voice Note | ✅ |
| Add support ubuntu/linux | ✅ | | Add support ubuntu/linux | ✅ |
@@ -80,7 +58,6 @@ await sendMediaVoiceNote(client, from, 'PTT-20220223-WA0000.opus')
## Instruciones ## Instruciones
__Descargar o Clonar repositorio__ __Descargar o Clonar repositorio__
![](https://i.imgur.com/dSpUbFz.png)
__Usas ¿Ubuntu / Linux?__ __Usas ¿Ubuntu / Linux?__
> Asegurate de instalar los siguientes paquetes > Asegurate de instalar los siguientes paquetes
@@ -92,9 +69,9 @@ sudo apt install -y gconf-service libasound2 libatk1.0-0 libc6 libcairo2 libcups
__Instalar dependencias (npm install)__ __Instalar dependencias (npm install)__
> Ubicate en le directorio que descargaste y via consola o terminal ejecuta el siguiente comando > Ubicate en le directorio que descargaste y via consola o terminal ejecuta el siguiente comando
`npm install` ```
npm i
![](https://i.imgur.com/BJuMjGR.png) ```
__Configurar .env__ __Configurar .env__
> Con el editor de texto crea un archivo `.env` el cual debes de guiarte del archivo `.env.example` > Con el editor de texto crea un archivo `.env` el cual debes de guiarte del archivo `.env.example`
@@ -113,21 +90,14 @@ SQL_PASS=
SQL_DATABASE= SQL_DATABASE=
``` ```
![](https://i.imgur.com/9poNnW0.png)
__Ejecutar el script__ __Ejecutar el script__
> Ubicate en le directorio que descargaste y via consola o terminal ejecuta el siguiente comando > Ubicate en le directorio que descargaste y via consola o terminal ejecuta el siguiente comando
`npm run start` `npm run start`
![](https://i.imgur.com/eMkBkuJ.png)
__Whatsapp en tu celular__ __Whatsapp en tu celular__
> Ahora abre la aplicación de Whatsapp en tu dispositivo y escanea el código QR > Ahora abre la aplicación de Whatsapp en tu dispositivo y escanea el código QR
<img src="https://i.imgur.com/RSbPtat.png" width="500" /> <img src="https://i.imgur.com/RSbPtat.png" width="500" />
Visitar la pagina Tambien puedes visitar la pagina http://127.0.0.1:3000/qr
`http://localhost:3000/qr`
![](https://i.imgur.com/Q3JEDlP.png)
__Listo 😎__ __Listo 😎__
> Cuando sale este mensaje tu BOT está __listo__ para trabajar! > Cuando sale este mensaje tu BOT está __listo__ para trabajar!
@@ -144,11 +114,3 @@ __Listo 😎__
> Ahora deberías obtener un arespuesta por parte del BOT como la siguiente, ademas de esto tambien se crea un archivo excel > Ahora deberías obtener un arespuesta por parte del BOT como la siguiente, ademas de esto tambien se crea un archivo excel
con el historial de conversación con el número de tu cliente con el historial de conversación con el número de tu cliente
![](https://i.imgur.com/lrMLgR8.png)
![](https://i.imgur.com/UYcoUSV.png)
## Preguntar al BOT
> Puedes interactuar con el bot ejemplo escribele __hola__ y el bot debe responderte!
![](https://i.imgur.com/cNAS51I.png)

View File

@@ -1,9 +1,11 @@
const dialogflow = require('@google-cloud/dialogflow'); const dialogflow = require('@google-cloud/dialogflow');
const fs = require('fs') const fs = require('fs')
const nanoid = require('nanoid')
/** /**
* Debes de tener tu archivo con el nombre "chatbot-account.json" en la raíz del proyecto * Debes de tener tu archivo con el nombre "chatbot-account.json" en la raíz del proyecto
*/ */
const KEEP_DIALOG_FLOW = (process.env.KEEP_DIALOG_FLOW === 'true')
let PROJECID; let PROJECID;
let CONFIGURATION; let CONFIGURATION;
let sessionClient; let sessionClient;
@@ -28,9 +30,9 @@ const checkFileCredentials = () => {
// Detect intent method // Detect intent method
const detectIntent = async (queryText) => { const detectIntent = async (queryText, waPhoneNumber) => {
let media = null; let media = null;
const sessionId = nanoid.nanoid() const sessionId = KEEP_DIALOG_FLOW ? 1 : waPhoneNumber;
const sessionPath = sessionClient.projectAgentSessionPath(PROJECID, sessionId); const sessionPath = sessionClient.projectAgentSessionPath(PROJECID, sessionId);
const languageCode = process.env.LANGUAGE const languageCode = process.env.LANGUAGE
const request = { const request = {
@@ -54,7 +56,7 @@ const detectIntent = async (queryText) => {
const { fields } = parsePayload.payload const { fields } = parsePayload.payload
media = fields.media.stringValue || null media = fields.media.stringValue || null
} }
// const customPayload = parsePayload['payload'] const customPayload = parsePayload ? parsePayload['payload'] : null
const parseData = { const parseData = {
replyMessage: queryResult.fulfillmentText, replyMessage: queryResult.fulfillmentText,
@@ -64,8 +66,8 @@ const detectIntent = async (queryText) => {
return parseData return parseData
} }
const getDataIa = (message = '', cb = () => { }) => { const getDataIa = (message = '', sessionId = '', cb = () => { }) => {
detectIntent(message).then((res) => { detectIntent(message, sessionId).then((res) => {
cb(res) cb(res)
}) })
} }

View File

@@ -52,13 +52,13 @@ const reply = (step) => new Promise((resolve, reject) => {
} }
}) })
const getIA = (message) => new Promise((resolve, reject) => { const getIA = (message, sessionId) => new Promise((resolve, reject) => {
/** /**
* Si usas dialogflow * Si usas dialogflow
*/ */
if (process.env.DATABASE === 'dialogflow') { if (process.env.DATABASE === 'dialogflow') {
let resData = { replyMessage: '', media: null, trigger: null } let resData = { replyMessage: '', media: null, trigger: null }
getDataIa(message,(dt) => { getDataIa(message, sessionId, (dt) => {
resData = { ...resData, ...dt } resData = { ...resData, ...dt }
resolve(resData) resolve(resData)
}) })
@@ -82,6 +82,7 @@ const saveMessage = ( message, trigger, number ) => new Promise( async (resolve
resolve( await saveMessageJson( message, trigger, number ) ) resolve( await saveMessageJson( message, trigger, number ) )
break; break;
default: default:
resolve(true)
break; break;
} }
}) })

View File

@@ -21,6 +21,7 @@ getReply = (option_key = '', callback) => connection.query(
replyMessage:response?.replyMessage || '', replyMessage:response?.replyMessage || '',
trigger:response?.trigger || '', trigger:response?.trigger || '',
media:response?.media || '' media:response?.media || ''
} }
callback(value) callback(value)
}); });
@@ -51,13 +52,15 @@ saveMessageMysql = ( message, date, trigger, number ) => new Promise((resolve,re
connection.query( connection.query(
`INSERT INTO ${DATABASE_NAME}.messages `+"( `message`, `date`, `trigger`, `number`)"+` VALUES ('${message}','${date}','${trigger}', '${number}')` , (error, results) => { `INSERT INTO ${DATABASE_NAME}.messages `+"( `message`, `date`, `trigger`, `number`)"+` VALUES ('${message}','${date}','${trigger}', '${number}')` , (error, results) => {
if(error) { if(error) {
if( error.code === 'ER_NO_SUCH_TABLE' ){ //TODO esta parte es mejor incluirla directamente en el archivo .sql template
connection.query( `CREATE TABLE ${DATABASE_NAME}.messages `+"( `date` DATE NOT NULL , `message` VARCHAR(450) NOT NULL , `trigger` VARCHAR(450) NOT NULL , `number` VARCHAR(50) NOT NULL ) ENGINE = InnoDB", async (error, results) => { console.log('DEBES DE CREAR LA TABLA DE MESSAGE')
setTimeout( async () => { // if( error.code === 'ER_NO_SUCH_TABLE' ){
return resolve( await this.saveMessageMysql( message, date, trigger, number ) ) // connection.query( `CREATE TABLE ${DATABASE_NAME}.messages `+"( `date` DATE NOT NULL , `message` VARCHAR(450) NOT NULL , `trigger` VARCHAR(450) NOT NULL , `number` VARCHAR(50) NOT NULL ) ENGINE = InnoDB", async (error, results) => {
}, 150) // setTimeout( async () => {
}) // return resolve( await this.saveMessageMysql( message, date, trigger, number ) )
} // }, 150)
// })
// }
} }
console.log('Saved') console.log('Saved')
console.log( results ) console.log( results )

145
app.js
View File

@@ -6,10 +6,10 @@ const fs = require('fs');
const express = require('express'); const express = require('express');
const cors = require('cors') const cors = require('cors')
const qrcode = require('qrcode-terminal'); const qrcode = require('qrcode-terminal');
const { Client, LegacySessionAuth, LocalAuth } = require('whatsapp-web.js'); const { Client, LocalAuth } = require('whatsapp-web.js');
const mysqlConnection = require('./config/mysql') const mysqlConnection = require('./config/mysql')
const { middlewareClient } = require('./middleware/client') const { middlewareClient } = require('./middleware/client')
const { generateImage, cleanNumber, checkEnvFile } = require('./controllers/handle') const { generateImage, cleanNumber, checkEnvFile, createClient, isValidNumber } = require('./controllers/handle')
const { connectionReady, connectionLost } = require('./controllers/connection') const { connectionReady, connectionLost } = require('./controllers/connection')
const { saveMedia } = require('./controllers/save') const { saveMedia } = require('./controllers/save')
const { getMessages, responseMessages, bothResponse } = require('./controllers/flows') const { getMessages, responseMessages, bothResponse } = require('./controllers/flows')
@@ -17,41 +17,29 @@ const { sendMedia, sendMessage, lastTrigger, sendMessageButton, readChat } = req
const app = express(); const app = express();
app.use(cors()) app.use(cors())
app.use(express.json()) app.use(express.json())
const MULTI_DEVICE = process.env.MULTI_DEVICE || 'true';
const server = require('http').Server(app) const server = require('http').Server(app)
const io = require('socket.io')(server, {
cors: {
origins: ['http://localhost:4200']
}
})
let socketEvents = {sendQR:() => {} ,sendStatus:() => {}};
io.on('connection', (socket) => {
const CHANNEL = 'main-channel';
socket.join(CHANNEL);
socketEvents = require('./controllers/socket')(socket)
console.log('Se conecto')
})
app.use('/', require('./routes/web'))
const port = process.env.PORT || 3000 const port = process.env.PORT || 3000
const SESSION_FILE_PATH = './session.json';
var client; var client;
var sessionData; app.use('/', require('./routes/web'))
/** /**
* Escuchamos cuando entre un mensaje * Escuchamos cuando entre un mensaje
*/ */
const listenMessage = () => client.on('message', async msg => { const listenMessage = () => client.on('message', async msg => {
const { from, body, hasMedia } = msg; const { from, body, hasMedia } = msg;
if (!isValidNumber(from)) {
return
}
// Este bug lo reporto Lucas Aldeco Brescia para evitar que se publiquen estados // Este bug lo reporto Lucas Aldeco Brescia para evitar que se publiquen estados
if (from === 'status@broadcast') { if (from === 'status@broadcast') {
return return
} }
message = body.toLowerCase(); message = body.toLowerCase();
console.log('BODY',message) console.log('BODY', message)
const number = cleanNumber(from) const number = cleanNumber(from)
await readChat(number, message) await readChat(number, message)
@@ -68,7 +56,8 @@ const listenMessage = () => client.on('message', async msg => {
*/ */
if (process.env.DATABASE === 'dialogflow') { if (process.env.DATABASE === 'dialogflow') {
const response = await bothResponse(message); if (!message.length) return;
const response = await bothResponse(message, number);
await sendMessage(client, from, response.replyMessage); await sendMessage(client, from, response.replyMessage);
if (response.media) { if (response.media) {
sendMedia(client, from, response.media); sendMedia(client, from, response.media);
@@ -101,7 +90,8 @@ const listenMessage = () => client.on('message', async msg => {
*/ */
await sendMessage(client, from, response.replyMessage, response.trigger); await sendMessage(client, from, response.replyMessage, response.trigger);
if(response.hasOwnProperty('actions')){
if (response.hasOwnProperty('actions')) {
const { actions } = response; const { actions } = response;
await sendMessageButton(client, from, null, actions); await sendMessageButton(client, from, null, actions);
return return
@@ -126,7 +116,7 @@ const listenMessage = () => client.on('message', async msg => {
/** /**
* Si quieres enviar botones * Si quieres enviar botones
*/ */
if(response.hasOwnProperty('actions')){ if (response.hasOwnProperty('actions')) {
const { actions } = response; const { actions } = response;
await sendMessageButton(client, from, null, actions); await sendMessageButton(client, from, null, actions);
} }
@@ -134,96 +124,38 @@ const listenMessage = () => client.on('message', async msg => {
} }
}); });
/**
* Revisamos si tenemos credenciales guardadas para inciar sessio
* este paso evita volver a escanear el QRCODE
*/
const withSession = () => {
// Si exsite cargamos el archivo con las credenciales
console.log(`Validando session con Whatsapp...`)
sessionData = require(SESSION_FILE_PATH);
client = new Client({
authStrategy: new LegacySessionAuth({
session: sessionData // saved session object
}),
restartOnAuthFail: true,
puppeteer: {
args: [
'--no-sandbox'
],
}
});
client.on('ready', () => {
connectionReady()
listenMessage()
loadRoutes(client);
socketEvents.sendStatus()
});
client.on('auth_failure', () => connectionLost()) client = new Client({
authStrategy: new LocalAuth(),
puppeteer: { headless: true }
});
client.initialize(); client.on('qr', qr => generateImage(qr, () => {
} qrcode.generate(qr, { small: true });
/** console.log(`Ver QR http://localhost:${port}/qr`)
* Generamos un QRCODE para iniciar sesion socketEvents.sendQR(qr)
*/ }))
const withOutSession = () => {
console.log('No tenemos session guardada');
console.log([
'🙌 El core de whatsapp se esta actualizando',
'🙌 para proximamente dar paso al multi-device',
'🙌 falta poco si quieres estar al pendiente unete',
'🙌 http://t.me/leifermendez',
'________________________',
].join('\n'));
client = new Client({ client.on('ready', (a) => {
authStrategy: new LocalAuth(), connectionReady()
puppeteer: { listenMessage()
headless: true, // socketEvents.sendStatus(client)
args: ['--no-sandbox'] });
},
clientId: 'client-one'
});
client.on('qr', qr => generateImage(qr, () => { client.on('auth_failure', (e) => {
qrcode.generate(qr, { small: true }); // console.log(e)
console.log(`Ver QR http://localhost:${port}/qr`) // connectionLost()
socketEvents.sendQR(qr) });
}))
client.on('ready', (a) => { client.on('authenticated', () => {
connectionReady() console.log('AUTHENTICATED');
listenMessage() });
loadRoutes(client);
// socketEvents.sendStatus(client)
});
client.on('auth_failure', (e) => { client.initialize();
// console.log(e)
// connectionLost()
});
client.on('authenticated', (session) => {
sessionData = session;
});
client.initialize();
}
/**
* Cargamos rutas de express
*/
const loadRoutes = (client) => {
app.use('/api/', middlewareClient(client), require('./routes/api'))
}
/**
* Revisamos si existe archivo con credenciales!
*/
(fs.existsSync(SESSION_FILE_PATH)) ? withSession() : withOutSession();
/** /**
* Verificamos si tienes un gesto de db * Verificamos si tienes un gesto de db
@@ -236,5 +168,4 @@ if (process.env.DATABASE === 'mysql') {
server.listen(port, () => { server.listen(port, () => {
console.log(`El server esta listo por el puerto ${port}`); console.log(`El server esta listo por el puerto ${port}`);
}) })
checkEnvFile(); checkEnvFile();

View File

@@ -1,9 +1,9 @@
const mysql = require('mysql'); const mysql = require('mysql');
const connection = mysql.createConnection({ const connection = mysql.createConnection({
host : process.env.SQL_HOST || 'localhost', host : process.env.SQL_HOST || 'localhost',
user : process.env.SQL_USER || 'me', user : process.env.SQL_USER || 'root',
password : process.env.SQL_PASS || '', password : process.env.SQL_PASS || '',
database : process.env.SQL_DATABASE || 'my_db' database : process.env.SQL_DATABASE || 'pruebas'
}); });
const connect = () => connection.connect(function(err) { const connect = () => connection.connect(function(err) {

View File

@@ -1,6 +1,7 @@
const connectionReady = (cb = () =>{}) => { const connectionReady = (cb = () =>{}) => {
console.log('Listo para escuchas mensajes') console.log('Listo para escuchas mensajes')
console.log('Client is ready!'); console.log('Client is ready!');
console.log('🔴 escribe: hola');
cb() cb()
} }

View File

@@ -15,8 +15,8 @@ const responseMessages = async (step) => {
return data return data
} }
const bothResponse = async (message) => { const bothResponse = async (message, sessionId) => {
const data = await getIA(message) const data = await getIA(message, sessionId)
if(data && data.media){ if(data && data.media){
const file = await saveExternalFile(data.media) const file = await saveExternalFile(data.media)
return {...data,...{media:file}} return {...data,...{media:file}}

View File

@@ -1,8 +1,10 @@
const { Client, LegacySessionAuth, LocalAuth } = require('whatsapp-web.js');
const http = require('http'); // or 'https' for https:// URLs const http = require('http'); // or 'https' for https:// URLs
const https = require('https'); // or 'https' for https:// URLs const https = require('https'); // or 'https' for https:// URLs
const fs = require('fs'); const fs = require('fs');
const qr = require('qr-image') const qr = require('qr-image')
const MULTI_DEVICE = process.env.MULTI_DEVICE || 'true';
const cleanNumber = (number) => { const cleanNumber = (number) => {
number = number.replace('@c.us', ''); number = number.replace('@c.us', '');
@@ -57,4 +59,25 @@ const checkEnvFile = () => {
} }
} }
module.exports = {cleanNumber, saveExternalFile, generateImage, checkIsUrl, checkEnvFile} /**
*
* @param {*} session
* @param {*} cb
*/
const createClient = () => {
client = new Client({
authStrategy: new LocalAuth(
{dataPath: './sessions/',
clientId: 'bot'}),
puppeteer: { headless: false }
});
}
const isValidNumber = (rawNumber) => {
const regexGroup = /\@g.us\b/gm;
const exist = rawNumber.match(regexGroup);
return !exist
}
module.exports = {cleanNumber, saveExternalFile, generateImage, checkIsUrl, checkEnvFile, createClient, isValidNumber}

View File

@@ -15,12 +15,17 @@ const { saveMessage } = require('../adapter')
* @param {*} fileName * @param {*} fileName
*/ */
const sendMedia = (client, number, fileName) => { const sendMedia = (client, number = null, fileName = null) => {
number = cleanNumber(number) if(!client) return cosnole.error("El objeto cliente no está definido.");
const file = `${DIR_MEDIA}/${fileName}`; try {
if (fs.existsSync(file)) { number = cleanNumber(number || 0)
const media = MessageMedia.fromFilePath(file); const file = `${DIR_MEDIA}/${fileName}`;
client.sendMessage(number, media, { sendAudioAsVoice: true }); if (fs.existsSync(file)) {
const media = MessageMedia.fromFilePath(file);
client.sendMessage(number, media, { sendAudioAsVoice: true });
}
} catch(e) {
throw e;
} }
} }
@@ -30,15 +35,21 @@ const sendMedia = (client, number, fileName) => {
* @param {*} fileName * @param {*} fileName
*/ */
const sendMediaVoiceNote = (client, number, fileName) => { const sendMediaVoiceNote = (client, number = null, fileName = null) => {
number = cleanNumber(number) if(!client) return cosnole.error("El objeto cliente no está definido.");
const file = `${DIR_MEDIA}/${fileName}`; try {
if (fs.existsSync(file)) { number = cleanNumber(number || 0)
const media = MessageMedia.fromFilePath(file); const file = `${DIR_MEDIA}/${fileName}`;
client.sendMessage(number, media ,{ sendAudioAsVoice: true }); if (fs.existsSync(file)) {
} const media = MessageMedia.fromFilePath(file);
client.sendMessage(number, media ,{ sendAudioAsVoice: true });
}
}catch(e) {
throw e;
} }
}
/** /**
* Enviamos un mensaje simple (texto) a nuestro cliente * Enviamos un mensaje simple (texto) a nuestro cliente
* @param {*} number * @param {*} number
@@ -99,4 +110,4 @@ const readChat = async (number, message, trigger = null) => {
console.log('Saved') console.log('Saved')
} }
module.exports = { sendMessage, sendMedia, lastTrigger, sendMessageButton, readChat, sendMediaVoiceNote } module.exports = { sendMessage, sendMedia, lastTrigger, sendMessageButton, readChat, sendMediaVoiceNote }

View File

@@ -2,6 +2,7 @@ const fs = require('fs')
const { sendMessage } = require('../controllers/send') const { sendMessage } = require('../controllers/send')
const sendMessagePost = (req, res) => { const sendMessagePost = (req, res) => {
console.log('asdasdasdasdasd')
const { message, number } = req.body const { message, number } = req.body
const client = req.clientWs || null; const client = req.clientWs || null;
sendMessage(client, number, message) sendMessage(client, number, message)

View File

@@ -27,7 +27,7 @@
"\n Si necesitas ver más info sobre las capacitacion tecnicas ", "\n Si necesitas ver más info sobre las capacitacion tecnicas ",
"escribe *cursos* o *info* o escribe *audio*" "escribe *cursos* o *info* o escribe *audio*"
], ],
"media":null, "media":"https://media2.giphy.com/media/VQJu0IeULuAmCwf5SL/giphy.gif",
"trigger":null, "trigger":null,
"actions":{ "actions":{
"title":"¿Que te interesa ver?", "title":"¿Que te interesa ver?",

7265
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -1,38 +1,56 @@
{ {
"name": "test-ws-bot", "name": "bot-whatsapp",
"version": "1.0.0", "version": "1.0.0",
"description": "", "description": "Bot de wahtsapp open source para MVP o pequeños negocios",
"main": "app.js", "main": "app.js",
"scripts": { "scripts": {
"start": "node ./app.js", "start": "node ./app.js",
"test": "echo \"Error: no test specified\" && exit 1" "test": "echo \"Error: no test specified\" && exit 1"
}, },
"keywords": [], "keywords": [
"author": "", "whatsapp",
"bot-whatsapp",
"node-bot-whatsapp"
],
"contributors": [
{
"email": "leifer33@gmail.com",
"name": "Leifer Mendez",
"url": "https://leifermendez.github.io"
},
{
"name": "aurik3",
"email": "aurik3@aurik3.com",
"url": "https://github.com/aurik3"
}
],
"repository": {
"type": "git",
"url": "https://github.com/leifermendez/bot-whatsapp"
},
"license": "ISC", "license": "ISC",
"dependencies": { "dependencies": {
"@google-cloud/dialogflow": "^4.6.0", "@google-cloud/dialogflow": "^5.2.0",
"cors": "^2.8.5", "cors": "^2.8.5",
"dotenv": "^11.0.0", "dotenv": "^16.0.1",
"exceljs": "^4.3.0", "exceljs": "^4.3.0",
"express": "^4.17.2", "express": "^4.18.1",
"file-type": "^16.5.3", "file-type": "^17.1.6",
"mime-db": "^1.51.0", "mime-db": "^1.52.0",
"moment": "^2.29.1", "moment": "^2.29.4",
"mysql": "^2.18.1", "mysql": "^2.18.1",
"nanoid": "^3.1.32",
"qr-image": "^3.2.0", "qr-image": "^3.2.0",
"qrcode-terminal": "^0.12.0", "qrcode-terminal": "^0.12.0",
"socket.io": "^4.4.1", "socket.io": "^4.5.1",
"stormdb": "^0.5.2", "stormdb": "^0.6.0",
"whatsapp-web.js": "^1.16.4", "whatsapp-web.js": "^1.18.4",
"xlsx": "^0.16.9" "xlsx": "^0.18.5"
}, },
"devDependencies": { "devDependencies": {
"pm2": "^5.1.2", "pm2": "^5.2.0",
"prettier": "2.5.1" "prettier": "2.7.1"
}, },
"engines": { "engines": {
"node": "14.x" "node": "16.x"
} }
} }

View File

@@ -1,6 +1,6 @@
const express = require('express') const express = require('express')
const router = express.Router(); const router = express.Router();
const { sendMessagePost } = require('../controllers/web') const { sendMessagePost } = require('../controllers/web')|
router.post('/send', sendMessagePost) router.post('/send', sendMessagePost)