/usr/local/lib/node_modules/travis-notify-geckoboard/node_modules/questor/index.js

index.js

'use strict';

var assign = require('lodash.assign');
var defaults = require('lodash.defaults');
var bl = require('bl');
var http = require('http');
var https = require('https');
var Promise = require('bluebird');
var url = require('url');

module.exports = questor;
function questor(uri, options) {
  if (!options) { options = {}; }

  options = defaults({}, options, url.parse(uri), {
    headers: {}
  });

  var requestBody = options.body ? new Buffer(options.body) : void 0;
  var requestBodyLength = options.body ? requestBody.length : 0;
  options.headers['content-length'] = requestBodyLength;
  var driver = options.protocol === 'http:' ? http : https;

  return new Promise(function (resolve, reject) {
    var request = driver.request(options, function(response) {
      response.pipe(bl(function(err, data) {
        var body = data.toString();
        var value = {
          body: body,
          headers: response.headers,
          status: response.statusCode
        };

        if (response.statusCode === 0) {
          reject(new Error('Network error'));
          return;
        }

        if (response.statusCode >= 300) {
          reject(assign(new Promise.RejectionError(value.body), value));
          return;
        }

        resolve(value);
      }));
    });

    if ('timeout' in options) {
      request.setTimeout(options.timeout, function () {
        request.abort();
      });
    }

    request.on('error', reject);

    request.end(requestBody);
  });
}