refactor(core): ensureFastOps is an op-generating proxy (#19377)

Startup benchmark shows no changes (within 1ms, identical system/user
times).

core/01_core.js

@@ -22,6 +22,7 @@
     PromiseReject,
     PromiseResolve,
     PromisePrototypeThen,
+    Proxy,
     RangeError,
     ReferenceError,
     ReflectHas,
@@ -762,19 +763,19 @@ for (let i = 0; i < 10; i++) {
     setUpAsyncStub(opName);
   }
 
-  function generateAsyncOpHandler(/* opNames... */) {
-    const fastOps = {};
-    for (const opName of new SafeArrayIterator(arguments)) {
-      if (ops[opName] === undefined) {
-        throw new Error(`Unknown or disabled op '${opName}'`);
-      }
-      if (asyncOps[opName] !== undefined) {
-        fastOps[opName] = setUpAsyncStub(opName);
-      } else {
-        fastOps[opName] = ops[opName];
-      }
-    }
-    return fastOps;
+  function ensureFastOps() {
+    return new Proxy({}, {
+      get(_target, opName) {
+        if (ops[opName] === undefined) {
+          throw new Error(`Unknown or disabled op '${opName}'`);
+        }
+        if (asyncOps[opName] !== undefined) {
+          return setUpAsyncStub(opName);
+        } else {
+          return ops[opName];
+        }
+      },
+    });
   }
 
   const {
@@ -787,22 +788,12 @@ for (let i = 0; i < 10; i++) {
     op_read_sync: readSync,
     op_write_sync: writeSync,
     op_shutdown: shutdown,
-  } = generateAsyncOpHandler(
-    "op_close",
-    "op_try_close",
-    "op_read",
-    "op_read_all",
-    "op_write",
-    "op_write_all",
-    "op_read_sync",
-    "op_write_sync",
-    "op_shutdown",
-  );
+  } = ensureFastOps();
 
   // Extra Deno.core.* exports
   const core = ObjectAssign(globalThis.Deno.core, {
     asyncStub,
-    generateAsyncOpHandler,
+    ensureFastOps,
     opAsync,
     resources,
     metrics,

core/examples/http_bench_json_ops/http_bench_json_ops.js

@@ -9,10 +9,7 @@ const { op_listen } = Deno.core.ops;
 const {
   op_accept,
   op_read_socket,
-} = Deno.core.generateAsyncOpHandler(
-  "op_accept",
-  "op_read_socket",
-);
+} = Deno.core.ensureFastOps();
 
 const requestBuf = new Uint8Array(64 * 1024);
 const responseBuf = new Uint8Array(

core/runtime.rs

@@ -2852,7 +2852,7 @@ pub mod tests {
       .execute_script_static(
         "filename.js",
         r#"
-        const { op_test } = Deno.core.generateAsyncOpHandler("op_test");
+        const { op_test } = Deno.core.ensureFastOps();
         let zero_copy_a = new Uint8Array([0]);
         op_test(null, zero_copy_a);
         "#,
@@ -4942,7 +4942,7 @@ Deno.core.opAsync("op_async_serialize_object_with_numbers_as_keys", {
       throw new Error();
     }
 
-    const { op_test_async } = Deno.core.generateAsyncOpHandler("op_test_async");
+    const { op_test_async } = Deno.core.ensureFastOps();
     if (op_test_async.name !== "op_test_async") {
       throw new Error();
     }

ext/fs/30_fs.js

@@ -10,13 +10,7 @@ const {
   op_fs_truncate_async,
   op_fs_link_async,
   op_fs_flock_async,
-} = Deno.core.generateAsyncOpHandler(
-  "op_fs_chmod_async",
-  "op_fs_ftruncate_async",
-  "op_fs_truncate_async",
-  "op_fs_link_async",
-  "op_fs_flock_async",
-);
+} = Deno.core.ensureFastOps();
 const primordials = globalThis.__bootstrap.primordials;
 const {
   ArrayPrototypeFilter,

ext/http/00_serve.js

@@ -70,25 +70,7 @@ const {
   op_http_upgrade_websocket_next,
   op_http_try_wait,
   op_http_wait,
-} = core.generateAsyncOpHandler(
-  "op_http_get_request_headers",
-  "op_http_get_request_method_and_url",
-  "op_http_read_request_body",
-  "op_http_serve",
-  "op_http_serve_on",
-  "op_http_set_promise_complete",
-  "op_http_set_response_body_bytes",
-  "op_http_set_response_body_resource",
-  "op_http_set_response_body_stream",
-  "op_http_set_response_body_text",
-  "op_http_set_response_header",
-  "op_http_set_response_headers",
-  "op_http_set_response_trailers",
-  "op_http_upgrade_raw",
-  "op_http_upgrade_websocket_next",
-  "op_http_try_wait",
-  "op_http_wait",
-);
+} = core.ensureFastOps();
 const _upgraded = Symbol("_upgraded");
 
 function internalServerError() {

ext/http/01_http.js

@@ -6,7 +6,7 @@ const core = globalThis.Deno.core;
 const internals = globalThis.__bootstrap.internals;
 const primordials = globalThis.__bootstrap.primordials;
 const { BadResourcePrototype, InterruptedPrototype, ops } = core;
-const { op_http_write } = Deno.core.generateAsyncOpHandler("op_http_write");
+const { op_http_write } = Deno.core.ensureFastOps();
 import * as webidl from "ext:deno_webidl/00_webidl.js";
 import { InnerBody } from "ext:deno_fetch/22_body.js";
 import { Event, setEventTargetData } from "ext:deno_web/02_event.js";

ext/node/polyfills/internal/crypto/random.ts

@@ -37,11 +37,7 @@ const {
   op_node_gen_prime_async,
   op_node_check_prime_bytes_async,
   op_node_check_prime_async,
-} = Deno.core.generateAsyncOpHandler(
-  "op_node_gen_prime_async",
-  "op_node_check_prime_bytes_async",
-  "op_node_check_prime_async",
-);
+} = Deno.core.ensureFastOps();
 
 export type LargeNumberLike =
   | ArrayBufferView

ext/web/02_timers.js

@@ -27,10 +27,7 @@ const {
 import * as webidl from "ext:deno_webidl/00_webidl.js";
 import { reportException } from "ext:deno_web/02_event.js";
 import { assert } from "ext:deno_web/00_infra.js";
-const { op_sleep, op_void_async_deferred } = core.generateAsyncOpHandler(
-  "op_sleep",
-  "op_void_async_deferred",
-);
+const { op_sleep, op_void_async_deferred } = core.ensureFastOps();
 
 const hrU8 = new Uint8Array(8);
 const hr = new Uint32Array(TypedArrayPrototypeGetBuffer(hrU8));

ext/websocket/01_websocket.js

@@ -57,14 +57,7 @@ const {
   op_ws_send_text,
   op_ws_next_event,
   op_ws_send_ping,
-} = core.generateAsyncOpHandler(
-  "op_ws_create",
-  "op_ws_close",
-  "op_ws_send_binary",
-  "op_ws_send_text",
-  "op_ws_next_event",
-  "op_ws_send_ping",
-);
+} = core.ensureFastOps();
 
 webidl.converters["sequence<DOMString> or DOMString"] = (
   V,

ext/websocket/02_websocketstream.js

@@ -39,13 +39,7 @@ const {
   op_ws_next_event,
   op_ws_create,
   op_ws_close,
-} = core.generateAsyncOpHandler(
-  "op_ws_send_text",
-  "op_ws_send_binary",
-  "op_ws_next_event",
-  "op_ws_create",
-  "op_ws_close",
-);
+} = core.ensureFastOps();
 
 webidl.converters.WebSocketStreamOptions = webidl.createDictionaryConverter(
   "WebSocketStreamOptions",