feat(cloudflare): enable native node.js compatibility

src/presets/cloudflare/preset.ts

@@ -8,20 +8,10 @@ import {
   writeCFPagesHeaders,
   writeCFPagesRedirects,
 } from "./utils";
+import { unenvCfPreset } from "./unenv/preset";
 
 export type { CloudflareOptions as PresetOptions } from "./types";
 
-const cloudflareExternals = [
-  // https://developers.cloudflare.com/email-routing/email-workers/reply-email-workers/
-  "cloudflare:email",
-  // https://developers.cloudflare.com/workers/runtime-apis/tcp-sockets/
-  "cloudflare:sockets",
-  // https://developers.cloudflare.com/durable-objects/get-started/walkthrough/
-  "cloudflare:workers",
-  // https://developers.cloudflare.com/workflows/build/workers-api/
-  "cloudflare:workflows",
-] as const;
-
 // TODO: Remove when wrangler -C support landed
 // https://github.com/cloudflare/workers-sdk/pull/7994
 const isWindows = process.platform === "win32";
@@ -42,9 +32,7 @@ const cloudflarePages = defineNitroPreset(
       publicDir: "{{ output.dir }}/{{ baseURL }}",
       serverDir: "{{ output.dir }}/_worker.js",
     },
-    unenv: {
-      external: [...cloudflareExternals],
-    },
+    unenv: unenvCfPreset,
     alias: {
       // Hotfix: Cloudflare appends /index.html if mime is not found and things like ico are not in standard lite.js!
       // https://github.com/nitrojs/nitro/pull/933
@@ -116,9 +104,6 @@ const cloudflare = defineNitroPreset(
     wasm: {
       lazy: true,
     },
-    unenv: {
-      external: [...cloudflareExternals],
-    },
     hooks: {
       async compiled(nitro: Nitro) {
         await writeFile(
@@ -156,9 +141,6 @@ const cloudflareModuleLegacy = defineNitroPreset(
         inlineDynamicImports: false,
       },
     },
-    unenv: {
-      external: [...cloudflareExternals],
-    },
     wasm: {
       lazy: false,
       esmImport: true,
@@ -192,9 +174,7 @@ const cloudflareModule = defineNitroPreset(
       preview: commandWithDir("npx wrangler dev"),
       deploy: commandWithDir("npx wrangler deploy"),
     },
-    unenv: {
-      external: [...cloudflareExternals],
-    },
+    unenv: unenvCfPreset,
     rollupConfig: {
       output: {
         format: "esm",
@@ -231,9 +211,7 @@ const cloudflareDurable = defineNitroPreset(
   {
     extends: "cloudflare-module",
     entry: "./runtime/cloudflare-durable",
-    unenv: {
-      external: [...cloudflareExternals],
-    },
+    unenv: unenvCfPreset,
   },
   {
     name: "cloudflare-durable" as const,

src/presets/cloudflare/unenv/preset.ts

@@ -0,0 +1,71 @@
+// https://github.com/cloudflare/workers-sdk/blob/main/packages/unenv-preset/src/preset.ts
+
+import type { Preset } from "unenv";
+import { fileURLToPath } from "mlly";
+import { join } from "pathe";
+
+export const cloudflareExternals = [
+  "cloudflare:email",
+  "cloudflare:sockets",
+  "cloudflare:workers",
+  "cloudflare:workflows",
+] as const;
+
+// Built-in APIs provided by workerd with nodejs compatibility.
+export const nodeCompatModules = [
+  "_stream_duplex",
+  "_stream_passthrough",
+  "_stream_readable",
+  "_stream_transform",
+  "_stream_writable",
+  "assert",
+  "assert/strict",
+  "buffer",
+  "diagnostics_channel",
+  "dns",
+  "dns/promises",
+  "events",
+  "net",
+  "path",
+  "path/posix",
+  "path/win32",
+  "querystring",
+  "stream",
+  "stream/consumers",
+  "stream/promises",
+  "stream/web",
+  "string_decoder",
+  "timers",
+  "timers/promises",
+  "url",
+  "util/types",
+  "zlib",
+];
+
+// Modules implemented via a mix of workerd APIs and polyfills.
+export const hybridNodeCompatModules = [
+  "async_hooks",
+  "crypto",
+  "perf_hooks",
+  "util",
+  "sys",
+  "node:sys",
+];
+
+const presetRuntimeDir = fileURLToPath(new URL("runtime/", import.meta.url));
+const resolvePresetRuntime = (m: string) => join(presetRuntimeDir, `${m}.mjs`);
+
+export const unenvCfPreset: Preset = {
+  external: nodeCompatModules.map((m) => `node:${m}`),
+  alias: {
+    // <id> => node:<id>
+    ...Object.fromEntries(nodeCompatModules.map((m) => [m, `node:${m}`])),
+    // node:<id> => runtime/<id>.mjs
+    ...Object.fromEntries(
+      hybridNodeCompatModules.map((m) => [
+        `node:${m}`,
+        resolvePresetRuntime(m === "sys" ? "util" : m),
+      ])
+    ),
+  },
+};

src/presets/cloudflare/unenv/runtime/async_hooks.mjs

@@ -0,0 +1,31 @@
+// https://github.com/cloudflare/workers-sdk/blob/main/packages/unenv-preset/src/runtime/node/async_hooks/index.ts
+
+import {
+  // asyncWrapProviders,
+  createHook,
+  executionAsyncId,
+  executionAsyncResource,
+  triggerAsyncId,
+} from "unenv/runtime/node/async_hooks/index";
+
+export {
+  // asyncWrapProviders,
+  createHook,
+  executionAsyncId,
+  executionAsyncResource,
+  triggerAsyncId,
+} from "unenv/runtime/node/async_hooks/index";
+
+const workerdAsyncHooks =
+  globalThis["proces" + "s"].getBuiltinModule("node:async_hooks");
+
+export const { AsyncLocalStorage, AsyncResource } = workerdAsyncHooks;
+
+export default {
+  createHook,
+  executionAsyncId,
+  executionAsyncResource,
+  triggerAsyncId,
+  AsyncLocalStorage,
+  AsyncResource,
+};

src/presets/cloudflare/unenv/runtime/crypto.mjs

@@ -0,0 +1,191 @@
+// https://github.com/cloudflare/workers-sdk/blob/main/packages/unenv-preset/src/runtime/node/crypto/index.ts
+
+import {
+  Cipher,
+  Cipheriv,
+  constants,
+  createCipher,
+  createCipheriv,
+  createDecipher,
+  createDecipheriv,
+  createECDH,
+  createSign,
+  createVerify,
+  Decipher,
+  Decipheriv,
+  diffieHellman,
+  ECDH,
+  getCipherInfo,
+  // hash,
+  privateDecrypt,
+  privateEncrypt,
+  pseudoRandomBytes,
+  publicDecrypt,
+  publicEncrypt,
+  Sign,
+  sign,
+  webcrypto as unenvCryptoWebcrypto,
+  Verify,
+  verify,
+} from "unenv/runtime/node/crypto/index";
+
+export {
+  Cipher,
+  Cipheriv,
+  Decipher,
+  Decipheriv,
+  ECDH,
+  Sign,
+  Verify,
+  constants,
+  createCipheriv,
+  createDecipheriv,
+  createECDH,
+  createSign,
+  createVerify,
+  diffieHellman,
+  getCipherInfo,
+  // hash,
+  privateDecrypt,
+  privateEncrypt,
+  publicDecrypt,
+  publicEncrypt,
+  sign,
+  verify,
+} from "unenv/runtime/node/crypto/index";
+
+const workerdCrypto =
+  globalThis["proces" + "s"].getBuiltinModule("node:crypto");
+
+export const {
+  Certificate,
+  DiffieHellman,
+  DiffieHellmanGroup,
+  Hash,
+  Hmac,
+  KeyObject,
+  X509Certificate,
+  checkPrime,
+  checkPrimeSync,
+  createDiffieHellman,
+  createDiffieHellmanGroup,
+  createHash,
+  createHmac,
+  createPrivateKey,
+  createPublicKey,
+  createSecretKey,
+  generateKey,
+  generateKeyPair,
+  generateKeyPairSync,
+  generateKeySync,
+  generatePrime,
+  generatePrimeSync,
+  getCiphers,
+  getCurves,
+  getDiffieHellman,
+  getFips,
+  getHashes,
+  hkdf,
+  hkdfSync,
+  pbkdf2,
+  pbkdf2Sync,
+  randomBytes,
+  randomFill,
+  randomFillSync,
+  randomInt,
+  randomUUID,
+  scrypt,
+  scryptSync,
+  secureHeapUsed,
+  setEngine,
+  setFips,
+  subtle,
+  timingSafeEqual,
+} = workerdCrypto;
+
+export const getRandomValues = workerdCrypto.getRandomValues.bind(
+  workerdCrypto.webcrypto
+);
+
+export const webcrypto = {
+  CryptoKey: unenvCryptoWebcrypto.CryptoKey,
+  getRandomValues,
+  randomUUID,
+  subtle,
+};
+
+const fips = workerdCrypto.fips;
+
+export default {
+  Certificate,
+  Cipher,
+  Cipheriv,
+  Decipher,
+  Decipheriv,
+  ECDH,
+  Sign,
+  Verify,
+  X509Certificate,
+  constants,
+  createCipheriv,
+  createDecipheriv,
+  createECDH,
+  createSign,
+  createVerify,
+  diffieHellman,
+  getCipherInfo,
+  hash,
+  privateDecrypt,
+  privateEncrypt,
+  publicDecrypt,
+  publicEncrypt,
+  scrypt,
+  scryptSync,
+  sign,
+  verify,
+  createCipher,
+  createDecipher,
+  pseudoRandomBytes,
+  DiffieHellman,
+  DiffieHellmanGroup,
+  Hash,
+  Hmac,
+  KeyObject,
+  checkPrime,
+  checkPrimeSync,
+  createDiffieHellman,
+  createDiffieHellmanGroup,
+  createHash,
+  createHmac,
+  createPrivateKey,
+  createPublicKey,
+  createSecretKey,
+  generateKey,
+  generateKeyPair,
+  generateKeyPairSync,
+  generateKeySync,
+  generatePrime,
+  generatePrimeSync,
+  getCiphers,
+  getCurves,
+  getDiffieHellman,
+  getFips,
+  getHashes,
+  getRandomValues,
+  hkdf,
+  hkdfSync,
+  pbkdf2,
+  pbkdf2Sync,
+  randomBytes,
+  randomFill,
+  randomFillSync,
+  randomInt,
+  randomUUID,
+  secureHeapUsed,
+  setEngine,
+  setFips,
+  subtle,
+  timingSafeEqual,
+  fips,
+  webcrypto,
+};