mirror of https://github.com/lukechilds/node.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
84 lines
2.4 KiB
84 lines
2.4 KiB
/**
|
|
* Fetch an HTTP url to a local file.
|
|
**/
|
|
|
|
var request = require("request")
|
|
, fs = require("graceful-fs")
|
|
, npm = require("../npm.js")
|
|
, url = require("url")
|
|
, log = require("npmlog")
|
|
, path = require("path")
|
|
, mkdir = require("mkdirp")
|
|
, chownr = require("chownr")
|
|
, regHost
|
|
|
|
module.exports = fetch
|
|
|
|
function fetch (remote, local, headers, cb) {
|
|
if (typeof cb !== "function") cb = headers, headers = {}
|
|
log.verbose("fetch", "to=", local)
|
|
mkdir(path.dirname(local), function (er, made) {
|
|
if (er) return cb(er)
|
|
fetch_(remote, local, headers, cb)
|
|
})
|
|
}
|
|
|
|
function fetch_ (remote, local, headers, cb) {
|
|
var fstr = fs.createWriteStream(local, { mode : npm.modes.file })
|
|
var response = null
|
|
var calledback = false
|
|
fstr.on("error", function (er) {
|
|
fs.close(fstr.fd, function () {})
|
|
if (calledback) return
|
|
calledback = true
|
|
cb(fstr._ERROR = er)
|
|
})
|
|
fstr.on("open", function () {
|
|
var req = makeRequest(remote, fstr, headers)
|
|
req.on("response", function (res) {
|
|
log.http(res.statusCode, remote)
|
|
response = res
|
|
})
|
|
})
|
|
fstr.on("close", function () {
|
|
if (calledback) return
|
|
calledback = true
|
|
if (response && response.statusCode && response.statusCode >= 400) {
|
|
var er = new Error(response.statusCode + " "
|
|
+ require("http").STATUS_CODES[response.statusCode])
|
|
cb(fstr._ERROR = er, response)
|
|
} else {
|
|
cb(null, response)
|
|
}
|
|
})
|
|
}
|
|
|
|
function makeRequest (remote, fstr, headers) {
|
|
remote = url.parse(remote)
|
|
log.http("GET", remote.href)
|
|
regHost = regHost || url.parse(npm.config.get("registry")).host
|
|
|
|
if (remote.host === regHost && npm.config.get("always-auth")) {
|
|
remote.auth = new Buffer( npm.config.get("_auth")
|
|
, "base64" ).toString("utf8")
|
|
if (!remote.auth) return fstr.emit("error", new Error(
|
|
"Auth required and none provided. Please run 'npm adduser'"))
|
|
}
|
|
|
|
var proxy
|
|
if (remote.protocol !== "https:" || !(proxy = npm.config.get("https-proxy"))) {
|
|
proxy = npm.config.get("proxy")
|
|
}
|
|
|
|
var opts = { url: remote
|
|
, proxy: proxy
|
|
, strictSSL: npm.config.get("strict-ssl")
|
|
, ca: remote.host === regHost ? npm.config.get("ca") : undefined
|
|
, headers: { "user-agent": npm.config.get("user-agent") }}
|
|
var req = request(opts)
|
|
req.on("error", function (er) {
|
|
fstr.emit("error", er)
|
|
})
|
|
req.pipe(fstr)
|
|
return req;
|
|
}
|
|
|