diff options
Diffstat (limited to 'node_modules/node-pre-gyp/lib/install.js')
| -rw-r--r-- | node_modules/node-pre-gyp/lib/install.js | 285 |
1 files changed, 0 insertions, 285 deletions
diff --git a/node_modules/node-pre-gyp/lib/install.js b/node_modules/node-pre-gyp/lib/install.js deleted file mode 100644 index 37a435a..0000000 --- a/node_modules/node-pre-gyp/lib/install.js +++ /dev/null @@ -1,285 +0,0 @@ -"use strict"; - -module.exports = exports = install; - -exports.usage = 'Attempts to install pre-built binary for module'; - -var fs = require('fs'); -var path = require('path'); -var log = require('npmlog'); -var existsAsync = fs.exists || path.exists; -var versioning = require('./util/versioning.js'); -var napi = require('./util/napi.js'); -var mkdirp = require('mkdirp'); - -var npgVersion = 'unknown'; -try { - // Read own package.json to get the current node-pre-pyp version. - var ownPackageJSON = fs.readFileSync(path.join(__dirname, '..', 'package.json'), 'utf8'); - npgVersion = JSON.parse(ownPackageJSON).version; -} catch (e) {} - -var http_get = { - impl: undefined, - type: undefined -}; - -try { - http_get.impl = require('request'); - http_get.type = 'request'; - log.warn("Using request for node-pre-gyp https download"); -} catch (e) { - http_get.impl = require('needle'); - http_get.type = 'needle'; - log.warn("Using needle for node-pre-gyp https download"); -} - -function download(uri,opts,callback) { - log.http('GET', uri); - - var req = null; - - // Try getting version info from the currently running npm. - var envVersionInfo = process.env.npm_config_user_agent || - 'node ' + process.version; - - var requestOpts = { - uri: uri.replace('+','%2B'), - headers: { - 'User-Agent': 'node-pre-gyp (v' + npgVersion + ', ' + envVersionInfo + ')' - }, - follow_max: 10, - }; - - if (opts.cafile) { - try { - requestOpts.ca = fs.readFileSync(opts.cafile); - } catch (e) { - return callback(e); - } - } else if (opts.ca) { - requestOpts.ca = opts.ca; - } - - var proxyUrl = opts.proxy || - process.env.http_proxy || - process.env.HTTP_PROXY || - process.env.npm_config_proxy; - if (proxyUrl) { - if (/^https?:\/\//i.test(proxyUrl)) { - log.verbose('download', 'using proxy url: "%s"', proxyUrl); - requestOpts.proxy = proxyUrl; - } else { - log.warn('download', 'ignoring invalid "proxy" config setting: "%s"', proxyUrl); - } - } - try { - req = http_get.impl.get(requestOpts.uri, requestOpts); - } catch (e) { - return callback(e); - } - if (req) { - req.on('response', function (res) { - log.http(res.statusCode, uri); - }); - } - return callback(null,req); -} - -function place_binary(from,to,opts,callback) { - download(from,opts,function(err,req) { - if (err) return callback(err); - if (!req) return callback(new Error("empty req")); - var badDownload = false; - var hasResponse = false; - - function afterExtract(err, extractCount) { - if (err) return callback(err); - if (badDownload) return callback(new Error("bad download")); - if (extractCount === 0) { - return callback(new Error('There was a fatal problem while downloading/extracting the tarball')); - } - log.info('tarball', 'done parsing tarball'); - callback(); - } - - // for request compatibility - req.on('error', function(err) { - badDownload = true; - if (!hasResponse) { - hasResponse = true; - return callback(err); - } - }); - - // for needle compatibility - req.on('err', function(err) { - badDownload = true; - if (!hasResponse) { - hasResponse = true; - return callback(err); - } - }); - - req.on('close', function () { - if (!hasResponse) { - hasResponse = true; - return callback(new Error('Connection closed while downloading tarball file')); - } - }); - - req.on('response', function(res) { - // ignore redirects, needle handles these automatically. - if (http_get.type === 'needle' && res.headers.hasOwnProperty('location') && res.headers.location !== '') { - return; - } - if (hasResponse) { - return; - } - hasResponse = true; - if (res.statusCode !== 200) { - badDownload = true; - var err = new Error(res.statusCode + ' status code downloading tarball ' + from); - err.statusCode = res.statusCode; - return callback(err); - } - // start unzipping and untaring - req.pipe(extract(to, afterExtract)); - }); - }); -} - -function extract_from_local(from, to, callback) { - if (!fs.existsSync(from)) { - return callback(new Error('Cannot find file ' + from)); - } - log.info('Found local file to extract from ' + from); - function afterExtract(err, extractCount) { - if (err) return callback(err); - if (extractCount === 0) { - return callback(new Error('There was a fatal problem while extracting the tarball')); - } - log.info('tarball', 'done parsing tarball'); - callback(); - } - fs.createReadStream(from).pipe(extract(to, afterExtract)); -} - -function extract(to, callback) { - var extractCount = 0; - function filter_func(entry) { - log.info('install','unpacking ' + entry.path); - extractCount++; - } - - function afterTarball(err) { - callback(err, extractCount); - } - - var tar = require('tar'); - return tar.extract({ - cwd: to, - strip: 1, - onentry: filter_func - }).on('close', afterTarball).on('error', callback); -} - - -function do_build(gyp,argv,callback) { - var args = ['rebuild'].concat(argv); - gyp.todo.push( { name: 'build', args: args } ); - process.nextTick(callback); -} - -function print_fallback_error(err,opts,package_json) { - var fallback_message = ' (falling back to source compile with node-gyp)'; - var full_message = ''; - if (err.statusCode !== undefined) { - // If we got a network response it but failed to download - // it means remote binaries are not available, so let's try to help - // the user/developer with the info to debug why - full_message = "Pre-built binaries not found for " + package_json.name + "@" + package_json.version; - full_message += " and " + opts.runtime + "@" + (opts.target || process.versions.node) + " (" + opts.node_abi + " ABI, " + opts.libc + ")"; - full_message += fallback_message; - log.warn("Tried to download(" + err.statusCode + "): " + opts.hosted_tarball); - log.warn(full_message); - log.http(err.message); - } else { - // If we do not have a statusCode that means an unexpected error - // happened and prevented an http response, so we output the exact error - full_message = "Pre-built binaries not installable for " + package_json.name + "@" + package_json.version; - full_message += " and " + opts.runtime + "@" + (opts.target || process.versions.node) + " (" + opts.node_abi + " ABI, " + opts.libc + ")"; - full_message += fallback_message; - log.warn(full_message); - log.warn("Hit error " + err.message); - } -} - -function install(gyp, argv, callback) { - var package_json = JSON.parse(fs.readFileSync('./package.json')); - var napi_build_version = napi.get_napi_build_version_from_command_args(argv); - var source_build = gyp.opts['build-from-source'] || gyp.opts.build_from_source; - var update_binary = gyp.opts['update-binary'] || gyp.opts.update_binary; - var should_do_source_build = source_build === package_json.name || (source_build === true || source_build === 'true'); - if (should_do_source_build) { - log.info('build','requesting source compile'); - return do_build(gyp,argv,callback); - } else { - var fallback_to_build = gyp.opts['fallback-to-build'] || gyp.opts.fallback_to_build; - var should_do_fallback_build = fallback_to_build === package_json.name || (fallback_to_build === true || fallback_to_build === 'true'); - // but allow override from npm - if (process.env.npm_config_argv) { - var cooked = JSON.parse(process.env.npm_config_argv).cooked; - var match = cooked.indexOf("--fallback-to-build"); - if (match > -1 && cooked.length > match && cooked[match+1] == "false") { - should_do_fallback_build = false; - log.info('install','Build fallback disabled via npm flag: --fallback-to-build=false'); - } - } - var opts; - try { - opts = versioning.evaluate(package_json, gyp.opts, napi_build_version); - } catch (err) { - return callback(err); - } - - opts.ca = gyp.opts.ca; - opts.cafile = gyp.opts.cafile; - - var from = opts.hosted_tarball; - var to = opts.module_path; - var binary_module = path.join(to,opts.module_name + '.node'); - existsAsync(binary_module,function(found) { - if (found && !update_binary) { - console.log('['+package_json.name+'] Success: "' + binary_module + '" already installed'); - console.log('Pass --update-binary to reinstall or --build-from-source to recompile'); - return callback(); - } else { - if (!update_binary) log.info('check','checked for "' + binary_module + '" (not found)'); - mkdirp(to,function(err) { - if (err) { - after_place(err); - } else { - var fileName = from.startsWith('file://') && from.replace(/^file:\/\//, ''); - if (fileName) { - extract_from_local(fileName, to, after_place); - } else { - place_binary(from,to,opts,after_place); - } - } - }); - } - function after_place(err) { - if (err && should_do_fallback_build) { - print_fallback_error(err,opts,package_json); - return do_build(gyp,argv,callback); - } else if (err) { - return callback(err); - } else { - console.log('['+package_json.name+'] Success: "' + binary_module + '" is installed via remote'); - return callback(); - } - } - }); - } -} |