diff options
Diffstat (limited to 'test/bun.js/fetch-gzip.test.ts')
-rw-r--r-- | test/bun.js/fetch-gzip.test.ts | 92 |
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(); |