Example of running ldapjs over the GitHub API

seattlejs.js

var fs = require('fs');

var ldap = require('ldapjs');
var log4js = require('log4js');
var GitHubApi = require("github").GitHubApi;



///--- Globals

var USER;
var TOKEN;
try {
  USER = process.argv[2];
  TOKEN = fs.readFileSync(process.env.HOME + '/.github', 'utf8');
} catch (e) {}

var OU_USERS = 'o=github';



///--- Mainline
log4js.setGlobalLogLevel('DEBUG');
var log = log4js.getLogger('main');
log.setLevel('INFO');

var github = new GitHubApi(true);
if (USER && TOKEN)
  github.authenticateToken(USER, TOKEN);

var server = ldap.createServer({
  log4js: log4js
});

server.search('o=github', function(req, res, next) {
  // Only handle basic filters (eq/ge/le)
  if (!req.filter.attribute)
    return next(new ldap.OperationsError(req.filter.toString() +
                                         ' not supported'));


  var user = USER;
  req.dn.rdns.forEach(function(rdn) {
    if (rdn.user)
      user = rdn.user;
  });

  switch (req.filter.attribute) {
  case 'user':
    if (req.filter.value)
      user = req.filter.value;

    github.getUserApi().show(user, function(err, _user) {
      if (err && err.status !== 404)
        return next(new ldap.OperationsError(err.msg.error[0]));

      if (!_user) {
        res.end();
        return next();
      }

      github.getUserApi().getFollowers(user, function(err, followers) {
        if (err)
          return next(new ldap.OperationsError(err.msg.error[0]));

        github.getUserApi().getFollowing(user, function(err, following) {
          if (err)
            return next(new ldap.OperationsError(err.msg.error[0]));

          var obj = {
            dn: 'user=' + _user.login + ', ' + OU_USERS,
            attributes: {
              user: _user.login,
              name: _user.name || null,
              company: _user.company || null,
              mail: _user.email || null,
              l: _user.location || null,
              plan: _user.plan ? _user.plan.name : null,
              follower: followers || null,
              follows: following || null,
              objectclass: 'user'
            }
          };

          Object.keys(obj.attributes).forEach(function(k) {
            if (obj.attributes[k] === null)
              delete obj.attributes[k];
          });

          if (req.filter.matches(obj.attributes) &&
              (req.dn.parentOf(obj.dn) || req.dn.equals(obj.dn)))
            res.send(obj);

          res.end();
        });
      });
    });
    break;

  case 'repository':
    github.getRepoApi().getUserRepos(user, function(err, repos) {
      if (err)
        return next(new ldap.OperationsError(err.msg.error[0]));

      var done = 0;
      repos.forEach(function(r) {
        github.getRepoApi().getRepoWatchers(user, r.name, function(err, w) {
          if (err)
            return next(new ldap.OperationsError(err.msg.error[0]));

          var obj = {
            dn: 'repository=' + r.name + ', user=' + user + ', ' + OU_USERS,
            attributes: {
              repository: r.name,
              description: r.description,
              url: r.url,
              forks: r.forks,
              homepage: r.homepage,
              language: r.language,
              issues: r.open_issues,
              watcher: w,
              objectclass: 'repository'
            }
          };

          if (req.filter.matches(obj.attributes) &&
              (req.dn.parentOf(obj.dn) || req.dn.equals(obj.dn)))
            res.send(obj);

          if (++done === repos.length)
            res.end();
        });
      });
    });

    break;

  case 'issue':
    github.getRepoApi().getUserRepos(user, function(err, repos) {
      if (err)
        return next(new ldap.OperationsError(err.msg.error[0]));

      var done = 0;
      repos.forEach(function(r) {
        github.getIssueApi().getList(user, r.name, 'open', function(err, is) {
          if (err)
            return next(new ldap.OperationsError(err.msg.error[0]));

          is.forEach(function(i) {
            var dn = 'issue=' + i.number +
              ', repository=' + r.name +
              ', user=' + user +
              ', ' + OU_USERS;

            var obj = {
              dn: dn,
              attributes: {
                issue: i.number,
                user: i.user,
                votes: i.votes,
                url: i.html_url,
                comments: i.comments,
                body: i.body,
                objectclass: 'issue'
              }
            };

            if (req.filter.matches(obj.attributes) &&
                (req.dn.parentOf(obj.dn) || req.dn.equals(obj.dn)))
              res.send(obj);
          });

          if (++done === repos.length)
            res.end();
        });
      });
    });
    break;

  default:
    res.end();
  }
});

server.listen(1389, function() {
  log.info('LDAP server listening at %s for github user %s',
           server.url, USER || '');
});

WTF is with all that base64 encoding? Well, ldapsearch decides that anything that's not in the "short ascii" (I made that term up ;) ) range means it should base64 encode content. Annoying, isn't it? Let's try this again, but grab just one:

lsearch -b repository=restdown,user=trentm,o=github -t issue=7
dn: issue=7, repository=restdown, user=trentm, o=github
issue: 7
user: mcavage
votes: 0
url: https://github.com/trentm/restdown/issues/7
comments: 0
body: please!
objectclass: issue