aboutsummaryrefslogtreecommitdiff
path: root/test/bun.js/fetch-gzip.test.ts
diff options
context:
space:
mode:
Diffstat (limited to 'test/bun.js/fetch-gzip.test.ts')
-rw-r--r--test/bun.js/fetch-gzip.test.ts92
1 files changed, 26 insertions, 66 deletions
diff --git a/test/bun.js/fetch-gzip.test.ts b/test/bun.js/fetch-gzip.test.ts
index bdfc48f53..eee841375 100644
--- a/test/bun.js/fetch-gzip.test.ts
+++ b/test/bun.js/fetch-gzip.test.ts
@@ -9,31 +9,23 @@ it("fetch() with a buffered gzip response works (one chunk)", async () => {
async fetch(req) {
gcTick(true);
- return new Response(
- require("fs").readFileSync(import.meta.dir + "/fixture.html.gz"),
- {
- headers: {
- "Content-Encoding": "gzip",
- "Content-Type": "text/html; charset=utf-8",
- },
+ return new Response(require("fs").readFileSync(import.meta.dir + "/fixture.html.gz"), {
+ headers: {
+ "Content-Encoding": "gzip",
+ "Content-Type": "text/html; charset=utf-8",
},
- );
+ });
},
});
gcTick(true);
- const res = await fetch(
- `http://${server.hostname}:${server.port}`,
- { verbose: true },
- );
+ const res = await fetch(`http://${server.hostname}:${server.port}`, { verbose: true });
gcTick(true);
const arrayBuffer = await res.arrayBuffer();
const clone = new Buffer(arrayBuffer);
gcTick(true);
await (async function () {
- const second = new Buffer(
- await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer(),
- );
+ const second = new Buffer(await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer());
gcTick(true);
expect(second.equals(clone)).toBe(true);
})();
@@ -47,31 +39,21 @@ it("fetch() with a redirect that returns a buffered gzip response works (one chu
async fetch(req) {
if (req.url.endsWith("/redirect"))
- return new Response(
- await Bun.file(import.meta.dir + "/fixture.html.gz").arrayBuffer(),
- {
- headers: {
- "Content-Encoding": "gzip",
- "Content-Type": "text/html; charset=utf-8",
- },
+ return new Response(await Bun.file(import.meta.dir + "/fixture.html.gz").arrayBuffer(), {
+ headers: {
+ "Content-Encoding": "gzip",
+ "Content-Type": "text/html; charset=utf-8",
},
- );
+ });
return Response.redirect("/redirect");
},
});
- const res = await fetch(
- `http://${server.hostname}:${server.port}/hey`,
- { verbose: true },
- );
+ const res = await fetch(`http://${server.hostname}:${server.port}/hey`, { verbose: true });
const arrayBuffer = await res.arrayBuffer();
expect(
- new Buffer(arrayBuffer).equals(
- new Buffer(
- await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer(),
- ),
- ),
+ new Buffer(arrayBuffer).equals(new Buffer(await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer())),
).toBe(true);
server.stop();
});
@@ -82,34 +64,24 @@ it("fetch() with a protocol-relative redirect that returns a buffered gzip respo
async fetch(req, server) {
if (req.url.endsWith("/redirect"))
- return new Response(
- await Bun.file(import.meta.dir + "/fixture.html.gz").arrayBuffer(),
- {
- headers: {
- "Content-Encoding": "gzip",
- "Content-Type": "text/html; charset=utf-8",
- },
+ return new Response(await Bun.file(import.meta.dir + "/fixture.html.gz").arrayBuffer(), {
+ headers: {
+ "Content-Encoding": "gzip",
+ "Content-Type": "text/html; charset=utf-8",
},
- );
+ });
return Response.redirect(`://${server.hostname}:${server.port}/redirect`);
},
});
- const res = await fetch(
- `http://${server.hostname}:${server.port}/hey`,
- { verbose: true },
- );
+ const res = await fetch(`http://${server.hostname}:${server.port}/hey`, { verbose: true });
expect(res.url).toBe(`http://${server.hostname}:${server.port}/redirect`);
expect(res.redirected).toBe(true);
expect(res.status).toBe(200);
const arrayBuffer = await res.arrayBuffer();
expect(
- new Buffer(arrayBuffer).equals(
- new Buffer(
- await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer(),
- ),
- ),
+ new Buffer(arrayBuffer).equals(new Buffer(await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer())),
).toBe(true);
server.stop();
@@ -126,9 +98,7 @@ it("fetch() with a gzip response works (one chunk, streamed, with a delay", asyn
async pull(controller) {
await 2;
- const buffer = await Bun.file(
- import.meta.dir + "/fixture.html.gz",
- ).arrayBuffer();
+ const buffer = await Bun.file(import.meta.dir + "/fixture.html.gz").arrayBuffer();
controller.write(buffer);
controller.close();
},
@@ -147,19 +117,13 @@ it("fetch() with a gzip response works (one chunk, streamed, with a delay", asyn
const res = await fetch(`http://${server.hostname}:${server.port}`, {});
const arrayBuffer = await res.arrayBuffer();
expect(
- new Buffer(arrayBuffer).equals(
- new Buffer(
- await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer(),
- ),
- ),
+ new Buffer(arrayBuffer).equals(new Buffer(await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer())),
).toBe(true);
server.stop();
});
-it("fetch() with a gzip response works (multiple chunks, TCP server", async (done) => {
- const compressed = await Bun.file(
- import.meta.dir + "/fixture.html.gz",
- ).arrayBuffer();
+it("fetch() with a gzip response works (multiple chunks, TCP server", async done => {
+ const compressed = await Bun.file(import.meta.dir + "/fixture.html.gz").arrayBuffer();
var socketToClose;
const server = Bun.listen({
port: 4024,
@@ -209,11 +173,7 @@ it("fetch() with a gzip response works (multiple chunks, TCP server", async (don
const res = await fetch(`http://${server.hostname}:${server.port}`, {});
const arrayBuffer = await res.arrayBuffer();
expect(
- new Buffer(arrayBuffer).equals(
- new Buffer(
- await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer(),
- ),
- ),
+ new Buffer(arrayBuffer).equals(new Buffer(await Bun.file(import.meta.dir + "/fixture.html").arrayBuffer())),
).toBe(true);
socketToClose.end();
server.stop();