More improvements to debugger support (#4345)

* More fixes for dap

* More changes

* More changes 2

* More fixes

* Fix debugger.ts

* Bun Terminal

1 files changed, 3 insertions, 3 deletions

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;
 //
 
 //