-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathTable.js
59 lines (54 loc) · 1.63 KB
/
Table.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
const { v4: uuidV4 } = require("uuid");
const fs = require("fs");
const TableDoesNotExistError = require("./errors/TableDoesNotExistError");
const { resolve } = require("path");
const { rejects } = require("assert");
const { error } = require("console");
module.exports = class Table {
constructor(tableName) {
this.tableName = tableName;
}
get filePath() {
return `data/${this.tableName}.json`;
}
overwriteTable(data) {
return new Promise((resolve, reject) => {
fs.writeFile(this.filePath, JSON.stringify(data), (error) => {
if (error) return reject(error);
resolve();
});
});
}
insertRecord(record) {
// record has unique id
const recordWithID = { _id: uuidV4(), ...record };
// get data
return new Promise((resolve, reject) => {
this.readData()
.catch((e) => {
if (e instanceof TableDoesNotExistError) {
return [];
} else {
reject(e);
}
})
.then((data) => {
fs.writeFile(this.filePath, JSON.stringify([...data, recordWithID]), (error) => {
if (error) return reject(error);
resolve(recordWithID);
});
});
});
// if table exists, append at the last
// else table doesnot exist create the table and enter the record
}
readData() {
return new Promise((resolve, reject) => {
fs.readFile(this.filePath, (error, data) => {
//if (error) return reject(new Error("Table not found"));
if (error) return reject(new TableDoesNotExistError(this.tableName));
resolve(JSON.parse(data));
});
});
}
};