"Этот разъем закрыт", когда stdout прослушивается в тесте Mocha

Этот тест

it.only('should not throw', () => {
    var output = '';

    function callback(data) {
        output += data.toString();
    }

    process.stdout.on('data', callback); // error is thrown at this line
    // ...
    process.stdout.removeListener('data', callback);
})

выдает ошибку:

Error: This socket is closed                                                                           
    at WriteStream.Socket._writeGeneric (net.js:679:19)                                                
    at WriteStream.Socket._write (net.js:730:8)                                                        
    at doWrite (_stream_writable.js:331:12)                                                            
    at writeOrBuffer (_stream_writable.js:317:5)                                                       
    at WriteStream.Writable.write (_stream_writable.js:243:11)                                         
    at WriteStream.Socket.write (net.js:657:40)                                                        
    at Console.log (console.js:43:16)                                                                  
    at Runner.<anonymous> (node_modules\mocha\lib\reporters\spec.js:80:13)
    at emitTwo (events.js:111:20)                                                                      
    at Runner.emit (events.js:191:7)                                                                   
    at Runner.fail (node_modules\mocha\lib\runner.js:251:8)               
    at Runner.uncaught (node_modules\mocha\lib\runner.js:757:8)           
    at process.uncaught (node_modules\mocha\lib\runner.js:839:10)         
    at emitOne (events.js:96:13)                                                                       
    at process.emit (events.js:188:7)                                                                  
    at process._fatalException (bootstrap_node.js:297:26)

Где node_modules\mocha\lib\reporters\spec.js:80:13 - это линии Mocha:

  runner.on('fail', function(test) {
    console.log(indent() + color('fail', '  %d) %s'), ++n, test.title);
  });

Он должен проверить код, который выводит на process.stdout с помощью spawn, но я не смог добраться до этой части; ошибка мгновенно process.stdout.on('data',...) вызове process.stdout.on('data',...).

Проблема сохраняется с последней версией Mocha (5.2.0) и по умолчанию, используемый репортер не влияет на результат.

Что происходит и как process.stdout может быть прослушан? Если это невозможно, то каким образом stdout из порожденного процесса будет протестирован в Mocha в противном случае?

Ответы

Ответ 1

Я не смог воспроизвести ошибку: process.stdout.on('data', callback);//error is thrown at this line process.stdout.on('data', callback);//error is thrown at this line. Настолько трудно сказать, почему это ломается для вас. В любом случае process.stdout является записываемым потоком, поэтому событие data не поддерживается. С другой стороны childProcess.stdout является читаемым потоком с родительской точки зрения.

Самый простой способ перехвата stdout дочернего процесса:

const ch = spawn(...)
ch.stdout.on('data', d => ...) // 'd' is a buffer

Если вы хотите протестировать против stdout произвольного процесса всплытия, я боюсь, что вам нужно передать пользовательский записываемый поток в качестве подпроцесса stdout, когда нерест процесса. Поток должен быть основан на дескрипторе файла, поэтому простой Duplex не будет работать, к сожалению.

Вот возможная настройка:

process.js

const { spawn } = require('child_process')

module.exports = (outStream) => {
  console.log('PARENT')
  const s = spawn('node', ['${__dirname}/child.js'], { stdio: ['ignore', outStream] })

  return () => {
    console.log('PARENT-DISPOSE')
    s.kill()
  }
}

child.js

process.stdout.write('FROM CHILD')
setTimeout(() => process.stdout.write('FROM CHILD END'), 100)

process.spec.js

const { spawn } = require('child_process')
const fs = require('fs')

const process = require('./process.js')

// path to temporary file
const commF = '${__dirname}/comm'

it('test spawn', (done) => {
  const w = fs.createWriteStream(commF)
  let dispose

  w.on('open', () => {
    dispose = process(w)
  })

  // unfortunately I was not able to make fs.createReadStram to read data in real-time
  // so here we use another subprocess just for that
  let readProcess = spawn('tail', ['-f', commF])

  readProcess.stdout.on('data', x => {
    const d = x && x.toString()
    console.log('TEST', d) // only logs from child are present here
    if (d.startsWith('FROM CHILD END')) {
      w.close()
      fs.unlinkSync(commF)
      dispose()
      readProcess.kill()
      done()
    }
  })
}).timeout(500)

Не сказать, что это лучший способ сделать это: его можно отвлечь для повторного использования, а tail зависимость может быть удалена.