replicate.js

var leveldb = require("levelidb")
var configure = require("level-scuttle/configure")
var put = require("level-scuttle/put")
var del = require("level-scuttle/del")
var replicate = require("level-scuttle/replicate")
var Model = require("scuttlebutt/model")

var db = leveldb("/tmp/level-1", { createIfMissing: true, encoding: "json" })
var db2 = leveldb("/tmp/level-2", { createIfMissing: true, encoding: "json" })

configure(db1, {
    "a": Model
})

configure(db2, {
    "a": Model
})

var stream1 = replicate(db, { start: "a:", end: "a;" })
var stream2 = replicate(db, { start: "a:", end: "a;" })

livefeed(db, { start: "a:", end: "a;" })
    .on("data", function (change) {
        assert.equal(change.key.substr(0, 3), "a:1")
        assert.deepEqual(change.value, { foo: "bar" })
    })

put(db2, "a:1", { foo: "bar" })