0.3.1

Author: denyncrawford

README.md

@@ -39,19 +39,20 @@ DnDB is an incredibly fast and powerful data store. All methods are streamed and
 ## 🧪 Quick test
 
 [Run the demo](/demo/README.md) to test DnDB in a server environment.
+Also this demo lives on [Codesandbox](https://codesandbox.io/s/6x0uw)
 
 ## 📦 Importing
 
 **deno.land**
 
 ```javascript
-import Datastore from 'https://deno.land/x/dndb@0.3.0/mod.ts'
+import Datastore from 'https://deno.land/x/dndb@0.3.1/mod.ts'
 ```
 
 **nest.land**
 
 ```javascript
-import Datastore from 'https://x.nest.land/dndb@0.3.0/mod.ts'
+import Datastore from 'https://x.nest.land/dndb@0.3.1/mod.ts'
 ```
 
 
@@ -71,7 +72,7 @@ All the api methods are asynchronous by default, so they return promises, but it
 ## ✔️ Instantiating the collection
 
 ```javascript
-import Datastore from 'https://deno.land/x/dndb@0.3.0/mod.ts'
+import Datastore from 'https://deno.land/x/dndb@0.3.1/mod.ts'
 
 const db = new Datastore({ filename:"./database.db", autoload: true })
 
@@ -253,9 +254,12 @@ await remove({ _id: 'id2' })
 
 > *Notice*: If you want to unset a  value from the document you must use update with the $unset operator. See all rules and operators list [here](https://www.npmjs.com/package/mingo)
 
-# 📝 TO DO
-
-- Event hooks on all the api usage
+# 📝 Roadmap
+- Standard methods
+- Database from datastores factory
+- Read and write streams and buffer
+- Global Queue executor
+- Event hooks on all the API usage
 - Count method
 - Improve documentation
 - Prevent updating immutable data

demo/README.md

@@ -4,10 +4,11 @@ This demo shows you how to use DnDB in a backend environment.
 
 ## Steps
 
+- Download this folder
 - Run the demo with the permission flags.
 
 ```bash
-deno run -A --unstable https://x.nest.land/dndb/0.2.7/demo/mod.js
+deno run -A --unstable https://deno.land/x/dndb@0.3.1/demo/mod.js
 ```
 
 You can start playing with the new demo UI. Fist try to insert a document typing an username and clicking 'Make Query'.

deps.ts

@@ -1,4 +1,4 @@
-import mongobj from "https://cdn.skypack.dev/mongobj"
+import updater from "https://cdn.skypack.dev/mongobj"
 import { matches }  from 'https://raw.githubusercontent.com/denyncrawford/safe-filter/master/dist/index.js'
 import project from 'https://raw.githubusercontent.com/denyncrawford/mongo-project.node/master/dist/bundle.js'
 import { EventEmitter } from "https://deno.land/std/node/events.ts";
@@ -7,7 +7,7 @@ import { existsSync } from "https://deno.land/std/fs/mod.ts";
 import { resolve, dirname, join } from 'https://deno.land/std/path/mod.ts';
 
 export { 
-  mongobj,
+  updater,
   matches,
   project,
   EventEmitter,

egg.json

@@ -3,7 +3,7 @@
   "description": "A Deno 🦕 persistent database for JS & TS",
   "stable": true,
   "entry": "./mod.ts",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "repository": "https://github.com/denyncrawford/dndb",
   "files": [
     "./mod.ts",

src/executor.ts

@@ -7,7 +7,7 @@ export default class Executor {
       this.queue.push(async () => {
         const finished = await method(...params);
         res(finished);
-        if (typeof finished === "undefined" || finished) this.next();      
+        if (typeof finished === "undefined" || finished === null || finished) this.next();      
       });
       if(!this.running) this.next();
     })

src/methods/update.js

@@ -1,4 +1,4 @@
-import { mongobj, matches } from '../../deps.ts';
+import { updater, matches } from '../../deps.ts';
 import { ReadFileStream, WriteFileStream } from '../storage.ts';
 
 export default async (filename ,query, operators, bufSize) => {
@@ -9,7 +9,7 @@ export default async (filename ,query, operators, bufSize) => {
   return new Promise((resolve, reject) => {
     readStream.on('document', obj => {
       if (matches(query, obj)) {
-        mongobj.update(obj, operators);
+        updater.update(obj, operators);
         updated.push(obj)
       }
       writeStream.write(obj)

src/methods/updateOne.js

@@ -1,4 +1,4 @@
-import { mongobj, matches } from '../../deps.ts';
+import { updater, matches } from '../../deps.ts';
 import { ReadFileStream, WriteFileStream } from '../storage.ts';
 import Executor from '../executor.ts'
 
@@ -10,7 +10,7 @@ export default async (filename ,query, operators, bufSize) => {
   return new Promise((resolve, reject) => {
     readStream.on('document', async obj => {
       if (matches(query, obj) && !updated.length) {
-        mongobj.update(obj, operators);
+        updater.update(obj, operators);
         updated.push(obj)
       }
       writeStream.write(obj)