const bdd = require("./bdd.js").bdd;
const DEBUG = require("../utils/debug").DEBUG;

function registerMessage(timestamp, rfc822size) {
    return new Promise((resolve, reject) => {
        resolve(0);
        //todo
        const query = `INSERT INTO messages (idate, rfc822size) VALUES (UNIX_TIMESTAMP('${timestamp}'), '${rfc822size}')`;
        bdd.query(query, (err, results, fields) => {
            if (err) reject(err);
            // resolve(results.insertId);
        });
    });
}

function registerMailbox_message(mailboxId, uid, messageId, modseq, seen, deleted) {
    return new Promise((resolve, reject) => {
        const query = `INSERT IGNORE INTO mailbox_messages (mailbox, uid, message, modseq, seen, deleted) VALUES ('${mailboxId}', '${uid}', '${messageId}', '${modseq}', '${seen}', '${deleted}')`;
        bdd.query(query, (err, results, fields) => {
            if (err) reject(err);
            resolve();
            // resolve(results.insertId);
        });
    });
}

function saveBodyparts() {}

function saveHeader_fields(message, part, position, field, value) {
    const query = `INSERT IGNORE INTO header_fields (message, part, position, field, value) VALUES ('${message}', '${part}', '${position}', '${field}', '${value}')`;
    bdd.query(query, (err, results, fields) => {
        if (err) throw err;
    }); 
}

function saveAddress_fields(message, part, position, field, number, address) {
    const query = `INSERT IGNORE INTO address_fields (message, part, position, field, number, address) VALUES ('${message}', '${part}', '${position}', '${field}', '${number}', '${address}')`;
    bdd.query(query, (err, results, fields) => {
        if (err) throw err;
    }); 
}

module.exports = {
    registerMessage,
    registerMailbox_message,
    saveHeader_fields,
    saveAddress_fields,
}