sudodoki/browser.js

## browser.js
/* jshint node:true */
var es = require('engine.io-stream');
var multilevel = require('multilevel');

var stream = es('/engine');
var db = multilevel.client();

stream.pipe(db.createRpcStream()).pipe(stream);
global.db = db;

stream.on('data', console.log.bind(console));

console.log(stream);

module.exports = db;

## index.jt
/* jshint node:true */
var level = require('levelup');
var memdown = require('memdown');
var http = require('http');
var browserify = require('browserify');
var es = require('engine.io-stream');
var multilevel = require('multilevel');

var server = http.createServer(function (req, res) {
  console.log(req.url);
  if (req.url == "/") {
    res.end("<!doctype html><script src='browser.js'></script>");
  } else if (req.url == '/browser.js') {
    browserify('./streaming.js').bundle().pipe(res);
  }
});
var db = level({db : memdown});

db.put('key', 'table', function (error) {
  db.get('key', function (error, value) {
    console.log('value:', value);
  });
});

var engine = es(function(stream) {
  stream.pipe(multilevel.server(db)).pipe(stream);
});
engine.attach(server, '/engine');

server.listen(process.env.PORT || 3000);
	/* jshint node:true */
	var es = require('engine.io-stream');
	var multilevel = require('multilevel');

	var stream = es('/engine');
	var db = multilevel.client();

	stream.pipe(db.createRpcStream()).pipe(stream);
	global.db = db;

	stream.on('data', console.log.bind(console));

	console.log(stream);

	module.exports = db;
	/* jshint node:true */
	var level = require('levelup');
	var memdown = require('memdown');
	var http = require('http');
	var browserify = require('browserify');
	var es = require('engine.io-stream');
	var multilevel = require('multilevel');

	var server = http.createServer(function (req, res) {
	console.log(req.url);
	if (req.url == "/") {
	res.end("<!doctype html><script src='browser.js'></script>");
	} else if (req.url == '/browser.js') {
	browserify('./streaming.js').bundle().pipe(res);
	}
	});
	var db = level({db : memdown});

	db.put('key', 'table', function (error) {
	db.get('key', function (error, value) {
	console.log('value:', value);
	});
	});

	var engine = es(function(stream) {
	stream.pipe(multilevel.server(db)).pipe(stream);
	});
	engine.attach(server, '/engine');

	server.listen(process.env.PORT \|\| 3000);