You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

277 lines
8.8 KiB

// Copyright Joyent, Inc. and other Node contributors.
//
// Permission is hereby granted, free of charge, to any person obtaining a
// copy of this software and associated documentation files (the
// "Software"), to deal in the Software without restriction, including
// without limitation the rights to use, copy, modify, merge, publish,
// distribute, sublicense, and/or sell copies of the Software, and to permit
// persons to whom the Software is furnished to do so, subject to the
// following conditions:
//
// The above copyright notice and this permission notice shall be included
// in all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
// USE OR OTHER DEALINGS IN THE SOFTWARE.
14 years ago
var common = require('../common');
var assert = require('assert');
15 years ago
common.globalCheck = false;
14 years ago
var net = require('net'),
repl = require('repl'),
message = 'Read, Eval, Print Loop',
prompt_unix = 'node via Unix socket> ',
prompt_tcp = 'node via TCP socket> ',
prompt_multiline = '... ',
server_tcp, server_unix, client_tcp, client_unix, timer;
15 years ago
// absolute path to test/fixtures/a.js
14 years ago
var moduleFilename = require('path').join(common.fixturesDir, 'a');
common.error('repl test');
// function for REPL to run
14 years ago
invoke_me = function(arg) {
return 'invoked ' + arg;
};
function send_expect(list) {
if (list.length > 0) {
var cur = list.shift();
14 years ago
common.error('sending ' + JSON.stringify(cur.send));
15 years ago
cur.client.expect = cur.expect;
cur.client.list = list;
if (cur.send.length > 0) {
cur.client.write(cur.send);
}
}
}
function clean_up() {
client_tcp.end();
client_unix.end();
clearTimeout(timer);
}
function error_test() {
14 years ago
// The other stuff is done so reuse unix socket
14 years ago
var read_buffer = '';
14 years ago
client_unix.removeAllListeners('data');
14 years ago
client_unix.addListener('data', function(data) {
14 years ago
read_buffer += data.toString('ascii', 0, data.length);
14 years ago
common.error('Unix data: ' + JSON.stringify(read_buffer) + ', expecting ' +
(client_unix.expect.exec ?
client_unix.expect :
JSON.stringify(client_unix.expect)));
14 years ago
if (read_buffer.indexOf(prompt_unix) !== -1) {
assert.ok(read_buffer.match(client_unix.expect));
14 years ago
common.error('match');
read_buffer = '';
14 years ago
if (client_unix.list && client_unix.list.length > 0) {
send_expect(client_unix.list);
} else {
14 years ago
common.error('End of Error test, running TCP test.');
14 years ago
tcp_test();
}
14 years ago
} else if (read_buffer === prompt_multiline) {
// Check that you meant to send a multiline test
assert.strictEqual(prompt_multiline, client_unix.expect);
14 years ago
read_buffer = '';
14 years ago
if (client_unix.list && client_unix.list.length > 0) {
send_expect(client_unix.list);
} else {
14 years ago
common.error('End of Error test, running TCP test.\n');
14 years ago
tcp_test();
}
14 years ago
} else {
14 years ago
common.error('didn\'t see prompt yet, buffering.');
14 years ago
}
});
send_expect([
// Uncaught error throws and prints out
14 years ago
{ client: client_unix, send: 'throw new Error(\'test error\');',
expect: /^Error: test error/ },
14 years ago
// Common syntax error is treated as multiline command
14 years ago
{ client: client_unix, send: 'function test_func() {',
expect: prompt_multiline },
14 years ago
// You can recover with the .break command
14 years ago
{ client: client_unix, send: '.break',
expect: prompt_unix },
14 years ago
// Can parse valid JSON
14 years ago
{ client: client_unix, send: 'JSON.parse(\'{"valid": "json"}\');',
expect: '{ valid: \'json\' }'},
// invalid input to JSON.parse error is special case of syntax error,
// should throw
{ client: client_unix, send: 'JSON.parse(\'{invalid: \\\'json\\\'}\');',
expect: /^SyntaxError: Unexpected token i/ },
// Named functions can be used:
{ client: client_unix, send: 'function blah() { return 1; }',
expect: prompt_unix },
{ client: client_unix, send: 'blah()',
expect: "1\n" + prompt_unix },
// Multiline object
{ client: client_unix, send: '{ a: ',
expect: prompt_multiline },
{ client: client_unix, send: '1 }',
expect: "{ a: 1 }" },
// Multiline anonymous function with comment
{ client: client_unix, send: '(function () {',
expect: prompt_multiline },
{ client: client_unix, send: '// blah',
expect: prompt_multiline },
{ client: client_unix, send: 'return 1;',
expect: prompt_multiline },
{ client: client_unix, send: '})()',
expect: "1" },
14 years ago
]);
}
function tcp_test() {
14 years ago
server_tcp = net.createServer(function(socket) {
assert.strictEqual(server_tcp, socket.server);
15 years ago
14 years ago
socket.addListener('end', function() {
socket.end();
});
repl.start(prompt_tcp, socket);
});
14 years ago
server_tcp.listen(common.PORT, function() {
var read_buffer = '';
15 years ago
client_tcp = net.createConnection(common.PORT);
14 years ago
client_tcp.addListener('connect', function() {
assert.equal(true, client_tcp.readable);
assert.equal(true, client_tcp.writable);
send_expect([
{ client: client_tcp, send: '',
expect: prompt_tcp },
{ client: client_tcp, send: 'invoke_me(333)\n',
expect: ('\'' + 'invoked 333' + '\'\n' + prompt_tcp) },
{ client: client_tcp, send: 'a += 1\n',
expect: ('12346' + '\n' + prompt_tcp) },
{ client: client_tcp,
send: 'require(' + JSON.stringify(moduleFilename) + ').number\n',
expect: ('42' + '\n' + prompt_tcp) }
]);
});
14 years ago
client_tcp.addListener('data', function(data) {
read_buffer += data.toString('ascii', 0, data.length);
14 years ago
common.error('TCP data: ' + JSON.stringify(read_buffer) +
', expecting ' + JSON.stringify(client_tcp.expect));
if (read_buffer.indexOf(prompt_tcp) !== -1) {
assert.strictEqual(client_tcp.expect, read_buffer);
14 years ago
common.error('match');
read_buffer = '';
if (client_tcp.list && client_tcp.list.length > 0) {
send_expect(client_tcp.list);
14 years ago
} else {
14 years ago
common.error('End of TCP test.\n');
clean_up();
}
14 years ago
} else {
14 years ago
common.error('didn\'t see prompt yet, buffering');
}
});
15 years ago
14 years ago
client_tcp.addListener('error', function(e) {
throw e;
});
15 years ago
14 years ago
client_tcp.addListener('close', function() {
server_tcp.close();
});
});
}
function unix_test() {
14 years ago
server_unix = net.createServer(function(socket) {
assert.strictEqual(server_unix, socket.server);
14 years ago
socket.addListener('end', function() {
socket.end();
});
repl.start(prompt_unix, socket).context.message = message;
});
14 years ago
server_unix.addListener('listening', function() {
var read_buffer = '';
15 years ago
client_unix = net.createConnection(common.PIPE);
14 years ago
client_unix.addListener('connect', function() {
assert.equal(true, client_unix.readable);
assert.equal(true, client_unix.writable);
send_expect([
{ client: client_unix, send: '',
expect: prompt_unix },
{ client: client_unix, send: 'message\n',
expect: ('\'' + message + '\'\n' + prompt_unix) },
{ client: client_unix, send: 'invoke_me(987)\n',
expect: ('\'' + 'invoked 987' + '\'\n' + prompt_unix) },
{ client: client_unix, send: 'a = 12345\n',
expect: ('12345' + '\n' + prompt_unix) },
{ client: client_unix, send: '{a:1}\n',
expect: ('{ a: 1 }' + '\n' + prompt_unix) },
]);
});
14 years ago
client_unix.addListener('data', function(data) {
read_buffer += data.toString('ascii', 0, data.length);
14 years ago
common.error('Unix data: ' + JSON.stringify(read_buffer) +
', expecting ' + JSON.stringify(client_unix.expect));
if (read_buffer.indexOf(prompt_unix) !== -1) {
assert.strictEqual(client_unix.expect, read_buffer);
14 years ago
common.error('match');
read_buffer = '';
if (client_unix.list && client_unix.list.length > 0) {
send_expect(client_unix.list);
15 years ago
} else {
14 years ago
common.error('End of Unix test, running Error test.\n');
process.nextTick(error_test);
}
14 years ago
} else {
14 years ago
common.error('didn\'t see prompt yet, buffering.');
}
});
15 years ago
14 years ago
client_unix.addListener('error', function(e) {
throw e;
});
14 years ago
client_unix.addListener('close', function() {
server_unix.close();
});
});
server_unix.listen(common.PIPE);
}
unix_test();
14 years ago
timer = setTimeout(function() {
assert.fail('Timeout');
}, 5000);