const sql = require('./mysql')

async function updateStreamData(userAccount, streamURL, expiaryDate) {
    // let result
    try {
        let result = sql.query(`UPDATE userAccounts SET streamURL = "${streamURL}", expiaryDate = ${expiaryDate} WHERE username = "${userAccount.username}" AND password = "${userAccount.password}";   `);
        return result
    } catch (error) {
        console.log(error)
    }
}

async function updateOtherURLs(streamName, newUrl) {
    // let result
    try {
        let result = sql.query(`update userAccounts
        set userAccounts.streamURL = '${newUrl}'
        WHERE userAccounts.stream ='${streamName}'`);
        return result
    } catch (error) {
        console.log(error)
    }
}


module.exports = {
    updateStreamData,
    updateOtherURLs
}