database.js

"use strict";
const cache = require("./cache-db");
const fs = require("graceful-fs");

function Database (path, spawnOptions) {
    let databases = {};
    let options = spawnOptions || {};

    // load the files and the directory
    if (!fs.existsSync(path)) {
        fs.mkdirSync(path);
    }

    fs.readdir(path, (err, files) => {
        if (!files || err) return; // nothing intialized!
        files.forEach(f => spawndb(f.replace(/\_?\.json$/i, "")));
    });

    function spawndb(id) {
        if (databases[id]) return;
        let db = new cache();
        db.load(path + "/" + id);
        if (options.timer) db.setTimer(spawnOptions.timer);
        databases[id] = db;
    }

    // the actual database
    function db (id) {
        if (!databases[id]) spawndb(id);
        return databases[id];
    }

    db.write = function () {
        for (let i in databases) {
            databases[i].write();
        }
    };

    db.keys = function() {
        return Object.keys(databases);
    };

    db.hasKey = function (id) {
        return id in databases;
    };

    db.config = function (id, value) {
        options[id] = value;
    };

    db.drop = function (id) {
        if (!this.hasKey(id)) return;
        databases[id].drop();

        // drop the timer
        clearInterval(databases[id].writeInterval);
        databases[id].writeInterval = null;

        delete databases[id]; // do not track anymore
    };

    db.spawn = spawndb;

    return db;
}

module.exports = Database;