LDAP.js

var ldapbinding = require("./build/default/LDAP");

var Connection = function() {
    var callbacks = {};
    var binding = new ldapbinding.LDAPConnection();
    var self = this;
    var querytimeout = 5000;
    var totalqueries = 0;

    self.BASE = 0;
    self.ONELEVEL = 1;
    self.SUBTREE = 2;
    self.SUBORDINATE = 3;
    self.DEFAULT = -1;
    
    self.DEREF_NEVER = 0;
    self.DEREF_SEARCHING = 1;
    self.DEREF_FINDING = 2;
    self.DEREF_ALWAYS = 3;

    self.setCallback = function(msgid, CB) {
        if (msgid >= 0) {
            totalqueries++;
            if (typeof(CB) == 'function') {
                callbacks[msgid] = {
                  cb: CB,
                  tm: setTimeout(function() {
                      CB(msgid, new Error(-2)); //Request timed out
                      delete callbacks[msgid];
                  }, self.querytimeout || querytimeout)
                };
            }
        } else {
            // msgid is -1, which means an error. We won't add the callback to the array,
            // instead, call the callback immediately.
            CB(msgid, new Error(-1)); //LDAP Error, TODO: expose a way to get the specific error
        }
    };

    self.open = function(uri, version) {
        if (arguments.length < 2) {
            return binding.open(uri, 3);
        }

        return binding.open(uri, version);
    };

    self.search = function(base, scope, filter, attrs, CB) {
        var msgid = binding.search(base, scope, filter, attrs);
        self.setCallback(msgid, CB);
    };
    
    self.searchDeref = function(base, scope, filter, attrs, deref, CB) {
        var msgid = binding.searchDeref(base, scope, filter, attrs, deref);
        self.setCallback(msgid, CB);
    };
    
    self.pagedSearch = function(base, scope, filter, attrs, pageOption, CB) {
      var msgid = binding.pagedSearch(base, scope, filter, attrs, pageOption);
      self.setCallback(msgid, CB);
    };

    self.simpleBind = function(binddn, password, CB) {
        var msgid;
        if (arguments.length === 0) {
            msgid = binding.simpleBind();
        } else {
            msgid = binding.simpleBind(binddn, password);
        }
        return self.setCallback(msgid, CB);
    };

    self.add = function(dn, data, CB) {
        var msgid = binding.add(dn, data);
        return self.setCallback(msgid, CB);
    };

    self.remove = function(dn, CB) {
        var msgid = binding.remove(dn);
        return self.setCallback(msgid, CB);
    };

    self.modify = function(dn, data, CB) {
        var msgid = binding.modify(dn, data);
        return self.setCallback(msgid, CB);
    };

    self.addListener = function(event, CB) {
        binding.addListener(event, CB);
    };

    self.removeListener = function(event, CB) {
        binding.removeListener(event, CB);
    };

    self.close = function() {
        binding.close();
    }

    binding.addListener("searchresult", function(msgid, result, data, context) {
        // result contains the LDAP response type. It's unused.
        if (callbacks[msgid]) {
            clearTimeout(callbacks[msgid].tm);
            callbacks[msgid].cb(msgid, null, data, context);
            delete(callbacks[msgid]);
        }
    });

    binding.addListener("result", function(msgid, result) {
        // result contains the LDAP response type. It's unused.
        if (callbacks[msgid]) {
            clearTimeout(callbacks[msgid].tm);
            callbacks[msgid].cb(msgid, null);
            delete(callbacks[msgid]);
        }
    });

    binding.addListener("error", function(msgid, err, msg) {
        if (callbacks[msgid]) {
            clearTimeout(callbacks[msgid].tm);
            callbacks[msgid].cb(msgid, new Error(err, msg));
            delete(callbacks[msgid]);
        }
    });
};

exports.Connection = Connection;