const sql = require('./mysql')

function getStreamNames() {
    let data = sql.query(`SELECT stream FROM BBLB_DNS.userAccounts`)
    // console.log(data)
    if (data.length == 0) {
        return 'StreamsFailed'
    } else {
        const cleanedNames = data.map(item => {
            if (item.stream) {
                return item.stream.split('(')[0].trim();
            }
            return '';
        }).filter(name => name !== '');
        const uniqueNames = [...new Set(cleanedNames)];
        return uniqueNames;
    }
}


function getURLandStreams() {
    let data = sql.query(`SELECT DISTINCT stream, streamURL FROM BBLB_DNS.userAccounts`)
    // console.log(data)
    if (data.length == 0) {
        return 'StreamsFailed'
    } else {
        return data
    }
}

module.exports = {
    getStreamNames,
    getURLandStreams
}