-
-
Notifications
You must be signed in to change notification settings - Fork 127
/
repl.ts
82 lines (65 loc) · 1.83 KB
/
repl.ts
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
import { testSuite } from 'manten';
import { tsx } from '../utils/tsx';
export default testSuite(async ({ describe }) => {
describe('repl', ({ test }) => {
test('handles ts', async () => {
const tsxProcess = tsx({
args: [],
});
const commands = [
'const message: string = "SUCCESS"',
'message',
];
await new Promise<void>((resolve) => {
tsxProcess.stdout!.on('data', (data: Buffer) => {
const chunkString = data.toString();
if (chunkString.includes('SUCCESS')) {
return resolve();
}
if (chunkString.includes('> ') && commands.length > 0) {
const command = commands.shift();
tsxProcess.stdin?.write(`${command}\n`);
}
});
});
tsxProcess.kill();
}, 5000);
test('doesn\'t error on require', async () => {
const tsxProcess = tsx({
args: [],
});
await new Promise<void>((resolve, reject) => {
tsxProcess.stdout!.on('data', (data: Buffer) => {
const chunkString = data.toString();
if (chunkString.includes('unsupported-require-call')) {
return reject(chunkString);
}
if (chunkString.includes('[Function: resolve]')) {
return resolve();
}
if (chunkString.includes('> ')) {
tsxProcess.stdin?.write('require("path")\n');
}
});
});
tsxProcess.kill();
}, 5000);
test('errors on import statement', async () => {
const tsxProcess = tsx({
args: [],
});
await new Promise<void>((resolve) => {
tsxProcess.stdout!.on('data', (data: Buffer) => {
const chunkString = data.toString();
if (chunkString.includes('SyntaxError: Cannot use import statement inside the Node.js REPL')) {
return resolve();
}
if (chunkString.includes('> ')) {
tsxProcess.stdin?.write('import fs from "fs"\n');
}
});
});
tsxProcess.kill();
}, 5000);
});
});