Merge pull request #28 from leifermendez/dev

Dev

.gitignore

@@ -7,4 +7,6 @@ media/*
 !media/.gitkeep
 mediaSend/*
 !mediaSend/.gitkeep
-.env
+!mediaSend/nota-de-voz.mp3
+.env
+.wwebjs_auth

README.md

@@ -5,10 +5,18 @@ El siguiente proyecto se realizó con fines educativos para el canal de [Youtube
 
 [![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-ventas) 
+[![Deploy](https://www.herokucdn.com/deploy/button.svg)](https://heroku.com/deploy?template=https://github.com/leifermendez/bot-whatsapp) 
 
 > Comprarme un cafe!
 
@@ -24,18 +32,52 @@ El siguiente proyecto se realizó con fines educativos para el canal de [Youtube
 | QR Scan (route) | ✅ |
 | Easy deploy heroku  | ✅  |
 | Buttons | ✅ |
+| Send Voice Note | ✅ |
 | Add support ubuntu/linux | ✅ |
 
-### (Nuevo) Botones
-
-[![btn](https://i.imgur.com/W7oYlSu.png)](https://youtu.be/5lEMCeWEJ8o) 
-
 ## Requisitos
 - node v14 o superior
 - VSCode (Editor de codigo) [Descargar](https://code.visualstudio.com/download)
 - MySql (opcional) solo aplica si vas a usar el modo 'mysql'  [sql-bot.sql migración](https://github.com/leifermendez/bot-whatsapp/blob/main/sql-bot.sql)
 - Dialogflow (opcional) solo aplica si vas a usar el modo 'dialogflow'
 
+### (Nuevo) Botones
+
+[![btn](https://i.imgur.com/W7oYlSu.png)](https://youtu.be/5lEMCeWEJ8o) 
+
+> Implementar los botones solo necesitas hacer uso del metodo __sendMessageButton__ que se encuentra dentro `./controllers/send` dejo un ejemplo de como usarlo.
+[Ver implementación](https://github.com/leifermendez/bot-whatsapp/blob/main/app.js#L123)
+
+``` javascript
+const { sendMessageButton } = require('./controllers/send')
+
+await sendMessageButton(
+    {
+        "title":"¿Que te interesa ver?",
+        "message":"Recuerda todo este contenido es gratis y estaria genial que me siguas!",
+        "footer":"Gracias",
+        "buttons":[
+            {"body":"😎 Cursos"},
+            {"body":"👉 Youtube"},
+            {"body":"😁 Telegram"}
+        ]
+    }
+)
+
+```
+
+## Notas de Voz
+[![voice note](https://i.imgur.com/zq6xYDp.png)](https://i.imgur.com/zq6xYDp.png) 
+
+> Se pueden enviar notas de voz con formato nativo para que no se vea como reenviado. En este ejemplo enviare el archivo __PTT-20220223-WA0000.opus__ que se encuentra dentro de la carpeta de __/mediaSend__
+
+``` javascript
+const { sendMediaVoiceNote } = require('./controllers/send')
+
+await sendMediaVoiceNote(client, from, 'PTT-20220223-WA0000.opus')
+
+```
+
 ## Instruciones
 __Descargar o Clonar repositorio__
 ![](https://i.imgur.com/dSpUbFz.png)

adapter/index.js

@@ -1,4 +1,5 @@
-const { getData, getReply } = require('./mysql')
+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')
@@ -64,4 +65,25 @@ const getIA = (message) => new Promise((resolve, reject) => {
     }
 })
 
-module.exports = { get, reply, getIA }
+/**
+ * 
+ * @param {*} message 
+ * @param {*} date 
+ * @param {*} trigger 
+ * @param {*} number 
+ * @returns 
+ */
+const saveMessage = ( message, trigger, number  ) => new Promise( async (resolve, reject) => {
+     switch ( process.env.DATABASE ) {
+         case 'mysql':
+             resolve( await saveMessageMysql( message, trigger, number ) )
+             break;
+         case 'none':
+             resolve( await saveMessageJson( message, trigger, number ) )
+             break;
+         default:
+             break;
+    }
+})
+
+module.exports = { get, reply, getIA, saveMessage }

adapter/jsonDb.js

