import fs from "fs"; import { it, expect } from "bun:test"; import path from "path"; import { gcTick } from "./gc"; it("Bun.file not found returns ENOENT", async () => { try { await gcTick(); await Bun.file("/does/not/exist.txt").text(); await gcTick(); } catch (exception) { expect(exception.code).toBe("ENOENT"); } await gcTick(); }); it("Bun.write('out.txt', 'string')", async () => { for (let erase of [true, false]) { if (erase) { try { fs.unlinkSync(path.join("/tmp", "out.txt")); } catch (e) {} } await gcTick(); expect(await Bun.write("/tmp/out.txt", "string")).toBe("string".length); await gcTick(); const out = Bun.file("/tmp/out.txt"); await gcTick(); expect(await out.text()).toBe("string"); await gcTick(); expect(await out.text()).toBe(fs.readFileSync("/tmp/out.txt", "utf8")); await gcTick(); } }); it("Bun.write blob", async () => { await Bun.write( Bun.file("/tmp/response-file.test.txt"), Bun.file(path.join(import.meta.dir, "fetch.js.txt")) ); await gcTick(); await Bun.write(Bun.file("/tmp/response-file.test.txt"), "blah blah blha"); await gcTick(); await Bun.write( Bun.file("/tmp/response-file.test.txt"), new Uint32Array(1024) ); await gcTick(); await Bun.write("/tmp/response-file.test.txt", new Uint32Array(1024)); await gcTick(); expect( await Bun.write( new TextEncoder().encode("/tmp/response-file.test.txt"), new Uint32Array(1024) ) ).toBe(new Uint32Array(1024).byteLength); await gcTick(); }); it("Bun.file -> Bun.file", async () => { try { fs.unlinkSync(path.join("/tmp", "fetch.js.in")); } catch (e) {} await gcTick(); try { fs.unlinkSync(path.join("/tmp", "fetch.js.out")); } catch (e) {} await gcTick(); const file = path.join(import.meta.dir, "fetch.js.txt"); await gcTick(); const text = fs.readFileSync(file, "utf8"); fs.writeFileSync("/tmp/fetch.js.in", text); await gcTick(); { const result = await Bun.write( Bun.file("/tmp/fetch.js.out"), Bun.file("/tmp/fetch.js.in") ); await gcTick(); expect(await Bun.file("/tmp/fetch.js.out").text()).toBe(text); await gcTick(); } { await Bun.write( Bun.file("/tmp/fetch.js.in").slice(0, (text.length / 2) | 0), Bun.file("/tmp/fetch.js.out") ); expect(await Bun.file("/tmp/fetch.js.in").text()).toBe( text.substring(0, (text.length / 2) | 0) ); } { await gcTick(); await Bun.write("/tmp/fetch.js.in", Bun.file("/tmp/fetch.js.out")); await gcTick(); expect(await Bun.file("/tmp/fetch.js.in").text()).toBe(text); } }); it("Bun.file", async () => { const file = path.join(import.meta.dir, "fetch.js.txt"); await gcTick(); expect(await Bun.file(file).text()).toBe(fs.readFileSync(file, "utf8")); await gcTick(); }); it("Bun.file as a Blob", async () => { const filePath = path.join(import.meta.path, "../fetch.js.txt"); const fixture = fs.readFileSync(filePath, "utf8"); // this is a Blob object with the same interface as the one returned by fetch // internally, instead of a byte array, it stores the file path! // this enables several performance optimizations var blob = Bun.file(filePath); await gcTick(); // no size because we haven't read it from disk yet expect(blob.size).toBe(0); await gcTick(); // now it reads "./fetch.js.txt" from the filesystem // it's lazy, only loads once we ask for it // if it fails, the promise will reject at this point expect(await blob.text()).toBe(fixture); await gcTick(); // now that it's loaded, the size updates expect(blob.size).toBe(fixture.length); await gcTick(); // and it only loads once for _all_ blobs pointing to that file path // until all references are released expect((await blob.arrayBuffer()).byteLength).toBe(fixture.length); await gcTick(); const array = new Uint8Array(await blob.arrayBuffer()); await gcTick(); const text = fixture; for (let i = 0; i < text.length; i++) { expect(array[i]).toBe(text.charCodeAt(i)); } await gcTick(); expect(blob.size).toBe(fixture.length); blob = null; await gcTick(); await new Promise((resolve) => setTimeout(resolve, 1)); // now we're back var blob = Bun.file(filePath); expect(blob.size).toBe(0); }); it("Response -> Bun.file", async () => { const file = path.join(import.meta.dir, "fetch.js.txt"); await gcTick(); const text = fs.readFileSync(file, "utf8"); await gcTick(); const response = new Response(Bun.file(file)); await gcTick(); expect(await response.text()).toBe(text); await gcTick(); }); it("Bun.file -> Response", async () => { // ensure the file doesn't already exist try { fs.unlinkSync("/tmp/fetch.js.out"); } catch {} await gcTick(); const file = path.join(import.meta.dir, "fetch.js.txt"); await gcTick(); const text = fs.readFileSync(file, "utf8"); await gcTick(); const resp = await fetch("https://example.com"); await gcTick(); expect(await Bun.write("/tmp/fetch.js.out", resp)).toBe(text.length); await gcTick(); expect(await Bun.file("/tmp/fetch.js.out").text()).toBe(text); await gcTick(); }); it("Response -> Bun.file -> Response -> text", async () => { await gcTick(); const file = path.join(import.meta.dir, "fetch.js.txt"); await gcTick(); const text = fs.readFileSync(file, "utf8"); await gcTick(); const response = new Response(Bun.file(file)); await gcTick(); const response2 = response.clone(); await gcTick(); expect(await response2.text()).toBe(text); await gcTick(); }); // If you write nothing to a file, it shouldn't modify it // If you want to truncate a file, it should be more explicit it("Bun.write('output.html', '')", async () => { await Bun.write("/tmp/output.html", "lalalala"); expect(await Bun.write("/tmp/output.html", "")).toBe(0); expect(await Bun.file("/tmp/output.html").text()).toBe("lalalala"); }); // Since Bun.file is resolved lazily, this needs to specifically be checked it("Bun.write('output.html', HTMLRewriter.transform(Bun.file)))", async () => { var rewriter = new HTMLRewriter(); rewriter.on("div", { element(element) { element.setInnerContent("it worked!", { html: true }); }, }); await Bun.write("/tmp/html-rewriter.txt.js", "
hello
"); var input = new Response(Bun.file("/tmp/html-rewriter.txt.js")); var output = rewriter.transform(input); const outpath = `/tmp/html-rewriter.${Date.now()}.html`; await Bun.write(outpath, output); expect(await Bun.file(outpath).text()).toBe( "
it worked!
" ); }); at/data-with-set'>feat/data-with-set Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/contributing.md (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2022-06-30Ci: improve times, reduce delay (#3780)Gravatar Fred K. Schott 1-14/+10
2022-06-30await error reporter (#3779)Gravatar Fred K. Schott 2-10/+25
2022-06-30[ci] formatGravatar natemoo-re 14-99/+95
2022-06-30MDX support (#3706)Gravatar Nate Moore 63-57/+1153
2022-06-30Fix integration name (`prefetch` instead of `lit`) (#3778)Gravatar hippotastic 2-1/+6
2022-06-30[ci] update lockfile (#3771)Gravatar Fred K. Bot 1-114/+112
2022-06-30Integration Docs Next Steps (#3677)Gravatar Dan Jutan 11-314/+666
2022-06-30[ci] formatGravatar tony-sull 1-2/+2
2022-06-30refactor to provide better cli error handling (#3768)Gravatar Fred K. Schott 2-43/+37
2022-06-30[ci] release (#3772)@astrojs/preact@0.3.1Gravatar Fred K. Bot 12-22/+23
2022-06-30Added Cloudflare adapter to README.md (#3773)Gravatar Isaac McFadyen 1-0/+1
2022-06-30[ci] formatGravatar hippotastic 1-5/+4
2022-06-30Fix "Invalid hook call" warning (#3769)Gravatar hippotastic 2-9/+79
2022-06-29[ci] release (#3759)astro@1.0.0-beta.59@astrojs/telemetry@0.2.2@astrojs/preact@0.3.0Gravatar Fred K. Bot 42-121/+117
2022-06-29[ci] formatGravatar FredKSchott 8-35/+36
2022-06-29manual lockfile update (#3751)Gravatar Fred K. Schott 3-2659/+2871
2022-06-29add error event to telemetry (#3750)Gravatar Fred K. Schott 16-85/+270