const app = require('express')()
const mysql = require('mysql')

app.get('/', (req, res)=>{

    const config = {
        host : 'localhost',
        user : 'root',
        password : 'password',
        database : 'ppob_new4pp5'
    }

    function Database(){
        this.connection = mysql.createConnection(config)
    }

    Database.prototype.query = function(query){
        return new Promise((resolve, reject)=>{
            this.connection.query(query, (err, res)=>{
                if(err){
                    return reject(err)
                }
                resolve(res)
            })
        })
    }

    Database.prototype.close = function(){
        return new Promise((resolve, reject)=>{
            this.connection.end((err)=>{
            if(err){
               return reject(err)
            }
            resolve("Now, closing a connection!")
            })
        })
    }

    const GetServices = new Database()
    GetServices.query("SELECT * FROM api")
    .then((results)=>{
        let iduser = results[0].iduser
        return GetServices.query(`SELECT nama_mitra FROM mitra WHERE iduser = ${iduser}`)
    })
    .then((rows)=>{
        res.json(rows)
        console.log("Success!")
    })
    .then(()=>{
        return GetServices.close().then((msg)=>{
            console.log(msg)
        })
    })
    .catch((err)=>{
        return GetServices.close().then((msg)=>{
            console.log({
                ERROR : err,
                MESSAGE : msg
            })
            res.json({
                 ERRORNO : err.errno,
                 REASON : err.code,
                 MESSAGE : msg + " cause ERROR"
                })
        })
    })
})
app.listen(3003, (req, res)=>{
    console.log("Port is listening on 3003")
})