Compare commits

...

27 Commits

Author SHA1 Message Date
Leifer Mendez
4819dfebda Create config.yml 2022-12-14 10:23:24 +01:00
Leifer Mendez
29fd94a0e1 Update bug.yml 2022-12-14 10:18:07 +01:00
Leifer Mendez
851052b3d2 Update bug.yml 2022-12-14 10:12:21 +01:00
Leifer Mendez
a43444bb3e Create bug.yml 2022-12-14 08:02:08 +01:00
Leifer Mendez
c2a6c6872d Create PULL_REQUEST_TEMPLATE.md 2022-12-14 07:59:13 +01:00
Leifer Mendez
f0a0bacec9 Merge pull request #191 from leifermendez/add-code-of-conduct-1
Create CODE_OF_CONDUCT.md
2022-12-12 16:42:40 +01:00
Leifer Mendez
ec32dc429f Create CODE_OF_CONDUCT.md 2022-12-12 16:42:12 +01:00
Leifer Mendez
5303dd7d25 Create FUNDING.yml 2022-12-12 00:44:58 +01:00
Leifer Mendez
0246fc0b91 Merge pull request #171 from leifermendez/add-license-1
Create LICENSE.md
2022-12-11 22:21:00 +01:00
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
19 changed files with 6723 additions and 770 deletions

2
.github/FUNDING.yml vendored Normal file
View File

@@ -0,0 +1,2 @@
patreon: leifermendez
custom: "https://www.buymeacoffee.com/leifermendez"

58
.github/ISSUE_TEMPLATE/bug.yml vendored Normal file
View File

