redis queue library version update

Author: hkulekci

libraries/database.js

@@ -1,6 +1,6 @@
-var mysql = require('mysql2');
+const mysql = require('mysql2');
 
-var pool = mysql.createPool({
+const pool = mysql.createPool({
   host: process.env.MYSQL_HOST,
   user: process.env.MYSQL_USER,
   password: process.env.MYSQL_PASS,
@@ -9,7 +9,10 @@ var pool = mysql.createPool({
   debug: process.env.MYSQL_DEBUG == 'true' ? true : false,
   connectionLimit: 10,
   supportBigNumbers: true,
-  insecureAuth: true // *** dont use production. ***
+  insecureAuth: true, // *** dont use production. ***
+  maxIdle: 10,
+  idleTimeout: 60000,
+  queueLimit: 0
 });
 
 module.exports = pool;

libraries/redis-client.js

@@ -1,10 +1,11 @@
-var redis = require('redis');
-  client = redis.createClient({'host': process.env.REDIS_HOST});
-
-await client.connect();
+const redis = require('redis');
+  client = redis.createClient({'url': process.env.REDIS_HOST});
 
 const RedisClient = {
   getClient: function() {
+    if (!client.isOpen) {
+      client.connect().then()
+    }
     return client;
   },
 
@@ -26,14 +27,17 @@ const RedisClient = {
     }
   },
 
-  get: function(key, callback) {
-    client.get(key, function(err, result) {
-      if (result) {
-        callback(err, JSON.parse(result));
-        return;
-      }
-      callback(true, {});
-    });
+  get: async function(key) {
+    if (!client.isOpen) {
+      await client.connect()
+    }
+    const value = await client.get(key);
+
+    if (value !== null) {
+      return JSON.parse(value);
+    }
+
+    return null;
   },
 
   delete: function() {