1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
/**
* 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
, once = require("once")
, crypto = require("crypto")
module.exports = fetch
function fetch (remote, local, headers, cb) {
if (typeof cb !== "function") cb = headers, headers = {}
cb = once(cb)
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
fstr.on("error", function (er) {
cb(er)
fstr.destroy()
})
var req = makeRequest(remote, fstr, headers)
req.on("response", function (res) {
log.http(res.statusCode, remote)
response = res
response.resume()
// Work around bug in node v0.10.0 where the CryptoStream
// gets stuck and never starts reading again.
if (process.version === "v0.10.0") {
response.resume = function (orig) { return function() {
var ret = orig.apply(response, arguments)
if (response.socket.encrypted)
response.socket.encrypted.read(0)
return ret
}}(response.resume)
}
})
fstr.on("close", function () {
var er
if (response && response.statusCode && response.statusCode >= 400) {
er = new Error(response.statusCode + " "
+ require("http").STATUS_CODES[response.statusCode])
}
cb(er, 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 sessionToken = npm.registry.sessionToken
if (!sessionToken) {
sessionToken = crypto.randomBytes(8).toString("hex")
npm.registry.sessionToken = sessionToken
}
var ca = remote.host === regHost ? npm.config.get("ca") : undefined
var opts = { url: remote
, proxy: proxy
, strictSSL: npm.config.get("strict-ssl")
, rejectUnauthorized: npm.config.get("strict-ssl")
, ca: ca
, headers:
{ "user-agent": npm.config.get("user-agent")
, "npm-session": sessionToken
, referer: npm.registry.refer
}
}
var req = request(opts)
req.on("error", function (er) {
fstr.emit("error", er)
})
req.pipe(fstr)
return req
}
|
