mirror of https://github.com/nodejs/node.git
110 lines
3.5 KiB
JavaScript
110 lines
3.5 KiB
JavaScript
'use strict'
|
|
|
|
const config = require('./config.js')
|
|
const errors = require('./errors.js')
|
|
const LRU = require('lru-cache')
|
|
|
|
module.exports = checkResponse
|
|
function checkResponse (method, res, registry, startTime, opts) {
|
|
opts = config(opts)
|
|
if (res.headers.has('npm-notice') && !res.headers.has('x-local-cache')) {
|
|
opts.log.notice('', res.headers.get('npm-notice'))
|
|
}
|
|
checkWarnings(res, registry, opts)
|
|
if (res.status >= 400) {
|
|
logRequest(method, res, startTime, opts)
|
|
return checkErrors(method, res, startTime, opts)
|
|
} else {
|
|
res.body.on('end', () => logRequest(method, res, startTime, opts))
|
|
if (opts.ignoreBody) {
|
|
res.body.resume()
|
|
res.body = null
|
|
}
|
|
return res
|
|
}
|
|
}
|
|
|
|
function logRequest (method, res, startTime, opts) {
|
|
const elapsedTime = Date.now() - startTime
|
|
const attempt = res.headers.get('x-fetch-attempts')
|
|
const attemptStr = attempt && attempt > 1 ? ` attempt #${attempt}` : ''
|
|
const cacheStr = res.headers.get('x-local-cache') ? ' (from cache)' : ''
|
|
opts.log.http(
|
|
'fetch',
|
|
`${method.toUpperCase()} ${res.status} ${res.url} ${elapsedTime}ms${attemptStr}${cacheStr}`
|
|
)
|
|
}
|
|
|
|
const WARNING_REGEXP = /^\s*(\d{3})\s+(\S+)\s+"(.*)"\s+"([^"]+)"/
|
|
const BAD_HOSTS = new LRU({ max: 50 })
|
|
|
|
function checkWarnings (res, registry, opts) {
|
|
if (res.headers.has('warning') && !BAD_HOSTS.has(registry)) {
|
|
const warnings = {}
|
|
res.headers.raw()['warning'].forEach(w => {
|
|
const match = w.match(WARNING_REGEXP)
|
|
if (match) {
|
|
warnings[match[1]] = {
|
|
code: match[1],
|
|
host: match[2],
|
|
message: match[3],
|
|
date: new Date(match[4])
|
|
}
|
|
}
|
|
})
|
|
BAD_HOSTS.set(registry, true)
|
|
if (warnings['199']) {
|
|
if (warnings['199'].message.match(/ENOTFOUND/)) {
|
|
opts.log.warn('registry', `Using stale data from ${registry} because the host is inaccessible -- are you offline?`)
|
|
} else {
|
|
opts.log.warn('registry', `Unexpected warning for ${registry}: ${warnings['199'].message}`)
|
|
}
|
|
}
|
|
if (warnings['111']) {
|
|
// 111 Revalidation failed -- we're using stale data
|
|
opts.log.warn(
|
|
'registry',
|
|
`Using stale data from ${registry} due to a request error during revalidation.`
|
|
)
|
|
}
|
|
}
|
|
}
|
|
|
|
function checkErrors (method, res, startTime, opts) {
|
|
return res.buffer()
|
|
.catch(() => null)
|
|
.then(body => {
|
|
let parsed = body
|
|
try {
|
|
parsed = JSON.parse(body.toString('utf8'))
|
|
} catch (e) {}
|
|
if (res.status === 401 && res.headers.get('www-authenticate')) {
|
|
const auth = res.headers.get('www-authenticate')
|
|
.split(/,\s*/)
|
|
.map(s => s.toLowerCase())
|
|
if (auth.indexOf('ipaddress') !== -1) {
|
|
throw new errors.HttpErrorAuthIPAddress(
|
|
method, res, parsed, opts.spec
|
|
)
|
|
} else if (auth.indexOf('otp') !== -1) {
|
|
throw new errors.HttpErrorAuthOTP(
|
|
method, res, parsed, opts.spec
|
|
)
|
|
} else {
|
|
throw new errors.HttpErrorAuthUnknown(
|
|
method, res, parsed, opts.spec
|
|
)
|
|
}
|
|
} else if (res.status === 401 && /one-time pass/.test(body.toString('utf8'))) {
|
|
// Heuristic for malformed OTP responses that don't include the www-authenticate header.
|
|
throw new errors.HttpErrorAuthOTP(
|
|
method, res, parsed, opts.spec
|
|
)
|
|
} else {
|
|
throw new errors.HttpErrorGeneral(
|
|
method, res, parsed, opts.spec
|
|
)
|
|
}
|
|
})
|
|
}
|