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
|
/* This smoke test runs against the Crc32 example program for now, but this example will be extended for more tests */
var crc32 = (function () {
var table = new Uint32Array(256);
for (var i = 256; i--;) {
var tmp = i;
for (var k = 8; k--;) {
tmp = tmp & 1 ? 3988292384 ^ tmp >>> 1 : tmp >>> 1;
}
table[i] = tmp;
}
return function (data) {
var crc = -1; // Begin with all bits set ( 0xffffffff )
for (var i = 0, l = data.length; i < l; i++) {
crc = crc >>> 8 ^ table[crc & 255 ^ data[i]];
}
return (crc ^ -1) >>> 0; // Apply binary NOT
};
})();
async function chunkedCrc32Test(array) {
console.log("Making chunked request with body size: " + array.length);
const stream = new ReadableStream(/*{type: "bytes"}, */{
async start(controller) {
await 1;
controller.enqueue(array);
controller.close();
},
});
const r = await fetch("http://localhost:3000", {
method: 'POST',
headers: { 'Content-Type': 'application/octet-stream' },
body: stream,
duplex: 'half',
});
/* Download the response body (it's a crc32 hash plus newline) */
const body = await r.body.getReader().read();
/* Make a crc32 comparison of the two (mind the newline in one!) */
const got = new TextDecoder().decode(body.value);
const want = crc32(array).toString(16);
if (got.toString().slice(0, -1) !== want.toString()) {
throw new Error("failed chunked test");
}
}
async function fixedCrc32Test(array) {
console.log("Making request with body size: " + array.length);
/* Send it with content-length */
const res = await fetch("http://localhost:3000", { keepalive: true, headers: { 'Content-Type': 'text/plain' }, method: "POST", body: array });
/* Download the response body (it's a crc32 hash plus newline) */
const body = await res.body.getReader().read();
/* Make a crc32 comparison of the two (mind the newline in one!) */
const got = new TextDecoder().decode(body.value);
const want = crc32(array).toString(16);
if (got.toString().slice(0, -1) !== want.toString()) {
throw new Error("failed test");
}
}
/* Maximum chunk size is less than 256mb */
const sizes = [0, 0, 32, 32, 128, 256, 1024, 65536, 1024 * 1024, 1024 * 1024 * 128, 0, 0, 32, 32];
for (let i = 0; i < sizes.length; i++) {
/* Create buffer with random data */
const array = new Uint8Array(sizes[i]);
//if (sizes[i] <= 65536) {
//self.crypto.getRandomValues(array);
//} else {
array.fill(Math.random() * 255);
//}
/* Do this for all methods */
await fixedCrc32Test(array);
await chunkedCrc32Test(array);
}
console.log("Done!");
|
