module.exports = simpleGet var concat = require('simple-concat') var http = require('http') var https = require('https') var once = require('once') var querystring = require('querystring') var decompressResponse = require('decompress-response') // excluded from browser build var url = require('url') function simpleGet (opts, cb) { opts = typeof opts === 'string' ? {url: opts} : Object.assign({}, opts) opts.headers = Object.assign({}, opts.headers) cb = once(cb) if (opts.url) parseOptsUrl(opts) if (opts.maxRedirects == null) opts.maxRedirects = 10 var body if (opts.form) body = typeof opts.form === 'string' ? opts.form : querystring.stringify(opts.form) if (opts.body) body = opts.json && !isStream(opts.body) ? JSON.stringify(opts.body) : opts.body if (opts.json) opts.headers.accept = 'application/json' if (opts.json && body) opts.headers['content-type'] = 'application/json' if (opts.form) opts.headers['content-type'] = 'application/x-www-form-urlencoded' if (body && !isStream(body)) opts.headers['content-length'] = Buffer.byteLength(body) delete opts.body delete opts.form if (body && !opts.method) opts.method = 'POST' if (opts.method) opts.method = opts.method.toUpperCase() // Request gzip/deflate var customAcceptEncoding = Object.keys(opts.headers).some(function (h) { return h.toLowerCase() === 'accept-encoding' }) if (!customAcceptEncoding) opts.headers['accept-encoding'] = 'gzip, deflate' // Support http/https urls var protocol = opts.protocol === 'https:' ? https : http var req = protocol.request(opts, function (res) { // Follow 3xx redirects if (res.statusCode >= 300 && res.statusCode < 400 && 'location' in res.headers) { opts.url = res.headers.location res.resume() // Discard response if (opts.maxRedirects > 0) { opts.maxRedirects -= 1 simpleGet(opts, cb) } else { cb(new Error('too many redirects')) } return } var tryUnzip = typeof decompressResponse === 'function' && opts.method !== 'HEAD' cb(null, tryUnzip ? decompressResponse(res) : res) }) req.on('timeout', function () { req.abort() cb(new Error('Request timed out')) }) req.on('error', cb) if (body && isStream(body)) body.on('error', cb).pipe(req) else req.end(body) return req } simpleGet.concat = function (opts, cb) { return simpleGet(opts, function (err, res) { if (err) return cb(err) concat(res, function (err, data) { if (err) return cb(err) if (opts.json) { try { data = JSON.parse(data.toString()) } catch (err) { return cb(err, res, data) } } cb(null, res, data) }) }) } ;['get', 'post', 'put', 'patch', 'head', 'delete'].forEach(function (method) { simpleGet[method] = function (opts, cb) { if (typeof opts === 'string') opts = {url: opts} opts.method = method.toUpperCase() return simpleGet(opts, cb) } }) function parseOptsUrl (opts) { var loc = url.parse(opts.url) if (loc.hostname) opts.hostname = loc.hostname if (loc.port) opts.port = loc.port if (loc.protocol) opts.protocol = loc.protocol if (loc.auth) opts.auth = loc.auth opts.path = loc.path delete opts.url } function isStream (obj) { return typeof obj.pipe === 'function' }