0.2.4

Author: denyncrawford

README.md

@@ -21,13 +21,13 @@ DnDB is an incredibly fast and powerful data store. All methods are streamed and
 **deno.land**
 
 ```javascript
-import Datastore from 'https://deno.land/x/dndb@0.2.2/mod.ts'
+import Datastore from 'https://deno.land/x/dndb@0.2.4/mod.ts'
 ```
 
 **nest.land**
 
 ```javascript
-import Datastore from 'https://x.nest.land/dndb@0.2.2/mod.ts'
+import Datastore from 'https://x.nest.land/dndb@0.2.4/mod.ts'
 ```
 
 
@@ -47,7 +47,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.2.2/mod.ts'
+import Datastore from 'https://deno.land/x/dndb@0.2.4/mod.ts'
 
 const db = new Datastore({ filename:"./database.db", autoload: true })
 
@@ -220,6 +220,8 @@ db.remove({ _id: 'id2' }, function (newdoc) {
 
 //OR
 
+const { remove } = db 
+
 await remove({ _id: 'id2' })
 ```
 

egg.json

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

src/methods/find.js

@@ -3,10 +3,10 @@ import { ReadFileStream } from '../storage.ts';
 
 export default async (filename, query, projection) => {
   let stream = new ReadFileStream(filename);
-  let found = []; 
+  let found = [];
+  query = query || {};
   stream.on('document', obj => {
     if (matches(query , obj)){
-      console.log(obj);
       obj = Object.keys(projection).length ? project(obj, projection) : obj;
       found.push(obj)
     }

src/methods/findOne.js

@@ -3,6 +3,7 @@ import { ReadFileStream } from '../storage.ts';
 
 export default async (filename, query, projection) => {
   let stream = new ReadFileStream(filename);
+  query = query || {};
   return new Promise((resolve, reject) => {
     stream.on('document', obj => {
       if (matches(query, obj)) {

src/methods/remove.js

@@ -5,6 +5,7 @@ export default async (filename, query) => {
   const readStream = new ReadFileStream(filename);
   const writeStream = new WriteFileStream(filename);
   let removed = [];
+  query = query || {};
   return new Promise((resolve, reject) => {
     readStream.on('document', obj => {
       if (!matches(query, obj)) 

src/methods/removeOne.js

@@ -5,6 +5,7 @@ export default async (filename, query) => {
   const readStream = new ReadFileStream(filename);
   const writeStream = new WriteFileStream(filename);
   let removed = [];
+  query = query || {};
   return new Promise((resolve, reject) => {
     readStream.on('document', obj => {
       if (matches(query, obj) && removed.length == 0) 

src/methods/update.js

@@ -5,6 +5,7 @@ export default async (filename ,query, operators, projection) => {
   const readStream = new ReadFileStream(filename);
   const writeStream = new WriteFileStream(filename);
   let updated = [];
+  query = query || {};
   return new Promise((resolve, reject) => {
     readStream.on('document', obj => {
       if (matches(query, obj)) {

src/methods/updateOne.js

@@ -5,6 +5,7 @@ export default async (filename ,query, operators, projection) => {
   const readStream = new ReadFileStream(filename);
   const writeStream = new WriteFileStream(filename);
   let updated = [];
+  query = query || {};
   return new Promise((resolve, reject) => {
     readStream.on('document', obj => {
       if (matches(query, obj) && !updated.length) {