//const voteCommands = require('./voteQueue/voteCommands')
const { Client } = require("pg");
 
const pgClient = new Client({
// login stuff
});
pgClient.connect();

//***********************************************************/
//                   New vote Commands                     //
//***********************************************************/
const voteSets = (text) => new Promise((resolve, reject) => {
    pgClient
    .query(text)
    .then(res => {
        //console.log(res.rows)
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

const voteQueue = (text,values) => new Promise((resolve, reject) => {
    console.log(`[voteQueue] sending query...${text}`)
    pgClient
    .query(text, values)
    .then(res => {
        //console.log(`Added ${values[1]} to vote queue`)
        resolve(res.rows)
    })
    .catch(err => {reject(console.log(`Error adding user to queue: ${text} ${values}`))})
})

const voteJoin = (text, values) => new Promise((resolve, reject) => {
    console.log(`[voteJoin] sending query...`)
    pgClient
    .query(text)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

const voteReady = (text, values) => new Promise((resolve, reject) => {
    console.log(`[voteReady] sending query...${text}`)
    pgClient
    .query(text,values)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

const voteStatus = (text, values) => new Promise ((resolve, reject) => {
    //console.log(`[voteStatus] Sending query ${text} with ${values}`)
    console.log(`[voteStatus] sending query...`)
    pgClient
    .query(text, values)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

const voteAddStatus = (text, values) => new Promise ((resolve, reject) => {
    console.log(`[voteAdd]Sending query ${text} with ${values}`)
    pgClient
    .query(text, values)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

const voteLeaveStatus = (text, values) => new Promise ((resolve, reject) => {
    console.log(`[voteLeave]Sending query ${text} with ${values}`)
    pgClient
    .query(text, values)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

const voteRemoveUsers = (text, values) => new Promise ((resolve, reject) => {
    console.log(`[RemoveUsers]Sending query ${text} with ${values}`)
    pgClient
    .query(text, values)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})
const voteFormats = (text) => new Promise ((resolve, reject) => {
    pgClient
    .query(text)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

const votestatusMessage = (text, values) => new Promise ((resolve, reject) => {
    console.log(`[votestatusMessage]Sending query..." ${text} with ${values}`)
    pgClient
    .query(text, values)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})
//const trackPostSQL = 'INSERT INTO userdata(discordid, discordname, postcount, firstfound) VALUES ($1, $2, $3, $4) ON CONFLICT (discordid) DO UPDATE SET postcount = (SELECT postcount FROM userstats WHERE discordid = $1) +1;'
const trackPost = (text, values) => new Promise((resolve, reject) => {
    pgClient
    .query(text, values)
    .then(res => {
        console.log(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

//const arenaUpdateSQL = 'INSERT INTO userdata(discordid, discordname, email, arenaname, postcount, firstfound) VALUES ($1, $2, $3, $4, $5, now()) ON CONFLICT (discordid) DO UPDATE SET arenaname = $4;
const arenaUpdate = (text, values) => new Promise((resolve, reject) => {
    pgClient
    .query(text, values)
    .then(res => {
        console.log(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})
const clearQueue = (text, values) => new Promise((resolve, reject) => {
    console.log(`Sending ${text} with ${values}`)
    pgClient
    .query(text,values)
    .then(res =>{
        console.log(`Clearing vote queue for format: ${values}`)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})
const arenaLookup = (text,values) => new Promise ((resolve, reject) => {
    console.log(`Sending ${text} with ${values}`)
    pgClient
    .query(text, values)
    .then(res => {
        resolve(res.rows)
    })
    .catch(err => {reject(`Error with query ${err}`)})
})

module.exports = {
voteSets,
voteQueue,
voteJoin,
voteReady,
voteStatus,
votestatusMessage,
voteAddStatus,
voteLeaveStatus,
voteRemoveUsers,
voteFormats,
trackPost,
arenaUpdate,
clearQueue,
arenaLookup
};