fix: ensuring close event is emited after stream has ended

For node 18 combaitibility fixes #321

Author: webark

lib/parse.js

@@ -28,6 +28,7 @@ const maxMetaEntrySize = 1024 * 1024
 const Entry = require('./read-entry.js')
 const Pax = require('./pax.js')
 const zlib = require('minizlib')
+const { nextTick } = require('process')
 
 const gzipHeader = Buffer.from([0x1f, 0x8b])
 const STATE = Symbol('state')
@@ -59,6 +60,7 @@ const DONE = Symbol('onDone')
 const SAW_VALID_ENTRY = Symbol('sawValidEntry')
 const SAW_NULL_BLOCK = Symbol('sawNullBlock')
 const SAW_EOF = Symbol('sawEOF')
+const CLOSESTREAM = Symbol('closeStream')
 
 const noop = _ => true
 
@@ -89,7 +91,6 @@ module.exports = warner(class Parser extends EE {
  this.emit('prefinish')
  this.emit('finish')
  this.emit('end')
- this.emit('close')
  })
  }
 
@@ -114,6 +115,9 @@ module.exports = warner(class Parser extends EE {
  this[ABORTED] = false
  this[SAW_NULL_BLOCK] = false
  this[SAW_EOF] = false
+
+ this.on('end', () => this[CLOSESTREAM]())
+
  if (typeof opt.onwarn === 'function') {
  this.on('warn', opt.onwarn)
  }
@@ -217,6 +221,10 @@ module.exports = warner(class Parser extends EE {
  }
  }
 
+ [CLOSESTREAM] () {
+ nextTick(() => this.emit('close'))
+ }
+
  [PROCESSENTRY] (entry) {
  let go = true
 

lib/unpack.js

@@ -234,7 +234,6 @@ class Unpack extends Parser {
  this.emit('prefinish')
  this.emit('finish')
  this.emit('end')
- this.emit('close')
  }
  }
 

package.json

@@ -33,9 +33,7 @@
  "events-to-array": "^1.1.2",
  "mutate-fs": "^2.1.1",
  "rimraf": "^3.0.2",
- "tap": "^16.0.1",
- "tar-fs": "^2.1.1",
- "tar-stream": "^2.2.0"
+ "tap": "^16.0.1"
  },
  "license": "ISC",
  "engines": {

test/extract.js

@@ -10,6 +10,8 @@ const mkdirp = require('mkdirp')
 const { promisify } = require('util')
 const rimraf = promisify(require('rimraf'))
 const mutateFS = require('mutate-fs')
+const pipeline = promisify(require('stream').pipeline)
+const https = require('https')
 
 t.teardown(_ => rimraf(extractdir))
 
@@ -54,6 +56,32 @@ t.test('basic extracting', t => {
  t.end()
 })
 
+t.test('ensure an open stream is not prematuraly closed', t => {
+ const dir = path.resolve(extractdir, 'basic-with-stream')
+
+ t.beforeEach(async () => {
+ await rimraf(dir)
+ await mkdirp(dir)
+ })
+
+ const check = async t => {
+ fs.lstatSync(dir + '/node-tar-main/LICENSE')
+ await rimraf(dir)
+ t.end()
+ }
+
+ t.test('async promisey', t => {
+ https.get('https://codeload.github.com/npm/node-tar/tar.gz/main', (stream) => {
+ return pipeline(
+ stream,
+ x({ cwd: dir }, ['node-tar-main/LICENSE'])
+ ).then(_ => check(t))
+ })
+ })
+
+ t.end()
+})
+
 t.test('file list and filter', t => {
  const file = path.resolve(tars, 'utf8.tar')
  const dir = path.resolve(extractdir, 'filter')