feat(core): server-side response caching using the Web Cache API

Author: iuioiua

bench.ts

@@ -0,0 +1,14 @@
+import { app } from "./www/main.ts";
+
+const handler = await app.handler();
+
+Deno.bench(
+  "handler",
+  async () => {
+    await handler(
+      new Request(
+        "http://localhost:8000/docs/examples/using-fresh-canary-version",
+      ),
+    );
+  },
+);

deno.lock

@@ -196,6 +196,11 @@ export class App<State> {
       req: Request,
       conn: Deno.ServeHandlerInfo = DEFAULT_CONN_INFO,
     ) => {
+      if (this.config.cache && req.method === "GET") {
+        const cachedResponse = await this.config.cache.match(req);
+        if (cachedResponse) return cachedResponse;
+      }
+
       const url = new URL(req.url);
       // Prevent open redirect attacks
       url.pathname = url.pathname.replace(/\/+/g, "/");
@@ -225,24 +230,28 @@ export class App<State> {
         span.setAttribute("http.route", pattern);
       }
 
+      let response: Response;
       try {
-        if (handlers.length === 1 && handlers[0].length === 1) {
-          return handlers[0][0](ctx);
-        }
-        return await runMiddlewares(handlers, ctx);
+        response = handlers.length === 1 && handlers[0].length === 1
+          ? await handlers[0][0](ctx)
+          : await runMiddlewares(handlers, ctx);
       } catch (err) {
         if (err instanceof HttpError) {
           if (err.status >= 500) {
             // deno-lint-ignore no-console
             console.error(err);
           }
-          return new Response(err.message, { status: err.status });
+          response = new Response(err.message, { status: err.status });
         }
 
         // deno-lint-ignore no-console
         console.error(err);
-        return new Response("Internal server error", { status: 500 });
+        response = new Response("Internal server error", { status: 500 });
+      }
+      if (this.config.cache && req.method === "GET") {
+        this.config.cache.put(req, response.clone());
       }
+      return response;
     };
   }
 

src/app.ts

@@ -16,6 +16,10 @@ export interface FreshConfig {
    */
   basePath?: string;
   staticDir?: string;
+  /**
+   * Server-side cache that stores responses for corresponding requests.
+   */
+  cache?: Cache;
 }
 
 /**
@@ -32,6 +36,10 @@ export interface ResolvedFreshConfig {
    * The mode Fresh can run in.
    */
   mode: "development" | "production";
+  /**
+   * Server-side cache that stores responses for corresponding requests.
+   */
+  cache?: Cache;
 }
 
 export function parseRootPath(root: string, cwd: string): string {
@@ -65,6 +73,7 @@ export function normalizeConfig(options: FreshConfig): ResolvedFreshConfig {
     basePath: options.basePath ?? "",
     staticDir: options.staticDir ?? path.join(root, "static"),
     mode: "production",
+    cache: options.cache,
   };
 }
 

src/config.ts

@@ -1,7 +1,9 @@
 import "./telemetry.ts";
 import { App, fsRoutes, staticFiles, trailingSlashes } from "fresh";
 
-export const app = new App({ root: import.meta.url })
+const cache = await caches.open("fresh");
+
+export const app = new App({ root: import.meta.url, cache })
   .use(staticFiles())
   .use(trailingSlashes("never"));