chatroom.js

var crudlet    = require("crudlet");
var localstore = require("crudlet-local-storage");
var pubnub     = require("crudlet-pubnub");

var localdb    = localstore();
var pubdb      = pubnub();
var allDbs     = crudlet.parallel(localdb, pubdb);

crudlet.run(pubdb, "tail").pipe(crudlet.stream(localdb));


crudlet.run(allDbs, "insert", { data: { message: "hello world" }});