add swarm code

index.js

@@ -2,6 +2,9 @@ const Base = require('cobox-group-base')
 const swarm = require('cobox-swarm')
 const assert = require('assert')
 const thunky = require('thunky')
+const debug = require('debug')('cobox-blind-replicator')
+const pump = require('pump')
+const hyperswarm = require('hyperswarm')
 
 module.exports = (storage, address, opts = {}) => (
   new BlindReplicator(storage, address, opts)
@@ -18,9 +21,20 @@ class BlindReplicator extends Base {
   }
 
   swarm (opts = {}) {
-    this._connection = swarm(this, Object.assign(opts, {
-      logger: this.config.logger
-    }))
+    var swarm = hyperswarm()
+
+    swarm.on('connection', (socket, details) => {
+      pump(socket, this.replicate(details.client), socket)
+      if (details.peer) debug(`connected ${util.inspect(details, null, 4)}`)
+    })
+
+    swarm.on('disconnection', (socket, details) => {
+      if (details.peer) debug(`disconnected from peer: ${details.peer.host}`)
+    })
+
+    swarm.join(this.discoveryKey, { lookup: true, announce: true })
+
+    this.connection = swarm
     this._isSwarming = true
     return true
   }