tar-stream regression in 13 with pipeline

[mafintosh]

• Version: 13.13.0
• Platform: Mac
• Subsystem: stream

What steps will reproduce the bug?

stream.pipeline no longer compatible with tar-stream (around 500k GitHub dependents) for tar files with more than one file.

Attached is a test case.

echo hello > hello.txt
echo world > world.txt
tar c hello.txt world.txt > test.tar

const tar = require('tar-stream')
const fs = require('fs')
const path = require('path')
const pipeline = require('stream').pipeline

fs.createReadStream('test.tar')
 .pipe(tar.extract())
 .on('entry', function (header, stream, done) {
 console.log(header.name) // in 13 this will only unpack one file due to
 // pipeline calling destroy on the substream
 // causing the entire extract stream to be destroyed
 // and silently fail.
 pipeline(stream, fs.createWriteStream(path.join('/tmp', header.name)), done)
 })

This seems to be related to changes that force autoDestroy behaviour on existing streams when using pipeline, added in #31940

Seems to be the same regression fixed for HTTP in #32197

[mcollina]

cc @ronag

[ronag]

I'm unsure how to fix this. tar-stream is conceptually a Duplex but is implemented as a Writable. As far as I can see Node does the correct thing and I can't think of a generic way to detect this scenario.

We are kind of stuck choosing between:

• Destroying legacy "streams" that don't want to be destroyed (e.g. tar-stream).
• Not destroying legacy streams that want to be destroyed but doesn't automatically handle it (this is what the docs say).

The only thing I can think of right now is to fix tar-stream by making it a Duplex. Alternatively add support for some kind of willEmitClose option/property that implementors can use to override the destroy on 'finish'/'end' behaviour.

[ronag]

Maybe if we destroy on nextTick might help. Testing.

[mafintosh]

@ronag not sure i follow what you mean by making it a duplex?

It's a writable stream that forwards parts of that stream as a series of streaming files as it parses them. the forced auto destroy in pipeline makes the sub-stream forward the stream destruction to the main input stream.

[mafintosh]

The tricky thing for tar-stream with this forced behaivor is that the substream (the one emitted in entry) doesn't know when it's done being piped, so when pipeline forces the destroy on it, it doesn't know if that destroy is because:

a) a user wants to destroy the main stream
b) a stream in the pipeline it's being used in crashed and pipeline is taking down all streams, even if they ended
c) is its a forced auto destroy by pipeline

[ronag]

@ronag not sure i follow what you mean by making it a duplex?

Instead of emitting 'entry', you could implement it as a Duplex with readableObjectMode: true emitting 'data' which are "entries" and in turn emits 'entry' as compat.

[ronag]

@mafintosh: I do see the problem but unless it's implemented as a Duplex I'm not sure how we could fix this while still maintaining the contract documented in the pipeline docs:

stream.pipeline() will call stream.destroy(err) on all streams except:

Readable streams which have emitted 'end' or 'close'.
Writable streams which have emitted 'finish' or 'close'.

[mafintosh]

I don't see how changing it will help. Any module that forwards a substream will have this problem, like HTTP did. Even if we did change it, this has +5mio weekly downloads, so massive breakage.

I'm open for ideas, but I think we're borked

[ronag]

I don't see how changing it will help.

Would you mind if I try to make a PR against tar-stream?

Any module that forwards a substream will have this problem, like HTTP did. Even if we did change it, this has +5mio weekly downloads, so massive breakage.

I'm not sure what to do here. If we break the pipeline destroy behavior other stuff might break.

@mcollina @lpinca I think we might need some more opinions.

[mcollina]

I think the best option is to restore the old behavior.

[mafintosh]

@ronag go for it

I don't think this case is possible to fix though

extract.on('error', function (err) {
 // err === that error from below
})
extract.on('entry', function (header, stream) {
 pipeline(stream, new Writable({
 write (data, enc, cb) {
 cb(null)
 },
 final (cb) {
 this.destroy(new Error('I am crashing now'))
 }
 )
})

[ronag]

I think the best option is to restore the old behavior.

I'm ok with that.

[mafintosh]

I'm +1 on restoring old behaviour also. I think autoDestroy is a better mechanic for this for modules. Also means we can drop the HTTP special casing.