import { assert, assertThrows, fail } from "../../testing/asserts.ts";import { assertCallbackErrorUncaught } from "../_utils.ts";import { close, closeSync } from "./_fs_close.ts";
Deno.test({ name: "ASYNC: File is closed", async fn() { const tempFile: string = await Deno.makeTempFile(); const file: Deno.FsFile = await Deno.open(tempFile);
assert(Deno.resources()[file.rid]); await new Promise<void>((resolve, reject) => { close(file.rid, (err) => { if (err !== null) reject(); else resolve(); }); }) .then(() => { assert(!Deno.resources()[file.rid]); }, () => { fail("No error expected"); }) .finally(async () => { await Deno.remove(tempFile); }); },});
Deno.test({ name: "ASYNC: Invalid fd", async fn() { await new Promise<void>((resolve, reject) => { close(-1, (err) => { if (err !== null) return resolve(); reject(); }); }); },});
Deno.test({ name: "close callback should be asynchronous", async fn() { const tempFile: string = Deno.makeTempFileSync(); const file: Deno.FsFile = Deno.openSync(tempFile);
let foo: string; const promise = new Promise<void>((resolve) => { close(file.rid, () => { assert(foo === "bar"); resolve(); }); foo = "bar"; });
await promise; Deno.removeSync(tempFile); },});
Deno.test({ name: "SYNC: File is closed", fn() { const tempFile: string = Deno.makeTempFileSync(); const file: Deno.FsFile = Deno.openSync(tempFile);
assert(Deno.resources()[file.rid]); closeSync(file.rid); assert(!Deno.resources()[file.rid]); Deno.removeSync(tempFile); },});
Deno.test({ name: "SYNC: Invalid fd", fn() { assertThrows(() => closeSync(-1)); },});
Deno.test("[std/node/fs] close callback isn't called twice if error is thrown", async () => { const tempFile = await Deno.makeTempFile(); const importUrl = new URL("./_fs_close.ts", import.meta.url); await assertCallbackErrorUncaught({ prelude: ` import { close } from ${JSON.stringify(importUrl)};
const file = await Deno.open(${JSON.stringify(tempFile)}); `, invocation: "close(file.rid, ", async cleanup() { await Deno.remove(tempFile); }, });});