test.js

var path = require('path')
var fs = require('fs')
var assert = require('assert')
var getRawBody = require('raw-body')
var ss = require('stream-stream');
var devnull = require('dev-null');

var Child_Process = require('./')

var image = path.join(__dirname, 'ts.jpg')

describe('Duplex Child Process', function () {
  it('should emit a close event', function (done) {
    var proc = Child_Process.spawn('identify', ['-format', '%m', image])
    proc.on('close', done)
    proc.on('error', done)
  })

  it('should emit a data event', function (done) {
    var proc = Child_Process.spawn('identify', ['-format', '%m', image])
    proc.once('data', function (chunk) {
      done()
    })
    proc.on('error', done)
  })

  it('should emit an end event', function (done) {
    var proc = Child_Process.spawn('identify', ['-format', '%m', image])
    proc.pipe(devnull())
    proc.on('end', done)
    proc.on('error', done)
  })

  it('should emit end event before close event', function(done) {
    var proc = Child_Process.spawn('identify', ['-format', '%m', image])

    var events = ['end', 'error', 'close']
    var triggered = [];
    events.forEach(function(ev) {
      proc.on(ev, function() {
        triggered.push(ev);
      });
    })
    proc.on('close', function() {
      assert.deepEqual(triggered, [ 'end', 'close' ])
      done()
    });
    proc.pipe(devnull())

  });


  it('should return the correct stdout', function (done) {
    var proc = Child_Process.spawn('identify', ['-format', '%m', image])

    getRawBody(proc, function (err, buf) {
      assert.ifError(err)
      assert.equal('JPEG', buf.toString('utf8').trim())
      done()
    })
  })

  it('should work with pipes', function (done) {
    var proc1 = Child_Process.spawn('convert', ['-', 'PNG:-'])
    var proc2 = Child_Process.spawn('identify', ['-format', '%m', '-'])

    fs.createReadStream(image)
    .on('error', done)
    .pipe(proc1)
    .on('error', done)
    .pipe(proc2)

    getRawBody(proc2, function (err, buf) {
      assert.ifError(err)
      assert.equal('PNG', buf.toString('utf8').trim())
      done()
    })
  })

  it('should cleanup after itself', function (done) {
    var proc = Child_Process.spawn('convert', ['-version'])
    .on('close', function () {
      setImmediate(function () {
        assert.ok(!proc._process)
        assert.ok(!proc._stdin)
        assert.ok(!proc._stdout)
        assert.ok(!proc._stderr)

        done()
      })
    })
  })

  it('should not emit an error on destroy', function (done) {
    var proc = Child_Process.spawn('convert', ['-version'])
    .on('close', done)
    .on('error', done)
    .destroy(done)
  })

  it('should pipe a source stream before spawning', function (done) {
    fs.createReadStream(image)
    .on('error', done)
    .pipe(new Child_Process())
    .spawn('convert', ['-', 'PNG:-'])
    .on('error', done)
    .pipe(new Child_Process())
    .spawn('identify', ['-format', '%m', '-'])
    .on('error', done)
    .once('readable', function () {
      assert.equal('PNG', this.read().toString('utf8').trim())

      done()
    })
  })

  it('should work with stream-stream', function(done) {
    var stream = ss();
    var sink = devnull();
    sink.on('finish', done);

    var process1 = Child_Process.spawn('sleep', ['0.1']);
    var process2 = Child_Process.spawn('sleep', ['0.5']);

    // we send the processes in reverse order because to highlight
    // the fact that the 'end' event from process1 should not
    // fire too early
    stream.write(process2);
    stream.write(process1);

    stream.end();
    stream.pipe(sink);
  }); 

  it('should not emit an end event when SIGKILL', function(done) {
    var sink = devnull();
    var proc = Child_Process.spawn('sleep', ['1']);
    var events = ['end', 'error', 'close']
    var triggered = [];
    events.forEach(function(ev) {
      proc.on(ev, function() {
        triggered.push(ev);
      });
    })
    proc.on('close', function() {
      assert.deepEqual(triggered, [ 'error', 'close' ])
      done();
    });
    proc.pipe(sink);
    setTimeout(function() {
      proc._process.kill('SIGKILL');
    }, 200);
  });

})