assign discoveryKey

index.js

@@ -1,5 +1,7 @@
 const Base = require('cobox-group-base')
 const swarm = require('cobox-swarm')
+const maybe = require('call-me-maybe')
+const assert = require('assert')
 
 module.exports = (storage, address, opts = {}) => (
   new BlindReplicator(storage, address, opts)
@@ -14,6 +16,18 @@ class BlindReplicator extends Base {
     this._isSwarming = true
   }
 
+  ready (callback) {
+    var self = this
+    return maybe(callback, new Promise((resolve, reject) => {
+      self._readyCallback((err) => {
+        if (err) return reject(err)
+        self.discoveryKey = self.multifeed._root.discoveryKey
+        self._isReady = true
+        return resolve()
+      })
+    }))
+  }
+
   swarm (opts = {}) {
     this._connection = swarm(this, Object.assign(opts, {
       logger: this.config.logger

package.json

@@ -16,6 +16,8 @@
   "author": "magma collective",
   "license": "AGPL-3.0-or-later",
   "dependencies": {
+    "assert": "^2.0.0",
+    "call-me-maybe": "^1.0.1",
     "cobox-group-base": "git+https://ledger-git.dyne.org/cobox/cobox-group-base",
     "cobox-swarm": "git+https://ledger-git.dyne.org/cobox/cobox-swarm"
   },

test/index.test.js

@@ -41,7 +41,7 @@ describe('basic', (context) => {
     replicator.unswarm()
 
     assert.notOk(replicator._connection, 'destroys the connection')
-    asser.notOk(repicator._isSwarming, 'stops swarming')
+    assert.notOk(replicator._isSwarming, 'stops swarming')
 
     cleanup(storage, next)
   })