1 files changed, 93 insertions, 0 deletions
diff --git a/node_modules/then-request/index.js b/node_modules/then-request/index.js
new file mode 100644
index 0000000..fc0657b
--- /dev/null
+++ b/node_modules/then-request/index.js
@@ -0,0 +1,93 @@
+'use strict';
+
+var assert = require('assert');
+var parseUrl = require('url').parse;
+var Promise = require('promise');
+var concat = require('concat-stream');
+var Response = require('http-response-object');
+var caseless = require('caseless');
+var handleQs = require('./lib/handle-qs.js');
+
+module.exports = doRequest;
+module.exports._request = require('http-basic');
+function doRequest(method, url, options, callback) {
+  var result = new Promise(function (resolve, reject) {
+    // check types of arguments
+
+    if (typeof method !== 'string') {
+      throw new TypeError('The method must be a string.');
+    }
+    if (typeof url !== 'string') {
+      throw new TypeError('The URL/path must be a string.');
+    }
+    if (typeof options === 'function') {
+      callback = options;
+      options = {};
+    }
+    if (options === null || options === undefined) {
+      options = {};
+    }
+    if (typeof options !== 'object') {
+      throw new TypeError('Options must be an object (or null).');
+    }
+    if (typeof callback !== 'function') {
+      callback = undefined;
+    }
+
+    method = method.toUpperCase();
+    options.headers = options.headers || {};
+    var headers = caseless(options.headers);
+
+    // handle query string
+    if (options.qs) {
+      url = handleQs(url, options.qs);
+    }
+
+    // handle json body
+    if (options.json) {
+      options.body = JSON.stringify(options.json);
+      headers.set('Content-Type', 'application/json');
+    }
+
+    var body = options.body ? options.body : new Buffer(0);
+    if (typeof body === 'string') body = new Buffer(body);
+    assert(Buffer.isBuffer(body), 'body should be a Buffer or a String');
+    if (!headers.has('Content-Length')) {
+      headers.set('Content-Length', body.length);
+    }
+
+    var req = module.exports._request(method, url, {
+      allowRedirectHeaders: options.allowRedirectHeaders,
+      headers: options.headers,
+      followRedirects: options.followRedirects !== false,
+      maxRedirects: options.maxRedirects,
+      gzip: options.gzip !== false,
+      cache: options.cache,
+      timeout: options.timeout,
+      socketTimeout: options.socketTimeout,
+      retry: options.retry,
+      retryDelay: options.retryDelay,
+      maxRetries: options.maxRetries
+    }, function (err, res) {
+      if (err) return reject(err);
+      res.body.on('error', reject);
+      res.body.pipe(concat(function (body) {
+        resolve(
+          new Response(
+            res.statusCode,
+            res.headers, Array.isArray(body) ? new Buffer(0) : body,
+            result.url
+          )
+        );
+      }));
+    });
+
+    if (req) {
+      req.end(body);
+    }
+  });
+  result.getBody = function (encoding) {
+    return result.then(function (res) { return res.getBody(encoding); });
+  };
+  return result.nodeify(callback);
+}