Node.js Redis Client

redis-node.js

//Sample usage
//var redis = require("./redis");
//var sys = require('sys');
 
//var c = redis.connect('0.0.0.0', 6379);
//c.addListener("connect", function (){
//    c.hasKey("foss").addCallback(function(data) {
//    sys.puts("Cool " + data);
//    c.quit();
//    });
//});



var tcp = require('tcp');
var sys = require('sys');

var conn;
var emitter = new process.EventEmitter();
var callbacks = [];
var response = '';

exports.connect = function(host, port) {
    conn = tcp.createConnection(port || 6379, host || '0.0.0.0');
    conn.addListener("connect", onConnect);
    conn.addListener("receive", onReceive);
    conn.addListener("disconnect", onDisconnect);
    return this;
}

exports.quit = function() {
    if (conn.readyState != "open")
        throw "connection is open";
    conn.close();
    emitter.emit("close");
}

function onConnect() {
    emitter.emit("connect");
}

function onDisconnect(hadError) {
    if (hadError)
        throw "disconnect from redis in error"
}

function onReceive(data) {
    var reply = data.replace("\n", "");
    var result = false;
    if(reply.indexOf(":1") > -1) {
        result = true;
    }
    var callback = callbacks.shift();
    callback.promise.emitSuccess(result);
}

exports.addListener = function(event, listener) {
    emitter.addListener(event, listener);
}

exports.hasKey = function (key) {
  var promise = new process.Promise;
  callbacks.push({'cmd' : 'hasKey', 'promise' : promise});
  conn.send("EXISTS " + key + "\r\n");
  return promise;
}