chatroom.js

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

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

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


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