stream: normalized destroy() #30906

module.exports = function destroy (stream, err, cb) {
  // TODO: cb should not be optional, throw if missing?
  let sync = true;
  const callback = once(er => {
    if (sync) {
      process.nextTick(cb, er);
    } else {
      cb(er);
    }
  });
 
  const s = stream._writableState || stream._readableState;

  if (stream.destroyed || (s && s.destroyed)) {
    // TODO: Move this logic into eos?
    // TODO: Move this logic into destroy(err, callback)?
    if (s) {
      if (s.errorEmitted) {
        // TODO: cb with error? Save error in errored?
        // callback(s.errored);
        return callback();
      } else if (s.closeEmitted) {
        // TODO: s.closeEmitted doesn't exists yet.
        // TODO: it's still possible for stream to emit 'error' after 'close'.
        return callback();
      } else if (typeof s.closeEmitted !== 'boolean' && (s.endEmitted || s.finished)) {
        // TODO: This is not entirely correct for Duplex w/ halfOpen
        setImmediate(callback);
        stream.on('error', callback);
      } else {
        eos(stream, callback);
      }
      if (err && typeof stream.destroy === 'function') {
        // Forward error
        stream.destroy(err);
      }
    } else {
      // TODO: How to handle?
      callback(new Error('invalid stream'));
    }
  } else if (typeof stream.destroy === 'function' && stream.destroy.length === 2) {
    stream.destroy(err, callback);
    // We handle error through callback
    stream.on('error', noop);
  } else {
    eos(stream, callback);
    if (typeof stream.abort === 'function') {
      stream.abort();
    } else if (stream.req && typeof stream.req.abort === 'function') {
      // HTTP response.destroy() is slightly broken. Try to avoid.
      stream.req.abort();
    } else if (typeof stream.destroy === 'function') {
      stream.destroy(err);
    } else if (typeof stream.end === 'function') {
      stream.end();
    } else {
      callback(new Error('invalid stream'));
    }
  }
  sync = false;
}

const { destroy } = require('stream');

const someStream = ...
... do stuff
destroy(someStream);