const mysql = require('mysql');
const dotenv = require('dotenv').config().parsed;
let connection = undefined;
let connected = false;
let onConnect = [];

const dbConnection = async () => {
    return new Promise((resolve, reject) => {
        try {
            connection = mysql.createConnection({
                host: dotenv.DB_HOST,
                user: dotenv.DB_USERNAME,
                password: dotenv.DB_PASSWORD,
                database: dotenv.DB_NAME
            });

            connection.connect();

            if (connection) {
                resolve(connection);
            } else {
                reject(connectionFail());
            }
        } catch(e) {
            console.log(e);
        }
    });
    //return connection;
};

const connectionFail = () => {
    console.log("A conexão com o banco de dados não conseguiu ser estabelecida.");
}

const consultarCasas = async () => {
    return new Promise((resolve, reject) => {
        let query = sqlQuery("SELECT * FROM vrp_home_permissions").then(row => {

        }).catch((err) => {
            
        });
    });
}

const sqlQuery = (sql, args = []) =>  {
    return new Promise((resolve, reject) => {
        if(!connection) {
            return;
        }

        connection.query(sql, args, (err, rows) => {
        if (err)
            reject(err);
        else
            resolve(rows);
        });
    });
};

let consultaCasas = await consultarCasas();
consultaCasas.then((obj) => {
    console.log(obj());
});

module.exports = () => {
    return dbConnection;
};
//# sourceMappingURL=dbCon.js.map