summaryrefslogtreecommitdiff
path: root/ext/node/polyfills/_fs/_fs_mkdtemp.ts
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2023-02-14 17:38:45 +0100
committerGitHub <noreply@github.com>2023-02-14 17:38:45 +0100
commitd47147fb6ad229b1c039aff9d0959b6e281f4df5 (patch)
tree6e9e790f2b9bc71b5f0c9c7e64b95cae31579d58 /ext/node/polyfills/_fs/_fs_mkdtemp.ts
parent1d00bbe47e2ca14e2d2151518e02b2324461a065 (diff)
feat(ext/node): embed std/node into the snapshot (#17724)
This commit moves "deno_std/node" in "ext/node" crate. The code is transpiled and snapshotted during the build process. During the first pass a minimal amount of work was done to create the snapshot, a lot of code in "ext/node" depends on presence of "Deno" global. This code will be gradually fixed in the follow up PRs to migrate it to import relevant APIs from "internal:" modules. Currently the code from snapshot is not used in any way, and all Node/npm compatibility still uses code from "https://deno.land/std/node" (or from the location specified by "DENO_NODE_COMPAT_URL"). This will also be handled in a follow up PRs. --------- Co-authored-by: crowlkats <crowlkats@toaxl.com> Co-authored-by: Divy Srivastava <dj.srivastava23@gmail.com> Co-authored-by: Yoshiya Hinosawa <stibium121@gmail.com>
Diffstat (limited to 'ext/node/polyfills/_fs/_fs_mkdtemp.ts')
-rw-r--r--ext/node/polyfills/_fs/_fs_mkdtemp.ts115
1 files changed, 115 insertions, 0 deletions
diff --git a/ext/node/polyfills/_fs/_fs_mkdtemp.ts b/ext/node/polyfills/_fs/_fs_mkdtemp.ts
new file mode 100644
index 000000000..de227b216
--- /dev/null
+++ b/ext/node/polyfills/_fs/_fs_mkdtemp.ts
@@ -0,0 +1,115 @@
+// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
+// Copyright Node.js contributors. All rights reserved. MIT License.
+
+import {
+ TextDecoder,
+ TextEncoder,
+} from "internal:deno_web/08_text_encoding.js";
+import { existsSync } from "internal:deno_node/polyfills/_fs/_fs_exists.ts";
+import {
+ mkdir,
+ mkdirSync,
+} from "internal:deno_node/polyfills/_fs/_fs_mkdir.ts";
+import {
+ ERR_INVALID_ARG_TYPE,
+ ERR_INVALID_OPT_VALUE_ENCODING,
+} from "internal:deno_node/polyfills/internal/errors.ts";
+import { promisify } from "internal:deno_node/polyfills/internal/util.mjs";
+
+export type mkdtempCallback = (
+ err: Error | null,
+ directory?: string,
+) => void;
+
+// https://nodejs.org/dist/latest-v15.x/docs/api/fs.html#fs_fs_mkdtemp_prefix_options_callback
+export function mkdtemp(prefix: string, callback: mkdtempCallback): void;
+export function mkdtemp(
+ prefix: string,
+ options: { encoding: string } | string,
+ callback: mkdtempCallback,
+): void;
+export function mkdtemp(
+ prefix: string,
+ optionsOrCallback: { encoding: string } | string | mkdtempCallback,
+ maybeCallback?: mkdtempCallback,
+) {
+ const callback: mkdtempCallback | undefined =
+ typeof optionsOrCallback == "function" ? optionsOrCallback : maybeCallback;
+ if (!callback) {
+ throw new ERR_INVALID_ARG_TYPE("callback", "function", callback);
+ }
+
+ const encoding: string | undefined = parseEncoding(optionsOrCallback);
+ const path = tempDirPath(prefix);
+
+ mkdir(
+ path,
+ { recursive: false, mode: 0o700 },
+ (err: Error | null | undefined) => {
+ if (err) callback(err);
+ else callback(null, decode(path, encoding));
+ },
+ );
+}
+
+export const mkdtempPromise = promisify(mkdtemp) as (
+ prefix: string,
+ options?: { encoding: string } | string,
+) => Promise<string>;
+
+// https://nodejs.org/dist/latest-v15.x/docs/api/fs.html#fs_fs_mkdtempsync_prefix_options
+export function mkdtempSync(
+ prefix: string,
+ options?: { encoding: string } | string,
+): string {
+ const encoding: string | undefined = parseEncoding(options);
+ const path = tempDirPath(prefix);
+
+ mkdirSync(path, { recursive: false, mode: 0o700 });
+ return decode(path, encoding);
+}
+
+function parseEncoding(
+ optionsOrCallback?: { encoding: string } | string | mkdtempCallback,
+): string | undefined {
+ let encoding: string | undefined;
+ if (typeof optionsOrCallback == "function") encoding = undefined;
+ else if (optionsOrCallback instanceof Object) {
+ encoding = optionsOrCallback?.encoding;
+ } else encoding = optionsOrCallback;
+
+ if (encoding) {
+ try {
+ new TextDecoder(encoding);
+ } catch {
+ throw new ERR_INVALID_OPT_VALUE_ENCODING(encoding);
+ }
+ }
+
+ return encoding;
+}
+
+function decode(str: string, encoding?: string): string {
+ if (!encoding) return str;
+ else {
+ const decoder = new TextDecoder(encoding);
+ const encoder = new TextEncoder();
+ return decoder.decode(encoder.encode(str));
+ }
+}
+
+const CHARS = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
+function randomName(): string {
+ return [...Array(6)].map(() =>
+ CHARS[Math.floor(Math.random() * CHARS.length)]
+ ).join("");
+}
+
+function tempDirPath(prefix: string): string {
+ let path: string;
+ do {
+ path = prefix + randomName();
+ } while (existsSync(path));
+
+ return path;
+}