create.js

var expect = require('expect.js');

var port = require('../');


describe('Port create', function(){


	it('should create a Pd process with -nogui flag and receive data from [print]', function(done){

		var pd = port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'open': __dirname + '/test-loadbang.pd'
			}
		});

		expect(pd).to.be.a(port);

		pd.on('stderr', function(buffer){
			expect(buffer).to.be.an('object');
			expect(buffer.toString()).to.be.ok();
			expect(buffer.toString().trim()).to.be('print: bang');
			pd.destroy();
			done();
		});

		pd.create();

	});


	it('should repeat the same test but with -path flag', function(done){

		var pd = port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'path': __dirname,
				'open': 'test-loadbang.pd'
			}
		});

		pd.on('stderr', function(buffer){
			expect(buffer).to.be.an('object');
			expect(buffer.toString()).to.be.ok();
			expect(buffer.toString().trim()).to.be('print: bang');
			pd.destroy();
			done();
		});

		pd.create();

	});

	it('should use basepath for prefixing -path flags', function(done){

		var pd = port({
			'basepath': __dirname,
			'flags': {
				'noprefs': true,
				'nogui': true,
				'stderr': true,
				'path': 'test-path',
				'open': 'test-loadbang2.pd'
			}
		});

		pd.on('stderr', function(buffer){
			expect(buffer).to.be.an('object');
			expect(buffer.toString()).to.be.ok();
			expect(buffer.toString().trim()).to.be('print: bang');
			pd.destroy();
			done();
		});

		pd.create();

	});

	it('should use basepath without -path flags', function(done){

		var pd = port({
			'basepath': __dirname + '/test-path',
			'flags': {
				'noprefs': true,
				'nogui': true,
				'stderr': true,
				'open': 'test-loadbang2.pd'
			}
		});

		pd.on('stderr', function(buffer){
			expect(buffer).to.be.an('object');
			expect(buffer.toString()).to.be.ok();
			expect(buffer.toString().trim()).to.be('print: bang');
			pd.destroy();
			done();
		});

		pd.create();

	});


	it('should create and destroy 20 times in a row', function(done){

		var i = 1;

		var pd = port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'stderr': true,
				'open': __dirname + '/test-loadbang.pd'
			}
		});

		pd.on('stderr', function(buffer){
			expect(buffer.toString().trim()).to.be('print: bang');
			pd.destroy();
		});

		pd.on('destroy', function(){
			if (i++ < 20) pd.create();
			else done();
		});

		pd.create();

	});


	it('should create a Pd process with -stderr flag and receive data from [print]', function(done){

		var pd = port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'stderr': true,
				'open': __dirname + '/test-loadbang.pd'
			}
		});

		pd.on('stderr', function(buffer){
			expect(buffer).to.be.an('object');
			expect(buffer.toString()).to.be.ok();
			expect(buffer.toString().trim()).to.be('print: bang');
			expect(this).to.be(pd);
			expect(this).to.be.a(port);
			this.destroy();
		});

		pd.on('destroy', function(){
			expect(this).to.be(pd);
			expect(this).to.be.a(port);
			done();
		});

		pd.create();

	});


	it('should send a message to Pd using the -send flag', function(done){

		var received = '';

		port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'send': 'node hi Pd!',
				'open': __dirname + '/test-receive.pd'
			}
		})
		.on('stderr', function(buffer){
			received += buffer.toString();
			if (!!received.match(/\n$/)){
				expect(received).to.be('print: hi Pd!\n');
				expect(received.toString().slice(0, -1)).to.be('print: hi Pd!');
				this.destroy();
				done();
			}
		})
		.create();

	});


	it('should send a long message to Pd using the -send flag', function(done){

		var received = '',
			data = [
				0, 1, 2, 3, 4, 5, 6, 7, 8, 9,
				10, 11, 12, 13, 14, 15, 16, 17, 18, 19,
				20, 21, 22, 23, 24, 25, 26, 27, 28, 29,
				30, 31, 32, 33, 34, 35, 36, 37, 38, 39,
				40, 41, 42, 43, 44, 45, 46, 47, 48, 49,
				50, 51, 52, 53, 54, 55, 56, 57, 58, 59,
				60, 61, 62, 63, 64, 65, 66, 67, 68, 69,
				70, 71, 72, 73, 74, 75, 76, 77, 78, 79,
				80, 81, 82, 83, 84, 85, 86, 87, 88, 89,
				90, 91, 92, 93, 94, 95, 96, 97, 98, 99
			].join(' ');


		port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'stderr': true,
				'send': 'node ' + data,
				'open': __dirname + '/test-receive.pd'
			}
		})
		.on('stderr', function(buffer){
			received += buffer.toString();
			if (!!received.match(/\n$/)){
				expect(received).to.be('print: ' + data + '\n');
				this.destroy();
				done();
			}
		})
		.create();

	});


	it('should send many messages to Pd using the -send flag', function(done){

		var in1 = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9],
			in2 = [10, 11, 12, 13, 14, 15, 16, 17, 18, 19],
			result = {
				'out1': [],
				'out2': []
			};

		port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'stderr': true,
				'send': 'in1 ' + in1.toString() + ';in2 ' + in2.toString(),
				'open': __dirname + '/test-receivers.pd'
			}
		})
		.on('stderr', function(buffer){
			var packet = buffer.toString().split('\n');
			packet.forEach(function(message){

				// parses each message into `<key>: <value>`
				var p = message.match(/^(.+):\s(\d+)$/);

				// parses integer and stores in results
				if (!!p) result[p[1]].push(parseInt(p[2]));
			});

			if (in1.length == result.out1.length
				&& in2.length == result.out2.length
			){
				expect(result.out1).to.eql(in1);
				expect(result.out2).to.eql(in2);
				this.destroy();
				done();
			}
		})
		.create();

	});


	it('should allow setting different options on the same instance', function(done){

		var pd = port({
			'flags': {
				'noprefs': true,
				'nogui': true,
				'stderr': true,
				'path': __dirname + '/test-path',
				'open': 'test-loadbang2.pd'
			}
		});

		// first test
		pd.on('stderr', function(buffer){

			expect(buffer.toString().trim()).to.be('print: bang');
			pd.removeAllListeners('stderr');
			pd.destroy();

		});

		// second test
		pd.once('destroy', function(){
			var received = '';

			pd.on('stderr', function(buffer){
				received += buffer.toString();
				if (!!received.match(/\n$/)){
					expect(received).to.be('print: hi Pd!\n');
					expect(received.toString().slice(0, -1)).to.be('print: hi Pd!');
					pd.destroy();
					done();
				}
			});

			pd.setOptions({
				'basepath': __dirname,
				'flags': {
					'noprefs': true,
					'nogui': true,
					'send': 'node hi Pd!',
					'open': 'test-receive.pd'
				}
			});

			pd.create();

		});

		pd.create();

	});

});