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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
import { ArrayBufferSink } from "bun";
import { describe, expect, it } from "bun:test";
import { mkfifo } from "mkfifo";
describe("FileSink", () => {
const fixtures = [
[
["abcdefghijklmnopqrstuvwxyz"],
new TextEncoder().encode("abcdefghijklmnopqrstuvwxyz"),
"abcdefghijklmnopqrstuvwxyz",
],
[
["abcdefghijklmnopqrstuvwxyz", "ABCDEFGHIJKLMNOPQRSTUVWXYZ"],
new TextEncoder().encode("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"),
"abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ",
],
[
["😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌"],
new TextEncoder().encode("😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌"),
"😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌",
],
[
["abcdefghijklmnopqrstuvwxyz", "😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌"],
new TextEncoder().encode("abcdefghijklmnopqrstuvwxyz" + "😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌"),
"abcdefghijklmnopqrstuvwxyz" + "😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌",
],
[
["abcdefghijklmnopqrstuvwxyz", "😋", " Get Emoji — All Emojis", " to ✂️ Copy and 📋 Paste 👌"],
new TextEncoder().encode("abcdefghijklmnopqrstuvwxyz" + "😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌"),
"(rope) " + "abcdefghijklmnopqrstuvwxyz" + "😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌",
],
[
[
new TextEncoder().encode("abcdefghijklmnopqrstuvwxyz"),
"😋",
" Get Emoji — All Emojis",
" to ✂️ Copy and 📋 Paste 👌",
],
new TextEncoder().encode("abcdefghijklmnopqrstuvwxyz" + "😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌"),
"(array) " + "abcdefghijklmnopqrstuvwxyz" + "😋 Get Emoji — All Emojis to ✂️ Copy and 📋 Paste 👌",
],
] as const;
function getPath(label) {
const path = `/tmp/bun-test-${Bun.hash(label).toString(10)}.txt`;
try {
require("fs").unlinkSync(path);
} catch (e) {}
return path;
}
var activeFIFO: Promise<string>;
var decoder = new TextDecoder();
function getFd(label) {
const path = `/tmp/bun-test-${Bun.hash(label).toString(10)}.txt`;
try {
require("fs").unlinkSync(path);
} catch (e) {}
mkfifo(path, 0o666);
activeFIFO = (async function (stream: ReadableStream<Uint8Array>) {
var chunks: Uint8Array[] = [];
for await (const chunk of stream) {
chunks.push(chunk);
}
return Buffer.concat(chunks).toString();
// test it on a small chunk size
})(Bun.file(path).stream(64));
return path;
}
for (let isPipe of [true, false] as const) {
describe(isPipe ? "pipe" : "file", () => {
for (const [input, expected, label] of fixtures) {
var getPathOrFd = () => (isPipe ? getFd(label) : getPath(label));
it(`${JSON.stringify(label)}`, async () => {
const path = getPathOrFd();
const sink = Bun.file(path).writer();
for (let i = 0; i < input.length; i++) {
sink.write(input[i]);
}
await sink.end();
if (!isPipe) {
const output = new Uint8Array(await Bun.file(path).arrayBuffer());
for (let i = 0; i < expected.length; i++) {
expect(output[i]).toBe(expected[i]);
}
expect(output.byteLength).toBe(expected.byteLength);
} else {
console.log("reading");
const output = await activeFIFO;
expect(output).toBe(decoder.decode(expected));
}
});
it(`flushing -> ${JSON.stringify(label)}`, async () => {
const path = getPathOrFd();
const sink = Bun.file(path).writer();
for (let i = 0; i < input.length; i++) {
sink.write(input[i]);
await sink.flush();
}
await sink.end();
if (!isPipe) {
const output = new Uint8Array(await Bun.file(path).arrayBuffer());
for (let i = 0; i < expected.length; i++) {
expect(output[i]).toBe(expected[i]);
}
expect(output.byteLength).toBe(expected.byteLength);
} else {
const output = await activeFIFO;
expect(output).toBe(decoder.decode(expected));
}
});
it(`highWaterMark -> ${JSON.stringify(label)}`, async () => {
const path = getPathOrFd();
const sink = Bun.file(path).writer({ highWaterMark: 1 });
for (let i = 0; i < input.length; i++) {
sink.write(input[i]);
await sink.flush();
}
await sink.end();
if (!isPipe) {
const output = new Uint8Array(await Bun.file(path).arrayBuffer());
for (let i = 0; i < expected.length; i++) {
expect(output[i]).toBe(expected[i]);
}
expect(output.byteLength).toBe(expected.byteLength);
} else {
const output = await activeFIFO;
expect(output).toBe(decoder.decode(expected));
}
});
}
});
}
});
|
