add swarm test

test/index.test.js

@@ -9,16 +9,39 @@ describe('basic', (context) => {
   context('inherits from cobox-group-base', async (assert, next) => {
     var storage = tmp()
     var address = crypto.address()
-    var group = BlindReplictor(storage, address)
-    assert.ok(group.config, 'has a config')
-    assert.ok(group.address, 'group created')
-    assert.ok(Buffer.isBuffer(group.address), 'address is a buffer')
-    assert.same(group.path, path.join(storage, address.toString('hex')))
-    assert.ok(group.storage, 'has random access file storage')
-    assert.ok(group.multifeed, 'has a multifeed instance')
-    assert.ok(typeof group.replicate === 'function', 'has a replicate function')
-
-    await group.ready()
+    var replicator = BlindReplictor(storage, address)
+    assert.ok(replicator.config, 'has a config')
+    assert.ok(replicator.address, 'replicator created')
+    assert.ok(Buffer.isBuffer(replicator.address), 'address is a buffer')
+    assert.same(replicator.path, path.join(storage, address.toString('hex')))
+    assert.ok(replicator.storage, 'has random access file storage')
+    assert.ok(replicator.multifeed, 'has a multifeed instance')
+    assert.ok(typeof replicator.replicate === 'function', 'has a replicate function')
+
+    await replicator.ready()
+
+    cleanup(storage, next)
+  })
+
+  context('swarm', async (assert, next) => {
+    var storage = tmp()
+    var address = crypto.address()
+    var replicator = BlindReplictor(storage, address)
+
+    assert.ok(typeof replicator.swarm === 'function', 'has a swarm function')
+    assert.ok(typeof replicator.unswarm === 'function', 'has an unswarm function')
+    assert.ok(replicator._connection === null, 'connection starts as null')
+
+    await replicator.ready()
+    replicator.swarm()
+
+    assert.ok(replicator._connection, 'caches a swarm connection')
+    assert.ok(replicator._isSwarming, 'stores isSwarming')
+
+    replicator.unswarm()
+
+    assert.notOk(replicator._connection, 'destroys the connection')
+    asser.notOk(repicator._isSwarming, 'stops swarming')
 
     cleanup(storage, next)
   })