Store all travis builds for a given repo in mongo

travis.js

/* global console */

var urijs = require('urijs');
var Promise = require('bluebird');
var request = Promise.promisifyAll(require('request'));
var mongodb = Promise.promisifyAll(require('mongodb'));

var baseUrl = 'https://api.travis-ci.org';
var client = mongodb.MongoClient.connect('mongodb://localhost:27017/dashboard');

function update(user, repo, opts) {
  return client.then(function(db) {
    var collection = db.collection('travis');
    var uri = urijs(baseUrl).path(['repos', user, repo, 'builds'].join('/'));
    return fetch(uri, collection, opts);
  });
}

function fetch(uri, collection, opts) {
  console.log('fetching', uri.toString());
  return request.getAsync(uri.toString()).then(function(response) {
    var builds = JSON.parse(response.body);
    if (!builds.length) { return; }
    var bulk = collection.initializeUnorderedBulkOp();
    builds.forEach(function(build) {
      bulk
        .find({id: build.id, repository_id: build.repository_id})
        .upsert().updateOne(build);
    });
    return bulk.execute().then(function(result) {
      if (result.nMatched && !opts.complete) { return; }
      var build = builds[builds.length - 1];
      var nextUri = uri.query({after_number: build.number});
      return fetch(nextUri, collection, opts);
    });
  });
}

module.exports = {update: update};