Add Miniflare 3 foundations

Author: mrbbot

.eslintignore

@@ -1 +1,2 @@
 dist
+packages/tre/src/runtime/config/sserve-conf.*

packages/tre/README.md

@@ -0,0 +1,12 @@
+# `@miniflare/tre`
+
+Experimental version of Miniflare powered by the soon-to-be open-sourced Workers
+runtime... 👀
+
+> ⚠️ This is currently intended for internal Cloudflare use only.
+
+# Additional Development Setup
+
+1. Copy the open-source runtime binary to `./lib/cfwrkr`
+2. Copy the config files `sserve-conf.{capnp,capnp.d.ts,capnp.js,ts}` to
+   `./src/runtime/config/`

packages/tre/lib/.gitignore

@@ -0,0 +1,2 @@
+*
+!.gitignore

packages/tre/package.json

@@ -0,0 +1,52 @@
+{
+  "name": "@miniflare/tre",
+  "version": "3.0.0-next.1",
+  "description": "Fun, full-featured, fully-local simulator for Cloudflare Workers",
+  "keywords": [
+    "cloudflare",
+    "workers",
+    "worker",
+    "local",
+    "cloudworker"
+  ],
+  "author": "MrBBot <[email protected]>",
+  "license": "MIT",
+  "main": "./dist/src/index.js",
+  "types": "./dist/src/index.d.ts",
+  "files": [
+    "dist/src"
+  ],
+  "engines": {
+    "node": ">=16.13"
+  },
+  "publishConfig": {
+    "access": "public"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/cloudflare/miniflare.git",
+    "directory": "packages/tre"
+  },
+  "bugs": {
+    "url": "https://github.com/cloudflare/miniflare/issues"
+  },
+  "homepage": "https://github.com/cloudflare/miniflare/tree/master/packages/tre#readme",
+  "volta": {
+    "extends": "../../package.json"
+  },
+  "dependencies": {
+    "@miniflare/shared": "3.0.0-next.1",
+    "acorn": "^8.8.0",
+    "acorn-walk": "^8.2.0",
+    "capnp-ts": "^0.7.0",
+    "get-port": "^5.1.1",
+    "kleur": "^4.1.5",
+    "stoppable": "^1.1.0",
+    "zod": "^3.18.0"
+  },
+  "devDependencies": {
+    "@types/debug": "^4.1.7",
+    "@types/estree": "^1.0.0",
+    "@types/stoppable": "^1.1.1"
+  }
+}

packages/tre/src/helpers.ts

@@ -0,0 +1,67 @@
+import { z } from "zod";
+
+export type Awaitable<T> = T | Promise<T>;
+
+// { a: A, b: B, ... } => A | B | ...
+export type ValueOf<T> = T[keyof T];
+
+// A | B | ... => A & B & ... (https://stackoverflow.com/a/50375286)
+export type UnionToIntersection<U> = (
+  U extends any ? (k: U) => void : never
+) extends (k: infer I) => void
+  ? I
+  : never;
+
+export type OptionalZodTypeOf<T extends z.ZodTypeAny | undefined> =
+  T extends z.ZodTypeAny ? z.TypeOf<T> : undefined;
+
+// https://github.com/colinhacks/zod/blob/59768246aa57133184b2cf3f7c2a1ba5c3ab08c3/README.md?plain=1#L1302-L1317
+export const LiteralSchema = z.union([
+  z.string(),
+  z.number(),
+  z.boolean(),
+  z.null(),
+]);
+export type Literal = z.infer<typeof LiteralSchema>;
+export type Json = Literal | { [key: string]: Json } | Json[];
+export const JsonSchema: z.ZodType<Json> = z.lazy(() =>
+  z.union([LiteralSchema, z.array(JsonSchema), z.record(JsonSchema)])
+);
+
+export class MiniflareError<
+  Code extends string | number = string | number
+> extends Error {
+  constructor(readonly code: Code, message?: string, readonly cause?: Error) {
+    super(message);
+    // Restore prototype chain:
+    // https://www.typescriptlang.org/docs/handbook/release-notes/typescript-2-2.html#support-for-newtarget
+    Object.setPrototypeOf(this, new.target.prototype);
+    this.name = `${new.target.name} [${code}]`;
+  }
+}
+
+export class HttpError extends MiniflareError<number> {
+  constructor(code: number, message?: string, cause?: Error) {
+    super(code, message, cause);
+  }
+}
+
+export type DeferredPromiseResolve<T> = (value: T | PromiseLike<T>) => void;
+export type DeferredPromiseReject = (reason?: any) => void;
+
+export class DeferredPromise<T> extends Promise<T> {
+  readonly resolve: DeferredPromiseResolve<T>;
+  readonly reject: DeferredPromiseReject;
+
+  constructor() {
+    let promiseResolve: DeferredPromiseResolve<T>;
+    let promiseReject: DeferredPromiseReject;
+    super((resolve, reject) => {
+      promiseResolve = resolve;
+      promiseReject = reject;
+    });
+    // Cannot access `this` until after `super`
+    this.resolve = promiseResolve!;
+    this.reject = promiseReject!;
+  }
+}