JDB.js

const path = require("path");
const fs = require("fs/promises");

class JDB {
  constructor(baseDir, indent = 4) {
    this.baseDir = baseDir;
    this.indent = indent;
    this.queue = Promise.resolve();
  }

  _getDirectoryPath(dirname) {
    return path.join(this.baseDir, dirname);
  }

  _getFilePath(dirname) {
    return path.join(this._getDirectoryPath(dirname), "jdb.json");
  }

  async _checkDirectoryExists(dirname) {
    try {
      await fs.access(this._getDirectoryPath(dirname));
      return true;
    } catch {
      return false;
    }
  }

  async _createDirectory(dirname) {
    if (!(await this._checkDirectoryExists(dirname))) {
      await fs.mkdir(this._getDirectoryPath(dirname), {
        recursive: true,
      });
    }
  }

  setIndent(indent) {
    this.indent = indent;
  }

  async create(input, dirname = "") {
    try {
      await this._createDirectory(dirname);
      await fs.writeFile(
        this._getFilePath(dirname),
        JSON.stringify(input, null, this.indent)
      );
    } catch (error) {
      throw new Error("Failed to create: " + error.message);
    }
  }

  async read(dirname = "") {
    if (await this._checkDirectoryExists(dirname)) {
      const data = await fs.readFile(this._getFilePath(dirname), "utf-8");
      try {
        return JSON.parse(data);
      } catch (e) {
        return null;
      }
    } else {
      throw new Error("Database not found");
    }
  }

  async update(input, dirname = "") {
    if (await this._checkDirectoryExists(dirname)) {
      await fs.writeFile(
        this._getFilePath(dirname),
        JSON.stringify(input, null, this.indent)
      );
    } else {
      throw new Error("Database not found");
    }
  }

  async patch(input, dirname = "") {
    this.queue = this.queue.then(async () => {
      if (await this._checkDirectoryExists(dirname)) {
        const data = await this.read(dirname);
        if (data) {
          const updatedData = { ...data, ...input };
          await fs.writeFile(
            this._getFilePath(dirname),
            JSON.stringify(updatedData, null, this.indent)
          );
        }
      } else {
        throw new Error("Database not found");
      }
    });
    return this.queue;
  }

  async delete(dirname) {
    if (await this._checkDirectoryExists(dirname)) {
      await fs.rm(this._getDirectoryPath(dirname), { recursive: true });
    } else {
      throw new Error("Database not found");
    }
  }

  async print(dirname = "") {
    if (await this._checkDirectoryExists(dirname)) {
      console.log(await this.read(dirname));
    } else {
      throw new Error("Database not found");
    }
  }

  // Shortened CRUD operations
  async c(key, value, dirname = "") {
    await this.create({ [key]: value }, dirname);
  }

  async r(key, dirname = "") {
    const data = await this.read(dirname);
    if (data && data[key]) {
      return data[key];
    } else {
      throw new Error("Key not found");
    }
  }

  async u(key, value, dirname = "") {
    await this.update({ [key]: value }, dirname);
  }

  async d(key, dirname = "") {
    const data = await this.read(dirname);
    if (data && data[key]) {
      delete data[key];
      await this.create(data, dirname);
    } else {
      throw new Error("Key not found");
    }
  }

  async p(key, value, dirname = "") {
    await this.patch({ [key]: value }, dirname);
  }

  // Special operations
  async prt(key, dirname = "") {
    const data = await this.read(dirname);
    if (data && data[key]) {
      console.log({ [key]: data[key] });
    } else {
      throw new Error("Key not found");
    }
  }

  async i(value, dirname = "") {
    const data = await this.read(dirname);
    const highestKey = Math.max(...Object.keys(data).map(Number), -1);
    await this.p(highestKey + 1, value, dirname);
  }

  async l(desc, value = "", dirname = "") {
    await this.i(`${desc} ${value}`, dirname);
  }

  async f(key, value, dirname = "") {
    const data = await this.read(dirname);
    if (!data || !data[key]) {
      await this.u(key, value, dirname);
    }
  }
}

module.exports = JDB;