bower/lib/core/source.js

// ==========================================
// BOWER: Source Api
// ==========================================
// Copyright 2012 Twitter, Inc
// Licensed under The MIT License
// http://opensource.org/licenses/MIT
// ==========================================

var request  = require('request');
var _        = require('underscore');
var config   = require('./config');

var endpoint = config.endpoint + '/packages';

// UZI
// allow for additional endpoints to be used for search and lookup
var endpoints = [];
endpoints.push(endpoint);
if (config.searchpath) {
  for (var i = 0; i < config.searchpath.length; i++) {
    endpoints.push(config.searchpath[i] + '/packages');
  }
}
// END UZI



// UZI
// modified so that this now checks each repository and finds the first match
exports.lookup = function (name, callback) {

  var f = function(i) {
	var endpoint = endpoints[i];	
	console.log("EP: " + endpoint);
	request.get(endpoint + '/' + encodeURIComponent(name), function (err, response, body) {
      if (!response) {
        console.log("No response from endpoint: " + endpoint);	
      }
      else if (err && response.statusCode !== 200 && response.statusCode !== 404) {
	    return callback(err || new Error(name + ' failed to look up for endpoint: ' + endpoint));
      }
	  if (response && response.statusCode !== 404) {
        callback(err, body && JSON.parse(body).url);
      } else {
	    if (i + 1 < endpoints.length) { 
		  f(i+1); 
		} else {
		  return callback(new Error(name + ' not found'));
		}
      }
	});	
  };
  f(0);
};
// END UZI



exports.register = function (name, url, callback) {

  var body = {name: name, url: url};

  request.post({url: endpoint, form: body}, function (err, response, body) {
    if (err) return callback(err);

    if (response.statusCode === 406) {
      return callback(new Error('Duplicate package'));
    }

    if (response.statusCode === 400) {
      return callback(new Error('Incorrect format'));
    }

    if (response.statusCode !== 201) {
      return callback(new Error('Unknown error: ' + response.statusCode));
    }

    callback();
  });
};



// UZI
// modified so now searches across many repositories
// hands back in order of preference with higher-level endpoint resources overriding lower-level
// also marks an "endpoint" property on the results to indicate which registry the search result was found in
// this uses a map to mark which "names" have been obscured by higher level endpoints
exports.search = function (name, callback) {

  var f = function(i, map, results) {
	var endpoint = endpoints[i];	
	request.get(endpoint + '/search/' + encodeURIComponent(name), function (err, response, body) {
      if (!response) {
        console.log("No response from endpoint: " + endpoint);	
      }
      else if (err && response.statusCode !== 200 && response.statusCode !== 404) {
	    return callback(err || new Error(name + ' failed to look up for endpoint: ' + endpoint));
      }
	  if (response && response.statusCode !== 404) {
        var array = body && JSON.parse(body);
        for (var x = 0; x < array.length; x++) {
	      var name = array[x].name;
	      if (!map[name]) {
            map[name] = name;
	        results.push({ name: array[x].name, url: array[x].url, endpoint: array[x].endpoint });
          }
        }
      }

      if (i + 1 < endpoints.length) { 
	    f(i + 1, map, results); 
	  } else {
		return callback(null, results);
	  }
	});		
  };
  f(0, {}, []);
};
// END UZI



exports.info = function (name, callback) {
  exports.lookup(name, function (err, url) {
    if (err) return callback(err);

    var Package = require('./package');
    var pkg     = new Package(name, url);

    pkg.once('resolve', function () {
      pkg.once('versions', function (versions) {
        callback(null, { pkg: pkg, versions: versions });
      }).versions();
    }).resolve();
  });
};



// UZI
// modified so this goes across all endpoints
// hands back in order of preference with higher-level endpoint resources overriding lower-level
exports.all = function (callback) {
	
  var f = function(i, results) {
	var endpoint = endpoints[i];	
	request.get(endpoint, function (err, response, body) {
      if (!response) {
        console.log("No response from endpoint: " + endpoint);	
      }
      else if (err && response.statusCode !== 200 && response.statusCode !== 404) {
	    return callback(err || new Error(name + ' failed to look up for endpoint: ' + endpoint));
      }
	  if (response && response.statusCode !== 404) {
        var array = body && JSON.parse(body);
        for (var x = 0; x < array.length; x++) {
          results.push({ name: array[x].name, url: array[x].url, endpoint: array[x].endpoint });
        }
      }

      if (i + 1 < endpoints.length) { 
	    f(i + 1, results); 
	  } else {
		return callback(new Error(name + ' not found'));
	  }
	});		
  };
  f(0, {});	

};
// END UZI