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
|
import { spawnSync, spawn } from "bun";
import { describe, expect, it } from "bun:test";
import { bunExe } from "bunExe";
describe("should work for static input", () => {
const inputs = [
"hello world",
"hello world\n",
"hello world\n\n",
"hello world\n\n\n",
"Hello\nWorld\n",
"1",
"💕 Red Heart ✨ Sparkles 🔥 Fire\n💕 Red Heart ✨ Sparkles\n💕 Red Heart\n💕\n\nnormal",
];
for (let input of inputs) {
it(input.replaceAll("\n", "\\n"), () => {
const { stdout } = spawnSync({
cmd: [bunExe(), import.meta.dir + "/" + "console-iterator-run.js"],
stdin: Buffer.from(input),
env: {
BUN_DEBUG_QUIET_LOGS: "1",
},
});
expect(stdout.toString()).toBe(input.replaceAll("\n", ""));
});
}
});
describe("should work for streaming input", () => {
const inputs = [
"hello world",
"hello world\n",
"hello world\n\n",
"hello world\n\n\n",
"Hello\nWorld\n",
"1",
"💕 Red Heart ✨ Sparkles 🔥 Fire\n 💕 Red Heart ✨ Sparkles\n 💕 Red Heart\n 💕 \n\nnormal",
];
for (let input of inputs) {
it(input.replaceAll("\n", "\\n"), async () => {
const proc = spawn({
cmd: [bunExe(), import.meta.dir + "/" + "console-iterator-run.js"],
stdin: "pipe",
stdout: "pipe",
env: {
BUN_DEBUG_QUIET_LOGS: "1",
},
});
const { stdout, stdin } = proc;
stdin.write(input.slice(0, (input.length / 2) | 0));
stdin.flush();
await new Promise(resolve => setTimeout(resolve, 1));
stdin.write(input.slice((input.length / 2) | 0));
stdin.flush();
stdin.end();
expect(await new Response(stdout).text()).toBe(input.replaceAll("\n", ""));
proc.kill(0);
});
}
});
|
