Implement `AsyncLocalStorage` (#3089)

* work to get async local storage working.

* a

* a

* everything but queueMicrotask

* sdfghj

* .

* finish

* tests

* test

* ok

* done

* im so stupid

* Upgrade WebKit

* refactor

* refactor

* changes requested

* oops

* cool

* fix runInAsyncScope

1 files changed, 0 insertions, 212 deletions

diff --git a/src/js/node/async_hooks.js b/src/js/node/async_hooks.js
deleted file mode 100644
index ec82ce8aa..000000000
--- a/src/js/node/async_hooks.js
+++ /dev/null
@@ -1,212 +0,0 @@
-// Hardcoded module "node:async_hooks"
-import { drainMicrotasks } from "bun:jsc";
-
-var notImplemented = () => {
-  console.warn(
-    "[bun] Warning: async_hooks has not been implemented yet. See https://github.com/oven-sh/bun/issues/1832",
-  );
-  notImplemented = () => {};
-};
-
-class AsyncLocalStorage {
-  #store;
-  _enabled;
-
-  constructor() {
-    this._enabled = false;
-    this.#store = null;
-  }
-
-  enterWith(store) {
-    this.#store = store;
-    notImplemented();
-
-    return this;
-  }
-
-  exit(cb, ...args) {
-    this.#store = null;
-    notImplemented();
-    typeof cb === "function" && cb(...args);
-  }
-
-  run(store, callback, ...args) {
-    if (typeof callback !== "function") throw new TypeError("ERR_INVALID_CALLBACK");
-    var result, err;
-
-    process.nextTick(store => {
-      const prev = this.#store;
-      this.enterWith(store);
-      try {
-        result = callback(...args);
-      } catch (e) {
-        err = e;
-      } finally {
-        this.#store = prev;
-      }
-    }, store);
-    drainMicrotasks();
-    if (typeof err !== "undefined") {
-      throw err;
-    }
-    return result;
-  }
-
-  getStore() {
-    return this.#store;
-  }
-}
-
-function createHook() {
-  return {
-    enable() {
-      notImplemented();
-    },
-    disable() {
-      notImplemented();
-    },
-  };
-}
-
-function executionAsyncId() {
-  return 0;
-}
-
-function triggerAsyncId() {
-  return 0;
-}
-
-function executionAsyncResource() {
-  return null;
-}
-
-const asyncWrapProviders = {
-  NONE: 0,
-  DIRHANDLE: 1,
-  DNSCHANNEL: 2,
-  ELDHISTOGRAM: 3,
-  FILEHANDLE: 4,
-  FILEHANDLECLOSEREQ: 5,
-  FIXEDSIZEBLOBCOPY: 6,
-  FSEVENTWRAP: 7,
-  FSREQCALLBACK: 8,
-  FSREQPROMISE: 9,
-  GETADDRINFOREQWRAP: 10,
-  GETNAMEINFOREQWRAP: 11,
-  HEAPSNAPSHOT: 12,
-  HTTP2SESSION: 13,
-  HTTP2STREAM: 14,
-  HTTP2PING: 15,
-  HTTP2SETTINGS: 16,
-  HTTPINCOMINGMESSAGE: 17,
-  HTTPCLIENTREQUEST: 18,
-  JSSTREAM: 19,
-  JSUDPWRAP: 20,
-  MESSAGEPORT: 21,
-  PIPECONNECTWRAP: 22,
-  PIPESERVERWRAP: 23,
-  PIPEWRAP: 24,
-  PROCESSWRAP: 25,
-  PROMISE: 26,
-  QUERYWRAP: 27,
-  SHUTDOWNWRAP: 28,
-  SIGNALWRAP: 29,
-  STATWATCHER: 30,
-  STREAMPIPE: 31,
-  TCPCONNECTWRAP: 32,
-  TCPSERVERWRAP: 33,
-  TCPWRAP: 34,
-  TTYWRAP: 35,
-  UDPSENDWRAP: 36,
-  UDPWRAP: 37,
-  SIGINTWATCHDOG: 38,
-  WORKER: 39,
-  WORKERHEAPSNAPSHOT: 40,
-  WRITEWRAP: 41,
-  ZLIB: 42,
-  CHECKPRIMEREQUEST: 43,
-  PBKDF2REQUEST: 44,
-  KEYPAIRGENREQUEST: 45,
-  KEYGENREQUEST: 46,
-  KEYEXPORTREQUEST: 47,
-  CIPHERREQUEST: 48,
-  DERIVEBITSREQUEST: 49,
-  HASHREQUEST: 50,
-  RANDOMBYTESREQUEST: 51,
-  RANDOMPRIMEREQUEST: 52,
-  SCRYPTREQUEST: 53,
-  SIGNREQUEST: 54,
-  TLSWRAP: 55,
-  VERIFYREQUEST: 56,
-  INSPECTORJSBINDING: 57,
-};
-
-class AsyncResource {
-  constructor(type, triggerAsyncId) {
-    this.type = type;
-    this.triggerAsyncId = triggerAsyncId;
-
-    if (AsyncResource.allowedRunInAsyncScope.has(type)) {
-      this.runInAsyncScope = this.#runInAsyncScope;
-    }
-  }
-
-  // We probably will not fully support AsyncResource
-  // But some packages in the wild do depend on it
-  static allowedRunInAsyncScope = new Set(["prisma-client-request"]);
-
-  type;
-  triggerAsyncId;
-
-  emitBefore() {
-    return true;
-  }
-
-  emitAfter() {
-    return true;
-  }
-
-  emitDestroy() {}
-
-  runInAsyncScope;
-
-  #runInAsyncScope(fn, ...args) {
-    var result, err;
-    process.nextTick(fn => {
-      try {
-        result = fn(...args);
-      } catch (err2) {
-        err = err2;
-      }
-    }, fn);
-    drainMicrotasks();
-    if (err) throw err;
-    return result;
-  }
-
-  asyncId() {
-    return 0;
-  }
-}
-
-export {
-  AsyncLocalStorage,
-  createHook,
-  executionAsyncId,
-  triggerAsyncId,
-  executionAsyncResource,
-  asyncWrapProviders,
-  AsyncResource,
-};
-
-export default {
-  AsyncLocalStorage,
-  createHook,
-  executionAsyncId,
-  triggerAsyncId,
-  executionAsyncResource,
-  asyncWrapProviders,
-  AsyncResource,
-  [Symbol.toStringTag]: "Module (not implemented yet)",
-  [Symbol.for("CommonJS")]: 0,
-};