Add cache plugin stubs

Author: mrbbot

packages/tre/src/plugins/cache/gateway.ts

@@ -0,0 +1,20 @@
+import { Clock, Storage } from "@miniflare/shared";
+
+export class CacheGateway {
+  constructor(
+    private readonly storage: Storage,
+    private readonly clock: Clock
+  ) {}
+
+  async match(key: string) {
+    throw new Error("Not yet implemented!");
+  }
+
+  async put(key: string, value: Uint8Array) {
+    throw new Error("Not yet implemented!");
+  }
+
+  async delete(key: string) {
+    throw new Error("Not yet implemented!");
+  }
+}

packages/tre/src/plugins/cache/index.ts

@@ -0,0 +1,32 @@
+import { z } from "zod";
+import { PersistenceSchema, Plugin } from "../shared";
+import { CacheGateway } from "./gateway";
+import { CacheRouter } from "./router";
+
+export const CacheOptionsSchema = z.object({
+  cache: z.boolean().optional(),
+  cacheWarnUsage: z.boolean().optional(),
+});
+export const CacheSharedOptionsSchema = z.object({
+  cachePersist: PersistenceSchema,
+});
+
+export const CACHE_PLUGIN_NAME = "cache";
+export const CACHE_PLUGIN: Plugin<
+  typeof CacheOptionsSchema,
+  typeof CacheSharedOptionsSchema,
+  CacheGateway
+> = {
+  gateway: CacheGateway,
+  router: CacheRouter,
+  options: CacheOptionsSchema,
+  sharedOptions: CacheSharedOptionsSchema,
+  getBindings(options) {
+    return undefined;
+  },
+  getServices(options) {
+    return undefined;
+  },
+};
+
+export * from "./gateway";

packages/tre/src/plugins/cache/router.ts

@@ -0,0 +1,40 @@
+import { Response } from "undici";
+import {
+  DELETE,
+  GET,
+  PUT,
+  RouteHandler,
+  Router,
+  decodePersist,
+} from "../shared";
+import { CacheGateway } from "./gateway";
+
+export interface CacheParams {
+  namespace: string;
+  key: string;
+}
+export class CacheRouter extends Router<CacheGateway> {
+  @GET("/:namespace/:key")
+  match: RouteHandler<CacheParams> = async (req, params) => {
+    const persist = decodePersist(req.headers);
+    const gateway = this.gatewayFactory.get(params.namespace, persist);
+    await gateway.match(params.key);
+    return new Response();
+  };
+
+  @PUT("/:namespace/:key")
+  put: RouteHandler<CacheParams> = async (req, params) => {
+    const persist = decodePersist(req.headers);
+    const gateway = this.gatewayFactory.get(params.namespace, persist);
+    await gateway.put(params.key, new Uint8Array(await req.arrayBuffer()));
+    return new Response();
+  };
+
+  @DELETE("/:namespace/:key")
+  delete: RouteHandler<CacheParams> = async (req, params) => {
+    const persist = decodePersist(req.headers);
+    const gateway = this.gatewayFactory.get(params.namespace, persist);
+    await gateway.delete(params.key);
+    return new Response();
+  };
+}