1 files changed, 81 insertions, 0 deletions
diff --git a/ext/node/polyfills/_fs/_fs_rm.ts b/ext/node/polyfills/_fs/_fs_rm.ts
new file mode 100644
index 000000000..80ba0b5f8
--- /dev/null
+++ b/ext/node/polyfills/_fs/_fs_rm.ts
@@ -0,0 +1,81 @@
+// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
+import {
+  validateRmOptions,
+  validateRmOptionsSync,
+} from "internal:deno_node/polyfills/internal/fs/utils.mjs";
+import { denoErrorToNodeError } from "internal:deno_node/polyfills/internal/errors.ts";
+import { promisify } from "internal:deno_node/polyfills/internal/util.mjs";
+
+type rmOptions = {
+  force?: boolean;
+  maxRetries?: number;
+  recursive?: boolean;
+  retryDelay?: number;
+};
+
+type rmCallback = (err: Error | null) => void;
+
+export function rm(path: string | URL, callback: rmCallback): void;
+export function rm(
+  path: string | URL,
+  options: rmOptions,
+  callback: rmCallback,
+): void;
+export function rm(
+  path: string | URL,
+  optionsOrCallback: rmOptions | rmCallback,
+  maybeCallback?: rmCallback,
+) {
+  const callback = typeof optionsOrCallback === "function"
+    ? optionsOrCallback
+    : maybeCallback;
+  const options = typeof optionsOrCallback === "object"
+    ? optionsOrCallback
+    : undefined;
+
+  if (!callback) throw new Error("No callback function supplied");
+
+  validateRmOptions(
+    path,
+    options,
+    false,
+    (err: Error | null, options: rmOptions) => {
+      if (err) {
+        return callback(err);
+      }
+      Deno.remove(path, { recursive: options?.recursive })
+        .then((_) => callback(null), (err: unknown) => {
+          if (options?.force && err instanceof Deno.errors.NotFound) {
+            callback(null);
+          } else {
+            callback(
+              err instanceof Error
+                ? denoErrorToNodeError(err, { syscall: "rm" })
+                : err,
+            );
+          }
+        });
+    },
+  );
+}
+
+export const rmPromise = promisify(rm) as (
+  path: string | URL,
+  options?: rmOptions,
+) => Promise<void>;
+
+export function rmSync(path: string | URL, options?: rmOptions) {
+  options = validateRmOptionsSync(path, options, false);
+  try {
+    Deno.removeSync(path, { recursive: options?.recursive });
+  } catch (err: unknown) {
+    if (options?.force && err instanceof Deno.errors.NotFound) {
+      return;
+    }
+    if (err instanceof Error) {
+      throw denoErrorToNodeError(err, { syscall: "stat" });
+    } else {
+      throw err;
+    }
+  }
+}