simple request

simple_request.js

var parse = require('url').parse,
    http = require('http'),
    StringDecoder = require('string_decoder').StringDecoder;

var request = function(url, body, func) {
  if (typeof url !== 'object') {
    url = parse(url);
  }
  
  if (!func) {
    func = body;
    body = undefined;
  }
  
  var opt = {
    host: url.hostname,
    port: url.port || 80,
    path: url.pathname
  };
  
  if (body) {
    opt.headers = {
      'Content-Type': 'application/octet-stream; charset=utf-8',
      'Content-Length': Buffer.byteLength(body)
    };
    opt.method = 'POST';
  } else {
    opt.method = 'GET';
  }
  
  var req = http.request(opt, function(res) {
    var decoder = new StringDecoder('utf-8'),
        total = 0, body = '';
    res.on('data', function(data) {
      if (total += data.length > 10240) {
        this.emit('error');
        return;
      }
      body += decoder.write(data);
    }).on('error', function(err) {
      func(err);
      this.destroy();
    }).on('end', function() {
      res.body = body;
      func(null, res);
    });
  });
  
  req.end(body);
};