tests/unit/read_dir_test.ts - main - githubmirror/deno

tests/unit/read_dir_test.ts
163 строки4 KB
fix(ext/fs): stream Deno.readDir entries (#35130)
11 июн 2026, 08:59
11 июн 2026, 08:59ecf9dc6
// Copyright 2018-2026 the Deno authors. MIT license.
import {
  assert,
  assertEquals,
  assertRejects,
  assertThrows,
  pathToAbsoluteFileUrl,
} from "./test_util.ts";

function assertSameContent(files: Deno.DirEntry[]) {
  let counter = 0;

  for (const entry of files) {
    if (entry.name === "subdir") {
      assert(entry.isDirectory);
      counter++;
    }
  }

  assertEquals(counter, 1);
}

Deno.test({ permissions: { read: true } }, function readDirSyncSuccess() {
  const files = [...Deno.readDirSync("tests/testdata")];
  assertSameContent(files);
});

Deno.test(
  { permissions: { read: true } },
  function readDirSyncResultHasIteratorHelperMethods() {
    const iterator = Deno.readDirSync("tests/testdata");
    assertEquals(typeof iterator.map, "function");
  },
);

Deno.test({ permissions: { read: true } }, function readDirSyncWithUrl() {
  const files = [
    ...Deno.readDirSync(pathToAbsoluteFileUrl("tests/testdata")),
  ];
  assertSameContent(files);
});

Deno.test({ permissions: { read: false } }, function readDirSyncPerm() {
  assertThrows(() => {
    Deno.readDirSync("tests/");
  }, Deno.errors.NotCapable);
});

Deno.test({ permissions: { read: true } }, function readDirSyncNotDir() {
  assertThrows(
    () => {
      Deno.readDirSync("tests/testdata/assets/fixture.json");
    },
    Error,
    `readdir 'tests/testdata/assets/fixture.json'`,
  );
});

Deno.test({ permissions: { read: true } }, function readDirSyncNotFound() {
  assertThrows(
    () => {
      Deno.readDirSync("bad_dir_name");
    },
    Deno.errors.NotFound,
    `readdir 'bad_dir_name'`,
  );
});

Deno.test({ permissions: { read: true } }, async function readDirSuccess() {
  const files = [];
  for await (const dirEntry of Deno.readDir("tests/testdata")) {
    files.push(dirEntry);
  }
  assertSameContent(files);
});

Deno.test({ permissions: { read: true } }, async function readDirWithUrl() {
  const files = [];
  for await (
    const dirEntry of Deno.readDir(pathToAbsoluteFileUrl("tests/testdata"))
  ) {
    files.push(dirEntry);
  }
  assertSameContent(files);
});

Deno.test(
  { permissions: { read: true } },
  async function readDirIterableCreatesIndependentIterators() {
    const dir = Deno.readDir("tests/testdata");
    const [filesA, filesB] = await Promise.all([
      Array.fromAsync(dir),
      Array.fromAsync(dir),
    ]);

    assertSameContent(filesA);
    assertSameContent(filesB);
  },
);

Deno.test(
  { permissions: { read: true, write: true } },
  async function readDirConcurrentNextRejectsWithBusy() {
    const tempDir = await Deno.makeTempDir();
    try {
      await Promise.all(
        Array.from(
          { length: 64 },
          (_, index) => Deno.writeTextFile(`${tempDir}/${index}.txt`, ""),
        ),
      );
      const iterator = Deno.readDir(tempDir)[Symbol.asyncIterator]();

      await assertRejects(
        async () => {
          await Promise.all(
            Array.from({ length: 64 }, () => iterator.next()),
          );
        },
        Deno.errors.Busy,
      );
      await iterator.return?.();
    } finally {
      await Deno.remove(tempDir, { recursive: true });
    }
  },
);

Deno.test({ permissions: { read: false } }, async function readDirPerm() {
  await assertRejects(async () => {
    await Deno.readDir("tests/")[Symbol.asyncIterator]().next();
  }, Deno.errors.NotCapable);
});

Deno.test(
  { permissions: "inherit", ignore: Deno.build.os == "windows" },
  async function readDirDevFd(): Promise<
    void
  > {
    for await (const _ of Deno.readDir("/dev/fd")) {
      // We don't actually care whats in here; just that we don't panic on non regular entries
    }
  },
);

Deno.test(
  { permissions: "inherit", ignore: Deno.build.os == "windows" },
  function readDirDevFdSync() {
    for (const _ of Deno.readDirSync("/dev/fd")) {
      // We don't actually care whats in here; just that we don't panic on non regular file entries
    }
  },
);

Deno.test({ permissions: { read: true } }, async function readDirNotFound() {
  await assertRejects(
    async () => {
      await Deno.readDir("bad_dir_name")[Symbol.asyncIterator]().next();
    },
    Deno.errors.NotFound,
    `readdir 'bad_dir_name'`,
  );
});