@@ -0,0 +1,20 @@
+const Path = require('path')
+const StormDB = require("stormdb");
+const date = new Date().toISOString();
+const saveMessageJson = (message, trigger, number) => new Promise( async(resolve,reject) =>{
+    try {
+        const engine = new StormDB.localFileEngine( Path.join(__dirname, `/../chats/${number}.json`) );
+        const db = new StormDB(engine);
+        // set default db value if db is empty
+        db.default({ messages: [] });
+        // add new users entry
+        db.get("messages").push({ message, date, trigger });
+        db.save();
+        resolve('Saved')
+    } catch (error) {
+        console.log(error)
+        reject(error)
+    }
+})
+
+module.exports = { saveMessageJson }

adapter/mysql.js

@@ -25,4 +25,47 @@ getReply = (option_key = '', callback) => connection.query(
     callback(value)
 });
 
-module.exports = {getData, getReply}
+getMessages = ( number ) => new Promise((resolve,reejct) => {
+    try {
+        connection.query(
+        `SELECT * FROM ${DATABASE_NAME}.response WHERE number = '${number}'`, (error, results) => {
+            if(error) {
+                console.log(error)
+            }
+            const [response] = results;
+            console.log(response)
+            const value = {
+                replyMessage:response?.replyMessage || '',
+                trigger:response?.trigger || '',
+                media:response?.media || ''
+            }
+            resolve(value)
+        })
+    } catch (error) {
+        
+    }
+})
+
+saveMessageMysql = ( message, date, trigger, number ) => new Promise((resolve,reejct) => {
+    try {
+        connection.query(
+        `INSERT INTO ${DATABASE_NAME}.messages  `+"( `message`, `date`, `trigger`, `number`)"+` VALUES ('${message}','${date}','${trigger}', '${number}')` , (error, results) => {
+            if(error) {
+                if( error.code === 'ER_NO_SUCH_TABLE' ){
+                    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) => {
+                        setTimeout( async () => {
+                            return resolve( await this.saveMessageMysql( message, date, trigger, number ) )
+                        }, 150)
+                    })
+                }
+            }
+            console.log('Saved')
+            console.log( results )
+            resolve(results)
+        })
+    } catch (error) {
+        
+    }
+})
+
+module.exports = {getData, getReply, saveMessageMysql}

app.js

@@ -6,10 +6,10 @@ const fs = require('fs');
 const express = require('express');
 const cors = require('cors')
 const qrcode = require('qrcode-terminal');
-const { Client } = require('whatsapp-web.js');
+const { Client, LegacySessionAuth } = require('whatsapp-web.js');
 const mysqlConnection = require('./config/mysql')
 const { middlewareClient } = require('./middleware/client')
-const { generateImage, cleanNumber } = require('./controllers/handle')
+const { generateImage, cleanNumber, checkEnvFile } = require('./controllers/handle')
 const { connectionReady, connectionLost } = require('./controllers/connection')
 const { saveMedia } = require('./controllers/save')
 const { getMessages, responseMessages, bothResponse } = require('./controllers/flows')
