Compare commits
10 commits
v2023.02.2
...
main
Author | SHA1 | Date | |
---|---|---|---|
|
c902d92711 | ||
|
90670ebb7b | ||
|
363492aef5 | ||
|
41d589ccbc | ||
|
74f4f42e50 | ||
|
492c49a086 | ||
|
c8410b0c6f | ||
|
387ab7e582 | ||
|
e74533f1f2 | ||
|
e269f2c9d3 |
2 changed files with 35 additions and 34 deletions
|
@ -1,6 +1,6 @@
|
|||
{
|
||||
"name": "mit.db",
|
||||
"version": "2023.02.23",
|
||||
"version": "2023.04.12",
|
||||
"description": "An easy and quick database",
|
||||
"main": "build/index.js",
|
||||
"types": "build/index.d.ts",
|
||||
|
@ -11,7 +11,7 @@
|
|||
"type": "git",
|
||||
"url": "git+https://github.com/ThunderNetworkRaD/mit.db.git"
|
||||
},
|
||||
"author": "Thunder Network Development | Killer Boss Original",
|
||||
"author": "ThunderNetworkRaD | Killer Boss Original",
|
||||
"license": "ISC",
|
||||
"bugs": {
|
||||
"url": "https://github.com/ThunderNetworkRaD/mit.db/issues"
|
||||
|
@ -20,6 +20,6 @@
|
|||
"devDependencies": {
|
||||
"@types/node": "^18.14.0",
|
||||
"tslib": "^2.4.1",
|
||||
"typescript": "^4.9.5"
|
||||
"typescript": "^5.0.3"
|
||||
}
|
||||
}
|
||||
|
|
61
src/index.ts
61
src/index.ts
|
@ -3,9 +3,12 @@ import * as fs from 'fs';
|
|||
|
||||
const writeDB = promisify(fs.writeFile);
|
||||
|
||||
let map: any, db: any, filename: string, dirname: string;
|
||||
|
||||
class MitDB {
|
||||
readonly db;
|
||||
filename: string;
|
||||
options: any;
|
||||
dirname: string;
|
||||
|
||||
/**
|
||||
* @constructor
|
||||
* @param filename If not set, MapDB will only use internal memory
|
||||
|
@ -13,18 +16,18 @@ class MitDB {
|
|||
* @param options Options to pass in the constructor
|
||||
* @param options.dirname where to put the database?
|
||||
*/
|
||||
constructor(fn?: string, options?: { dirname: string }) {
|
||||
if (!dirname || dirname != 'data') dirname = 'data';
|
||||
constructor(filename: string, options?: { dirname: string }) {
|
||||
if (options && options.dirname) {
|
||||
this.dirname = options.dirname;
|
||||
} else {
|
||||
this.dirname = 'data';
|
||||
}
|
||||
|
||||
map = new Map();
|
||||
this.filename = filename;
|
||||
|
||||
if (fn) filename = fn;
|
||||
if (!fs.existsSync(this.dirname)) fs.mkdirSync(this.dirname);
|
||||
|
||||
if (options && options.dirname) dirname = options.dirname;
|
||||
|
||||
if (!fs.existsSync(dirname)) fs.mkdirSync(dirname);
|
||||
|
||||
db = `./${dirname}/${filename}`
|
||||
this.db = `./${this.dirname}/${this.filename}`;
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -34,18 +37,18 @@ class MitDB {
|
|||
*/
|
||||
async set(key: string | number, value: any) {
|
||||
try {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
const i = data.findIndex((pair: any) => pair.key == key);
|
||||
|
||||
!data[i] ? data.push({ key, value }) : data[i] = { key, value };
|
||||
|
||||
await writeDB(db, JSON.stringify(data));
|
||||
await writeDB(this.db, JSON.stringify(data));
|
||||
return data;
|
||||
} catch {
|
||||
await writeDB(db, `[${JSON.stringify({ key, value })}]`).then(() => {
|
||||
return JSON.parse(fs.readFileSync(db).toString());
|
||||
await writeDB(this.db, `[${JSON.stringify({ key, value })}]`).then(() => {
|
||||
return JSON.parse(fs.readFileSync(this.db).toString());
|
||||
});
|
||||
}
|
||||
|
||||
|
@ -58,7 +61,7 @@ class MitDB {
|
|||
*/
|
||||
|
||||
get(key: string | number) {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
return data.find((pair: any) => pair.key == key)?.value || undefined;
|
||||
|
@ -69,28 +72,28 @@ class MitDB {
|
|||
* @param key
|
||||
*/
|
||||
has(key: string | number) {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
return data.find((pair: any) => pair.key == key) ? true : false;
|
||||
}
|
||||
|
||||
entries() {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
return data.map((pair: any) => [pair.key, pair.value]);
|
||||
}
|
||||
|
||||
keys() {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
return data.map((pair: any) => pair.key);
|
||||
}
|
||||
|
||||
values() {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
return data.map((pair: any) => pair.value);
|
||||
|
@ -98,13 +101,13 @@ class MitDB {
|
|||
|
||||
/**
|
||||
*
|
||||
* @param callbackfn
|
||||
* @param callbackfilename
|
||||
*/
|
||||
forEach(callback: (value: any, key: any, map: Map<any, any>) => void) {
|
||||
const file = fs.readFileSync(db);
|
||||
forEach(callback: (value: any, key: any) => void) {
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
data.forEach((pair: any) => callback(pair.value, pair.key, map));
|
||||
data.forEach((pair: any) => callback(pair.value, pair.key));
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -113,29 +116,27 @@ class MitDB {
|
|||
*/
|
||||
async delete(key: string | number) {
|
||||
try {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
const i = data.findIndex((pair: any) => pair.key == key);
|
||||
|
||||
if (data[i]) {
|
||||
data.splice(i, 1);
|
||||
await writeDB(db, JSON.stringify(data));
|
||||
await writeDB(this.db, JSON.stringify(data));
|
||||
|
||||
return true;
|
||||
} else if (!map) {
|
||||
return false;
|
||||
}
|
||||
} catch {}
|
||||
return 'error';
|
||||
}
|
||||
|
||||
async clear() {
|
||||
await writeDB(db, JSON.stringify([])).catch(() => {});
|
||||
await writeDB(this.db, JSON.stringify([])).catch(() => {});
|
||||
}
|
||||
|
||||
size() {
|
||||
const file = fs.readFileSync(db);
|
||||
const file = fs.readFileSync(this.db);
|
||||
const data: any[] = JSON.parse(file.toString());
|
||||
|
||||
return data.length;
|
||||
|
|
Loading…
Reference in a new issue