@@ -0,0 +1,58 @@
name: 🐛 Reporte Bug
description: Algo no va bien?. Hazlo saber
labels: [bug, triage]
title: '[🐛]'
body:
- type: markdown
attributes:
value: |
Gracias por tomarte el tiempo de reportar este problema
- type: dropdown
id: version
attributes:
label: ¿Que versión estas usando?
description: '__INFO:__ Recuerda que puedes consultar dudas directamente en [discord](https://link.codigoencasa.com/DISCORD)'
options:
- v2
- v1
validations:
required: true
- type: dropdown
id: component
attributes:
label: ¿Sobre que afecta?
options:
- Flujo de palabras (Flow)
- DialogFlow
- Base de datos
- Otro
validations:
required: true
- type: textarea
id: description
attributes:
description: 'Trata de ser lo más claro posible, de esa manera podemos entender el contexto de tu problema y darte una mejor solución'
label: Describe tu problema
placeholder: Yo tengo un problema....
validations:
required: true
- type: input
id: reproduction
attributes:
label: Reproducir error
description: __(Recomendación)__ trata de grabar un video puedes usar algunas de las siguientes herramientas [https://www.vidyard.com/](https://www.vidyard.com/) [https://www.loom.com/](https://www.loom.com/) y en lo posbile apoyate en [https://stackblitz.com/](https://stackblitz.com/) para compartir el código de ser necesario
placeholder: URL video o stackblitz
validations:
required: false
- type: textarea
id: additional_information
attributes:
label: Información Adicional
validations:
required: false

4
.github/ISSUE_TEMPLATE/config.yml vendored Normal file
View File

@@ -0,0 +1,4 @@
contact_links:
- name: 🤔 Core Team
url: https://link.codigoencasa.com/DISCORD
about: Si quieres formar parte del CoreTeam, patrocinar el proyecto o propuesta profesionales

23
.github/PULL_REQUEST_TEMPLATE.md vendored Normal file
View File

@@ -0,0 +1,23 @@
# Cual version del BOT es?
- [ ] v2
- [ ] v1
# Que tipo de ISSUE es?
- [ ] Mejoras
- [ ] Bug
- [ ] Docs / tests
# Description
Por favor agrega una descripción de tu problema para tener más contexto y poder ayudar más rápido. Si es de ayuda puedes usar plataformar como [https://www.loom.com/](https://www.loom.com/) para grabar un video.
> Forma parte de este proyecto.
- [Discord](https://link.codigoencasa.com/DISCORD)
- [Twitter](https://twitter.com/leifermendez)
- [Youtube](https://www.youtube.com/watch?v=5lEMCeWEJ8o&list=PL_WGMLcL4jzWPhdhcUyhbFU6bC0oJd2BR)
- [Telegram](https://t.me/leifermendez)

128
CODE_OF_CONDUCT.md Normal file
View File

@@ -0,0 +1,128 @@
# Contributor Covenant Code of Conduct
## Our Pledge
We as members, contributors, and leaders pledge to make participation in our
community a harassment-free experience for everyone, regardless of age, body
size, visible or invisible disability, ethnicity, sex characteristics, gender
identity and expression, level of experience, education, socio-economic status,
nationality, personal appearance, race, religion, or sexual identity
and orientation.
We pledge to act and interact in ways that contribute to an open, welcoming,
diverse, inclusive, and healthy community.
## Our Standards
Examples of behavior that contributes to a positive environment for our
community include:
* Demonstrating empathy and kindness toward other people
* Being respectful of differing opinions, viewpoints, and experiences
* Giving and gracefully accepting constructive feedback
* Accepting responsibility and apologizing to those affected by our mistakes,
and learning from the experience
* Focusing on what is best not just for us as individuals, but for the
overall community
Examples of unacceptable behavior include:
* The use of sexualized language or imagery, and sexual attention or
advances of any kind
* Trolling, insulting or derogatory comments, and personal or political attacks
* Public or private harassment
* Publishing others' private information, such as a physical or email
address, without their explicit permission
* Other conduct which could reasonably be considered inappropriate in a
professional setting
## Enforcement Responsibilities
Community leaders are responsible for clarifying and enforcing our standards of
acceptable behavior and will take appropriate and fair corrective action in
response to any behavior that they deem inappropriate, threatening, offensive,
or harmful.
Community leaders have the right and responsibility to remove, edit, or reject
comments, commits, code, wiki edits, issues, and other contributions that are
not aligned to this Code of Conduct, and will communicate reasons for moderation
decisions when appropriate.
## Scope
This Code of Conduct applies within all community spaces, and also applies when
an individual is officially representing the community in public spaces.
Examples of representing our community include using an official e-mail address,
posting via an official social media account, or acting as an appointed
representative at an online or offline event.
## Enforcement
Instances of abusive, harassing, or otherwise unacceptable behavior may be
reported to the community leaders responsible for enforcement at
leifer.contacto@gmail.com.
All complaints will be reviewed and investigated promptly and fairly.
All community leaders are obligated to respect the privacy and security of the
reporter of any incident.
## Enforcement Guidelines
Community leaders will follow these Community Impact Guidelines in determining
the consequences for any action they deem in violation of this Code of Conduct:
### 1. Correction
**Community Impact**: Use of inappropriate language or other behavior deemed
unprofessional or unwelcome in the community.
**Consequence**: A private, written warning from community leaders, providing
clarity around the nature of the violation and an explanation of why the
behavior was inappropriate. A public apology may be requested.
### 2. Warning
**Community Impact**: A violation through a single incident or series
of actions.
**Consequence**: A warning with consequences for continued behavior. No
interaction with the people involved, including unsolicited interaction with
those enforcing the Code of Conduct, for a specified period of time. This
includes avoiding interactions in community spaces as well as external channels
like social media. Violating these terms may lead to a temporary or
permanent ban.
### 3. Temporary Ban
**Community Impact**: A serious violation of community standards, including
sustained inappropriate behavior.
**Consequence**: A temporary ban from any sort of interaction or public
communication with the community for a specified period of time. No public or
private interaction with the people involved, including unsolicited interaction
with those enforcing the Code of Conduct, is allowed during this period.
Violating these terms may lead to a permanent ban.
### 4. Permanent Ban
**Community Impact**: Demonstrating a pattern of violation of community
standards, including sustained inappropriate behavior, harassment of an
individual, or aggression toward or disparagement of classes of individuals.
**Consequence**: A permanent ban from any sort of public interaction within
the community.
## Attribution
This Code of Conduct is adapted from the [Contributor Covenant][homepage],
version 2.0, available at
https://www.contributor-covenant.org/version/2/0/code_of_conduct.html.
Community Impact Guidelines were inspired by [Mozilla's code of conduct
enforcement ladder](https://github.com/mozilla/diversity).
[homepage]: https://www.contributor-covenant.org
For answers to common questions about this code of conduct, see the FAQ at
https://www.contributor-covenant.org/faq. Translations are available at
https://www.contributor-covenant.org/translations.

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,27 +1,4 @@
## Chatbot Whatsapp (OpenSource) ## Chatbot Whatsapp (OpenSource)
#### Actualizado Abril 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 🔴
> 💥💥 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
> 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)
### Busco colaboradores ⭐
Hola amigos me gusta mucho este proyecto pero por cuestiones de tiempo se me dificulta mantener las actualizaciones si alguno quieres participar en el proyecto escribeme a leifer.contacto@gmail.com
#### 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
@@ -81,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
@@ -93,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`
@@ -114,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!
@@ -145,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,6 +1,6 @@
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
*/ */
@@ -30,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 = KEEP_DIALOG_FLOW ? 1 : 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 = {
@@ -56,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,
@@ -66,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)
}) })

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)
}); });

101
app.js
View File

@@ -6,7 +6,7 @@ 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 } = 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, createClient, isValidNumber } = require('./controllers/handle') const { generateImage, cleanNumber, checkEnvFile, createClient, isValidNumber } = require('./controllers/handle')
@@ -21,10 +21,7 @@ const MULTI_DEVICE = process.env.MULTI_DEVICE || 'true';
const server = require('http').Server(app) const server = require('http').Server(app)
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')) app.use('/', require('./routes/web'))
/** /**
@@ -33,7 +30,7 @@ app.use('/', require('./routes/web'))
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)){ if (!isValidNumber(from)) {
return return
} }
@@ -42,7 +39,7 @@ const listenMessage = () => client.on('message', async msg => {
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)
@@ -59,8 +56,8 @@ const listenMessage = () => client.on('message', async msg => {
*/ */
if (process.env.DATABASE === 'dialogflow') { if (process.env.DATABASE === 'dialogflow') {
if(!message.length) return; if (!message.length) return;
const response = await bothResponse(message); 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);
@@ -94,7 +91,7 @@ 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
@@ -119,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);
} }
@@ -127,77 +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 = () => {
console.log(`Validando session con Whatsapp...`)
sessionData = require(SESSION_FILE_PATH);
client = new Client(createClient(sessionData,true));
client.on('ready', () => {
connectionReady()
listenMessage()
});
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',
'🙌 Si estas usando el modo multi-device se generan 2 QR Code escanealos',
'🙌 Ten paciencia se esta generando el QR CODE',
'________________________',
].join('\n'));
client = new Client(createClient()); client.on('ready', (a) => {
connectionReady()
listenMessage()
// socketEvents.sendStatus(client)
});
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() });
// socketEvents.sendStatus(client)
});
client.on('auth_failure', (e) => { client.initialize();
// console.log(e)
// connectionLost()
});
client.on('authenticated', (session) => {
sessionData = session;
if(sessionData){
fs.writeFile(SESSION_FILE_PATH, JSON.stringify(session), function (err) {
if (err) {
console.log(`Ocurrio un error con el archivo: `, err);
}
});
}
});
client.initialize();
}
/**
* Revisamos si existe archivo con credenciales!
*/
(fs.existsSync(SESSION_FILE_PATH) && MULTI_DEVICE === 'false') ? withSession() : withOutSession();
/** /**
* Verificamos si tienes un gesto de db * Verificamos si tienes un gesto de db
@@ -211,4 +169,3 @@ 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

@@ -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

@@ -64,32 +64,14 @@ const checkEnvFile = () => {
* @param {*} session * @param {*} session
* @param {*} cb * @param {*} cb
*/ */
const createClient = (session = {}, login = false) => { const createClient = () => {
console.log(`Mode: ${(MULTI_DEVICE === 'false') ? 'No Multi-device' : 'Si Multi-device'} `) client = new Client({
const objectLegacy = (login) ? { authStrategy: new LocalAuth(
authStrategy: new LegacySessionAuth({ {dataPath: './sessions/',
session clientId: 'bot'}),
}) puppeteer: { headless: false }
} : {session};
if(MULTI_DEVICE == 'false') { });
return {...objectLegacy,
restartOnAuthFail: true,
puppeteer: {
args: [
'--no-sandbox'
],
}
}
}else{
return {
puppeteer: {
headless: true,
args: ['--no-sandbox']
},
clientId: 'client-one'
}
}
} }
const isValidNumber = (rawNumber) => { const isValidNumber = (rawNumber) => {

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

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)

6950
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.7.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.2", "moment": "^2.29.4",
"mysql": "^2.18.1", "mysql": "^2.18.1",
"nanoid": "^3.3.2",
"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.6", "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)