mirror of
https://github.com/denoland/deno.git
synced 2024-12-22 07:14:47 -05:00
test(ext/node): add fs read unit tests (#19588)
This commit is contained in:
Kaique da Silva
GitHub
parent
b37b286f7f
commit
c7d38e593f
2 changed files with 293 additions and 0 deletions
|
|
@ -21,6 +21,7 @@ util::unit_test_factory!(
|
|||
_fs_dir_test = _fs / _fs_dir_test,
|
||||
_fs_dirent_test = _fs / _fs_dirent_test,
|
||||
_fs_open_test = _fs / _fs_open_test,
|
||||
_fs_read_test = _fs / _fs_read_test,
|
||||
_fs_exists_test = _fs / _fs_exists_test,
|
||||
_fs_fdatasync_test = _fs / _fs_fdatasync_test,
|
||||
_fs_fstat_test = _fs / _fs_fstat_test,
|
||||
|
|
|
|||
292
cli/tests/unit_node/_fs/_fs_read_test.ts
Normal file
292
cli/tests/unit_node/_fs/_fs_read_test.ts
Normal file
|
|
@ -0,0 +1,292 @@
|
|||
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
||||
import {
|
||||
assertEquals,
|
||||
assertFalse,
|
||||
assertMatch,
|
||||
assertStrictEquals,
|
||||
} from "../../../../test_util/std/testing/asserts.ts";
|
||||
import { read, readSync } from "node:fs";
|
||||
import { open, openSync } from "node:fs";
|
||||
import { Buffer } from "node:buffer";
|
||||
import * as path from "../../../../test_util/std/path/mod.ts";
|
||||
import { closeSync } from "node:fs";
|
||||
import { deferred } from "../../../../test_util/std/async/deferred.ts";
|
||||
|
||||
async function readTest(
|
||||
testData: string,
|
||||
buffer: Buffer,
|
||||
offset: number,
|
||||
length: number,
|
||||
position: number | null = null,
|
||||
expected: (
|
||||
fd: number,
|
||||
bytesRead: number | null,
|
||||
data: Buffer | undefined,
|
||||
) => void,
|
||||
) {
|
||||
let fd1 = 0;
|
||||
await new Promise<{
|
||||
fd: number;
|
||||
bytesRead: number | null;
|
||||
data: Buffer | undefined;
|
||||
}>((resolve, reject) => {
|
||||
open(testData, "r", (err, fd) => {
|
||||
if (err) reject(err);
|
||||
read(fd, buffer, offset, length, position, (err, bytesRead, data) => {
|
||||
if (err) reject(err);
|
||||
resolve({ fd, bytesRead, data });
|
||||
});
|
||||
});
|
||||
})
|
||||
.then(({ fd, bytesRead, data }) => {
|
||||
fd1 = fd;
|
||||
expected(fd, bytesRead, data);
|
||||
})
|
||||
.finally(() => closeSync(fd1));
|
||||
}
|
||||
|
||||
Deno.test({
|
||||
name: "readSuccess",
|
||||
async fn() {
|
||||
const moduleDir = path.dirname(path.fromFileUrl(import.meta.url));
|
||||
const testData = path.resolve(moduleDir, "testdata", "hello.txt");
|
||||
const buf = Buffer.alloc(1024);
|
||||
await readTest(
|
||||
testData,
|
||||
buf,
|
||||
buf.byteOffset,
|
||||
buf.byteLength,
|
||||
null,
|
||||
(_fd, bytesRead, data) => {
|
||||
assertStrictEquals(bytesRead, 11);
|
||||
assertEquals(data instanceof Buffer, true);
|
||||
assertMatch((data as Buffer).toString(), /hello world/);
|
||||
},
|
||||
);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name:
|
||||
"[std/node/fs] Read only five bytes, so that the position moves to five",
|
||||
async fn() {
|
||||
const moduleDir = path.dirname(path.fromFileUrl(import.meta.url));
|
||||
const testData = path.resolve(moduleDir, "testdata", "hello.txt");
|
||||
const buf = Buffer.alloc(5);
|
||||
await readTest(
|
||||
testData,
|
||||
buf,
|
||||
buf.byteOffset,
|
||||
5,
|
||||
null,
|
||||
(_fd, bytesRead, data) => {
|
||||
assertStrictEquals(bytesRead, 5);
|
||||
assertEquals(data instanceof Buffer, true);
|
||||
assertEquals((data as Buffer).toString(), "hello");
|
||||
},
|
||||
);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name:
|
||||
"[std/node/fs] position option of fs.read() specifies where to begin reading from in the file",
|
||||
async fn() {
|
||||
const moduleDir = path.dirname(path.fromFileUrl(import.meta.url));
|
||||
const testData = path.resolve(moduleDir, "testdata", "hello.txt");
|
||||
const fd = openSync(testData, "r");
|
||||
const buf = Buffer.alloc(5);
|
||||
const positions = [6, 0, -1, null];
|
||||
const expected = [
|
||||
[119, 111, 114, 108, 100],
|
||||
[104, 101, 108, 108, 111],
|
||||
[104, 101, 108, 108, 111],
|
||||
[32, 119, 111, 114, 108],
|
||||
];
|
||||
for (const [i, position] of positions.entries()) {
|
||||
await new Promise((resolve) => {
|
||||
read(
|
||||
fd,
|
||||
{
|
||||
buffer: buf,
|
||||
offset: buf.byteOffset,
|
||||
length: buf.byteLength,
|
||||
position,
|
||||
},
|
||||
(err, bytesRead, data) => {
|
||||
assertEquals(err, null);
|
||||
assertStrictEquals(bytesRead, 5);
|
||||
assertEquals(
|
||||
data,
|
||||
Buffer.from(expected[i]),
|
||||
);
|
||||
return resolve(true);
|
||||
},
|
||||
);
|
||||
});
|
||||
}
|
||||
closeSync(fd);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name: "[std/node/fs] Read fs.read(fd, options, cb) signature",
|
||||
async fn() {
|
||||
const file = Deno.makeTempFileSync();
|
||||
Deno.writeTextFileSync(file, "hi there");
|
||||
const fd = openSync(file, "r+");
|
||||
const buf = Buffer.alloc(11);
|
||||
await read(
|
||||
fd,
|
||||
{
|
||||
buffer: buf,
|
||||
offset: buf.byteOffset,
|
||||
length: buf.byteLength,
|
||||
position: null,
|
||||
},
|
||||
(err, bytesRead, data) => {
|
||||
assertEquals(err, null);
|
||||
assertStrictEquals(bytesRead, 8);
|
||||
assertEquals(
|
||||
data,
|
||||
Buffer.from([104, 105, 32, 116, 104, 101, 114, 101, 0, 0, 0]),
|
||||
);
|
||||
},
|
||||
);
|
||||
closeSync(fd);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name: "[std/node/fs] Read fs.read(fd, cb) signature",
|
||||
async fn() {
|
||||
const file = Deno.makeTempFileSync();
|
||||
Deno.writeTextFileSync(file, "hi deno");
|
||||
const fd = openSync(file, "r+");
|
||||
await read(fd, (err, bytesRead, data) => {
|
||||
assertEquals(err, null);
|
||||
assertStrictEquals(bytesRead, 7);
|
||||
assertStrictEquals(data?.byteLength, 16384);
|
||||
});
|
||||
closeSync(fd);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name: "SYNC: readSuccess",
|
||||
fn() {
|
||||
const moduleDir = path.dirname(path.fromFileUrl(import.meta.url));
|
||||
const testData = path.resolve(moduleDir, "testdata", "hello.txt");
|
||||
const buffer = Buffer.alloc(1024);
|
||||
const fd = openSync(testData, "r");
|
||||
const bytesRead = readSync(
|
||||
fd,
|
||||
buffer,
|
||||
buffer.byteOffset,
|
||||
buffer.byteLength,
|
||||
null,
|
||||
);
|
||||
assertStrictEquals(bytesRead, 11);
|
||||
closeSync(fd);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name: "[std/node/fs] Read only two bytes, so that the position moves to two",
|
||||
fn() {
|
||||
const moduleDir = path.dirname(path.fromFileUrl(import.meta.url));
|
||||
const testData = path.resolve(moduleDir, "testdata", "hello.txt");
|
||||
const buffer = Buffer.alloc(2);
|
||||
const fd = openSync(testData, "r");
|
||||
const bytesRead = readSync(fd, buffer, buffer.byteOffset, 2, null);
|
||||
assertStrictEquals(bytesRead, 2);
|
||||
closeSync(fd);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name:
|
||||
"[std/node/fs] position option of fs.readSync() specifies where to begin reading from in the file",
|
||||
fn() {
|
||||
const moduleDir = path.dirname(path.fromFileUrl(import.meta.url));
|
||||
const testData = path.resolve(moduleDir, "testdata", "hello.txt");
|
||||
const fd = openSync(testData, "r");
|
||||
const buf = Buffer.alloc(5);
|
||||
const positions = [6, 0, -1, null];
|
||||
const expected = [
|
||||
[119, 111, 114, 108, 100],
|
||||
[104, 101, 108, 108, 111],
|
||||
[104, 101, 108, 108, 111],
|
||||
[32, 119, 111, 114, 108],
|
||||
];
|
||||
for (const [i, position] of positions.entries()) {
|
||||
const bytesRead = readSync(
|
||||
fd,
|
||||
buf,
|
||||
buf.byteOffset,
|
||||
buf.byteLength,
|
||||
position,
|
||||
);
|
||||
assertStrictEquals(bytesRead, 5);
|
||||
assertEquals(
|
||||
buf,
|
||||
Buffer.from(expected[i]),
|
||||
);
|
||||
}
|
||||
closeSync(fd);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name: "[std/node/fs] Read fs.readSync(fd, buffer[, options]) signature",
|
||||
fn() {
|
||||
const file = Deno.makeTempFileSync();
|
||||
Deno.writeTextFileSync(file, "hello deno");
|
||||
const buffer = Buffer.alloc(1024);
|
||||
const fd = openSync(file, "r+");
|
||||
const bytesRead = readSync(fd, buffer, {
|
||||
length: buffer.byteLength,
|
||||
offset: buffer.byteOffset,
|
||||
position: null,
|
||||
});
|
||||
assertStrictEquals(bytesRead, 10);
|
||||
closeSync(fd);
|
||||
},
|
||||
});
|
||||
|
||||
Deno.test({
|
||||
name: "[std/node/fs] fs.read is async",
|
||||
async fn(t) {
|
||||
const file = await Deno.makeTempFile();
|
||||
await Deno.writeTextFile(file, "abc");
|
||||
|
||||
await t.step("without position option", async () => {
|
||||
const promise = deferred<void>();
|
||||
let called = false;
|
||||
const fd = openSync(file, "r");
|
||||
read(fd, () => {
|
||||
called = true;
|
||||
closeSync(fd);
|
||||
promise.resolve();
|
||||
});
|
||||
assertFalse(called);
|
||||
await promise;
|
||||
});
|
||||
|
||||
await t.step("with position option", async () => {
|
||||
const promise = deferred<void>();
|
||||
let called = false;
|
||||
const buffer = Buffer.alloc(2);
|
||||
const fd = openSync(file, "r");
|
||||
read(fd, { position: 1, buffer, offset: 0, length: 2 }, () => {
|
||||
called = true;
|
||||
closeSync(fd);
|
||||
promise.resolve();
|
||||
});
|
||||
assertFalse(called);
|
||||
await promise;
|
||||
});
|
||||
|
||||
await Deno.remove(file);
|
||||
},
|
||||
});
|
||||
Loading…
Reference in a new issue