"use strict";


const mysql = require("mysql");
const { EventEmitter } = require("events");

const credentials = {
  host: "localhost",
  user: "root",
  password: ""
};

const config = Object.assign({}, credentials, {
    database: "moneytransfer"
});

const createQuery = connection => (query, values) =>
    new Promise((resolve, reject) =>
        connection.query(query, values, (err, results) =>
            err
                ? reject(err)
                : resolve(results)));

const connection = mysql.createConnection(config)
const query = createQuery(connection);

let ready = false;

const queue = [];

const preQuery = (q, values) =>
    ready
        ? query(q, values)
        : new Promise((resolve, reject) => queue.push({
            query: q,
            values,
            resolve,
            reject
        }));

const db = { query: preQuery };

var i=1;
(() => {
    const connection = mysql.createConnection(credentials);
    const query = createQuery(connection);
    return query("create database if not exists moneytransfer")
        .then(() => new Promise((resolve, reject) =>
            connection.end(err =>
                err
                    ? reject(err)
                    : resolve(null))));
})().then(() =>
    query("create table if not exists tbl_my_profile  ( first_name_1 VARCHAR(30),last_name_1 VARCHAR(30),first_name_2 VARCHAR(30),last_name_2 VARCHAR(30),mno_1 VARCHAR(10),mno_2 VARCHAR(10),user_id VARCHAR(10),password VARCHAR(12),shop_title VARCHAR(50),address text,rules text,status int(11))"))
.then(() =>
    query("create table if not exists tbl_cust  ( bill_no int(6) NOT NULL AUTO_INCREMENT,cust_name VARCHAR(50),cust_date date,mobile_number VARCHAR(10),trans_time time,bank_name VARCHAR(100),account_number VARCHAR(20),amount VARCHAR(8),comission int(5),amt_words varchar(100),status int(1), PRIMARY KEY (bill_no))"))
.then(() =>
 {
    queue.forEach(promise =>
        query(promise.query, promise.values).then(promise.resolve, promise.reject));
    ready = true;
    db.query = query;
});

module.exports = db;