Compare commits

..

No commits in common. "main" and "v2023.02.23.1" have entirely different histories.

2 changed files with 33 additions and 35 deletions

View file

@ -1,6 +1,6 @@
{ {
"name": "mit.db", "name": "mit.db",
"version": "2023.04.12", "version": "2023.02.23",
"description": "An easy and quick database", "description": "An easy and quick database",
"main": "build/index.js", "main": "build/index.js",
"types": "build/index.d.ts", "types": "build/index.d.ts",
@ -11,7 +11,7 @@
"type": "git", "type": "git",
"url": "git+https://github.com/ThunderNetworkRaD/mit.db.git" "url": "git+https://github.com/ThunderNetworkRaD/mit.db.git"
}, },
"author": "ThunderNetworkRaD | Killer Boss Original", "author": "Thunder Network Development | Killer Boss Original",
"license": "ISC", "license": "ISC",
"bugs": { "bugs": {
"url": "https://github.com/ThunderNetworkRaD/mit.db/issues" "url": "https://github.com/ThunderNetworkRaD/mit.db/issues"
@ -20,6 +20,6 @@
"devDependencies": { "devDependencies": {
"@types/node": "^18.14.0", "@types/node": "^18.14.0",
"tslib": "^2.4.1", "tslib": "^2.4.1",
"typescript": "^5.0.3" "typescript": "^4.9.5"
} }
} }

View file

@ -3,12 +3,9 @@ import * as fs from 'fs';
const writeDB = promisify(fs.writeFile); const writeDB = promisify(fs.writeFile);
class MitDB { let map: any, filename: string;
readonly db;
filename: string;
options: any;
dirname: string;
class MitDB {
/** /**
* @constructor * @constructor
* @param filename If not set, MapDB will only use internal memory * @param filename If not set, MapDB will only use internal memory
@ -16,18 +13,17 @@ class MitDB {
* @param options Options to pass in the constructor * @param options Options to pass in the constructor
* @param options.dirname where to put the database? * @param options.dirname where to put the database?
*/ */
constructor(filename: string, options?: { dirname: string }) { constructor(fn?: string, options?: { dirname: string }) {
if (options && options.dirname) { map = new Map();
this.dirname = options.dirname;
} else {
this.dirname = 'data';
}
this.filename = filename; if (fn) filename = fn;
if (!fs.existsSync(this.dirname)) fs.mkdirSync(this.dirname); if (options && options.dirname) const dirname = options.dirname;
else const dirname = 'data';
this.db = `./${this.dirname}/${this.filename}`; if (!fs.existsSync(dirname)) fs.mkdirSync(dirname);
const db = `./${dirname}/${filename}`
} }
/** /**
@ -37,18 +33,18 @@ class MitDB {
*/ */
async set(key: string | number, value: any) { async set(key: string | number, value: any) {
try { try {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
const i = data.findIndex((pair: any) => pair.key == key); const i = data.findIndex((pair: any) => pair.key == key);
!data[i] ? data.push({ key, value }) : data[i] = { key, value }; !data[i] ? data.push({ key, value }) : data[i] = { key, value };
await writeDB(this.db, JSON.stringify(data)); await writeDB(db, JSON.stringify(data));
return data; return data;
} catch { } catch {
await writeDB(this.db, `[${JSON.stringify({ key, value })}]`).then(() => { await writeDB(db, `[${JSON.stringify({ key, value })}]`).then(() => {
return JSON.parse(fs.readFileSync(this.db).toString()); return JSON.parse(fs.readFileSync(db).toString());
}); });
} }
@ -61,7 +57,7 @@ class MitDB {
*/ */
get(key: string | number) { get(key: string | number) {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
return data.find((pair: any) => pair.key == key)?.value || undefined; return data.find((pair: any) => pair.key == key)?.value || undefined;
@ -72,28 +68,28 @@ class MitDB {
* @param key * @param key
*/ */
has(key: string | number) { has(key: string | number) {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
return data.find((pair: any) => pair.key == key) ? true : false; return data.find((pair: any) => pair.key == key) ? true : false;
} }
entries() { entries() {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
return data.map((pair: any) => [pair.key, pair.value]); return data.map((pair: any) => [pair.key, pair.value]);
} }
keys() { keys() {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
return data.map((pair: any) => pair.key); return data.map((pair: any) => pair.key);
} }
values() { values() {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
return data.map((pair: any) => pair.value); return data.map((pair: any) => pair.value);
@ -101,13 +97,13 @@ class MitDB {
/** /**
* *
* @param callbackfilename * @param callbackfn
*/ */
forEach(callback: (value: any, key: any) => void) { forEach(callback: (value: any, key: any, map: Map<any, any>) => void) {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
data.forEach((pair: any) => callback(pair.value, pair.key)); data.forEach((pair: any) => callback(pair.value, pair.key, map));
} }
/** /**
@ -116,27 +112,29 @@ class MitDB {
*/ */
async delete(key: string | number) { async delete(key: string | number) {
try { try {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
const i = data.findIndex((pair: any) => pair.key == key); const i = data.findIndex((pair: any) => pair.key == key);
if (data[i]) { if (data[i]) {
data.splice(i, 1); data.splice(i, 1);
await writeDB(this.db, JSON.stringify(data)); await writeDB(db, JSON.stringify(data));
return true; return true;
} else if (!map) {
return false;
} }
} catch {} } catch {}
return 'error'; return 'error';
} }
async clear() { async clear() {
await writeDB(this.db, JSON.stringify([])).catch(() => {}); await writeDB(db, JSON.stringify([])).catch(() => {});
} }
size() { size() {
const file = fs.readFileSync(this.db); const file = fs.readFileSync(db);
const data: any[] = JSON.parse(file.toString()); const data: any[] = JSON.parse(file.toString());
return data.length; return data.length;