From ffaa7b04a2f3622e0df2e549366fbda68a23db82 Mon Sep 17 00:00:00 2001
From: Leifer Mendez <leifer33@gmail.com>
Date: Tue, 18 Jan 2022 13:00:04 +0100
Subject: [PATCH] mysql working

---
 .env.example        |  1 +
 adapter/mysql.js    | 10 ++++++----
 app.js              |  7 +++++++
 controllers/send.js |  1 -
 flow/response.json  | 10 ++++++++++
 5 files changed, 24 insertions(+), 5 deletions(-)

diff --git a/.env.example b/.env.example
index fbf1d72..ff8f502 100644
--- a/.env.example
+++ b/.env.example
@@ -1,5 +1,6 @@
 ######DATABASE: none, mysql, mongo, dialogflow
 
+DEFAULT_MESSAGE=true
 SAVE_MEDIA=true
 PORT=3000
 DATABASE=none
diff --git a/adapter/mysql.js b/adapter/mysql.js
index dcaaefc..a516f0a 100644
--- a/adapter/mysql.js
+++ b/adapter/mysql.js
@@ -1,7 +1,8 @@
 const {connection} = require('../config/mysql')
+const DATABASE_NAME = process.env.SQL_DATABASE || 'db_test'
 
 getData = (message = '', callback) => connection.query(
-    `SELECT * FROM db_test.keywords WHERE value LIKE '%${message}%'  LIMIT 1`,
+    `SELECT * FROM ${DATABASE_NAME}.initial WHERE keywords LIKE '%${message}%'  LIMIT 1`,
     (error, results
         ) => {
     const [response] = results
@@ -11,12 +12,13 @@ getData = (message = '', callback) => connection.query(
 
 
 getReply = (option_key = '', callback) => connection.query(
-    `SELECT * FROM db_test.replies WHERE option_key = '${option_key}'  LIMIT 1`,
+    `SELECT * FROM ${DATABASE_NAME}.response WHERE option_key = '${option_key}'  LIMIT 1`,
     (error, results
         ) => {
-    const [response] = results
+    const [response] = results;
+    console.log(response)
     const value = {
-        replyMessage:response?.value || '',
+        replyMessage:response?.replyMessage || '',
         trigger:response?.trigger || '',
         media:response?.media || ''
     }
diff --git a/app.js b/app.js
index 2b684ea..8ea8127 100644
--- a/app.js
+++ b/app.js
@@ -86,6 +86,13 @@ const listenMessage = () => client.on('message', async msg => {
         }
         return
     }
+
+    if(process.env.DEFAULT_MESSAGE === 'true'){
+        console.log('hehehe',(process.env.DEFAULT_MESSAGE) , step)
+        const response = await responseMessages('DEFAULT')
+        await sendMessage(client, from, response.replyMessage, response.trigger);
+        return
+    }
 });
 
 /**
diff --git a/controllers/send.js b/controllers/send.js
index f8353ef..95991e4 100644
--- a/controllers/send.js
+++ b/controllers/send.js
@@ -13,7 +13,6 @@ const { saveMedia } = require('../controllers/save')
 
 const sendMedia = (client, number, fileName) => {
     const dirMedia = `${__dirname}/../mediaSend/${fileName}`;
-    console.log(dirMedia)
     number = cleanNumber(number)
     if(fs.existsSync(dirMedia)){
         const media = MessageMedia.fromFilePath(dirMedia);
diff --git a/flow/response.json b/flow/response.json
index 759ff15..af6d4e8 100644
--- a/flow/response.json
+++ b/flow/response.json
@@ -1,4 +1,14 @@
 {
+    "DEFAULT":{
+        "replyMessage":[
+            "✌️ 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*"
+        ],
+        "media":null,
+        "trigger":null
+    },
     "STEP_0":{
         "replyMessage":[
             "El flujo ha finalizado \n",