initial commit, test basic replicator

README.md

@@ -0,0 +1,3 @@
+# cobox-blind-replicator
+
+Blind Replicator class for cobox groups.

index.js

@@ -0,0 +1,14 @@
+const Base = require('cobox-group-base')
+
+module.exports = (storage, address, opts = {}) => (
+  new BlindReplicator(storage, address, opts)
+)
+
+class BlindReplicator extends Base {
+  constructor (storage, address, opts = {}) {
+    super(storage, address, opts)
+    this._initFeeds(opts)
+    this._readyCallback = this.multifeed.ready.bind(this.multifeed)
+  }
+}
+

package.json

@@ -0,0 +1,29 @@
+{
+  "name": "cobox-blind-replicator",
+  "version": "0.1.0",
+  "description": "blind replicator class",
+  "main": "index.js",
+  "scripts": {
+    "test": "tape test/**/*.test.js | tap-spec"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://ledger-git.dyne.org/cobox/cobox-blind-replicator"
+  },
+  "keywords": [
+    "cobox"
+  ],
+  "author": "magma collective",
+  "license": "AGPL-3.0-or-later",
+  "dependencies": {
+    "cobox-group-base": "git+https://ledger-git.dyne.org/cobox/cobox-group-base"
+  },
+  "devDependencies": {
+    "nyc": "^14.1.1",
+    "rimraf": "^3.0.0",
+    "tap-spec": "^5.0.0",
+    "tape": "^4.11.0",
+    "tape-plus": "^1.0.0",
+    "tmp": "^0.1.0"
+  }
+}

test/index.test.js

@@ -0,0 +1,25 @@
+const { describe } = require('tape-plus')
+const crypto = require('cobox-crypto')
+const path = require('path')
+
+const BlindReplictor = require('../')
+const { tmp, cleanup } = require('./util')
+
+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()
+
+    cleanup(storage, next)
+  })
+})

test/util.js

@@ -0,0 +1,63 @@
+const rimraf = require('rimraf')
+const debug = require('debug')('cleanup')
+const tmpdir = require('tmp').dirSync
+const mkdirp = require('mkdirp')
+
+function cleanup (dirs, cb) {
+  if (!cb) cb = noop
+  if (!Array.isArray(dirs)) dirs = [dirs]
+  var pending = 1
+
+  function next (n) {
+    var dir = dirs[n]
+    if (!dir) return done()
+    ++pending
+    process.nextTick(next, n + 1)
+
+    rimraf(dir, (err) => {
+      if (err) return done(err)
+      done()
+    })
+  }
+
+  function done (err) {
+    if (err) {
+      pending = Infinity
+      return cb(err)
+    }
+    if (!--pending) return cb()
+  }
+
+  next(0)
+}
+
+function tmp () {
+  var path = '.'+tmpdir().name
+  mkdirp.sync(path)
+  return path
+}
+
+function replicate (a, b, opts, cb) {
+  if (typeof opts === 'function') return replicate(a, b, {}, opts)
+  if (!cb) cb = noop
+
+  var s = a.replicate(true, Object.assign({ live: false }, opts))
+  var d = b.replicate(false, Object.assign({ live: false }, opts))
+
+  s.pipe(d).pipe(s)
+
+  s.on('error', (err) => {
+    if (err) return cb(err)
+  })
+
+  s.on('end', cb)
+}
+
+function uniq (array) {
+  if (!Array.isArray(array)) array = [array]
+  return Array.from(new Set(array))
+}
+
+function noop () {}
+
+module.exports = { cleanup, tmp, replicate, uniq }