cheap hook

cheap-hook.js

var level = require('level')
var net = require('net')
var mts = require('monotonic-timestamp')
var multilevel = require('multilevel')
var db = level('./db', { valueEncoding: 'json' })
var cl = level('./cl', { valueEncoding: 'json' })

var put = db.put

db.put = function(key, value, options, cb) {

  if (typeof options == 'function') {
    cb = options;
    options = {};
  }

  var change_value = {
    type: 'put',
    key: key,
    verified: false
  }

  var change_key = mts();

  cl.put(change_key, change_value, function(err) {
    if (err) return // emit to server
    put.call(db, key, value, options, function(err) {
      if (err) return cb(err)
      change_value.verified = true;
      cl.put(change_key, change_value, function(err) {
        if (err) return // emit to server
        cb(null)
      })
    })
  })
}

var server = net.createServer(function (con) {
    con.pipe(multilevel.server(db)).pipe(con);
}).listen(3000);


var mc = multilevel.client();
var con = net.connect(3000);
con.pipe(mc.createRpcStream()).pipe(con);

mc.put('foo', 100, function(err) {
  console.log(err || 'OK')
})