![]() System : Linux absol.cf 5.4.0-198-generic #218-Ubuntu SMP Fri Sep 27 20:18:53 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory : /usr/local/lib/node_modules/npm/lib/ |
Upload File : |
const EventEmitter = require('events') const { resolve, dirname } = require('path') const Config = require('@npmcli/config') const log = require('npmlog') // Patch the global fs module here at the app level require('graceful-fs').gracefulify(require('fs')) // TODO make this only ever load once (or unload) in tests const procLogListener = require('./utils/proc-log-listener.js') // Timers in progress const timers = new Map() // Finished timers const timings = {} const processOnTimeHandler = (name) => { timers.set(name, Date.now()) } const processOnTimeEndHandler = (name) => { if (timers.has(name)) { const ms = Date.now() - timers.get(name) log.timing(name, `Completed in ${ms}ms`) timings[name] = ms timers.delete(name) } else log.silly('timing', "Tried to end timer that doesn't exist:", name) } const { definitions, flatten, shorthands } = require('./utils/config/index.js') const { shellouts } = require('./utils/cmd-list.js') const usage = require('./utils/npm-usage.js') const which = require('which') const deref = require('./utils/deref-command.js') const setupLog = require('./utils/setup-log.js') const cleanUpLogFiles = require('./utils/cleanup-log-files.js') const getProjectScope = require('./utils/get-project-scope.js') let warnedNonDashArg = false const _load = Symbol('_load') const _tmpFolder = Symbol('_tmpFolder') const _title = Symbol('_title') const pkg = require('../package.json') class Npm extends EventEmitter { static get version () { return pkg.version } constructor () { super() this.started = Date.now() this.command = null this.timings = timings this.timers = timers process.on('time', processOnTimeHandler) process.on('timeEnd', processOnTimeEndHandler) procLogListener() process.emit('time', 'npm') this.config = new Config({ npmPath: dirname(__dirname), definitions, flatten, shorthands, }) this[_title] = process.title this.updateNotification = null } get version () { return this.constructor.version } get shelloutCommands () { return shellouts } deref (c) { return deref(c) } // Get an instantiated npm command // npm.command is already taken as the currently running command, a refactor // would be needed to change this async cmd (cmd) { await this.load() const command = this.deref(cmd) if (!command) { throw Object.assign(new Error(`Unknown command ${cmd}`), { code: 'EUNKNOWNCOMMAND', }) } const Impl = require(`./commands/${command}.js`) const impl = new Impl(this) return impl } // Call an npm command async exec (cmd, args) { const command = await this.cmd(cmd) process.emit('time', `command:${cmd}`) // since 'test', 'start', 'stop', etc. commands re-enter this function // to call the run-script command, we need to only set it one time. if (!this.command) { process.env.npm_command = command.name this.command = command.name } // Options are prefixed by a hyphen-minus (-, \u2d). // Other dash-type chars look similar but are invalid. if (!warnedNonDashArg) { args.filter(arg => /^[\u2010-\u2015\u2212\uFE58\uFE63\uFF0D]/.test(arg)) .forEach(arg => { warnedNonDashArg = true this.log.error('arg', 'Argument starts with non-ascii dash, this is probably invalid:', arg) }) } const workspacesEnabled = this.config.get('workspaces') const workspacesFilters = this.config.get('workspace') if (workspacesEnabled === false && workspacesFilters.length > 0) throw new Error('Can not use --no-workspaces and --workspace at the same time') const filterByWorkspaces = workspacesEnabled || workspacesFilters.length > 0 // normally this would go in the constructor, but our tests don't // actually use a real npm object so this.npm.config isn't always // populated. this is the compromise until we can make that a reality // and then move this into the constructor. command.workspaces = this.config.get('workspaces') command.workspacePaths = null // normally this would be evaluated in base-command#setWorkspaces, see // above for explanation command.includeWorkspaceRoot = this.config.get('include-workspace-root') if (this.config.get('usage')) { this.output(command.usage) return } if (filterByWorkspaces) { if (this.config.get('global')) throw new Error('Workspaces not supported for global packages') return command.execWorkspaces(args, this.config.get('workspace')).finally(() => { process.emit('timeEnd', `command:${cmd}`) }) } else { return command.exec(args).finally(() => { process.emit('timeEnd', `command:${cmd}`) }) } } async load () { if (!this.loadPromise) { process.emit('time', 'npm:load') this.log.pause() this.loadPromise = new Promise((resolve, reject) => { this[_load]().catch(er => er).then((er) => { this.loadErr = er if (!er && this.config.get('force')) this.log.warn('using --force', 'Recommended protections disabled.') process.emit('timeEnd', 'npm:load') if (er) return reject(er) resolve() }) }) } return this.loadPromise } get loaded () { return this.config.loaded } get title () { return this[_title] } set title (t) { process.title = t this[_title] = t } async [_load] () { process.emit('time', 'npm:load:whichnode') let node try { node = which.sync(process.argv[0]) } catch (_) { // TODO should we throw here? } process.emit('timeEnd', 'npm:load:whichnode') if (node && node.toUpperCase() !== process.execPath.toUpperCase()) { this.log.verbose('node symlink', node) process.execPath = node this.config.execPath = node } process.emit('time', 'npm:load:configload') await this.config.load() process.emit('timeEnd', 'npm:load:configload') this.argv = this.config.parsedArgv.remain // note: this MUST be shorter than the actual argv length, because it // uses the same memory, so node will truncate it if it's too long. // if it's a token revocation, then the argv contains a secret, so // don't show that. (Regrettable historical choice to put it there.) // Any other secrets are configs only, so showing only the positional // args keeps those from being leaked. process.emit('time', 'npm:load:setTitle') const tokrev = deref(this.argv[0]) === 'token' && this.argv[1] === 'revoke' this.title = tokrev ? 'npm token revoke' + (this.argv[2] ? ' ***' : '') : ['npm', ...this.argv].join(' ') process.emit('timeEnd', 'npm:load:setTitle') process.emit('time', 'npm:load:setupLog') setupLog(this.config) process.emit('timeEnd', 'npm:load:setupLog') process.env.COLOR = this.color ? '1' : '0' process.emit('time', 'npm:load:cleanupLog') cleanUpLogFiles(this.cache, this.config.get('logs-max'), this.log.warn) process.emit('timeEnd', 'npm:load:cleanupLog') this.log.resume() process.emit('time', 'npm:load:configScope') const configScope = this.config.get('scope') if (configScope && !/^@/.test(configScope)) this.config.set('scope', `@${configScope}`, this.config.find('scope')) process.emit('timeEnd', 'npm:load:configScope') process.emit('time', 'npm:load:projectScope') this.projectScope = this.config.get('scope') || getProjectScope(this.prefix) process.emit('timeEnd', 'npm:load:projectScope') } get flatOptions () { const { flat } = this.config if (this.command) flat.npmCommand = this.command return flat } get color () { // This is a special derived value that takes into consideration not only // the config, but whether or not we are operating in a tty. return this.flatOptions.color } get lockfileVersion () { return 2 } get log () { return log } get cache () { return this.config.get('cache') } set cache (r) { this.config.set('cache', r) } get globalPrefix () { return this.config.globalPrefix } set globalPrefix (r) { this.config.globalPrefix = r } get localPrefix () { return this.config.localPrefix } set localPrefix (r) { this.config.localPrefix = r } get globalDir () { return process.platform !== 'win32' ? resolve(this.globalPrefix, 'lib', 'node_modules') : resolve(this.globalPrefix, 'node_modules') } get localDir () { return resolve(this.localPrefix, 'node_modules') } get dir () { return (this.config.get('global')) ? this.globalDir : this.localDir } get globalBin () { const b = this.globalPrefix return process.platform !== 'win32' ? resolve(b, 'bin') : b } get localBin () { return resolve(this.dir, '.bin') } get bin () { return this.config.get('global') ? this.globalBin : this.localBin } get prefix () { return this.config.get('global') ? this.globalPrefix : this.localPrefix } set prefix (r) { const k = this.config.get('global') ? 'globalPrefix' : 'localPrefix' this[k] = r } get usage () { return usage(this) } // XXX add logging to see if we actually use this get tmp () { if (!this[_tmpFolder]) { const rand = require('crypto').randomBytes(4).toString('hex') this[_tmpFolder] = `npm-${process.pid}-${rand}` } return resolve(this.config.get('tmp'), this[_tmpFolder]) } // output to stdout in a progress bar compatible way output (...msg) { this.log.clearProgress() console.log(...msg) this.log.showProgress() } } module.exports = Npm