diff options
Diffstat (limited to 'tests/unit/test_util.ts')
-rw-r--r-- | tests/unit/test_util.ts | 87 |
1 files changed, 87 insertions, 0 deletions
diff --git a/tests/unit/test_util.ts b/tests/unit/test_util.ts new file mode 100644 index 000000000..2f2730794 --- /dev/null +++ b/tests/unit/test_util.ts @@ -0,0 +1,87 @@ +// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license. + +import * as colors from "@test_util/std/fmt/colors.ts"; +export { colors }; +import { join, resolve } from "@test_util/std/path/mod.ts"; +export { + assert, + assertEquals, + assertFalse, + AssertionError, + assertIsError, + assertMatch, + assertNotEquals, + assertNotStrictEquals, + assertRejects, + assertStrictEquals, + assertStringIncludes, + assertThrows, + fail, + unimplemented, + unreachable, +} from "@test_util/std/assert/mod.ts"; +export { delay } from "@test_util/std/async/delay.ts"; +export { readLines } from "@test_util/std/io/read_lines.ts"; +export { parse as parseArgs } from "@test_util/std/flags/mod.ts"; + +export function pathToAbsoluteFileUrl(path: string): URL { + path = resolve(path); + + return new URL(`file://${Deno.build.os === "windows" ? "/" : ""}${path}`); +} + +export function execCode(code: string): Promise<readonly [number, string]> { + return execCode2(code).finished(); +} + +export function execCode2(code: string) { + const command = new Deno.Command(Deno.execPath(), { + args: [ + "eval", + "--unstable", + "--no-check", + code, + ], + stdout: "piped", + stderr: "inherit", + }); + + const child = command.spawn(); + const stdout = child.stdout.pipeThrough(new TextDecoderStream()).getReader(); + let output = ""; + + return { + async waitStdoutText(text: string) { + while (true) { + const readData = await stdout.read(); + if (readData.value) { + output += readData.value; + if (output.includes(text)) { + return; + } + } + if (readData.done) { + throw new Error(`Did not find text '${text}' in stdout.`); + } + } + }, + async finished() { + while (true) { + const readData = await stdout.read(); + if (readData.value) { + output += readData.value; + } + if (readData.done) { + break; + } + } + const status = await child.status; + return [status.code, output] as const; + }, + }; +} + +export function tmpUnixSocketPath(): string { + const folder = Deno.makeTempDirSync(); + return join(folder, "socket"); +} |