Support 'deno' runtime for server functions

Author: littledivy

packages/open-next/src/build.ts

@@ -677,15 +677,16 @@ async function createCacheAssets(monorepoRoot: string) {
 /* Server Helper Functions */
 /***************************/
 
-function compileCache() {
-  const outfile = path.join(options.outputDir, ".build", "cache.cjs");
+export function compileCache(format: "cjs" | "esm" = "cjs") {
+  const ext = format === "cjs" ? "cjs" : "mjs";
+  const outfile = path.join(options.outputDir, ".build", `cache.${ext}`);
   esbuildSync(
     {
       external: ["next", "styled-jsx", "react", "@aws-sdk/*"],
       entryPoints: [path.join(__dirname, "adapters", "cache.js")],
       outfile,
       target: ["node18"],
-      format: "cjs",
+      format,
       banner: {
         js: [
           `globalThis.disableIncrementalCache = ${

packages/open-next/src/build/createServerBundle.ts

@@ -10,6 +10,7 @@ import {
 } from "types/open-next";
 import url from "url";
 
+import { compileCache } from "../build.js";
 import logger from "../logger.js";
 import { minifyAll } from "../minimize-js.js";
 import { openNextReplacementPlugin } from "../plugins/replacement.js";
@@ -37,6 +38,13 @@ export async function createServerBundle(
   const defaultFn = config.default;
   const functions = Object.entries(config.functions ?? {});
 
+  if (
+    defaultFn.runtime === "deno" ||
+    functions.some(([, fn]) => fn.runtime === "deno")
+  ) {
+    compileCache("esm");
+  }
+
   const promises = functions.map(async ([name, fnOptions]) => {
     const routes = fnOptions.routes;
     routes.forEach((route) => foundRoutes.add(route));
@@ -134,11 +142,16 @@ async function generateBundle(
   const packagePath = path.relative(monorepoRoot, appBuildOutputPath);
   fs.mkdirSync(path.join(outputPath, packagePath), { recursive: true });
 
+  const ext = fnOptions.runtime === "deno" ? "mjs" : "cjs";
   fs.copyFileSync(
-    path.join(outputDir, ".build", "cache.cjs"),
+    path.join(outputDir, ".build", `cache.${ext}`),
     path.join(outputPath, packagePath, "cache.cjs"),
   );
 
+  if (fnOptions.runtime === "deno") {
+    addDenoJson(outputPath, packagePath);
+  }
+
   // Bundle next server if necessary
   const isBundled = fnOptions.experimentalBundledNextServer ?? false;
   if (isBundled) {
@@ -227,14 +240,18 @@ async function generateBundle(
         .join(",")}] for Next version: ${options.nextVersion}`,
     );
   }
+
+  const outfileExt = fnOptions.runtime === "deno" ? "ts" : "mjs";
   await esbuildAsync(
     {
       entryPoints: [path.join(__dirname, "../adapters", "server-adapter.js")],
       external: ["next", "./middleware.mjs", "./next-server.runtime.prod.js"],
-      outfile: path.join(outputPath, packagePath, "index.mjs"),
+      outfile: path.join(outputPath, packagePath, `index.${outfileExt}`),
       banner: {
         js: [
           `globalThis.monorepoPackagePath = "${packagePath}";`,
+          "import process from 'node:process';",
+          "import { Buffer } from 'node:buffer';",
           "import { createRequire as topLevelCreateRequire } from 'module';",
           "const require = topLevelCreateRequire(import.meta.url);",
           "import bannerUrl from 'url';",
@@ -280,6 +297,17 @@ function shouldGenerateDockerfile(options: FunctionOptions) {
   return options.override?.generateDockerfile ?? false;
 }
 
+function addDenoJson(outputPath: string, packagePath: string) {
+  const config = {
+    // Enable "bring your own node_modules" mode
+    unstable: ["byonm", "fs"],
+  };
+  fs.writeFileSync(
+    path.join(outputPath, packagePath, "deno.json"),
+    JSON.stringify(config, null, 2),
+  );
+}
+
 //TODO: check if this PR is still necessary https://github.com/sst/open-next/pull/341
 function addMonorepoEntrypoint(outputPath: string, packagePath: string) {
   // Note: in the monorepo case, the handler file is output to

packages/open-next/src/types/open-next.ts

@@ -188,7 +188,7 @@ export interface FunctionOptions extends DefaultFunctionOptions {
    * Runtime used
    * @default "node"
    */
-  runtime?: "node" | "edge";
+  runtime?: "node" | "edge" | "deno";
   /**
    * @default "regional"
    */