wip

packages/remote-runner/src/client.ts

@@ -1,9 +1,5 @@
 // https://github.com/cloudflare/workers-sdk/blame/ad1d056cb2710b790ff5d4532e9f694e099c27e2/packages/miniflare/src/plugins/core/proxy/client.ts
 
-export class ProxyClient {
-  constructor() {}
-}
-
 // proxy only get/apply?
 // everything async
 
@@ -12,3 +8,53 @@ export class ProxyClient {
 //   import
 // primitives
 // function
+
+// const client = new ProxyClient({ post });
+// const proxy = client.getRootProxy();
+// (await (await proxy.runner).import)
+// const mod = await proxy.runner.import("/src/entry");
+// const res = await mod.default(req);
+
+// const server = new ProxyServer({ on, root: { runner } });
+
+export type ProxyTarget = {
+  address: number;
+};
+
+// direct value to return
+export type ProxyResult =
+  | {
+      type: "value";
+      value: unknown;
+    }
+  | {
+      type: "proxy";
+      address: number;
+    };
+
+export class ProxyClient {
+  constructor() {}
+
+  async invokeCall(t: ProxyTarget, args: unknown[]) {
+    t;
+    args;
+  }
+
+  // sync fetch...?
+  async invokeGet(t: ProxyTarget, p: keyof any) {
+    t;
+    p;
+  }
+
+  createProxy(t: ProxyTarget) {
+    const client = this;
+    return new Proxy(() => {}, {
+      apply(_target, _thisArg, argArray) {
+        return client.invokeCall(t, argArray);
+      },
+      get(_target, p, _receiver) {
+        return client.invokeGet(t, p);
+      },
+    });
+  }
+}

packages/remote-runner/src/server.ts

@@ -1,7 +1,23 @@
 // https://github.com/cloudflare/workers-sdk/blame/ad1d056cb2710b790ff5d4532e9f694e099c27e2/packages/miniflare/src/workers/core/proxy.worker.ts#
 
+import type { ProxyTarget } from "./client";
+
 export class ProxyServer {
   heap = new Map<number, unknown>();
+  heapInv = new WeakMap<object, number>();
 
   constructor() {}
+
+  async handleCall(t: ProxyTarget, args: unknown[]) {
+    t;
+    args;
+    t.address;
+    this.heap.get(t.address);
+  }
+
+  async handleGet(t: ProxyTarget, p: keyof any) {
+    this.heap.get(t.address);
+    t;
+    p;
+  }
 }