utiliy

var fs = require('fs');
//const curl = new (require( 'curl-request' ))();
var request = require('request');
var mysql = require('mysql');
var db_config = {
  host: "localhost",
  user: "root",
  password: "",
  database: "prod_jet_exchange"
};
var con = mysql.createConnection(db_config);
con.connect(function(err) {
  if (err) throw err;
  console.log("Connected!");
});
//- Reconnection function
function reconnect(con){
  return new Promise(function (resolve, reject) {
  console.log("\n New connection tentative...");
  //- Destroy the current connection variable
  if(con) con.destroy();
  //- Create a new one
  var con = mysql.createConnection(db_config);
  //- Try to reconnect
  con.connect(function(err){
      if (err) {
          reject(err);
      } else {
          console.log("\n\t *** New connection established with the database. ***")
          resolve(con);
      }
  });
});
}
module.exports = {
  stringToDate: function (_date, _format, _delimiter) {
    var formatLowerCase = _format.toLowerCase();
    var formatItems = formatLowerCase.split(_delimiter);
    var dateItems = _date.split(_delimiter);
    var monthIndex = formatItems.indexOf("mm");
    var dayIndex = formatItems.indexOf("dd");
    var yearIndex = formatItems.indexOf("yyyy");
    var month = parseInt(dateItems[monthIndex]);
    month -= 1;
    var formatedDate = new Date(dateItems[yearIndex], month, dateItems[dayIndex]);
    return formatedDate;
  },
  getCurrentDateTime: function () {
    var offset = 5.5;
    var d = new Date(new Date(new Date().getTime() + offset * 3600 * 1000).toUTCString().replace(/ GMT$/, ""));
    return d.getFullYear() + "-" + ("0" + (d.getMonth() + 1)).slice(-2) + "-" + ("0" + d.getDate()).slice(-2) + " " + ("0" + d.getHours()).slice(-2) + ":" + ("0" + d.getMinutes()).slice(-2) + ":" + ("0" + d.getSeconds()).slice(-2);
  },
  test2: function () {
    console.log("Test 2 called");
  },
 getUsers : function () {
    return new Promise(function (resolve, reject) {
      if (con && con.state != "disconnected") {
        console.log("Connected!");
        var values = [];
        // var sql = "SELECT * FROM register_client1 where status<>0";
        var sql = "SELECT * FROM exchange_users";
        con.query(sql, function (err, result, fields) {
          if (err) {
            console.log(err.message);
            reject(err.message);
          } else {
            console.log(result);
            resolve(result);
          }
      });
      } else {
        reconnect(con).then(con =>{
            var values = [];
            // var sql = "SELECT * FROM register_client1 where status<>0";
            var sql = "SELECT * FROM exchange_users";
            con.query(sql, function (err, result, fields) {
              if (err) {
                console.log(err.message);
                reject(err.message);
              } else {
                console.log(result);
                resolve(result);
              }
          });
        }).catch(function (err) {
          console.log("Error in Mysql Connection " + err.message);
          //reject(Error(err.message));
      });
      }
  });
}

};