/**
 * @module utils/asyncDatabase
 */
import sqlite3 from 'sqlite3';

/**
 * @param {sqlite3.Database} database
 * @param {string} sqlQuery
 * @param {function} callback - function (rows)
 * @returns {Promise<any>} Promise for database operation
 * @example
 * const result = await asyncDatabaseRead(userDatabase, `SELECT * FROM users`, (rows) => {
 *     return wrapInTable(rows);
 * });
 */
const asyncDatabaseRead = (database, sqlQuery, callback) => {
    return new Promise((resolve, reject) => {
        database.serialize(() => {
            database.all(sqlQuery, (err, rows) => {
                if (err) {
                    reject(err);
                } else {
                    resolve(callback(rows));
                }
            });
        });
    });
};

/**
 * @param {sqlite3.Database} database
 * @param {string} sqlQuery
 * @param {function} callback - function ()
 * @returns {Promise<any>} Promise for database operation
 * @example
 * let sqlQuery = `INSERT INTO users (id, name, age) VALUES (${genID()}, "${userName}", "${userAge}");`;
 * await asyncDatabaseWrite(userDatabase, sqlQuery, () => {
 *     console.log("Added User ", userName);
 * });
 */
const asyncDatabaseWrite = (database, sqlQuery, callback) => {
    return new Promise((resolve, reject) => {
        database.serialize(() => {
            database.run(sqlQuery, (err, rows) => {
                if (err) {
                    reject(err);
                } else {
                    resolve(callback(rows));
                }
            });
        });
    });
};

export { asyncDatabaseRead, asyncDatabaseWrite };