Merge pull request #848 from MartnReus/fix/mysql-conection-timeout

fix(database): MySQL conection timeout
codigoencasa · Sep 9, 2023 · aedd4b1 · aedd4b1
2 parents eade995 + 8391037
commit aedd4b1
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/packages/database/src/mysql/index.js b/packages/database/src/mysql/index.js
@@ -25,25 +25,27 @@ class MyslAdapter {
         })
     }
 
-    getPrevByNumber = (from) =>
-        new Promise((resolve, reject) => {
-            const sql = `SELECT * FROM history WHERE phone='${from}' ORDER BY id DESC`
+    getPrevByNumber = async (from) => {
+        if (this.db._closing) await this.init() 
+        return await new Promise((resolve, reject) => {
+            const sql = `SELECT * FROM history WHERE phone='${from}' ORDER BY id DESC`;
             this.db.query(sql, (error, rows) => {
                 if (error) {
-                    reject(error)
+                    reject(error);
                 }
 
                 if (rows.length) {
-                    const [row] = rows
-                    row.options = JSON.parse(row.options)
-                    resolve(row)
+                    const [row] = rows;
+                    row.options = JSON.parse(row.options);
+                    resolve(row);
                 }
 
                 if (!rows.length) {
-                    resolve(null)
+                    resolve(null);
                 }
-            })
+            });
         })
+    }
 
     save = (ctx) => {
         const values = [