Merge branch 'replicator' of CoBox/cobox-group-store into development

index.js

@@ -10,7 +10,7 @@ module.exports = (storage, factory, opts) => new GroupStore(storage, factory, op
 
 class GroupStore {
   constructor (storage, factory, opts = {}) {
-    this._id = crypto.randomBytes(16).toString('hex')
+    this._id = crypto.randomBytes(2).toString('hex')
     this.storage = storage
     this.opts = opts
     this.factory = factory
@@ -77,8 +77,7 @@ class GroupStore {
 
   _ready (callback) {
     var pending = 1
-    var self = this
-    var collection = Object.values(self.collection)
+    var collection = uniq(Object.values(this.collection))
 
     function next (n) {
       var entry = collection[n]

package.json

@@ -18,9 +18,9 @@
     "thunky": "^1.1.0"
   },
   "devDependencies": {
-    "cobox-blind-replicator": "git+https://ledger-git.dyne.org/cobox/cobox-blind-replicator",
-    "cobox-crypto": "git+https://ledger-git.dyne.org/cobox/cobox-crypto",
-    "cobox-group": "git+https://ledger-git.dyne.org/cobox/cobox-group",
+    "cobox-crypto": "^1.2.0",
+    "cobox-group": "^2.1.1",
+    "cobox-replicator": "^1.0.0",
     "mkdirp": "^0.5.1",
     "rimraf": "^3.0.0",
     "tap-spec": "^5.0.0",

test/index.test.js

@@ -1,11 +1,11 @@
 const { describe } = require('tape-plus')
 const Config = require('cobox-config')
 const crypto = require('cobox-crypto')
-const Store = require('../')
+const Group = require('cobox-group')
+const Replicator = require('cobox-replicator')
 
+const Store = require('../')
 const { tmp, cleanup } = require('./util')
-const Group = require('cobox-group/test/mock')
-const BlindReplicator = require('cobox-blind-replicator/test/mock')
 
 describe('group store: basic', (context) => {
   context('ready()', async function (assert, next) {
@@ -19,13 +19,9 @@ describe('group store: basic', (context) => {
     const store = Store(storage, Group, { config })
     store.seed(collection)
 
-    try {
-      await store.ready()
-      assert.same(Object.values(store.collection).length, 1, 'builds then caches groups from the config')
-      assert.ok(store.collection[params.address.toString('hex')], 'accessible using address hex string')
-    } catch (err) {
-      assert.error(err, 'no error')
-    }
+    await store.ready()
+    assert.same(Object.values(store.collection).length, 1, 'builds then caches groups from the config')
+    assert.ok(store.collection[params.address.toString('hex')], 'accessible using address hex string')
 
     cleanup(storage, next)
   })
@@ -41,14 +37,10 @@ describe('group store: basic', (context) => {
     const store = Store(storage, Group, { config })
     store.seed(collection)
 
-    try {
-      await store.ready()
-      var response = await store.all(params)
-      assert.ok(Array.isArray(response), 'returns an array')
-      assert.same(response.length, 1, 'returns the correct number')
-    } catch (err) {
-      assert.error(err, 'no error')
-    }
+    await store.ready()
+    var response = await store.all(params)
+    assert.ok(Array.isArray(response), 'returns an array')
+    assert.same(response.length, 1, 'returns the correct number')
 
     cleanup(storage, next)
   })
@@ -65,20 +57,16 @@ describe('group store: basic', (context) => {
     const store = Store(storage, Group, { config })
     store.seed(collection)
 
-    try {
-      await store.ready()
-      var response = await store.where({
-        name: 'magma',
-        address: params.address
-      })
+    await store.ready()
+    var response = await store.where({
+      name: 'magma',
+      address: params.address
+    })
 
-      assert.ok(Array.isArray(response), 'returns an array')
-      var entry = response[0]
-      assert.ok(entry, 'finds a entry')
-      assert.same(entry && entry.address, params.address, 'finds the correct entry')
-    } catch (err) {
-      assert.error(err, 'no error')
-    }
+    assert.ok(Array.isArray(response), 'returns an array')
+    var entry = response[0]
+    assert.ok(entry, 'finds a entry')
+    assert.same(entry && entry.address, params.address, 'finds the correct entry')
 
     cleanup(storage, next)
 
@@ -330,7 +318,7 @@ describe('multiple', (context) => {
         store: Store(storage, Group, { config })
       },
       replicators: {
-        store: Store(storage, BlindReplicator, { config })
+        store: Store(storage, Replicator, { config })
       }
     }