![]() Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /proc/self/root/usr/lib/node_modules/npm/node_modules/pacote/ |
'use strict' const BB = require('bluebird') const fs = require('fs') const getStream = require('get-stream') const mkdirp = BB.promisify(require('mkdirp')) const npa = require('npm-package-arg') const optCheck = require('./lib/util/opt-check.js') const PassThrough = require('stream').PassThrough const path = require('path') const rimraf = BB.promisify(require('rimraf')) const withTarballStream = require('./lib/with-tarball-stream.js') module.exports = tarball function tarball (spec, opts) { opts = optCheck(opts) spec = npa(spec, opts.where) return withTarballStream(spec, opts, stream => getStream.buffer(stream)) } module.exports.stream = tarballStream function tarballStream (spec, opts) { opts = optCheck(opts) spec = npa(spec, opts.where) const output = new PassThrough() let hasTouchedOutput = false let lastError = null withTarballStream(spec, opts, stream => { if (hasTouchedOutput && lastError) { throw lastError } else if (hasTouchedOutput) { throw new Error('abort, abort!') } else { return new BB((resolve, reject) => { stream.on('error', reject) output.on('error', reject) output.on('error', () => { hasTouchedOutput = true }) output.on('finish', resolve) stream.pipe(output) stream.once('data', () => { hasTouchedOutput = true }) }).catch(err => { lastError = err throw err }) } }) .catch(err => output.emit('error', err)) return output } module.exports.toFile = tarballToFile function tarballToFile (spec, dest, opts) { opts = optCheck(opts) spec = npa(spec, opts.where) return mkdirp(path.dirname(dest)) .then(() => withTarballStream(spec, opts, stream => { return rimraf(dest) .then(() => new BB((resolve, reject) => { const writer = fs.createWriteStream(dest) stream.on('error', reject) writer.on('error', reject) writer.on('close', resolve) stream.pipe(writer) })) })) }