More improvements to debugger support (#4345)

* More fixes for dap

* More changes

* More changes 2

* More fixes

* Fix debugger.ts

* Bun Terminal

6 files changed, 109 insertions, 39 deletions

diff --git a/src/bun.js/node/types.zig b/src/bun.js/node/types.zig
index 79fdf9e6b..6c4ee9f51 100644
--- a/src/bun.js/node/types.zig
+++ b/src/bun.js/node/types.zig
@@ -626,6 +626,14 @@ pub const PathLike = union(Tag) {
 
     pub const Tag = enum { string, buffer, slice_with_underlying_string };
 
+    pub fn estimatedSize(this: *const PathLike) usize {
+        return switch (this.*) {
+            .string => this.string.estimatedSize(),
+            .buffer => this.buffer.slice().len,
+            .slice_with_underlying_string => 0,
+        };
+    }
+
     pub fn deinit(this: *const PathLike) void {
         if (this.* == .slice_with_underlying_string) {
             this.slice_with_underlying_string.deinit();
@@ -1059,6 +1067,13 @@ pub const PathOrFileDescriptor = union(Tag) {
         }
     }
 
+    pub fn estimatedSize(this: *const PathOrFileDescriptor) usize {
+        return switch (this.*) {
+            .path => this.path.estimatedSize(),
+            .fd => 0,
+        };
+    }
+
     pub fn toThreadSafe(this: *PathOrFileDescriptor) void {
         if (this.* == .path) {
             this.path.toThreadSafe();
diff --git a/src/bun.js/webcore/blob.zig b/src/bun.js/webcore/blob.zig
index 604726c1e..c8d842a21 100644
--- a/src/bun.js/webcore/blob.zig
+++ b/src/bun.js/webcore/blob.zig
@@ -1253,8 +1253,8 @@ pub const Blob = struct {
         if (this.store) |store| {
             size += @sizeOf(Blob.Store);
             size += switch (store.data) {
-                .bytes => store.data.bytes.stored_name.len,
-                .file => store.data.file.pathlike.path.slice().len,
+                .bytes => store.data.bytes.stored_name.estimatedSize(),
+                .file => store.data.file.pathlike.estimatedSize(),
             };
         }
 
diff --git a/src/cli.zig b/src/cli.zig
index 0fb618afc..156f9e48d 100644
--- a/src/cli.zig
+++ b/src/cli.zig
@@ -543,6 +543,15 @@ pub const Arguments = struct {
                         .wait_for_connection = true,
                         .set_breakpoint_on_first_line = true,
                     } };
+            } else if (bun.getenvZ("BUN_INSPECT")) |inspect_value| {
+                ctx.runtime_options.debugger = if (inspect_value.len == 0 or inspect_value[0] == '0')
+                    Command.Debugger{ .unspecified = {} }
+                else
+                    Command.Debugger{ .enable = .{
+                        .path_or_port = inspect_value[1..],
+                        .wait_for_connection = inspect_value[0] == '1' or inspect_value[0] == '2',
+                        .set_breakpoint_on_first_line = inspect_value[0] == '2',
+                    } };
             }
         }
 
diff --git a/src/js/internal/debugger.ts b/src/js/internal/debugger.ts
index 2b121949a..2e76b2c7c 100644
--- a/src/js/internal/debugger.ts
+++ b/src/js/internal/debugger.ts
@@ -2,6 +2,7 @@ import type * as BunType from "bun";
 
 // We want to avoid dealing with creating a prototype for the inspector class
 let sendFn_, disconnectFn_;
+const colors = Bun.enableANSIColors && process.env.NO_COLOR !== "1";
 
 var debuggerCounter = 1;
 class DebuggerWithMessageQueue {
@@ -31,7 +32,7 @@ function generatePath() {
 }
 
 function terminalLink(url) {
-  if (Bun.enableANSIColors) {
+  if (colors) {
     // bold + hyperlink + reset
     return "\x1b[1m\x1b]8;;" + url + "\x1b\\" + url + "\x1b]8;;\x1b\\" + "\x1b[22m";
   }
@@ -40,7 +41,7 @@ function terminalLink(url) {
 }
 
 function dim(text) {
-  if (Bun.enableANSIColors) {
+  if (colors) {
     return "\x1b[2m" + text + "\x1b[22m";
   }
 
@@ -63,7 +64,12 @@ class WebSocketListener {
   start(url: string): BunType.Server {
     let defaultHostname = "localhost";
     let usingDefaultPort = false;
-    if (/^[0-9]*$/.test(url)) {
+    let isUnix = false;
+
+    if (url.startsWith("ws+unix://")) {
+      isUnix = true;
+      url = url.slice(10);
+    } else if (/^[0-9]*$/.test(url)) {
       url = "ws://" + defaultHostname + ":" + url + generatePath();
     } else if (!url || url.startsWith("/")) {
       url = "ws://" + defaultHostname + ":" + defaultPort + generatePath();
@@ -81,19 +87,21 @@ class WebSocketListener {
       }
     }
 
-    try {
-      var { hostname, port, pathname } = new URL(url);
-      this.url = pathname.toLowerCase();
-    } catch (e) {
-      console.error("[Inspector]", "Failed to parse url", '"' + url + '"');
-      process.exit(1);
+    if (!isUnix) {
+      try {
+        var { hostname, port, pathname } = new URL(url);
+        this.url = pathname.toLowerCase();
+      } catch (e) {
+        console.error("[Inspector]", "Failed to parse url", '"' + url + '"');
+        process.exit(1);
+      }
     }
 
     const serveOptions: BunType.WebSocketServeOptions<DebuggerWithMessageQueue> = {
-      hostname,
+      ...(isUnix ? { unix: url } : { hostname }),
       development: false,
 
-      //  ts-ignore
+      // @ts-ignore
       reusePort: false,
 
       websocket: {
@@ -130,16 +138,18 @@ class WebSocketListener {
             },
           );
 
-          console.log(
-            "[Inspector]",
-            "Connection #" + connection.count + " opened",
-            "(" +
-              new Intl.DateTimeFormat(undefined, {
-                "timeStyle": "long",
-                "dateStyle": "short",
-              }).format(new Date()) +
-              ")",
-          );
+          if (!isUnix) {
+            console.log(
+              "[Inspector]",
+              "Connection #" + connection.count + " opened",
+              "(" +
+                new Intl.DateTimeFormat(undefined, {
+                  "timeStyle": "long",
+                  "dateStyle": "short",
+                }).format(new Date()) +
+                ")",
+            );
+          }
         },
         drain: socket => {
           const queue = socket.data.messageQueue;
@@ -160,16 +170,18 @@ class WebSocketListener {
         },
         close: socket => {
           socket.data.disconnect();
-          console.log(
-            "[Inspector]",
-            "Connection #" + socket.data.count + " closed",
-            "(" +
-              new Intl.DateTimeFormat(undefined, {
-                "timeStyle": "long",
-                "dateStyle": "short",
-              }).format(new Date()) +
-              ")",
-          );
+          if (!isUnix) {
+            console.log(
+              "[Inspector]",
+              "Connection #" + socket.data.count + " closed",
+              "(" +
+                new Intl.DateTimeFormat(undefined, {
+                  "timeStyle": "long",
+                  "dateStyle": "short",
+                }).format(new Date()) +
+                ")",
+            );
+          }
           this.activeConnections.delete(socket);
         },
       },
@@ -186,7 +198,7 @@ class WebSocketListener {
           });
         }
 
-        if (pathname === this.url) {
+        if (!this.url || pathname === this.url) {
           const refHeader = req.headers.get("Ref-Event-Loop");
           if (
             server.upgrade(req, {
@@ -224,6 +236,9 @@ class WebSocketListener {
             ...serveOptions,
             port: portNumber++,
           });
+          if (isUnix) {
+            notify();
+          }
         } catch (e) {
           lastError = e;
         }
@@ -234,6 +249,9 @@ class WebSocketListener {
           ...serveOptions,
           port: portNumber,
         });
+        if (isUnix) {
+          notify();
+        }
       } catch (e) {
         lastError = e;
       }
@@ -253,10 +271,16 @@ class WebSocketListener {
       console.write(textToWrite);
     }
 
+    if (!this.url) {
+      return server;
+    }
+
     // yellow foreground
     writeToConsole(dim(`------------------ Bun Inspector ------------------` + "\n"));
-    // reset background
-    writeToConsole("\x1b[49m");
+    if (colors) {
+      // reset background
+      writeToConsole("\x1b[49m");
+    }
 
     writeToConsole(
       "Listening at:\n  " +
@@ -273,6 +297,24 @@ class WebSocketListener {
   }
 }
 
+function notify(): void {
+  const unix = process.env["BUN_INSPECT_NOTIFY"];
+  if (!unix || !unix.startsWith("unix://")) {
+    return;
+  }
+  Bun.connect({
+    unix: unix.slice(7),
+    socket: {
+      open: socket => {
+        socket.end("1");
+      },
+      data: () => {}, // required or it errors
+    },
+  }).finally(() => {
+    // Do nothing
+  });
+}
+
 interface Debugger {
   send(msg: string): void;
   disconnect(): void;
diff --git a/src/js/out/InternalModuleRegistryConstants.h b/src/js/out/InternalModuleRegistryConstants.h
index 3c8ff89c3..2977af3cf 100644
--- a/src/js/out/InternalModuleRegistryConstants.h
+++ b/src/js/out/InternalModuleRegistryConstants.h
@@ -14,7 +14,7 @@ static constexpr ASCIILiteral BunSqliteCode = "(function (){\"use strict\";// sr
 //
 
 //
-static constexpr ASCIILiteral InternalDebuggerCode = "(function (){\"use strict\";// src/js/out/tmp/internal/debugger.ts\nvar generatePath = function() {\n  if (!generatedPath)\n    generatedPath = \"/\" + Math.random().toString(36).slice(2);\n  return generatedPath;\n}, terminalLink = function(url) {\n  if (Bun.enableANSIColors)\n    return \"\\x1B[1m\\x1B]8;;\" + url + \"\\x1B\\\\\" + url + \"\\x1B]8;;\\x1B\\\\\" + \"\\x1B[22m\";\n  return url;\n}, dim = function(text) {\n  if (Bun.enableANSIColors)\n    return \"\\x1B[2m\" + text + \"\\x1B[22m\";\n  return text;\n}, $, sendFn_, disconnectFn_, debuggerCounter = 1;\n\nclass DebuggerWithMessageQueue {\n  debugger = void 0;\n  messageQueue = [];\n  count = debuggerCounter++;\n  send(msg) {\n    sendFn_.call(this.debugger, msg);\n  }\n  disconnect() {\n    disconnectFn_.call(this.debugger), this.messageQueue.length = 0;\n  }\n}\nvar defaultPort = 6499, generatedPath = \"\";\n\nclass WebSocketListener {\n  server;\n  url = \"\";\n  createInspectorConnection;\n  scriptExecutionContextId = 0;\n  activeConnections = new Set;\n  constructor(scriptExecutionContextId = 0, url, createInspectorConnection) {\n    this.scriptExecutionContextId = scriptExecutionContextId, this.createInspectorConnection = createInspectorConnection, this.server = this.start(url);\n  }\n  start(url) {\n    let defaultHostname = \"localhost\", usingDefaultPort = !1;\n    if (/^[0-9]*$/.test(url))\n      url = \"ws://\" + defaultHostname + \":\" + url + generatePath();\n    else if (!url || url.startsWith(\"/\"))\n      url = \"ws://\" + defaultHostname + \":\" + defaultPort + generatePath(), usingDefaultPort = !0;\n    else if (url.includes(\":\") && !url.includes(\"://\"))\n      try {\n        const insertSlash = !url.includes(\"/\");\n        if (url = new URL(\"ws://\" + url).href, insertSlash)\n          url += generatePath().slice(1);\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    try {\n      var { hostname, port, pathname } = new URL(url);\n      this.url = pathname.toLowerCase();\n    } catch (e) {\n      console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n    }\n    const serveOptions = {\n      hostname,\n      development: !1,\n      reusePort: !1,\n      websocket: {\n        idleTimeout: 0,\n        open: (socket) => {\n          var connection = new DebuggerWithMessageQueue;\n          const shouldRefEventLoop = !!socket.data\?.shouldRefEventLoop;\n          socket.data = connection, this.activeConnections.add(socket), connection.debugger = this.createInspectorConnection(this.scriptExecutionContextId, shouldRefEventLoop, (...msgs) => {\n            if (socket.readyState > 1) {\n              connection.disconnect();\n              return;\n            }\n            if (connection.messageQueue.length > 0) {\n              connection.messageQueue.push(...msgs);\n              return;\n            }\n            for (let i = 0;i < msgs.length; i++)\n              if (!socket.sendText(msgs[i])) {\n                if (socket.readyState < 2)\n                  connection.messageQueue.push(...msgs.slice(i));\n                return;\n              }\n          }), console.log(\"[Inspector]\", \"Connection #\" + connection.count + \" opened\", \"(\" + new Intl.DateTimeFormat(void 0, {\n            timeStyle: \"long\",\n            dateStyle: \"short\"\n          }).format(new Date) + \")\");\n        },\n        drain: (socket) => {\n          const queue = socket.data.messageQueue;\n          for (let i = 0;i < queue.length; i++)\n            if (!socket.sendText(queue[i])) {\n              socket.data.messageQueue = queue.slice(i);\n              return;\n            }\n          queue.length = 0;\n        },\n        message: (socket, message) => {\n          if (typeof message !== \"string\") {\n            console.warn(\"[Inspector]\", \"Received non-string message\");\n            return;\n          }\n          socket.data.send(message);\n        },\n        close: (socket) => {\n          socket.data.disconnect(), console.log(\"[Inspector]\", \"Connection #\" + socket.data.count + \" closed\", \"(\" + new Intl.DateTimeFormat(void 0, {\n            timeStyle: \"long\",\n            dateStyle: \"short\"\n          }).format(new Date) + \")\"), this.activeConnections.delete(socket);\n        }\n      },\n      fetch: (req, server2) => {\n        let { pathname: pathname2 } = new URL(req.url);\n        if (pathname2 = pathname2.toLowerCase(), pathname2 === \"/json/version\")\n          return Response.json({\n            Browser: navigator.userAgent,\n            \"WebKit-Version\": process.versions.webkit,\n            \"Bun-Version\": Bun.version,\n            \"Bun-Revision\": Bun.revision\n          });\n        if (pathname2 === this.url) {\n          const refHeader = req.headers.get(\"Ref-Event-Loop\");\n          if (server2.upgrade(req, {\n            data: {\n              shouldRefEventLoop: !!refHeader && refHeader !== \"0\"\n            }\n          }))\n            return new Response;\n          return new Response(\"WebSocket expected\", {\n            status: 400\n          });\n        }\n        return new Response(\"Not found\", {\n          status: 404\n        });\n      }\n    };\n    if (port === \"\")\n      port = defaultPort + \"\";\n    let portNumber = Number(port);\n    var server, lastError;\n    if (usingDefaultPort)\n      for (let tries = 0;tries < 10 && !server; tries++)\n        try {\n          lastError = void 0, server = Bun.serve({\n            ...serveOptions,\n            port: portNumber++\n          });\n        } catch (e) {\n          lastError = e;\n        }\n    else\n      try {\n        server = Bun.serve({\n          ...serveOptions,\n          port: portNumber\n        });\n      } catch (e) {\n        lastError = e;\n      }\n    if (!server) {\n      if (console.error(\"[Inspector]\", \"Failed to start server\"), lastError)\n        console.error(lastError);\n      process.exit(1);\n    }\n    let textToWrite = \"\";\n    function writeToConsole(text) {\n      textToWrite += text;\n    }\n    function flushToConsole() {\n      console.write(textToWrite);\n    }\n    return writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), writeToConsole(\"\\x1B[49m\"), writeToConsole(\"Listening at:\\n  \" + `ws://${hostname}:${server.port}${this.url}` + \"\\n\\nInspect in browser:\\n  \" + terminalLink(new URL(`https://debug.bun.sh#${server.hostname}:${server.port}${this.url}`).href) + \"\\n\"), writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), flushToConsole(), server;\n  }\n}\nvar listener;\n$ = function start(debuggerId, hostOrPort, createInspectorConnection, sendFn, disconnectFn) {\n  try {\n    sendFn_ = sendFn, disconnectFn_ = disconnectFn, globalThis.listener = listener ||= new WebSocketListener(debuggerId, hostOrPort, createInspectorConnection);\n  } catch (e) {\n    console.error(\"Bun Inspector threw an exception\\n\", e), process.exit(1);\n  }\n  return `http://${listener.server.hostname}:${listener.server.port}${listener.url}`;\n};\nreturn $})\n"_s;
+static constexpr ASCIILiteral InternalDebuggerCode = "(function (){\"use strict\";// src/js/out/tmp/internal/debugger.ts\nvar generatePath = function() {\n  if (!generatedPath)\n    generatedPath = \"/\" + Math.random().toString(36).slice(2);\n  return generatedPath;\n}, terminalLink = function(url) {\n  if (colors)\n    return \"\\x1B[1m\\x1B]8;;\" + url + \"\\x1B\\\\\" + url + \"\\x1B]8;;\\x1B\\\\\" + \"\\x1B[22m\";\n  return url;\n}, dim = function(text) {\n  if (colors)\n    return \"\\x1B[2m\" + text + \"\\x1B[22m\";\n  return text;\n}, notify = function() {\n  const unix = process.env.BUN_INSPECT_NOTIFY;\n  if (!unix || !unix.startsWith(\"unix://\"))\n    return;\n  Bun.connect({\n    unix: unix.slice(7),\n    socket: {\n      open: (socket) => {\n        socket.end(\"1\");\n      },\n      data: () => {\n      }\n    }\n  }).finally(() => {\n  });\n}, $, sendFn_, disconnectFn_, colors = Bun.enableANSIColors && process.env.NO_COLOR !== \"1\", debuggerCounter = 1;\n\nclass DebuggerWithMessageQueue {\n  debugger = void 0;\n  messageQueue = [];\n  count = debuggerCounter++;\n  send(msg) {\n    sendFn_.call(this.debugger, msg);\n  }\n  disconnect() {\n    disconnectFn_.call(this.debugger), this.messageQueue.length = 0;\n  }\n}\nvar defaultPort = 6499, generatedPath = \"\";\n\nclass WebSocketListener {\n  server;\n  url = \"\";\n  createInspectorConnection;\n  scriptExecutionContextId = 0;\n  activeConnections = new Set;\n  constructor(scriptExecutionContextId = 0, url, createInspectorConnection) {\n    this.scriptExecutionContextId = scriptExecutionContextId, this.createInspectorConnection = createInspectorConnection, this.server = this.start(url);\n  }\n  start(url) {\n    let defaultHostname = \"localhost\", usingDefaultPort = !1, isUnix = !1;\n    if (url.startsWith(\"ws+unix://\"))\n      isUnix = !0, url = url.slice(10);\n    else if (/^[0-9]*$/.test(url))\n      url = \"ws://\" + defaultHostname + \":\" + url + generatePath();\n    else if (!url || url.startsWith(\"/\"))\n      url = \"ws://\" + defaultHostname + \":\" + defaultPort + generatePath(), usingDefaultPort = !0;\n    else if (url.includes(\":\") && !url.includes(\"://\"))\n      try {\n        const insertSlash = !url.includes(\"/\");\n        if (url = new URL(\"ws://\" + url).href, insertSlash)\n          url += generatePath().slice(1);\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    if (!isUnix)\n      try {\n        var { hostname, port, pathname } = new URL(url);\n        this.url = pathname.toLowerCase();\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    const serveOptions = {\n      ...isUnix \? { unix: url } : { hostname },\n      development: !1,\n      reusePort: !1,\n      websocket: {\n        idleTimeout: 0,\n        open: (socket) => {\n          var connection = new DebuggerWithMessageQueue;\n          const shouldRefEventLoop = !!socket.data\?.shouldRefEventLoop;\n          if (socket.data = connection, this.activeConnections.add(socket), connection.debugger = this.createInspectorConnection(this.scriptExecutionContextId, shouldRefEventLoop, (...msgs) => {\n            if (socket.readyState > 1) {\n              connection.disconnect();\n              return;\n            }\n            if (connection.messageQueue.length > 0) {\n              connection.messageQueue.push(...msgs);\n              return;\n            }\n            for (let i = 0;i < msgs.length; i++)\n              if (!socket.sendText(msgs[i])) {\n                if (socket.readyState < 2)\n                  connection.messageQueue.push(...msgs.slice(i));\n                return;\n              }\n          }), !isUnix)\n            console.log(\"[Inspector]\", \"Connection #\" + connection.count + \" opened\", \"(\" + new Intl.DateTimeFormat(void 0, {\n              timeStyle: \"long\",\n              dateStyle: \"short\"\n            }).format(new Date) + \")\");\n        },\n        drain: (socket) => {\n          const queue = socket.data.messageQueue;\n          for (let i = 0;i < queue.length; i++)\n            if (!socket.sendText(queue[i])) {\n              socket.data.messageQueue = queue.slice(i);\n              return;\n            }\n          queue.length = 0;\n        },\n        message: (socket, message) => {\n          if (typeof message !== \"string\") {\n            console.warn(\"[Inspector]\", \"Received non-string message\");\n            return;\n          }\n          socket.data.send(message);\n        },\n        close: (socket) => {\n          if (socket.data.disconnect(), !isUnix)\n            console.log(\"[Inspector]\", \"Connection #\" + socket.data.count + \" closed\", \"(\" + new Intl.DateTimeFormat(void 0, {\n              timeStyle: \"long\",\n              dateStyle: \"short\"\n            }).format(new Date) + \")\");\n          this.activeConnections.delete(socket);\n        }\n      },\n      fetch: (req, server2) => {\n        let { pathname: pathname2 } = new URL(req.url);\n        if (pathname2 = pathname2.toLowerCase(), pathname2 === \"/json/version\")\n          return Response.json({\n            Browser: navigator.userAgent,\n            \"WebKit-Version\": process.versions.webkit,\n            \"Bun-Version\": Bun.version,\n            \"Bun-Revision\": Bun.revision\n          });\n        if (!this.url || pathname2 === this.url) {\n          const refHeader = req.headers.get(\"Ref-Event-Loop\");\n          if (server2.upgrade(req, {\n            data: {\n              shouldRefEventLoop: !!refHeader && refHeader !== \"0\"\n            }\n          }))\n            return new Response;\n          return new Response(\"WebSocket expected\", {\n            status: 400\n          });\n        }\n        return new Response(\"Not found\", {\n          status: 404\n        });\n      }\n    };\n    if (port === \"\")\n      port = defaultPort + \"\";\n    let portNumber = Number(port);\n    var server, lastError;\n    if (usingDefaultPort)\n      for (let tries = 0;tries < 10 && !server; tries++)\n        try {\n          if (lastError = void 0, server = Bun.serve({\n            ...serveOptions,\n            port: portNumber++\n          }), isUnix)\n            notify();\n        } catch (e) {\n          lastError = e;\n        }\n    else\n      try {\n        if (server = Bun.serve({\n          ...serveOptions,\n          port: portNumber\n        }), isUnix)\n          notify();\n      } catch (e) {\n        lastError = e;\n      }\n    if (!server) {\n      if (console.error(\"[Inspector]\", \"Failed to start server\"), lastError)\n        console.error(lastError);\n      process.exit(1);\n    }\n    let textToWrite = \"\";\n    function writeToConsole(text) {\n      textToWrite += text;\n    }\n    function flushToConsole() {\n      console.write(textToWrite);\n    }\n    if (!this.url)\n      return server;\n    if (writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), colors)\n      writeToConsole(\"\\x1B[49m\");\n    return writeToConsole(\"Listening at:\\n  \" + `ws://${hostname}:${server.port}${this.url}` + \"\\n\\nInspect in browser:\\n  \" + terminalLink(new URL(`https://debug.bun.sh#${server.hostname}:${server.port}${this.url}`).href) + \"\\n\"), writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), flushToConsole(), server;\n  }\n}\nvar listener;\n$ = function start(debuggerId, hostOrPort, createInspectorConnection, sendFn, disconnectFn) {\n  try {\n    sendFn_ = sendFn, disconnectFn_ = disconnectFn, globalThis.listener = listener ||= new WebSocketListener(debuggerId, hostOrPort, createInspectorConnection);\n  } catch (e) {\n    console.error(\"Bun Inspector threw an exception\\n\", e), process.exit(1);\n  }\n  return `http://${listener.server.hostname}:${listener.server.port}${listener.url}`;\n};\nreturn $})\n"_s;
 //
 
 //
@@ -247,7 +247,7 @@ static constexpr ASCIILiteral BunSqliteCode = "(function (){\"use strict\";// sr
 //
 
 //
-static constexpr ASCIILiteral InternalDebuggerCode = "(function (){\"use strict\";// src/js/out/tmp/internal/debugger.ts\nvar generatePath = function() {\n  if (!generatedPath)\n    generatedPath = \"/\" + Math.random().toString(36).slice(2);\n  return generatedPath;\n}, terminalLink = function(url) {\n  if (Bun.enableANSIColors)\n    return \"\\x1B[1m\\x1B]8;;\" + url + \"\\x1B\\\\\" + url + \"\\x1B]8;;\\x1B\\\\\" + \"\\x1B[22m\";\n  return url;\n}, dim = function(text) {\n  if (Bun.enableANSIColors)\n    return \"\\x1B[2m\" + text + \"\\x1B[22m\";\n  return text;\n}, $, sendFn_, disconnectFn_, debuggerCounter = 1;\n\nclass DebuggerWithMessageQueue {\n  debugger = void 0;\n  messageQueue = [];\n  count = debuggerCounter++;\n  send(msg) {\n    sendFn_.call(this.debugger, msg);\n  }\n  disconnect() {\n    disconnectFn_.call(this.debugger), this.messageQueue.length = 0;\n  }\n}\nvar defaultPort = 6499, generatedPath = \"\";\n\nclass WebSocketListener {\n  server;\n  url = \"\";\n  createInspectorConnection;\n  scriptExecutionContextId = 0;\n  activeConnections = new Set;\n  constructor(scriptExecutionContextId = 0, url, createInspectorConnection) {\n    this.scriptExecutionContextId = scriptExecutionContextId, this.createInspectorConnection = createInspectorConnection, this.server = this.start(url);\n  }\n  start(url) {\n    let defaultHostname = \"localhost\", usingDefaultPort = !1;\n    if (/^[0-9]*$/.test(url))\n      url = \"ws://\" + defaultHostname + \":\" + url + generatePath();\n    else if (!url || url.startsWith(\"/\"))\n      url = \"ws://\" + defaultHostname + \":\" + defaultPort + generatePath(), usingDefaultPort = !0;\n    else if (url.includes(\":\") && !url.includes(\"://\"))\n      try {\n        const insertSlash = !url.includes(\"/\");\n        if (url = new URL(\"ws://\" + url).href, insertSlash)\n          url += generatePath().slice(1);\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    try {\n      var { hostname, port, pathname } = new URL(url);\n      this.url = pathname.toLowerCase();\n    } catch (e) {\n      console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n    }\n    const serveOptions = {\n      hostname,\n      development: !1,\n      reusePort: !1,\n      websocket: {\n        idleTimeout: 0,\n        open: (socket) => {\n          var connection = new DebuggerWithMessageQueue;\n          const shouldRefEventLoop = !!socket.data\?.shouldRefEventLoop;\n          socket.data = connection, this.activeConnections.add(socket), connection.debugger = this.createInspectorConnection(this.scriptExecutionContextId, shouldRefEventLoop, (...msgs) => {\n            if (socket.readyState > 1) {\n              connection.disconnect();\n              return;\n            }\n            if (connection.messageQueue.length > 0) {\n              connection.messageQueue.push(...msgs);\n              return;\n            }\n            for (let i = 0;i < msgs.length; i++)\n              if (!socket.sendText(msgs[i])) {\n                if (socket.readyState < 2)\n                  connection.messageQueue.push(...msgs.slice(i));\n                return;\n              }\n          }), console.log(\"[Inspector]\", \"Connection #\" + connection.count + \" opened\", \"(\" + new Intl.DateTimeFormat(void 0, {\n            timeStyle: \"long\",\n            dateStyle: \"short\"\n          }).format(new Date) + \")\");\n        },\n        drain: (socket) => {\n          const queue = socket.data.messageQueue;\n          for (let i = 0;i < queue.length; i++)\n            if (!socket.sendText(queue[i])) {\n              socket.data.messageQueue = queue.slice(i);\n              return;\n            }\n          queue.length = 0;\n        },\n        message: (socket, message) => {\n          if (typeof message !== \"string\") {\n            console.warn(\"[Inspector]\", \"Received non-string message\");\n            return;\n          }\n          socket.data.send(message);\n        },\n        close: (socket) => {\n          socket.data.disconnect(), console.log(\"[Inspector]\", \"Connection #\" + socket.data.count + \" closed\", \"(\" + new Intl.DateTimeFormat(void 0, {\n            timeStyle: \"long\",\n            dateStyle: \"short\"\n          }).format(new Date) + \")\"), this.activeConnections.delete(socket);\n        }\n      },\n      fetch: (req, server2) => {\n        let { pathname: pathname2 } = new URL(req.url);\n        if (pathname2 = pathname2.toLowerCase(), pathname2 === \"/json/version\")\n          return Response.json({\n            Browser: navigator.userAgent,\n            \"WebKit-Version\": process.versions.webkit,\n            \"Bun-Version\": Bun.version,\n            \"Bun-Revision\": Bun.revision\n          });\n        if (pathname2 === this.url) {\n          const refHeader = req.headers.get(\"Ref-Event-Loop\");\n          if (server2.upgrade(req, {\n            data: {\n              shouldRefEventLoop: !!refHeader && refHeader !== \"0\"\n            }\n          }))\n            return new Response;\n          return new Response(\"WebSocket expected\", {\n            status: 400\n          });\n        }\n        return new Response(\"Not found\", {\n          status: 404\n        });\n      }\n    };\n    if (port === \"\")\n      port = defaultPort + \"\";\n    let portNumber = Number(port);\n    var server, lastError;\n    if (usingDefaultPort)\n      for (let tries = 0;tries < 10 && !server; tries++)\n        try {\n          lastError = void 0, server = Bun.serve({\n            ...serveOptions,\n            port: portNumber++\n          });\n        } catch (e) {\n          lastError = e;\n        }\n    else\n      try {\n        server = Bun.serve({\n          ...serveOptions,\n          port: portNumber\n        });\n      } catch (e) {\n        lastError = e;\n      }\n    if (!server) {\n      if (console.error(\"[Inspector]\", \"Failed to start server\"), lastError)\n        console.error(lastError);\n      process.exit(1);\n    }\n    let textToWrite = \"\";\n    function writeToConsole(text) {\n      textToWrite += text;\n    }\n    function flushToConsole() {\n      console.write(textToWrite);\n    }\n    return writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), writeToConsole(\"\\x1B[49m\"), writeToConsole(\"Listening at:\\n  \" + `ws://${hostname}:${server.port}${this.url}` + \"\\n\\nInspect in browser:\\n  \" + terminalLink(new URL(`https://debug.bun.sh#${server.hostname}:${server.port}${this.url}`).href) + \"\\n\"), writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), flushToConsole(), server;\n  }\n}\nvar listener;\n$ = function start(debuggerId, hostOrPort, createInspectorConnection, sendFn, disconnectFn) {\n  try {\n    sendFn_ = sendFn, disconnectFn_ = disconnectFn, globalThis.listener = listener ||= new WebSocketListener(debuggerId, hostOrPort, createInspectorConnection);\n  } catch (e) {\n    console.error(\"Bun Inspector threw an exception\\n\", e), process.exit(1);\n  }\n  return `http://${listener.server.hostname}:${listener.server.port}${listener.url}`;\n};\nreturn $})\n"_s;
+static constexpr ASCIILiteral InternalDebuggerCode = "(function (){\"use strict\";// src/js/out/tmp/internal/debugger.ts\nvar generatePath = function() {\n  if (!generatedPath)\n    generatedPath = \"/\" + Math.random().toString(36).slice(2);\n  return generatedPath;\n}, terminalLink = function(url) {\n  if (colors)\n    return \"\\x1B[1m\\x1B]8;;\" + url + \"\\x1B\\\\\" + url + \"\\x1B]8;;\\x1B\\\\\" + \"\\x1B[22m\";\n  return url;\n}, dim = function(text) {\n  if (colors)\n    return \"\\x1B[2m\" + text + \"\\x1B[22m\";\n  return text;\n}, notify = function() {\n  const unix = process.env.BUN_INSPECT_NOTIFY;\n  if (!unix || !unix.startsWith(\"unix://\"))\n    return;\n  Bun.connect({\n    unix: unix.slice(7),\n    socket: {\n      open: (socket) => {\n        socket.end(\"1\");\n      },\n      data: () => {\n      }\n    }\n  }).finally(() => {\n  });\n}, $, sendFn_, disconnectFn_, colors = Bun.enableANSIColors && process.env.NO_COLOR !== \"1\", debuggerCounter = 1;\n\nclass DebuggerWithMessageQueue {\n  debugger = void 0;\n  messageQueue = [];\n  count = debuggerCounter++;\n  send(msg) {\n    sendFn_.call(this.debugger, msg);\n  }\n  disconnect() {\n    disconnectFn_.call(this.debugger), this.messageQueue.length = 0;\n  }\n}\nvar defaultPort = 6499, generatedPath = \"\";\n\nclass WebSocketListener {\n  server;\n  url = \"\";\n  createInspectorConnection;\n  scriptExecutionContextId = 0;\n  activeConnections = new Set;\n  constructor(scriptExecutionContextId = 0, url, createInspectorConnection) {\n    this.scriptExecutionContextId = scriptExecutionContextId, this.createInspectorConnection = createInspectorConnection, this.server = this.start(url);\n  }\n  start(url) {\n    let defaultHostname = \"localhost\", usingDefaultPort = !1, isUnix = !1;\n    if (url.startsWith(\"ws+unix://\"))\n      isUnix = !0, url = url.slice(10);\n    else if (/^[0-9]*$/.test(url))\n      url = \"ws://\" + defaultHostname + \":\" + url + generatePath();\n    else if (!url || url.startsWith(\"/\"))\n      url = \"ws://\" + defaultHostname + \":\" + defaultPort + generatePath(), usingDefaultPort = !0;\n    else if (url.includes(\":\") && !url.includes(\"://\"))\n      try {\n        const insertSlash = !url.includes(\"/\");\n        if (url = new URL(\"ws://\" + url).href, insertSlash)\n          url += generatePath().slice(1);\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    if (!isUnix)\n      try {\n        var { hostname, port, pathname } = new URL(url);\n        this.url = pathname.toLowerCase();\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    const serveOptions = {\n      ...isUnix \? { unix: url } : { hostname },\n      development: !1,\n      reusePort: !1,\n      websocket: {\n        idleTimeout: 0,\n        open: (socket) => {\n          var connection = new DebuggerWithMessageQueue;\n          const shouldRefEventLoop = !!socket.data\?.shouldRefEventLoop;\n          if (socket.data = connection, this.activeConnections.add(socket), connection.debugger = this.createInspectorConnection(this.scriptExecutionContextId, shouldRefEventLoop, (...msgs) => {\n            if (socket.readyState > 1) {\n              connection.disconnect();\n              return;\n            }\n            if (connection.messageQueue.length > 0) {\n              connection.messageQueue.push(...msgs);\n              return;\n            }\n            for (let i = 0;i < msgs.length; i++)\n              if (!socket.sendText(msgs[i])) {\n                if (socket.readyState < 2)\n                  connection.messageQueue.push(...msgs.slice(i));\n                return;\n              }\n          }), !isUnix)\n            console.log(\"[Inspector]\", \"Connection #\" + connection.count + \" opened\", \"(\" + new Intl.DateTimeFormat(void 0, {\n              timeStyle: \"long\",\n              dateStyle: \"short\"\n            }).format(new Date) + \")\");\n        },\n        drain: (socket) => {\n          const queue = socket.data.messageQueue;\n          for (let i = 0;i < queue.length; i++)\n            if (!socket.sendText(queue[i])) {\n              socket.data.messageQueue = queue.slice(i);\n              return;\n            }\n          queue.length = 0;\n        },\n        message: (socket, message) => {\n          if (typeof message !== \"string\") {\n            console.warn(\"[Inspector]\", \"Received non-string message\");\n            return;\n          }\n          socket.data.send(message);\n        },\n        close: (socket) => {\n          if (socket.data.disconnect(), !isUnix)\n            console.log(\"[Inspector]\", \"Connection #\" + socket.data.count + \" closed\", \"(\" + new Intl.DateTimeFormat(void 0, {\n              timeStyle: \"long\",\n              dateStyle: \"short\"\n            }).format(new Date) + \")\");\n          this.activeConnections.delete(socket);\n        }\n      },\n      fetch: (req, server2) => {\n        let { pathname: pathname2 } = new URL(req.url);\n        if (pathname2 = pathname2.toLowerCase(), pathname2 === \"/json/version\")\n          return Response.json({\n            Browser: navigator.userAgent,\n            \"WebKit-Version\": process.versions.webkit,\n            \"Bun-Version\": Bun.version,\n            \"Bun-Revision\": Bun.revision\n          });\n        if (!this.url || pathname2 === this.url) {\n          const refHeader = req.headers.get(\"Ref-Event-Loop\");\n          if (server2.upgrade(req, {\n            data: {\n              shouldRefEventLoop: !!refHeader && refHeader !== \"0\"\n            }\n          }))\n            return new Response;\n          return new Response(\"WebSocket expected\", {\n            status: 400\n          });\n        }\n        return new Response(\"Not found\", {\n          status: 404\n        });\n      }\n    };\n    if (port === \"\")\n      port = defaultPort + \"\";\n    let portNumber = Number(port);\n    var server, lastError;\n    if (usingDefaultPort)\n      for (let tries = 0;tries < 10 && !server; tries++)\n        try {\n          if (lastError = void 0, server = Bun.serve({\n            ...serveOptions,\n            port: portNumber++\n          }), isUnix)\n            notify();\n        } catch (e) {\n          lastError = e;\n        }\n    else\n      try {\n        if (server = Bun.serve({\n          ...serveOptions,\n          port: portNumber\n        }), isUnix)\n          notify();\n      } catch (e) {\n        lastError = e;\n      }\n    if (!server) {\n      if (console.error(\"[Inspector]\", \"Failed to start server\"), lastError)\n        console.error(lastError);\n      process.exit(1);\n    }\n    let textToWrite = \"\";\n    function writeToConsole(text) {\n      textToWrite += text;\n    }\n    function flushToConsole() {\n      console.write(textToWrite);\n    }\n    if (!this.url)\n      return server;\n    if (writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), colors)\n      writeToConsole(\"\\x1B[49m\");\n    return writeToConsole(\"Listening at:\\n  \" + `ws://${hostname}:${server.port}${this.url}` + \"\\n\\nInspect in browser:\\n  \" + terminalLink(new URL(`https://debug.bun.sh#${server.hostname}:${server.port}${this.url}`).href) + \"\\n\"), writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), flushToConsole(), server;\n  }\n}\nvar listener;\n$ = function start(debuggerId, hostOrPort, createInspectorConnection, sendFn, disconnectFn) {\n  try {\n    sendFn_ = sendFn, disconnectFn_ = disconnectFn, globalThis.listener = listener ||= new WebSocketListener(debuggerId, hostOrPort, createInspectorConnection);\n  } catch (e) {\n    console.error(\"Bun Inspector threw an exception\\n\", e), process.exit(1);\n  }\n  return `http://${listener.server.hostname}:${listener.server.port}${listener.url}`;\n};\nreturn $})\n"_s;
 //
 
 //
@@ -481,7 +481,7 @@ static constexpr ASCIILiteral BunSqliteCode = "(function (){\"use strict\";// sr
 //
 
 //
-static constexpr ASCIILiteral InternalDebuggerCode = "(function (){\"use strict\";// src/js/out/tmp/internal/debugger.ts\nvar generatePath = function() {\n  if (!generatedPath)\n    generatedPath = \"/\" + Math.random().toString(36).slice(2);\n  return generatedPath;\n}, terminalLink = function(url) {\n  if (Bun.enableANSIColors)\n    return \"\\x1B[1m\\x1B]8;;\" + url + \"\\x1B\\\\\" + url + \"\\x1B]8;;\\x1B\\\\\" + \"\\x1B[22m\";\n  return url;\n}, dim = function(text) {\n  if (Bun.enableANSIColors)\n    return \"\\x1B[2m\" + text + \"\\x1B[22m\";\n  return text;\n}, $, sendFn_, disconnectFn_, debuggerCounter = 1;\n\nclass DebuggerWithMessageQueue {\n  debugger = void 0;\n  messageQueue = [];\n  count = debuggerCounter++;\n  send(msg) {\n    sendFn_.call(this.debugger, msg);\n  }\n  disconnect() {\n    disconnectFn_.call(this.debugger), this.messageQueue.length = 0;\n  }\n}\nvar defaultPort = 6499, generatedPath = \"\";\n\nclass WebSocketListener {\n  server;\n  url = \"\";\n  createInspectorConnection;\n  scriptExecutionContextId = 0;\n  activeConnections = new Set;\n  constructor(scriptExecutionContextId = 0, url, createInspectorConnection) {\n    this.scriptExecutionContextId = scriptExecutionContextId, this.createInspectorConnection = createInspectorConnection, this.server = this.start(url);\n  }\n  start(url) {\n    let defaultHostname = \"localhost\", usingDefaultPort = !1;\n    if (/^[0-9]*$/.test(url))\n      url = \"ws://\" + defaultHostname + \":\" + url + generatePath();\n    else if (!url || url.startsWith(\"/\"))\n      url = \"ws://\" + defaultHostname + \":\" + defaultPort + generatePath(), usingDefaultPort = !0;\n    else if (url.includes(\":\") && !url.includes(\"://\"))\n      try {\n        const insertSlash = !url.includes(\"/\");\n        if (url = new URL(\"ws://\" + url).href, insertSlash)\n          url += generatePath().slice(1);\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    try {\n      var { hostname, port, pathname } = new URL(url);\n      this.url = pathname.toLowerCase();\n    } catch (e) {\n      console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n    }\n    const serveOptions = {\n      hostname,\n      development: !1,\n      reusePort: !1,\n      websocket: {\n        idleTimeout: 0,\n        open: (socket) => {\n          var connection = new DebuggerWithMessageQueue;\n          const shouldRefEventLoop = !!socket.data\?.shouldRefEventLoop;\n          socket.data = connection, this.activeConnections.add(socket), connection.debugger = this.createInspectorConnection(this.scriptExecutionContextId, shouldRefEventLoop, (...msgs) => {\n            if (socket.readyState > 1) {\n              connection.disconnect();\n              return;\n            }\n            if (connection.messageQueue.length > 0) {\n              connection.messageQueue.push(...msgs);\n              return;\n            }\n            for (let i = 0;i < msgs.length; i++)\n              if (!socket.sendText(msgs[i])) {\n                if (socket.readyState < 2)\n                  connection.messageQueue.push(...msgs.slice(i));\n                return;\n              }\n          }), console.log(\"[Inspector]\", \"Connection #\" + connection.count + \" opened\", \"(\" + new Intl.DateTimeFormat(void 0, {\n            timeStyle: \"long\",\n            dateStyle: \"short\"\n          }).format(new Date) + \")\");\n        },\n        drain: (socket) => {\n          const queue = socket.data.messageQueue;\n          for (let i = 0;i < queue.length; i++)\n            if (!socket.sendText(queue[i])) {\n              socket.data.messageQueue = queue.slice(i);\n              return;\n            }\n          queue.length = 0;\n        },\n        message: (socket, message) => {\n          if (typeof message !== \"string\") {\n            console.warn(\"[Inspector]\", \"Received non-string message\");\n            return;\n          }\n          socket.data.send(message);\n        },\n        close: (socket) => {\n          socket.data.disconnect(), console.log(\"[Inspector]\", \"Connection #\" + socket.data.count + \" closed\", \"(\" + new Intl.DateTimeFormat(void 0, {\n            timeStyle: \"long\",\n            dateStyle: \"short\"\n          }).format(new Date) + \")\"), this.activeConnections.delete(socket);\n        }\n      },\n      fetch: (req, server2) => {\n        let { pathname: pathname2 } = new URL(req.url);\n        if (pathname2 = pathname2.toLowerCase(), pathname2 === \"/json/version\")\n          return Response.json({\n            Browser: navigator.userAgent,\n            \"WebKit-Version\": process.versions.webkit,\n            \"Bun-Version\": Bun.version,\n            \"Bun-Revision\": Bun.revision\n          });\n        if (pathname2 === this.url) {\n          const refHeader = req.headers.get(\"Ref-Event-Loop\");\n          if (server2.upgrade(req, {\n            data: {\n              shouldRefEventLoop: !!refHeader && refHeader !== \"0\"\n            }\n          }))\n            return new Response;\n          return new Response(\"WebSocket expected\", {\n            status: 400\n          });\n        }\n        return new Response(\"Not found\", {\n          status: 404\n        });\n      }\n    };\n    if (port === \"\")\n      port = defaultPort + \"\";\n    let portNumber = Number(port);\n    var server, lastError;\n    if (usingDefaultPort)\n      for (let tries = 0;tries < 10 && !server; tries++)\n        try {\n          lastError = void 0, server = Bun.serve({\n            ...serveOptions,\n            port: portNumber++\n          });\n        } catch (e) {\n          lastError = e;\n        }\n    else\n      try {\n        server = Bun.serve({\n          ...serveOptions,\n          port: portNumber\n        });\n      } catch (e) {\n        lastError = e;\n      }\n    if (!server) {\n      if (console.error(\"[Inspector]\", \"Failed to start server\"), lastError)\n        console.error(lastError);\n      process.exit(1);\n    }\n    let textToWrite = \"\";\n    function writeToConsole(text) {\n      textToWrite += text;\n    }\n    function flushToConsole() {\n      console.write(textToWrite);\n    }\n    return writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), writeToConsole(\"\\x1B[49m\"), writeToConsole(\"Listening at:\\n  \" + `ws://${hostname}:${server.port}${this.url}` + \"\\n\\nInspect in browser:\\n  \" + terminalLink(new URL(`https://debug.bun.sh#${server.hostname}:${server.port}${this.url}`).href) + \"\\n\"), writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), flushToConsole(), server;\n  }\n}\nvar listener;\n$ = function start(debuggerId, hostOrPort, createInspectorConnection, sendFn, disconnectFn) {\n  try {\n    sendFn_ = sendFn, disconnectFn_ = disconnectFn, globalThis.listener = listener ||= new WebSocketListener(debuggerId, hostOrPort, createInspectorConnection);\n  } catch (e) {\n    console.error(\"Bun Inspector threw an exception\\n\", e), process.exit(1);\n  }\n  return `http://${listener.server.hostname}:${listener.server.port}${listener.url}`;\n};\nreturn $})\n"_s;
+static constexpr ASCIILiteral InternalDebuggerCode = "(function (){\"use strict\";// src/js/out/tmp/internal/debugger.ts\nvar generatePath = function() {\n  if (!generatedPath)\n    generatedPath = \"/\" + Math.random().toString(36).slice(2);\n  return generatedPath;\n}, terminalLink = function(url) {\n  if (colors)\n    return \"\\x1B[1m\\x1B]8;;\" + url + \"\\x1B\\\\\" + url + \"\\x1B]8;;\\x1B\\\\\" + \"\\x1B[22m\";\n  return url;\n}, dim = function(text) {\n  if (colors)\n    return \"\\x1B[2m\" + text + \"\\x1B[22m\";\n  return text;\n}, notify = function() {\n  const unix = process.env.BUN_INSPECT_NOTIFY;\n  if (!unix || !unix.startsWith(\"unix://\"))\n    return;\n  Bun.connect({\n    unix: unix.slice(7),\n    socket: {\n      open: (socket) => {\n        socket.end(\"1\");\n      },\n      data: () => {\n      }\n    }\n  }).finally(() => {\n  });\n}, $, sendFn_, disconnectFn_, colors = Bun.enableANSIColors && process.env.NO_COLOR !== \"1\", debuggerCounter = 1;\n\nclass DebuggerWithMessageQueue {\n  debugger = void 0;\n  messageQueue = [];\n  count = debuggerCounter++;\n  send(msg) {\n    sendFn_.call(this.debugger, msg);\n  }\n  disconnect() {\n    disconnectFn_.call(this.debugger), this.messageQueue.length = 0;\n  }\n}\nvar defaultPort = 6499, generatedPath = \"\";\n\nclass WebSocketListener {\n  server;\n  url = \"\";\n  createInspectorConnection;\n  scriptExecutionContextId = 0;\n  activeConnections = new Set;\n  constructor(scriptExecutionContextId = 0, url, createInspectorConnection) {\n    this.scriptExecutionContextId = scriptExecutionContextId, this.createInspectorConnection = createInspectorConnection, this.server = this.start(url);\n  }\n  start(url) {\n    let defaultHostname = \"localhost\", usingDefaultPort = !1, isUnix = !1;\n    if (url.startsWith(\"ws+unix://\"))\n      isUnix = !0, url = url.slice(10);\n    else if (/^[0-9]*$/.test(url))\n      url = \"ws://\" + defaultHostname + \":\" + url + generatePath();\n    else if (!url || url.startsWith(\"/\"))\n      url = \"ws://\" + defaultHostname + \":\" + defaultPort + generatePath(), usingDefaultPort = !0;\n    else if (url.includes(\":\") && !url.includes(\"://\"))\n      try {\n        const insertSlash = !url.includes(\"/\");\n        if (url = new URL(\"ws://\" + url).href, insertSlash)\n          url += generatePath().slice(1);\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    if (!isUnix)\n      try {\n        var { hostname, port, pathname } = new URL(url);\n        this.url = pathname.toLowerCase();\n      } catch (e) {\n        console.error(\"[Inspector]\", \"Failed to parse url\", '\"' + url + '\"'), process.exit(1);\n      }\n    const serveOptions = {\n      ...isUnix \? { unix: url } : { hostname },\n      development: !1,\n      reusePort: !1,\n      websocket: {\n        idleTimeout: 0,\n        open: (socket) => {\n          var connection = new DebuggerWithMessageQueue;\n          const shouldRefEventLoop = !!socket.data\?.shouldRefEventLoop;\n          if (socket.data = connection, this.activeConnections.add(socket), connection.debugger = this.createInspectorConnection(this.scriptExecutionContextId, shouldRefEventLoop, (...msgs) => {\n            if (socket.readyState > 1) {\n              connection.disconnect();\n              return;\n            }\n            if (connection.messageQueue.length > 0) {\n              connection.messageQueue.push(...msgs);\n              return;\n            }\n            for (let i = 0;i < msgs.length; i++)\n              if (!socket.sendText(msgs[i])) {\n                if (socket.readyState < 2)\n                  connection.messageQueue.push(...msgs.slice(i));\n                return;\n              }\n          }), !isUnix)\n            console.log(\"[Inspector]\", \"Connection #\" + connection.count + \" opened\", \"(\" + new Intl.DateTimeFormat(void 0, {\n              timeStyle: \"long\",\n              dateStyle: \"short\"\n            }).format(new Date) + \")\");\n        },\n        drain: (socket) => {\n          const queue = socket.data.messageQueue;\n          for (let i = 0;i < queue.length; i++)\n            if (!socket.sendText(queue[i])) {\n              socket.data.messageQueue = queue.slice(i);\n              return;\n            }\n          queue.length = 0;\n        },\n        message: (socket, message) => {\n          if (typeof message !== \"string\") {\n            console.warn(\"[Inspector]\", \"Received non-string message\");\n            return;\n          }\n          socket.data.send(message);\n        },\n        close: (socket) => {\n          if (socket.data.disconnect(), !isUnix)\n            console.log(\"[Inspector]\", \"Connection #\" + socket.data.count + \" closed\", \"(\" + new Intl.DateTimeFormat(void 0, {\n              timeStyle: \"long\",\n              dateStyle: \"short\"\n            }).format(new Date) + \")\");\n          this.activeConnections.delete(socket);\n        }\n      },\n      fetch: (req, server2) => {\n        let { pathname: pathname2 } = new URL(req.url);\n        if (pathname2 = pathname2.toLowerCase(), pathname2 === \"/json/version\")\n          return Response.json({\n            Browser: navigator.userAgent,\n            \"WebKit-Version\": process.versions.webkit,\n            \"Bun-Version\": Bun.version,\n            \"Bun-Revision\": Bun.revision\n          });\n        if (!this.url || pathname2 === this.url) {\n          const refHeader = req.headers.get(\"Ref-Event-Loop\");\n          if (server2.upgrade(req, {\n            data: {\n              shouldRefEventLoop: !!refHeader && refHeader !== \"0\"\n            }\n          }))\n            return new Response;\n          return new Response(\"WebSocket expected\", {\n            status: 400\n          });\n        }\n        return new Response(\"Not found\", {\n          status: 404\n        });\n      }\n    };\n    if (port === \"\")\n      port = defaultPort + \"\";\n    let portNumber = Number(port);\n    var server, lastError;\n    if (usingDefaultPort)\n      for (let tries = 0;tries < 10 && !server; tries++)\n        try {\n          if (lastError = void 0, server = Bun.serve({\n            ...serveOptions,\n            port: portNumber++\n          }), isUnix)\n            notify();\n        } catch (e) {\n          lastError = e;\n        }\n    else\n      try {\n        if (server = Bun.serve({\n          ...serveOptions,\n          port: portNumber\n        }), isUnix)\n          notify();\n      } catch (e) {\n        lastError = e;\n      }\n    if (!server) {\n      if (console.error(\"[Inspector]\", \"Failed to start server\"), lastError)\n        console.error(lastError);\n      process.exit(1);\n    }\n    let textToWrite = \"\";\n    function writeToConsole(text) {\n      textToWrite += text;\n    }\n    function flushToConsole() {\n      console.write(textToWrite);\n    }\n    if (!this.url)\n      return server;\n    if (writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), colors)\n      writeToConsole(\"\\x1B[49m\");\n    return writeToConsole(\"Listening at:\\n  \" + `ws://${hostname}:${server.port}${this.url}` + \"\\n\\nInspect in browser:\\n  \" + terminalLink(new URL(`https://debug.bun.sh#${server.hostname}:${server.port}${this.url}`).href) + \"\\n\"), writeToConsole(dim(\"------------------ Bun Inspector ------------------\\n\")), flushToConsole(), server;\n  }\n}\nvar listener;\n$ = function start(debuggerId, hostOrPort, createInspectorConnection, sendFn, disconnectFn) {\n  try {\n    sendFn_ = sendFn, disconnectFn_ = disconnectFn, globalThis.listener = listener ||= new WebSocketListener(debuggerId, hostOrPort, createInspectorConnection);\n  } catch (e) {\n    console.error(\"Bun Inspector threw an exception\\n\", e), process.exit(1);\n  }\n  return `http://${listener.server.hostname}:${listener.server.port}${listener.url}`;\n};\nreturn $})\n"_s;
 //
 
 //
diff --git a/src/string_types.zig b/src/string_types.zig
index ab048b008..4697a5508 100644
--- a/src/string_types.zig
+++ b/src/string_types.zig
@@ -31,6 +31,10 @@ pub const PathString = packed struct {
         return this.toValue().asObjectRef();
     }
 
+    pub fn estimatedSize(this: *const PathString) usize {
+        return @as(usize, this.len);
+    }
+
     pub fn toJS(this: PathString, ctx: JSC.C.JSContextRef, _: JSC.C.ExceptionRef) JSC.C.JSValueRef {
         var zig_str = JSC.ZigString.init(this.slice());
         zig_str.detectEncoding();