scuttle.js

var leveldb = require("levelidb")
var bucket = require("scuttlebucket")
var LevelScuttle = require("level-scuttle")
var Model = LevelScuttle(require("scuttlebutt/model"))
var livefeed = require("level-livefeed")
var assert = require("assert")

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

var a1 = Model(db, "a:1")
var a2 = Model(db, "a:2")

var a3 = Model(db2, "a:1")
var a4 = Model(db2, "a:2")

var bucket1 = bucket()
    .add(a1, a1.name)
    .add(a2, a2.name)

var bucket2 = bucket()
    .add(a3, a3.name)
    .add(a4, a4.name)

var stream1 = bucket1.createStream()
var stream2 = bucket2.createStream()

stream1.pipe(stream2).pipe(stream1)

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" })
    })

a3.set("foo",  "bar")