Merge pull request #93 from shamb0t/master

Add DocumentStore

package.json

@@ -18,7 +18,8 @@
     "orbit-db-eventstore": "0.1.5",
     "orbit-db-feedstore": "0.1.4",
     "orbit-db-kvstore": "0.1.3",
-    "orbit-db-pubsub": "0.0.4"
+    "orbit-db-pubsub": "0.0.4",
+    "orbit-db-docstore": "0.0.7"
   },
   "devDependencies": {
     "asyncawait": "^1.0.6",

src/OrbitDB.js

@@ -5,6 +5,7 @@ const EventStore    = require('orbit-db-eventstore')
 const FeedStore     = require('orbit-db-feedstore')
 const KeyValueStore = require('orbit-db-kvstore')
 const CounterStore  = require('orbit-db-counterstore')
+const DocumentStore = require('orbit-db-docstore')
 const Pubsub        = require('orbit-db-pubsub')
 const Cache         = require('./Cache')
 
@@ -37,6 +38,10 @@ class OrbitDB {
     return this._createStore(CounterStore, dbname, options)
   }
 
+  docstore(dbname, options) {
+    return this._createStore(DocumentStore, dbname, options)
+  }
+
   disconnect() {
     if (this._pubsub) this._pubsub.disconnect()
     this.events.removeAllListeners('data')

test/client.test.js

@@ -64,7 +64,7 @@ IpfsApis.forEach(function(ipfsApi) {
             assert.notEqual(second, null)
             assert.notEqual(second, head)
             assert.equal(second.startsWith('Qm'), true)
-            assert.equal(second.length, 46)              
+            assert.equal(second.length, 46)
           })
       })
 
@@ -88,7 +88,7 @@ IpfsApis.forEach(function(ipfsApi) {
           .then((hash) => {
             assert.notEqual(hash, null)
             assert.equal(hash.startsWith('Qm'), true)
-            assert.equal(hash.length, 46)            
+            assert.equal(hash.length, 46)
           })
       })
     })
@@ -523,8 +523,92 @@ IpfsApis.forEach(function(ipfsApi) {
           const value = db.get('key1')
           assert.equal(value, 'hello2')
         }))
-        await(db.put('key1', 'hello1'))
-        await(db2.put('key1', 'hello2'))
+      }))
+    })
+
+    describe('Document Store - default index \'_id\'', function() {
+      beforeEach(() => {
+        db = client.docstore(channel, { subscribe: false })
+        db.delete()
+      })
+
+      afterEach(() => {
+        db.close()
+      })
+
+      it('put', async(() => {
+        await(db.put({ _id: 'hello world', doc: 'all the things'}))
+        const value = db.get('hello world')
+        assert.deepEqual(value, [{ _id: 'hello world', doc: 'all the things'}])
+      }))
+
+      it('get - partial term match', async(() => {
+        await(db.put({ _id: 'hello world', doc: 'some things'}))
+        await(db.put({ _id: 'hello universe', doc: 'all the things'}))
+        await(db.put({ _id: 'sup world', doc: 'other things'}))
+        const value = db.get('hello')
+        assert.deepEqual(value, [{ _id: 'hello world', doc: 'some things' },
+                                 { _id: 'hello universe', doc: 'all the things'}])
+      }))
+
+      it('get after delete', async(() => {
+        await(db.put({ _id: 'hello world', doc: 'some things'}))
+        await(db.put({ _id: 'hello universe', doc: 'all the things'}))
+        await(db.put({ _id: 'sup world', doc: 'other things'}))
+        await(db.del('hello universe'))
+        const value = db.get('hello')
+        assert.deepEqual(value, [{ _id: 'hello world', doc: 'some things'}])
+      }))
+
+      it('put updates a value', async(() => {
+        await(db.put({ _id: 'hello world', doc: 'all the things'}))
+        await(db.put({ _id: 'hello world', doc: 'some of the things'}))
+        const value = db.get('hello')
+        assert.deepEqual(value, [{ _id: 'hello world', doc: 'some of the things'}])
+      }))
+
+      it('query', async(() => {
+        await(db.put({ _id: 'hello world', doc: 'all the things', views: 17}))
+        await(db.put({ _id: 'sup world', doc: 'some of the things', views: 10}))
+        await(db.put({ _id: 'hello other world', doc: 'none of the things', views: 5}))
+        await(db.put({ _id: 'hey universe', doc: ''}))
+        const value = db.query((e) => e.views > 5)
+        assert.deepEqual(value, [{ _id: 'hello world', doc: 'all the things', views: 17},
+                                 { _id: 'sup world', doc: 'some of the things', views: 10}])
+      }))
+
+      it('query after delete', async(() => {
+        await(db.put({ _id: 'hello world', doc: 'all the things', views: 17}))
+        await(db.put({ _id: 'sup world', doc: 'some of the things', views: 10}))
+        await(db.put({ _id: 'hello other world', doc: 'none of the things', views: 5}))
+        await(db.del('hello world'))
+        await(db.put({ _id: 'hey universe', doc: ''}))
+        const value = db.query((e) => e.views > 5)
+        assert.deepEqual(value, [{ _id: 'sup world', doc: 'some of the things', views: 10}])
+      }))
+    })
+
+    describe('Document Store - specified index', function() {
+      beforeEach(() => {
+        db = client.docstore(channel, { subscribe: false, indexBy: 'doc' })
+        db.delete()
+      })
+
+      afterEach(() => {
+        db.close()
+      })
+
+      it('put', async(() => {
+        await(db.put({ _id: 'hello world', doc: 'all the things'}))
+        const value = db.get('all')
+        assert.deepEqual(value, [{ _id: 'hello world', doc: 'all the things'}])
+      }))
+
+      it('get - matches specified index', async(() => {
+        await(db.put({ _id: 'hello universe', doc: 'all the things'}))
+        await(db.put({ _id: 'hello world', doc: 'some things'}))
+        const value = db.get('all')
+        assert.deepEqual(value, [{ _id: 'hello universe', doc: 'all the things'}])
       }))
     })
   })