@@ -54,6 +54,7 @@ const listenMessage = () => client.on('message', async msg => {
     console.log('BODY',message)
     const number = cleanNumber(from)
     await readChat(number, message)
+
     /**
      * Guardamos el archivo multimedia que envia
      */
@@ -82,7 +83,6 @@ const listenMessage = () => client.on('message', async msg => {
     */
 
     const lastStep = await lastTrigger(from) || null;
-    console.log({ lastStep })
     if (lastStep) {
         const response = await responseMessages(lastStep)
         await sendMessage(client, from, response.replyMessage);
@@ -92,12 +92,20 @@ const listenMessage = () => client.on('message', async msg => {
      * Respondemos al primero paso si encuentra palabras clave
      */
     const step = await getMessages(message);
-    console.log({ step })
 
     if (step) {
-        const response = await responseMessages(step)
+        const response = await responseMessages(step);
+
+        /**
+         * Si quieres enviar botones
+         */
+
         await sendMessage(client, from, response.replyMessage, response.trigger);
-        
+        if(response.hasOwnProperty('actions')){
+            const { actions } = response;
+            await sendMessageButton(client, from, null, actions);
+            return
+        }
 
         if (!response.delay && response.media) {
             sendMedia(client, from, response.media);
@@ -135,7 +143,10 @@ const withSession = () => {
     console.log(`Validando session con Whatsapp...`)
     sessionData = require(SESSION_FILE_PATH);
     client = new Client({
-        session: sessionData,
+        authStrategy: new LegacySessionAuth({
+            session: sessionData // saved session object
+        }),
+        restartOnAuthFail: true,
         puppeteer: {
             args: [
                 '--no-sandbox'
@@ -160,8 +171,20 @@ const withSession = () => {
  */
 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({
+        session: { },
+        // authStrategy: new LegacySessionAuth({
+        //     session: { }
+        // }),
+        restartOnAuthFail: true,
         puppeteer: {
             args: [
                 '--no-sandbox'
@@ -182,7 +205,10 @@ const withOutSession = () => {
         // socketEvents.sendStatus(client)
     });
 
-    client.on('auth_failure', () => connectionLost());
+    client.on('auth_failure', (e) => {
+        // console.log(e)
+        // connectionLost()
+    });
 
     client.on('authenticated', (session) => {
         sessionData = session;
@@ -219,5 +245,5 @@ if (process.env.DATABASE === 'mysql') {
 server.listen(port, () => {
     console.log(`El server esta listo por el puerto ${port}`);
 })
-
+checkEnvFile();
 

config/mysql.js

@@ -2,7 +2,7 @@ const mysql      = require('mysql');
 const connection = mysql.createConnection({
   host     : process.env.SQL_HOST || 'localhost',
   user     : process.env.SQL_USER || 'me',
-  password : process.env.SQL_PASS || 'secret',
+  password : process.env.SQL_PASS || '',
   database : process.env.SQL_DATABASE || 'my_db'
 });
 

controllers/flows.js

@@ -1,5 +1,5 @@
 const {get, reply, getIA} = require('../adapter')
-const {saveExternalFile} = require('./handle')
+const {saveExternalFile, checkIsUrl} = require('./handle')
 
 const getMessages = async (message) => {
     const data = await get(message)
@@ -9,7 +9,7 @@ const getMessages = async (message) => {
 const responseMessages = async (step) => {
     const data = await reply(step)
     if(data && data.media){
-        const file = await saveExternalFile(data.media)
+        const file = checkIsUrl(data.media) ? await saveExternalFile(data.media) : data.media;
         return {...data,...{media:file}}
     }
     return data

controllers/handle.js

@@ -31,6 +31,16 @@ const saveExternalFile = (url) => new Promise((resolve, reject) => {
     });
 })
 
+const checkIsUrl = (path) => {
+    try{
+        regex = /^(http(s)?:\/\/)[\w.-]+(?:\.[\w\.-]+)+[\w\-\._~:/?#[\]@!\$&'\(\)\*\+,;=.]+$/i;
+        match = path.match(regex);
+        return match[0]
+    }catch(e){
+        return null
+    }
+}
+
 const generateImage = (base64, cb = () => {}) => {
     let qr_svg = qr.image(base64, { type: 'svg', margin: 4 });
     qr_svg.pipe(require('fs').createWriteStream('./mediaSend/qr-code.svg'));
@@ -39,4 +49,12 @@ const generateImage = (base64, cb = () => {}) => {
     cb()
 }
 
-module.exports = {cleanNumber, saveExternalFile, generateImage}
+const checkEnvFile = () => {
+    const pathEnv = `${__dirname}/../.env`;
+    const isExist = fs.existsSync(pathEnv);
+    if(!isExist){
+        console.log(`🆗 ATENCION! 🆗 te falta crear tu archivo .env de lo contrario no funcionara`)
+    }
+}
+
+module.exports = {cleanNumber, saveExternalFile, generateImage, checkIsUrl, checkEnvFile}

controllers/send.js

@@ -4,7 +4,11 @@ const moment = require('moment');
 const fs = require('fs');
 const { MessageMedia, Buttons } = require('whatsapp-web.js');
 const { cleanNumber } = require('./handle')
-const { saveMedia } = require('../controllers/save')
+const DELAY_TIME = 170; //ms
+const DIR_MEDIA = `${__dirname}/../mediaSend`;
+// import { Low, JSONFile } from 'lowdb'
+// import { join } from 'path'
+const { saveMessage } = require('../adapter')
 /**
  * Enviamos archivos multimedia a nuestro cliente
  * @param {*} number 
@@ -12,11 +16,26 @@ const { saveMedia } = require('../controllers/save')
  */
 
 const sendMedia = (client, number, fileName) => {
-    const dirMedia = `${__dirname}/../mediaSend/${fileName}`;
     number = cleanNumber(number)
-    if (fs.existsSync(dirMedia)) {
-        const media = MessageMedia.fromFilePath(dirMedia);
-        client.sendMessage(number, media);
+    const file = `${DIR_MEDIA}/${fileName}`;
+    if (fs.existsSync(file)) {
+        const media = MessageMedia.fromFilePath(file);
+        client.sendMessage(number, media, { sendAudioAsVoice: true });
+    }
+}
+
+/**
+ * Enviamos archivos como notas de voz
+ * @param {*} number 
+ * @param {*} fileName 
+ */
+
+ const sendMediaVoiceNote = (client, number, fileName) => {
+    number = cleanNumber(number)
+    const file = `${DIR_MEDIA}/${fileName}`;
+    if (fs.existsSync(file)) {
+        const media = MessageMedia.fromFilePath(file);
+        client.sendMessage(number, media ,{ sendAudioAsVoice: true });
     }
 }
 
@@ -25,11 +44,13 @@ const sendMedia = (client, number, fileName) => {
  * @param {*} number 
  */
 const sendMessage = async (client, number = null, text = null, trigger = null) => {
+   setTimeout(async () => {
     number = cleanNumber(number)
     const message = text
     client.sendMessage(number, message);
     await readChat(number, message, trigger)
     console.log(`⚡⚡⚡ Enviando mensajes....`);
+   },DELAY_TIME)
 }
 
 /**
@@ -73,49 +94,9 @@ const lastTrigger = (number) => new Promise((resolve, reject) => {
  * @param {*} message 
  */
 const readChat = async (number, message, trigger = null) => {
-    setTimeout(() => {
-        const pathExcel = `${__dirname}/../chats/${number}.xlsx`;
-    const workbook = new ExcelJS.Workbook();
-    const today = moment().format('DD-MM-YYYY hh:mm')
-
-    if (fs.existsSync(pathExcel)) {
-        /**
-         * Si existe el archivo de conversacion lo actualizamos
-         */
-        const workbook = new ExcelJS.Workbook();
-        workbook.xlsx.readFile(pathExcel)
-            .then(() => {
-                const worksheet = workbook.getWorksheet(1);
-                const lastRow = worksheet.lastRow;
-                var getRowInsert = worksheet.getRow(++(lastRow.number));
-                getRowInsert.getCell('A').value = today;
-                getRowInsert.getCell('B').value = message;
-                getRowInsert.getCell('C').value = trigger;
-                getRowInsert.commit();
-                workbook.xlsx.writeFile(pathExcel);
-            });
-
-    } else {
-        /**
-         * NO existe el archivo de conversacion lo creamos
-         */
-        const worksheet = workbook.addWorksheet('Chats');
-        worksheet.columns = [
-            { header: 'Fecha', key: 'number_customer' },
-            { header: 'Mensajes', key: 'message' },
-            { header: 'Disparador', key: 'trigger' }
-        ];
-        worksheet.addRow([today, message, trigger]);
-        workbook.xlsx.writeFile(pathExcel)
-            .then(() => {
-
-                console.log("saved");
-            })
-            .catch((err) => {
-                console.log("err", err);
-            });
-    }
-    }, 900)
+    number = cleanNumber(number)
+    await saveMessage( message, trigger, number )
+    console.log('Saved')
 }
 
-module.exports = { sendMessage, sendMedia, lastTrigger, sendMessageButton, readChat }
+module.exports = { sendMessage, sendMedia, lastTrigger, sendMessageButton, readChat, sendMediaVoiceNote }

flow/initial.json

@@ -21,8 +21,7 @@
         "keywords":  [
             "cursos",
             "info",
-            "curso"
-        ],
+            "curso"        ],
         "key": "STEP_2"
     },
     {
@@ -69,20 +68,26 @@
     },
     {
         "keywords":  [
-            "👉 Youtube"
+            "youtube"
         ],
         "key": "STEP_5"
     },
     {
         "keywords":  [
-            "😎 Cursos"
+            "VER_CURSOS"
         ],
         "key": "STEP_6"
     },
     {
         "keywords":  [
-            "😁 Telegram"
+            "telegram"
         ],
         "key": "STEP_7"
+    },
+    {
+        "keywords":  [
+            "audio"
+        ],
+        "key": "STEP_8"
     }
 ]

flow/response.json

@@ -1,21 +1,15 @@
 {
     "DEFAULT":{
         "replyMessage":[
-            "🆗 Bienvenido a este 🤖 CHATBOT de Whatsapp, lo primero \n",
-            "decirte que mi nombre es *Leifer Mendez*😎 y te dejo opciones rapidas \n"
+            "*Esta respuesta es un respuesta default* cuando no se consigue una palabra clave \n",
+            "la puedes desactivar en tu archivo .env DEFAULT_MESSAGE=false \n",
+            "tambien te quiero recordar que si presentas algun error pasarte por el repositorio \n",
+            "https://github.com/leifermendez/bot-whatsapp#chatbot-whatsapp-opensource \n",
+            "y recuerda tener la ultima versión del proyecto \n\n",
+            "Prueba escribiendo *hola* \n"
         ],
         "media":null,
-        "trigger":null,
-        "actions":{
-            "title":"¿Que te interesa ver?",
-            "message":"Recuerda todo este contenido es gratis y estaria genial que me siguas!",
-            "footer":"Gracias",
-            "buttons":[
-                {"body":"😎 Cursos"},
-                {"body":"👉 Youtube"},
-                {"body":"😁 Telegram"}
-            ]
-        }
+        "trigger":null
     },
     "STEP_0":{
         "replyMessage":[
@@ -28,13 +22,23 @@
     },
     "STEP_1":{
         "replyMessage":[
-            "✌️ Bienvenido a este 🤖 CHATBOT de Whatsapp, lo primero \n",
+            "Hola! y✌️ Bienvenido a este 🤖 CHATBOT de Whatsapp, lo primero \n",
             "decirte que mi nombre es *Leifer Mendez*😎  \n",
             "\n Si necesitas ver más info sobre las capacitacion tecnicas ",
-            "escribe *cursos* o *info*"
+            "escribe *cursos* o *info* o escribe *audio*"
         ],
         "media":null,
-        "trigger":null
+        "trigger":null,
+        "actions":{
+            "title":"¿Que te interesa ver?",
+            "message":"Recuerda todo este contenido es gratis y estaria genial que me siguas!",
+            "footer":"Gracias",
+            "buttons":[
+                {"body":"Cursos"},
+                {"body":"Youtube"},
+                {"body":"Telegram"}
+            ]
+        }
     },
     "STEP_2":{
         "replyMessage":[
@@ -106,9 +110,10 @@
     },
     "STEP_5":{
         "replyMessage":[
-            "Muy bien te comparto el canal de Youtube \n"
+            "Muy bien te comparto el canal de Youtube \n",
+            "https://youtube.com/leifermendez \n"
         ],
-        "media":"https://youtube.com/leifermendez",
+        "media":null,
         "trigger":null
     },
     "STEP_6":{
@@ -127,9 +132,17 @@
     },
     "STEP_7":{
         "replyMessage":[
-            "Vente al telegram \n"
+            "Vente al telegram \n",
+            "https://t.me/leifermendez \n"
         ],
-        "media":"https://t.me/leifermendez",
+        "media":null,
+        "trigger":null
+    },
+    "STEP_8":{
+        "replyMessage":[
+            "Esto es una nota de voz \n"
+        ],
+        "media":"nota-de-voz.mp3",
         "trigger":null
     }
 }

package.json

@@ -24,7 +24,8 @@
     "qr-image": "^3.2.0",
     "qrcode-terminal": "^0.12.0",
     "socket.io": "^4.4.1",
-    "whatsapp-web.js": "^1.15.4",
+    "stormdb": "^0.5.2",
+    "whatsapp-web.js": "^1.16.4",
     "xlsx": "^0.16.9"
   },
   "devDependencies": {