Skip to content

Commit

Permalink
feat: v1.0.0
Browse files Browse the repository at this point in the history
  • Loading branch information
@r-rajaneesh
r-rajaneesh committed Oct 26, 2022
1 parent e6fa1cf commit e0eb7bf
Show file tree
Hide file tree
Showing 15 changed files with 2,514 additions and 1,098 deletions.
5 changes: 5 additions & 0 deletions .gitignore
View file
Original file line number Diff line number Diff line change
Expand Up @@ -41,3 +41,8 @@ test.js
package-lock.json
old/
databases/


# Added by cargo

/target
2,998 changes: 2,158 additions & 840 deletions package-lock.json
View file

Large diffs are not rendered by default.

14 changes: 8 additions & 6 deletions package.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
"type": "module",
"scripts": {
"build": "tsc index.ts -t esnext -m esnext -d --allowSyntheticDefaultImports --moduleResolution node --outDir ./dist",
"build-packages":"cd packages/core && npm run build && cd.. && cd.. && cd packages/firestore && npm run build && cd.. && cd.. && cd packages/sqlite && npm run build && cd.. && cd..",
"build-packages": "cd packages/core && npm run build && cd.. && cd.. && cd packages/firestore && npm run build && cd.. && cd.. && cd packages/sqlite && npm run build && cd.. && cd..",
"publish-beta-public": "npm publish --tag beta --registry=https://registry.npmjs.com --workspaces",
"publish-beta-private": "npm publish --tag beta --workspaces",
"publish-public": "npm publish --registry=https://registry.npmjs.com --workspaces",
Expand Down Expand Up @@ -32,20 +32,22 @@
"dependencies": {
"@firebase/firestore": "^3.6.0",
"@hapi/hapi": "^20.2.2",
"axios": "^1.1.3",
"better-sqlite3": "^7.6.2",
"bson": "^4.7.0",
"firebase": "^9.11.0",
"firebase-admin": "^11.0.1",
"fs-extra": "^10.1.0",
"is-what": "^4.1.7",
"knex": "^2.3.0",
"lodash": "^4.17.21",
"merge-anything": "^5.0.4"
},
"devDependencies": {
"@types/better-sqlite3": "^7.6.0",
"@types/better-sqlite3": "^7.6.2",
"@types/fs-extra": "^9.0.13",
"@types/hapi__hapi": "^20.0.12",
"@types/lodash": "^4.14.182",
"@types/node": "^18.6.1",
"typescript": "^4.8.3"
"@types/lodash": "^4.14.186",
"@types/node": "^18.11.3",
"typescript": "^4.8.4"
}
}
36 changes: 15 additions & 21 deletions packages/core/dist/index.d.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,23 +2,16 @@ interface constructorOptions {
providers: providers[];
}
interface providers {
createCollectionProvider(collectionName: String, cb?: Function): void;
createDocProvider(data: document, cb?: Function): void;
deleteCollectionProvider(collectionName: String, cb?: Function): void;
deleteDocProvider(data: document | fn, cb?: Function): void;
getCollectionProvider(collectionName: String, cb?: Function): any[];
getDocProvider(data: document | fn, cb?: Function): any;
getCollectionsProvider(cb?: Function): Collection[];
updateDocProvider(refData: document | fn, data: document, cb?: Function): void;
}
interface Collection {
createDoc(data: document | fn, cb?: Function): any;
deleteDoc(data: document | fn, cb?: Function): any;
getDoc(data: document | fn, cb?: Function): any;
hasDoc(data: document | fn, cb?: Function): any;
getRaw(): any;
}
declare type fn = (data: Object[] | Object) => void;
createCollectionProvider(collectionName: String, cb?: Function): Promise<any> | any;
createDocProvider(data: document, cb?: Function): Promise<any> | any;
deleteCollectionProvider(collectionName: String, cb?: Function): Promise<any> | any;
deleteDocProvider(data: document | fn, cb?: Function): Promise<any> | any;
getCollectionProvider(collectionName: String, cb?: Function): Promise<any> | any;
getCollectionsProvider(cb?: Function): Promise<any> | any[];
getDocProvider(data: document | fn, cb?: Function): Promise<any> | any;
updateDocProvider(refData: document | fn, data: document, cb?: Function): Promise<any> | any;
}
declare type fn = (data: Object[] | Object) => any;
interface storage {
[collection: string]: document[];
}
Expand Down Expand Up @@ -47,11 +40,12 @@ declare class Docs {
createDoc(data: document | document[], cb?: Function): Promise<document>;
deleteDoc(data: document | fn, cb?: Function): Promise<void>;
findDoc(data: document | fn, cb?: Function): Promise<object>;
findOrcreateDoc(data: document, cb?: Function): Promise<document>;
getOrcreateDoc(data: document, cb?: Function): Promise<document>;
getRaw(cb?: Function): Promise<any[]>;
getDoc(data: document | fn | String, cb?: Function): Promise<object>;
getRaw(cb?: Function): Promise<any>;
updateDoc(refData: document, data: document | fn, cb?: Function): Promise<any>;
updateRaw(refData: document, cb?: Function): Promise<{
[x: string]: any;
save: Function;
}>;
private $add;
private $subtract;
private $multiply;
Expand Down
119 changes: 74 additions & 45 deletions packages/core/dist/index.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,32 +11,30 @@ export default class QuipoDB {
this.providers = options.providers;
this.storage = {};
this.Docs = Docs;
// Time-To-Live
setInterval(() => {
this.providers.forEach(async (provider) => {
await provider.getCollectionsProvider().forEach(async (collectionName) => {
await provider.getCollectionProvider(collectionName).forEach(async (doc) => {
if (doc.ttl <= Date.now()) {
await provider.deleteDocProvider(doc);
}
});
});
});
}, 5000);
}
createCollection(collectionName, cb = () => { }) {
this.collectionName = collectionName;
this.providers.forEach(async (provider) => {
await provider.createCollectionProvider(collectionName, cb);
});
try {
this.providers.forEach(async (provider) => {
await provider.createCollectionProvider(collectionName, cb);
});
}
catch (error) {
error;
}
const docs = new this.Docs({ providers: this.providers, collectionName: this.collectionName });
cb(docs);
return docs;
}
deleteCollection(collectionName, cb = () => { }) {
this.providers.forEach(async (provider) => {
await provider.deleteCollectionProvider(collectionName);
});
try {
this.providers.forEach(async (provider) => {
await provider.deleteCollectionProvider(collectionName);
});
}
catch (error) {
error;
}
cb();
return;
}
Expand All @@ -58,51 +56,55 @@ class Docs {
});
});
}
this.providers.forEach(async (provider) => {
await provider.createDocProvider(data);
});
try {
this.providers.forEach(async (provider) => {
await provider.createDocProvider(data);
});
}
catch (error) {
error;
}
cb(data);
return data;
}
async deleteDoc(data, cb = () => { }) {
if (typeof data === "function")
data = data(await this.providers[0].getCollectionProvider(this.collectionName));
this.providers.forEach(async (provider) => {
await provider.deleteDocProvider(data);
});
try {
this.providers.forEach(async (provider) => {
await provider.deleteDocProvider(data);
});
}
catch (error) {
error;
}
cb();
return;
}
async findDoc(data, cb = () => { }) {
let result = {};
if (typeof data === "function")
data = data(await this.providers[0].getCollectionProvider(this.collectionName)) ?? {};
result = await this.providers[0].getDocProvider(data);
cb(result);
return result;
}
async findOrcreateDoc(data, cb = () => { }) {
let result = {};
const Data = this.findDoc(data);
if (Data)
result = Data;
else {
result = this.createDoc(data);
try {
result = await this.providers[0].getDocProvider(data);
}
catch (error) {
error;
}
cb(result);
return result;
}
async getOrcreateDoc(data, cb = () => { }) {
return this.findOrcreateDoc(data, cb);
}
async getRaw(cb = () => { }) {
const data = await this.providers[0].getCollectionProvider(this.collectionName);
const data = await this.providers[0].getCollectionProvider(`${this.collectionName}`);
cb(data);
return data;
}
async getDoc(data, cb = () => { }) {
return this.findDoc(data, cb);
}
async updateDoc(refData, data, cb = () => { }) {
const oldDoc = this.findDoc(refData);
if (!oldDoc) {
cb();
return;
}
const storage = await this.providers[0].getCollectionProvider(this.collectionName);
const index = storage.findIndex((doc) => doc === oldDoc);
if (typeof data === "function")
Expand All @@ -112,12 +114,39 @@ class Docs {
.forEach((atomic, i) => {
data = _.defaultsDeep(this[atomic](oldDoc, data[atomic]), oldDoc);
});
this.providers.forEach(async (provider) => {
await provider.updateDocProvider(refData, data);
});
try {
this.providers.forEach(async (provider) => {
await provider.updateDocProvider(refData, data);
});
}
catch (error) {
error;
}
cb(storage[index]);
return storage[index];
}
async updateRaw(refData, cb = () => { }) {
let data = this.findDoc(refData);
if (!data) {
cb();
return;
}
const self = this;
const func = {
...data,
save: async function () {
try {
delete this.save;
await self.updateDoc(refData, this);
}
catch (error) {
error;
}
},
};
cb(func);
return func;
}
$add(...data) {
const deepMerge = (oldData, newData) => {
return Object.keys(oldData).reduce((acc, key) => {
Expand Down
Loading

0 comments on commit e0eb7bf

Please sign in to comment.