const chokidar = require('chokidar');
const mysql = require('mysql');
const path = './web/files/clientes/**/*.csv';

let watcher = chokidar.watch(path, {
    ignored : /[\/\\]\./,
    persistent : true
});

console.log('>> Ouvindo alterações no diretório: ' + path);

watcher.on('change', (path) => {
    let splitPath = path.split('/');
    let cpfCnpj = splitPath[3];
    let fileName = splitPath[4];

    console.log("CPF/CNPJ: " + cpfCnpj, "CSV: " + fileName);

    let mySqlConnection = mysql.createConnection({
        host : "localhost",
        port : 3306,
        user : "root",
        password : "123456",
        database : "imobbi"
    });

    mySqlConnection.connect((err) => {
        if (err) {
            throw err
        }

        let sqlCliente = "SELECT `id` FROM `clientes` WHERE `cnpj` = " + cpfCnpj;

        mySqlConnection.query(sqlCliente, (error, results, fields) => {
            if (error) {
                return console.log(error);
            }

            if (!results[0]) {
                return console.log('Cliente com CPF/CNPJ ' + cpfCnpj + ' não encontrado.');
            }

            let clienteId = parseInt(results[0].id);

            let sqlCsv = `
                UPDATE \`csv\` SET \`sincronizado\` = 0, \`sincronizado_data\` = NOW()
                WHERE \`clientes_id\` = ${clienteId}
                AND \`arquivo\` = "${fileName}"
            `;

            mySqlConnection.query(sqlCsv, (error, results, fields) => {
                if (error) {
                    return console.log(error);
                }

                console.log('CSV atualizado!');
            });
        });

        console.log("MySQL Connected! =D");
    });
});