import mysql from "mysql"
import { logger } from "./logger"


class DB {
    constructor() {
        const params = {
            host: 'localhost',
            user: 'db_user',
            password: 'db_password',
            database: 'mvc_db',
            port: 3306
        }
        this.connection = mysql.createConnection(params)
        this.connection.connect(function(err) {
            if (err) {
                logger.log(`[DB] Could not create db connection\n${err}`, 'error')
                throw new Error('Could not create db connection')
            }
        })
    }

    async close() {
        this.connection.end()
            .then(res => {
                return Promise.resolve(res)
            })
            .catch(err => {
                logger.log('[DB] Error closing connection', err)
                return Promise.reject(err)
            })
    }

}

export default new DB()