Promises

promise.js

/**
 *  Sumologic module
 *  @module lib/sumologic
 */
var rsvp = require('rsvp');
var fs = require('fs');
var request = require('request')
var util = require('util');


var upload = function(filename, url){
  var options = {
    headers: {
      'Content-Encoding': 'gzip'
    },
    url: url
  }

  return new rsvp.Promise(function(resolve, reject){
    fs.createReadStream(filename).pipe(
      request
        .post(options)
        .on('response', function(response){
          if(response.statusCode != 200){
            reject(new Error(util.format("Unable to upload file %s to %s", filename, url)));
          }
          resolve(response);
        })
      );
  })
}

module.exports = {
  /** Upload a gzip encoded file to sumologic http collector **/
  upload: upload
}