loki-incremental-adapter.js

(function (root, factory) {
  module.exports = factory();
})(this, function () {
  return (function () {
    const fs = require("fs");

    const accessDataDir = (datadir) => {
      return new Promise((resolve, reject) => {
        fs.lstat(datadir, (err, stats) => {
          if (err) {
            reject({
              message: "Dir does not exist",
            });
          }
          resolve(stats);
        });
      });
    };

    const saveRecord = (coll, obj, dir) => {
      console.log(`File is ${dir}/${coll}/${obj.$loki}.json`);
      fs.writeFile(
        `${dir}/${coll}/${obj.$loki}.json`,
        JSON.stringify(obj),
        {
          encoding: "utf8",
        },
        (err) => {
          if (err) {
            console.log("Document save failed.");
            throw err;
          }
          console.log("Document saved correctly");
        }
      );
    };

    const iterateFolders = (db, dir) => {
      console.log(`Colls: ${db.listCollections().length}`);

      console.log(`Changes: ${db.generateChangesNotification().length}`);
      db.generateChangesNotification().forEach((change) => {
        saveRecord(change.name, change.obj, dir);
      });
    };

    class LokiIncrementalAdapter {
      constructor(options) {
        const config = options || {
          journaling: false,
          format: "json",
        };
        this.mode = "reference";
        this.journaling = config.journaling;
        this.format = config.format;
      }

      checkAvailability() {
        if (typeof fs !== "undefined" && fs) return true;
        return false;
      }

      exportDatabase(dir, dbref, callback) {
        console.log("Saving with incremental adapter");

        console.log("Database dir is " + dir);
        const promise = accessDataDir(dir);
        console.log(promise);
        promise.then(() => {
          console.log("iterating folders...");
          iterateFolders(dbref, dir);
        });
        promise.catch((err) => {
          console.log(err);
        });
        if (callback) {
          callback();
        }
      }

      loadDatabase(dbname, callback) {
        console.log(this, dbname, callback);
      }
    }

    return LokiIncrementalAdapter;
  })();
});