From 2bd12b9553a2aecda419baa18f59bc6be7db2d34 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mateusz=20Burzy=C5=84ski?= <mateuszburzynski@gmail.com>
Date: Wed, 7 Jan 2026 16:57:24 +0100
Subject: [PATCH] Use await using for installation token cleanup

---
 .node-version     |   2 +-
 entry             | 996 ++++++++++++++++++++++++----------------------
 esbuild.config.js |   4 +-
 main.ts           |  19 +-
 utils/github.ts   |  25 +-
 5 files changed, 546 insertions(+), 500 deletions(-)

diff --git a/.node-version b/.node-version
index 517f386..3d48712 100644
--- a/.node-version
+++ b/.node-version
@@ -1 +1 @@
-v22.14.0
+v24.3.0
diff --git a/entry b/entry
index 658ea19..4d08062 100755
--- a/entry
+++ b/entry
@@ -5,6 +5,10 @@ var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
 var __getOwnPropNames = Object.getOwnPropertyNames;
 var __getProtoOf = Object.getPrototypeOf;
 var __hasOwnProp = Object.prototype.hasOwnProperty;
+var __knownSymbol = (name, symbol) => (symbol = Symbol[name]) ? symbol : Symbol.for("Symbol." + name);
+var __typeError = (msg) => {
+  throw TypeError(msg);
+};
 var __require = /* @__PURE__ */ ((x) => typeof require !== "undefined" ? require : typeof Proxy !== "undefined" ? new Proxy(x, {
   get: (a, b) => (typeof require !== "undefined" ? require : a)[b]
 }) : x)(function(x) {
@@ -37,6 +41,47 @@ var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__ge
   isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target,
   mod
 ));
+var __using = (stack, value2, async) => {
+  if (value2 != null) {
+    if (typeof value2 !== "object" && typeof value2 !== "function") __typeError("Object expected");
+    var dispose, inner;
+    if (async) dispose = value2[__knownSymbol("asyncDispose")];
+    if (dispose === void 0) {
+      dispose = value2[__knownSymbol("dispose")];
+      if (async) inner = dispose;
+    }
+    if (typeof dispose !== "function") __typeError("Object not disposable");
+    if (inner) dispose = function() {
+      try {
+        inner.call(this);
+      } catch (e) {
+        return Promise.reject(e);
+      }
+    };
+    stack.push([async, dispose, value2]);
+  } else if (async) {
+    stack.push([async]);
+  }
+  return value2;
+};
+var __callDispose = (stack, error41, hasError) => {
+  var E = typeof SuppressedError === "function" ? SuppressedError : function(e, s, m, _) {
+    return _ = Error(m), _.name = "SuppressedError", _.error = e, _.suppressed = s, _;
+  };
+  var fail = (e) => error41 = hasError ? new E(e, error41, "An error was suppressed during disposal") : (hasError = true, e);
+  var next2 = (it) => {
+    while (it = stack.pop()) {
+      try {
+        var result = it[1] && it[1].call(it[2]);
+        if (it[0]) return Promise.resolve(result).then(next2, (e) => (fail(e), next2()));
+      } catch (e) {
+        fail(e);
+      }
+    }
+    if (hasError) throw error41;
+  };
+  return next2();
+};
 
 // node_modules/.pnpm/@actions+core@1.11.1/node_modules/@actions/core/lib/utils.js
 var require_utils = __commonJS({
@@ -312,7 +357,7 @@ var require_tunnel = __commonJS({
     var http2 = __require("http");
     var https = __require("https");
     var events = __require("events");
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var util3 = __require("util");
     exports.httpOverHttp = httpOverHttp;
     exports.httpsOverHttp = httpsOverHttp;
@@ -943,7 +988,7 @@ var require_constants = __commonJS({
 var require_util = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/core/util.js"(exports, module) {
     "use strict";
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { kDestroyed, kBodyUsed } = require_symbols();
     var { IncomingMessage } = __require("http");
     var stream = __require("stream");
@@ -1025,7 +1070,7 @@ var require_util = __commonJS({
     function getHostname(host) {
       if (host[0] === "[") {
         const idx2 = host.indexOf("]");
-        assert2(idx2 !== -1);
+        assert3(idx2 !== -1);
         return host.substring(1, idx2);
       }
       const idx = host.indexOf(":");
@@ -1036,7 +1081,7 @@ var require_util = __commonJS({
       if (!host) {
         return null;
       }
-      assert2.strictEqual(typeof host, "string");
+      assert3.strictEqual(typeof host, "string");
       const servername = getHostname(host);
       if (net.isIP(servername)) {
         return "";
@@ -3639,7 +3684,7 @@ var require_util2 = __commonJS({
     var { getGlobalOrigin } = require_global();
     var { performance: performance2 } = __require("perf_hooks");
     var { isBlobLike, toUSVString, ReadableStreamFrom } = require_util();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { isUint8Array } = __require("util/types");
     var supportedHashes = [];
     var crypto2;
@@ -3829,7 +3874,7 @@ var require_util2 = __commonJS({
     }
     function determineRequestsReferrer(request2) {
       const policy = request2.referrerPolicy;
-      assert2(policy);
+      assert3(policy);
       let referrerSource = null;
       if (request2.referrer === "client") {
         const globalOrigin = getGlobalOrigin();
@@ -3887,7 +3932,7 @@ var require_util2 = __commonJS({
       }
     }
     function stripURLForReferrer(url2, originOnly) {
-      assert2(url2 instanceof URL);
+      assert3(url2 instanceof URL);
       if (url2.protocol === "file:" || url2.protocol === "about:" || url2.protocol === "blank:") {
         return "no-referrer";
       }
@@ -4066,7 +4111,7 @@ var require_util2 = __commonJS({
       if (result === void 0) {
         throw new TypeError("Value is not JSON serializable");
       }
-      assert2(typeof result === "string");
+      assert3(typeof result === "string");
       return result;
     }
     var esIteratorPrototype = Object.getPrototypeOf(Object.getPrototypeOf([][Symbol.iterator]()));
@@ -4160,7 +4205,7 @@ var require_util2 = __commonJS({
     }
     function isomorphicEncode(input) {
       for (let i = 0; i < input.length; i++) {
-        assert2(input.charCodeAt(i) <= 255);
+        assert3(input.charCodeAt(i) <= 255);
       }
       return input;
     }
@@ -4180,7 +4225,7 @@ var require_util2 = __commonJS({
       }
     }
     function urlIsLocal(url2) {
-      assert2("protocol" in url2);
+      assert3("protocol" in url2);
       const protocol = url2.protocol;
       return protocol === "about:" || protocol === "blob:" || protocol === "data:";
     }
@@ -4191,7 +4236,7 @@ var require_util2 = __commonJS({
       return url2.protocol === "https:";
     }
     function urlIsHttpHttpsScheme(url2) {
-      assert2("protocol" in url2);
+      assert3("protocol" in url2);
       const protocol = url2.protocol;
       return protocol === "http:" || protocol === "https:";
     }
@@ -4633,7 +4678,7 @@ var require_webidl = __commonJS({
 // node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/fetch/dataURL.js
 var require_dataURL = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/fetch/dataURL.js"(exports, module) {
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { atob: atob2 } = __require("buffer");
     var { isomorphicDecode } = require_util2();
     var encoder = new TextEncoder();
@@ -4641,7 +4686,7 @@ var require_dataURL = __commonJS({
     var HTTP_WHITESPACE_REGEX = /(\u000A|\u000D|\u0009|\u0020)/;
     var HTTP_QUOTED_STRING_TOKENS = /[\u0009|\u0020-\u007E|\u0080-\u00FF]/;
     function dataURLProcessor(dataURL) {
-      assert2(dataURL.protocol === "data:");
+      assert3(dataURL.protocol === "data:");
       let input = URLSerializer(dataURL, true);
       input = input.slice(5);
       const position = { position: 0 };
@@ -4827,7 +4872,7 @@ var require_dataURL = __commonJS({
     function collectAnHTTPQuotedString(input, position, extractValue) {
       const positionStart = position.position;
       let value2 = "";
-      assert2(input[position.position] === '"');
+      assert3(input[position.position] === '"');
       position.position++;
       while (true) {
         value2 += collectASequenceOfCodePoints(
@@ -4848,7 +4893,7 @@ var require_dataURL = __commonJS({
           value2 += input[position.position];
           position.position++;
         } else {
-          assert2(quoteOrBackslash === '"');
+          assert3(quoteOrBackslash === '"');
           break;
         }
       }
@@ -4858,7 +4903,7 @@ var require_dataURL = __commonJS({
       return input.slice(positionStart, position.position);
     }
     function serializeAMimeType(mimeType) {
-      assert2(mimeType !== "failure");
+      assert3(mimeType !== "failure");
       const { parameters, essence } = mimeType;
       let serialization = essence;
       for (let [name, value2] of parameters.entries()) {
@@ -5277,7 +5322,7 @@ var require_body = __commonJS({
     var { DOMException: DOMException2, structuredClone } = require_constants2();
     var { Blob: Blob2, File: NativeFile } = __require("buffer");
     var { kBodyUsed } = require_symbols();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { isErrored } = require_util();
     var { isUint8Array, isArrayBuffer } = __require("util/types");
     var { File: UndiciFile } = require_file();
@@ -5315,7 +5360,7 @@ var require_body = __commonJS({
           type: void 0
         });
       }
-      assert2(isReadableStreamLike(stream));
+      assert3(isReadableStreamLike(stream));
       let action = null;
       let source = null;
       let length = null;
@@ -5431,8 +5476,8 @@ Content-Type: ${value2.type || "application/octet-stream"}\r
         ReadableStream2 = __require("stream/web").ReadableStream;
       }
       if (object2 instanceof ReadableStream2) {
-        assert2(!util3.isDisturbed(object2), "The body has already been consumed.");
-        assert2(!object2.locked, "The stream is locked.");
+        assert3(!util3.isDisturbed(object2), "The body has already been consumed.");
+        assert3(!object2.locked, "The stream is locked.");
       }
       return extractBody(object2, keepalive);
     }
@@ -5643,7 +5688,7 @@ var require_request = __commonJS({
       InvalidArgumentError,
       NotSupportedError
     } = require_errors();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { kHTTP2BuildRequest, kHTTP2CopyHeaders, kHTTP1BuildRequest } = require_symbols();
     var util3 = require_util();
     var tokenRegExp = /^[\^_`a-zA-Z\-0-9!#$%&'*+.|~]+$/;
@@ -5824,8 +5869,8 @@ var require_request = __commonJS({
         }
       }
       onConnect(abort) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         if (this.error) {
           abort(this.error);
         } else {
@@ -5834,8 +5879,8 @@ var require_request = __commonJS({
         }
       }
       onHeaders(statusCode, headers, resume, statusText) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         if (channels.headers.hasSubscribers) {
           channels.headers.publish({ request: this, response: { statusCode, headers, statusText } });
         }
@@ -5846,8 +5891,8 @@ var require_request = __commonJS({
         }
       }
       onData(chunk) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         try {
           return this[kHandler].onData(chunk);
         } catch (err) {
@@ -5856,13 +5901,13 @@ var require_request = __commonJS({
         }
       }
       onUpgrade(statusCode, headers, socket) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         return this[kHandler].onUpgrade(statusCode, headers, socket);
       }
       onComplete(trailers) {
         this.onFinally();
-        assert2(!this.aborted);
+        assert3(!this.aborted);
         this.completed = true;
         if (channels.trailers.hasSubscribers) {
           channels.trailers.publish({ request: this, trailers });
@@ -6193,7 +6238,7 @@ var require_connect = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/core/connect.js"(exports, module) {
     "use strict";
     var net = __require("net");
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var util3 = require_util();
     var { InvalidArgumentError, ConnectTimeoutError } = require_errors();
     var tls;
@@ -6263,7 +6308,7 @@ var require_connect = __commonJS({
           servername = servername || options.servername || util3.getServerName(host) || null;
           const sessionKey = servername || hostname2;
           const session = sessionCache.get(sessionKey) || null;
-          assert2(sessionKey);
+          assert3(sessionKey);
           socket = tls.connect({
             highWaterMark: 16384,
             // TLS in node can't have bigger HWM anyway...
@@ -6282,7 +6327,7 @@ var require_connect = __commonJS({
             sessionCache.set(sessionKey, session2);
           });
         } else {
-          assert2(!httpSocket, "httpSocket can only be sent on TLS update");
+          assert3(!httpSocket, "httpSocket can only be sent on TLS update");
           socket = net.connect({
             highWaterMark: 64 * 1024,
             // Same as nodejs fs streams.
@@ -6691,7 +6736,7 @@ var require_RedirectHandler = __commonJS({
     "use strict";
     var util3 = require_util();
     var { kBodyUsed } = require_symbols();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { InvalidArgumentError } = require_errors();
     var EE = __require("events");
     var redirectableStatusCodes = [300, 301, 302, 303, 307, 308];
@@ -6702,7 +6747,7 @@ var require_RedirectHandler = __commonJS({
         this[kBodyUsed] = false;
       }
       async *[Symbol.asyncIterator]() {
-        assert2(!this[kBodyUsed], "disturbed");
+        assert3(!this[kBodyUsed], "disturbed");
         this[kBodyUsed] = true;
         yield* this[kBody];
       }
@@ -6723,7 +6768,7 @@ var require_RedirectHandler = __commonJS({
         if (util3.isStream(this.opts.body)) {
           if (util3.bodyLength(this.opts.body) === 0) {
             this.opts.body.on("data", function() {
-              assert2(false);
+              assert3(false);
             });
           }
           if (typeof this.opts.body.readableDidRead !== "boolean") {
@@ -6827,7 +6872,7 @@ var require_RedirectHandler = __commonJS({
           }
         }
       } else {
-        assert2(headers == null, "headers must be an object or an array");
+        assert3(headers == null, "headers must be an object or an array");
       }
       return ret;
     }
@@ -6875,7 +6920,7 @@ var require_llhttp_simd_wasm = __commonJS({
 var require_client = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/client.js"(exports, module) {
     "use strict";
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var net = __require("net");
     var http2 = __require("http");
     var { pipeline: pipeline2 } = __require("stream");
@@ -7213,7 +7258,7 @@ var require_client = __commonJS({
       }
     };
     function onHttp2SessionError(err) {
-      assert2(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
+      assert3(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
       this[kSocket][kError] = err;
       onError(this[kClient], err);
     }
@@ -7234,7 +7279,7 @@ var require_client = __commonJS({
       client[kSocket] = null;
       client[kHTTP2Session] = null;
       if (client.destroyed) {
-        assert2(this[kPending] === 0);
+        assert3(this[kPending] === 0);
         const requests = client[kQueue].splice(client[kRunningIdx]);
         for (let i = 0; i < requests.length; i++) {
           const request2 = requests[i];
@@ -7246,7 +7291,7 @@ var require_client = __commonJS({
         errorRequest(client, request2, err);
       }
       client[kPendingIdx] = client[kRunningIdx];
-      assert2(client[kRunning] === 0);
+      assert3(client[kRunning] === 0);
       client.emit(
         "disconnect",
         client[kUrl],
@@ -7273,35 +7318,35 @@ var require_client = __commonJS({
             return 0;
           },
           wasm_on_status: (p, at, len) => {
-            assert2.strictEqual(currentParser.ptr, p);
+            assert3.strictEqual(currentParser.ptr, p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onStatus(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
           },
           wasm_on_message_begin: (p) => {
-            assert2.strictEqual(currentParser.ptr, p);
+            assert3.strictEqual(currentParser.ptr, p);
             return currentParser.onMessageBegin() || 0;
           },
           wasm_on_header_field: (p, at, len) => {
-            assert2.strictEqual(currentParser.ptr, p);
+            assert3.strictEqual(currentParser.ptr, p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onHeaderField(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
           },
           wasm_on_header_value: (p, at, len) => {
-            assert2.strictEqual(currentParser.ptr, p);
+            assert3.strictEqual(currentParser.ptr, p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onHeaderValue(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
           },
           wasm_on_headers_complete: (p, statusCode, upgrade, shouldKeepAlive) => {
-            assert2.strictEqual(currentParser.ptr, p);
+            assert3.strictEqual(currentParser.ptr, p);
             return currentParser.onHeadersComplete(statusCode, Boolean(upgrade), Boolean(shouldKeepAlive)) || 0;
           },
           wasm_on_body: (p, at, len) => {
-            assert2.strictEqual(currentParser.ptr, p);
+            assert3.strictEqual(currentParser.ptr, p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onBody(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
           },
           wasm_on_message_complete: (p) => {
-            assert2.strictEqual(currentParser.ptr, p);
+            assert3.strictEqual(currentParser.ptr, p);
             return currentParser.onMessageComplete() || 0;
           }
           /* eslint-enable camelcase */
@@ -7320,7 +7365,7 @@ var require_client = __commonJS({
     var TIMEOUT_IDLE = 3;
     var Parser = class {
       constructor(client, socket, { exports: exports2 }) {
-        assert2(Number.isFinite(client[kMaxHeadersSize]) && client[kMaxHeadersSize] > 0);
+        assert3(Number.isFinite(client[kMaxHeadersSize]) && client[kMaxHeadersSize] > 0);
         this.llhttp = exports2;
         this.ptr = this.llhttp.llhttp_alloc(constants.TYPE.RESPONSE);
         this.client = client;
@@ -7366,10 +7411,10 @@ var require_client = __commonJS({
         if (this.socket.destroyed || !this.paused) {
           return;
         }
-        assert2(this.ptr != null);
-        assert2(currentParser == null);
+        assert3(this.ptr != null);
+        assert3(currentParser == null);
         this.llhttp.llhttp_resume(this.ptr);
-        assert2(this.timeoutType === TIMEOUT_BODY);
+        assert3(this.timeoutType === TIMEOUT_BODY);
         if (this.timeout) {
           if (this.timeout.refresh) {
             this.timeout.refresh();
@@ -7389,9 +7434,9 @@ var require_client = __commonJS({
         }
       }
       execute(data) {
-        assert2(this.ptr != null);
-        assert2(currentParser == null);
-        assert2(!this.paused);
+        assert3(this.ptr != null);
+        assert3(currentParser == null);
+        assert3(!this.paused);
         const { socket, llhttp } = this;
         if (data.length > currentBufferSize) {
           if (currentBufferPtr) {
@@ -7433,8 +7478,8 @@ var require_client = __commonJS({
         }
       }
       destroy() {
-        assert2(this.ptr != null);
-        assert2(currentParser == null);
+        assert3(this.ptr != null);
+        assert3(currentParser == null);
         this.llhttp.llhttp_free(this.ptr);
         this.ptr = null;
         timers.clearTimeout(this.timeout);
@@ -7491,17 +7536,17 @@ var require_client = __commonJS({
       }
       onUpgrade(head) {
         const { upgrade, client, socket, headers, statusCode } = this;
-        assert2(upgrade);
+        assert3(upgrade);
         const request2 = client[kQueue][client[kRunningIdx]];
-        assert2(request2);
-        assert2(!socket.destroyed);
-        assert2(socket === client[kSocket]);
-        assert2(!this.paused);
-        assert2(request2.upgrade || request2.method === "CONNECT");
+        assert3(request2);
+        assert3(!socket.destroyed);
+        assert3(socket === client[kSocket]);
+        assert3(!this.paused);
+        assert3(request2.upgrade || request2.method === "CONNECT");
         this.statusCode = null;
         this.statusText = "";
         this.shouldKeepAlive = null;
-        assert2(this.headers.length % 2 === 0);
+        assert3(this.headers.length % 2 === 0);
         this.headers = [];
         this.headersSize = 0;
         socket.unshift(head);
@@ -7529,8 +7574,8 @@ var require_client = __commonJS({
         if (!request2) {
           return -1;
         }
-        assert2(!this.upgrade);
-        assert2(this.statusCode < 200);
+        assert3(!this.upgrade);
+        assert3(this.statusCode < 200);
         if (statusCode === 100) {
           util3.destroy(socket, new SocketError("bad response", util3.getSocketInfo(socket)));
           return -1;
@@ -7539,7 +7584,7 @@ var require_client = __commonJS({
           util3.destroy(socket, new SocketError("bad upgrade", util3.getSocketInfo(socket)));
           return -1;
         }
-        assert2.strictEqual(this.timeoutType, TIMEOUT_HEADERS);
+        assert3.strictEqual(this.timeoutType, TIMEOUT_HEADERS);
         this.statusCode = statusCode;
         this.shouldKeepAlive = shouldKeepAlive || // Override llhttp value which does not allow keepAlive for HEAD.
         request2.method === "HEAD" && !socket[kReset] && this.connection.toLowerCase() === "keep-alive";
@@ -7552,16 +7597,16 @@ var require_client = __commonJS({
           }
         }
         if (request2.method === "CONNECT") {
-          assert2(client[kRunning] === 1);
+          assert3(client[kRunning] === 1);
           this.upgrade = true;
           return 2;
         }
         if (upgrade) {
-          assert2(client[kRunning] === 1);
+          assert3(client[kRunning] === 1);
           this.upgrade = true;
           return 2;
         }
-        assert2(this.headers.length % 2 === 0);
+        assert3(this.headers.length % 2 === 0);
         this.headers = [];
         this.headersSize = 0;
         if (this.shouldKeepAlive && client[kPipelining]) {
@@ -7604,14 +7649,14 @@ var require_client = __commonJS({
           return -1;
         }
         const request2 = client[kQueue][client[kRunningIdx]];
-        assert2(request2);
-        assert2.strictEqual(this.timeoutType, TIMEOUT_BODY);
+        assert3(request2);
+        assert3.strictEqual(this.timeoutType, TIMEOUT_BODY);
         if (this.timeout) {
           if (this.timeout.refresh) {
             this.timeout.refresh();
           }
         }
-        assert2(statusCode >= 200);
+        assert3(statusCode >= 200);
         if (maxResponseSize > -1 && this.bytesRead + buf.length > maxResponseSize) {
           util3.destroy(socket, new ResponseExceededMaxSizeError());
           return -1;
@@ -7630,15 +7675,15 @@ var require_client = __commonJS({
           return;
         }
         const request2 = client[kQueue][client[kRunningIdx]];
-        assert2(request2);
-        assert2(statusCode >= 100);
+        assert3(request2);
+        assert3(statusCode >= 100);
         this.statusCode = null;
         this.statusText = "";
         this.bytesRead = 0;
         this.contentLength = "";
         this.keepAlive = "";
         this.connection = "";
-        assert2(this.headers.length % 2 === 0);
+        assert3(this.headers.length % 2 === 0);
         this.headers = [];
         this.headersSize = 0;
         if (statusCode < 200) {
@@ -7651,7 +7696,7 @@ var require_client = __commonJS({
         request2.onComplete(headers);
         client[kQueue][client[kRunningIdx]++] = null;
         if (socket[kWriting]) {
-          assert2.strictEqual(client[kRunning], 0);
+          assert3.strictEqual(client[kRunning], 0);
           util3.destroy(socket, new InformationalError("reset"));
           return constants.ERROR.PAUSED;
         } else if (!shouldKeepAlive) {
@@ -7671,7 +7716,7 @@ var require_client = __commonJS({
       const { socket, timeoutType, client } = parser;
       if (timeoutType === TIMEOUT_HEADERS) {
         if (!socket[kWriting] || socket.writableNeedDrain || client[kRunning] > 1) {
-          assert2(!parser.paused, "cannot be paused while waiting for headers");
+          assert3(!parser.paused, "cannot be paused while waiting for headers");
           util3.destroy(socket, new HeadersTimeoutError());
         }
       } else if (timeoutType === TIMEOUT_BODY) {
@@ -7679,7 +7724,7 @@ var require_client = __commonJS({
           util3.destroy(socket, new BodyTimeoutError());
         }
       } else if (timeoutType === TIMEOUT_IDLE) {
-        assert2(client[kRunning] === 0 && client[kKeepAliveTimeoutValue]);
+        assert3(client[kRunning] === 0 && client[kKeepAliveTimeoutValue]);
         util3.destroy(socket, new InformationalError("socket idle timeout"));
       }
     }
@@ -7691,7 +7736,7 @@ var require_client = __commonJS({
     }
     function onSocketError(err) {
       const { [kClient]: client, [kParser]: parser } = this;
-      assert2(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
+      assert3(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
       if (client[kHTTPConnVersion] !== "h2") {
         if (err.code === "ECONNRESET" && parser.statusCode && !parser.shouldKeepAlive) {
           parser.onMessageComplete();
@@ -7703,13 +7748,13 @@ var require_client = __commonJS({
     }
     function onError(client, err) {
       if (client[kRunning] === 0 && err.code !== "UND_ERR_INFO" && err.code !== "UND_ERR_SOCKET") {
-        assert2(client[kPendingIdx] === client[kRunningIdx]);
+        assert3(client[kPendingIdx] === client[kRunningIdx]);
         const requests = client[kQueue].splice(client[kRunningIdx]);
         for (let i = 0; i < requests.length; i++) {
           const request2 = requests[i];
           errorRequest(client, request2, err);
         }
-        assert2(client[kSize] === 0);
+        assert3(client[kSize] === 0);
       }
     }
     function onSocketEnd() {
@@ -7734,7 +7779,7 @@ var require_client = __commonJS({
       const err = this[kError] || new SocketError("closed", util3.getSocketInfo(this));
       client[kSocket] = null;
       if (client.destroyed) {
-        assert2(client[kPending] === 0);
+        assert3(client[kPending] === 0);
         const requests = client[kQueue].splice(client[kRunningIdx]);
         for (let i = 0; i < requests.length; i++) {
           const request2 = requests[i];
@@ -7746,19 +7791,19 @@ var require_client = __commonJS({
         errorRequest(client, request2, err);
       }
       client[kPendingIdx] = client[kRunningIdx];
-      assert2(client[kRunning] === 0);
+      assert3(client[kRunning] === 0);
       client.emit("disconnect", client[kUrl], [client], err);
       resume(client);
     }
     async function connect(client) {
-      assert2(!client[kConnecting]);
-      assert2(!client[kSocket]);
+      assert3(!client[kConnecting]);
+      assert3(!client[kSocket]);
       let { host, hostname: hostname2, protocol, port } = client[kUrl];
       if (hostname2[0] === "[") {
         const idx = hostname2.indexOf("]");
-        assert2(idx !== -1);
+        assert3(idx !== -1);
         const ip2 = hostname2.substring(1, idx);
-        assert2(net.isIP(ip2));
+        assert3(net.isIP(ip2));
         hostname2 = ip2;
       }
       client[kConnecting] = true;
@@ -7798,7 +7843,7 @@ var require_client = __commonJS({
           return;
         }
         client[kConnecting] = false;
-        assert2(socket);
+        assert3(socket);
         const isH2 = socket.alpnProtocol === "h2";
         if (isH2) {
           if (!h2ExperimentalWarned) {
@@ -7874,7 +7919,7 @@ var require_client = __commonJS({
           });
         }
         if (err.code === "ERR_TLS_CERT_ALTNAME_INVALID") {
-          assert2(client[kRunning] === 0);
+          assert3(client[kRunning] === 0);
           while (client[kPending] > 0 && client[kQueue][client[kPendingIdx]].servername === client[kServerName]) {
             const request2 = client[kQueue][client[kPendingIdx]++];
             errorRequest(client, request2, err);
@@ -7906,7 +7951,7 @@ var require_client = __commonJS({
     function _resume(client, sync) {
       while (true) {
         if (client.destroyed) {
-          assert2(client[kPending] === 0);
+          assert3(client[kPending] === 0);
           return;
         }
         if (client[kClosedResolve] && !client[kSize]) {
@@ -8078,13 +8123,13 @@ upgrade: ${upgrade}\r
 \r
 `, "latin1");
         } else {
-          assert2(contentLength === null, "no body must not have content length");
+          assert3(contentLength === null, "no body must not have content length");
           socket.write(`${header}\r
 `, "latin1");
         }
         request2.onRequestSent();
       } else if (util3.isBuffer(body)) {
-        assert2(contentLength === body.byteLength, "buffer body must have content length");
+        assert3(contentLength === body.byteLength, "buffer body must have content length");
         socket.cork();
         socket.write(`${header}content-length: ${contentLength}\r
 \r
@@ -8107,7 +8152,7 @@ upgrade: ${upgrade}\r
       } else if (util3.isIterable(body)) {
         writeIterable({ body, client, request: request2, socket, contentLength, header, expectsPayload });
       } else {
-        assert2(false);
+        assert3(false);
       }
       return true;
     }
@@ -8176,7 +8221,7 @@ upgrade: ${upgrade}\r
         process.emitWarning(new RequestContentLengthMismatchError());
       }
       if (contentLength != null) {
-        assert2(body, "no body must not have content length");
+        assert3(body, "no body must not have content length");
         headers[HTTP2_HEADER_CONTENT_LENGTH] = `${contentLength}`;
       }
       session.ref();
@@ -8232,7 +8277,7 @@ upgrade: ${upgrade}\r
         if (!body) {
           request2.onRequestSent();
         } else if (util3.isBuffer(body)) {
-          assert2(contentLength === body.byteLength, "buffer body must have content length");
+          assert3(contentLength === body.byteLength, "buffer body must have content length");
           stream.cork();
           stream.write(body);
           stream.uncork();
@@ -8286,12 +8331,12 @@ upgrade: ${upgrade}\r
             socket: client[kSocket]
           });
         } else {
-          assert2(false);
+          assert3(false);
         }
       }
     }
     function writeStream({ h2stream, body, client, request: request2, socket, contentLength, header, expectsPayload }) {
-      assert2(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined");
+      assert3(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined");
       if (client[kHTTPConnVersion] === "h2") {
         let onPipeData = function(chunk) {
           request2.onBodySent(chunk);
@@ -8349,7 +8394,7 @@ upgrade: ${upgrade}\r
           return;
         }
         finished = true;
-        assert2(socket.destroyed || socket[kWriting] && client[kRunning] <= 1);
+        assert3(socket.destroyed || socket[kWriting] && client[kRunning] <= 1);
         socket.off("drain", onDrain).off("error", onFinished);
         body.removeListener("data", onData).removeListener("end", onFinished).removeListener("error", onFinished).removeListener("close", onAbort);
         if (!err) {
@@ -8373,7 +8418,7 @@ upgrade: ${upgrade}\r
       socket.on("drain", onDrain).on("error", onFinished);
     }
     async function writeBlob({ h2stream, body, client, request: request2, socket, contentLength, header, expectsPayload }) {
-      assert2(contentLength === body.size, "blob body must have content length");
+      assert3(contentLength === body.size, "blob body must have content length");
       const isH2 = client[kHTTPConnVersion] === "h2";
       try {
         if (contentLength != null && contentLength !== body.size) {
@@ -8403,7 +8448,7 @@ upgrade: ${upgrade}\r
       }
     }
     async function writeIterable({ h2stream, body, client, request: request2, socket, contentLength, header, expectsPayload }) {
-      assert2(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
+      assert3(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
       let callback = null;
       function onDrain() {
         if (callback) {
@@ -8413,7 +8458,7 @@ upgrade: ${upgrade}\r
         }
       }
       const waitForDrain = () => new Promise((resolve, reject) => {
-        assert2(callback === null);
+        assert3(callback === null);
         if (socket[kError]) {
           reject(socket[kError]);
         } else {
@@ -8561,7 +8606,7 @@ ${len.toString(16)}\r
         const { socket, client } = this;
         socket[kWriting] = false;
         if (err) {
-          assert2(client[kRunning] <= 1, "pipeline should only contain this request");
+          assert3(client[kRunning] <= 1, "pipeline should only contain this request");
           util3.destroy(socket, err);
         }
       }
@@ -8569,7 +8614,7 @@ ${len.toString(16)}\r
     function errorRequest(client, request2, err) {
       try {
         request2.onError(err);
-        assert2(request2.aborted);
+        assert3(request2.aborted);
       } catch (err2) {
         client.emit("error", err2);
       }
@@ -9211,7 +9256,7 @@ var require_agent = __commonJS({
 var require_readable = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/api/readable.js"(exports, module) {
     "use strict";
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { Readable } = __require("stream");
     var { RequestAbortedError, NotSupportedError, InvalidArgumentError } = require_errors();
     var util3 = require_util();
@@ -9320,7 +9365,7 @@ var require_readable = __commonJS({
           this[kBody] = ReadableStreamFrom(this);
           if (this[kConsume]) {
             this[kBody].getReader();
-            assert2(this[kBody].locked);
+            assert3(this[kBody].locked);
           }
         }
         return this[kBody];
@@ -9371,7 +9416,7 @@ var require_readable = __commonJS({
       if (isUnusable(stream)) {
         throw new TypeError("unusable");
       }
-      assert2(!stream[kConsume]);
+      assert3(!stream[kConsume]);
       return new Promise((resolve, reject) => {
         stream[kConsume] = {
           type: type2,
@@ -9462,13 +9507,13 @@ var require_readable = __commonJS({
 // node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/api/util.js
 var require_util3 = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/api/util.js"(exports, module) {
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var {
       ResponseStatusCodeError
     } = require_errors();
     var { toUSVString } = require_util();
     async function getResolveErrorBodyCallback({ callback, body, contentType, statusCode, statusMessage, headers }) {
-      assert2(body);
+      assert3(body);
       let chunks = [];
       let limit = 0;
       for await (const chunk of body) {
@@ -9896,7 +9941,7 @@ var require_api_pipeline = __commonJS({
     var util3 = require_util();
     var { AsyncResource } = __require("async_hooks");
     var { addSignal, removeSignal } = require_abort_signal();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var kResume = Symbol("resume");
     var PipelineRequest = class extends Readable {
       constructor() {
@@ -9996,7 +10041,7 @@ var require_api_pipeline = __commonJS({
       }
       onConnect(abort, context) {
         const { ret, res } = this;
-        assert2(!res, "pipeline cannot be retried");
+        assert3(!res, "pipeline cannot be retried");
         if (ret.destroyed) {
           throw new RequestAbortedError();
         }
@@ -10085,7 +10130,7 @@ var require_api_upgrade = __commonJS({
     var { AsyncResource } = __require("async_hooks");
     var util3 = require_util();
     var { addSignal, removeSignal } = require_abort_signal();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var UpgradeHandler = class extends AsyncResource {
       constructor(opts, callback) {
         if (!opts || typeof opts !== "object") {
@@ -10118,7 +10163,7 @@ var require_api_upgrade = __commonJS({
       }
       onUpgrade(statusCode, rawHeaders, socket) {
         const { callback, opaque, context } = this;
-        assert2.strictEqual(statusCode, 101);
+        assert3.strictEqual(statusCode, 101);
         removeSignal(this);
         this.callback = null;
         const headers = this.responseHeaders === "raw" ? util3.parseRawHeaders(rawHeaders) : util3.parseHeaders(rawHeaders);
@@ -11225,7 +11270,7 @@ var require_proxy_agent = __commonJS({
 // node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/handler/RetryHandler.js
 var require_RetryHandler = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/handler/RetryHandler.js"(exports, module) {
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { kRetryHandlerDefaultRetry } = require_symbols();
     var { RequestRetryError } = require_errors();
     var { isDisturbed, parseHeaders, parseRangeHeader } = require_util();
@@ -11390,8 +11435,8 @@ var require_RetryHandler = __commonJS({
             return false;
           }
           const { start, size, end = size } = contentRange;
-          assert2(this.start === start, "content-range mismatch");
-          assert2(this.end == null || this.end === end, "content-range mismatch");
+          assert3(this.start === start, "content-range mismatch");
+          assert3(this.end == null || this.end === end, "content-range mismatch");
           this.resume = resume;
           return true;
         }
@@ -11407,12 +11452,12 @@ var require_RetryHandler = __commonJS({
               );
             }
             const { start, size, end = size } = range2;
-            assert2(
+            assert3(
               start != null && Number.isFinite(start) && this.start !== start,
               "content-range mismatch"
             );
-            assert2(Number.isFinite(start));
-            assert2(
+            assert3(Number.isFinite(start));
+            assert3(
               end != null && Number.isFinite(end) && this.end !== end,
               "invalid content-length"
             );
@@ -11423,8 +11468,8 @@ var require_RetryHandler = __commonJS({
             const contentLength = headers["content-length"];
             this.end = contentLength != null ? Number(contentLength) : null;
           }
-          assert2(Number.isFinite(this.start));
-          assert2(
+          assert3(Number.isFinite(this.start));
+          assert3(
             this.end == null || Number.isFinite(this.end),
             "invalid content-length"
           );
@@ -11567,7 +11612,7 @@ var require_headers = __commonJS({
     } = require_util2();
     var util3 = __require("util");
     var { webidl } = require_webidl();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var kHeadersMap = Symbol("headers map");
     var kHeadersSortedMap = Symbol("headers map sorted");
     function isHTTPWhiteSpaceCharCode(code) {
@@ -11825,7 +11870,7 @@ var require_headers = __commonJS({
               headers.push([name, cookies[j]]);
             }
           } else {
-            assert2(value2 !== null);
+            assert3(value2 !== null);
             headers.push([name, value2]);
           }
         }
@@ -11971,7 +12016,7 @@ var require_response = __commonJS({
     var { getGlobalOrigin } = require_global();
     var { URLSerializer } = require_dataURL();
     var { kHeadersList, kConstruct } = require_symbols();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { types } = __require("util");
     var ReadableStream2 = globalThis.ReadableStream || __require("stream/web").ReadableStream;
     var textEncoder = new TextEncoder("utf-8");
@@ -12187,7 +12232,7 @@ var require_response = __commonJS({
           return p in state ? state[p] : target[p];
         },
         set(target, p, value2) {
-          assert2(!(p in state));
+          assert3(!(p in state));
           target[p] = value2;
           return true;
         }
@@ -12221,11 +12266,11 @@ var require_response = __commonJS({
           body: null
         });
       } else {
-        assert2(false);
+        assert3(false);
       }
     }
     function makeAppropriateNetworkError(fetchParams, err = null) {
-      assert2(isCancelled(fetchParams));
+      assert3(isCancelled(fetchParams));
       return isAborted4(fetchParams) ? makeNetworkError(Object.assign(new DOMException2("The operation was aborted.", "AbortError"), { cause: err })) : makeNetworkError(Object.assign(new DOMException2("Request was cancelled."), { cause: err }));
     }
     function initializeResponse(response, init, body) {
@@ -12353,7 +12398,7 @@ var require_request2 = __commonJS({
     var { getGlobalOrigin } = require_global();
     var { URLSerializer } = require_dataURL();
     var { kHeadersList, kConstruct } = require_symbols();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { getMaxListeners, setMaxListeners: setMaxListeners2, getEventListeners, defaultMaxListeners } = __require("events");
     var TransformStream2 = globalThis.TransformStream;
     var kAbortController = Symbol("abortController");
@@ -12397,7 +12442,7 @@ var require_request2 = __commonJS({
           request2 = makeRequest({ urlList: [parsedURL] });
           fallbackMode = "cors";
         } else {
-          assert2(input instanceof _Request);
+          assert3(input instanceof _Request);
           request2 = input[kState];
           signal = input[kSignal];
         }
@@ -13006,7 +13051,7 @@ var require_fetch = __commonJS({
       urlHasHttpsScheme
     } = require_util2();
     var { kState, kHeaders, kGuard, kRealm } = require_symbols2();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { safelyExtractBody } = require_body();
     var {
       redirectStatusSet,
@@ -13086,7 +13131,7 @@ var require_fetch = __commonJS({
         requestObject.signal,
         () => {
           locallyAborted = true;
-          assert2(controller != null);
+          assert3(controller != null);
           controller.abort(requestObject.signal.reason);
           abortFetch(p, request2, responseObject, requestObject.signal.reason);
         }
@@ -13219,7 +13264,7 @@ var require_fetch = __commonJS({
         taskDestination,
         crossOriginIsolatedCapability
       };
-      assert2(!request2.body || request2.body.stream);
+      assert3(!request2.body || request2.body.stream);
       if (request2.window === "client") {
         request2.window = request2.client?.globalObject?.constructor?.name === "Window" ? request2.client : "no-window";
       }
@@ -13312,7 +13357,7 @@ var require_fetch = __commonJS({
         } else if (request2.responseTainting === "opaque") {
           response = filterResponse(response, "opaque");
         } else {
-          assert2(false);
+          assert3(false);
         }
       }
       let internalResponse = response.status === 0 ? response : response.internalResponse;
@@ -13504,7 +13549,7 @@ var require_fetch = __commonJS({
         } else if (request2.redirect === "follow") {
           response = await httpRedirectFetch(fetchParams, response);
         } else {
-          assert2(false);
+          assert3(false);
         }
       }
       response.timingInfo = timingInfo;
@@ -13557,7 +13602,7 @@ var require_fetch = __commonJS({
         request2.headersList.delete("host");
       }
       if (request2.body != null) {
-        assert2(request2.body.source != null);
+        assert3(request2.body.source != null);
         request2.body = safelyExtractBody(request2.body.source)[0];
       }
       const timingInfo = fetchParams.timingInfo;
@@ -13690,7 +13735,7 @@ var require_fetch = __commonJS({
       return response;
     }
     async function httpNetworkFetch(fetchParams, includeCredentials = false, forceNewConnection = false) {
-      assert2(!fetchParams.controller.connection || fetchParams.controller.connection.destroyed);
+      assert3(!fetchParams.controller.connection || fetchParams.controller.connection.destroyed);
       fetchParams.controller.connection = {
         abort: null,
         destroyed: false,
@@ -14825,7 +14870,7 @@ var require_symbols4 = __commonJS({
 var require_util5 = __commonJS({
   "node_modules/.pnpm/undici@5.29.0/node_modules/undici/lib/cache/util.js"(exports, module) {
     "use strict";
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { URLSerializer } = require_dataURL();
     var { isValidHeaderName } = require_util2();
     function urlEquals(A, B, excludeFragment = false) {
@@ -14834,7 +14879,7 @@ var require_util5 = __commonJS({
       return serializedA === serializedB;
     }
     function fieldValues(header) {
-      assert2(header !== null);
+      assert3(header !== null);
       const values = [];
       for (let value2 of header.split(",")) {
         value2 = value2.trim();
@@ -14868,7 +14913,7 @@ var require_cache = __commonJS({
     var { kState, kHeaders, kGuard, kRealm } = require_symbols2();
     var { fetching } = require_fetch();
     var { urlIsHttpHttpsScheme, createDeferredPromise, readAllBytes } = require_util2();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     var { getGlobalDispatcher } = require_global2();
     var Cache = class _Cache {
       /**
@@ -15129,7 +15174,7 @@ var require_cache = __commonJS({
             return false;
           }
         } else {
-          assert2(typeof request2 === "string");
+          assert3(typeof request2 === "string");
           r = new Request2(request2)[kState];
         }
         const operations = [];
@@ -15238,7 +15283,7 @@ var require_cache = __commonJS({
               }
               for (const requestResponse of requestResponses) {
                 const idx = cache.indexOf(requestResponse);
-                assert2(idx !== -1);
+                assert3(idx !== -1);
                 cache.splice(idx, 1);
               }
             } else if (operation.type === "put") {
@@ -15270,7 +15315,7 @@ var require_cache = __commonJS({
               requestResponses = this.#queryCache(operation.request);
               for (const requestResponse of requestResponses) {
                 const idx = cache.indexOf(requestResponse);
-                assert2(idx !== -1);
+                assert3(idx !== -1);
                 cache.splice(idx, 1);
               }
               cache.push([operation.request, operation.response]);
@@ -15657,7 +15702,7 @@ var require_parse = __commonJS({
     var { maxNameValuePairSize, maxAttributeValueSize } = require_constants4();
     var { isCTLExcludingHtab } = require_util6();
     var { collectASequenceOfCodePointsFast } = require_dataURL();
-    var assert2 = __require("assert");
+    var assert3 = __require("assert");
     function parseSetCookie(header) {
       if (isCTLExcludingHtab(header)) {
         return null;
@@ -15699,7 +15744,7 @@ var require_parse = __commonJS({
       if (unparsedAttributes.length === 0) {
         return cookieAttributeList;
       }
-      assert2(unparsedAttributes[0] === ";");
+      assert3(unparsedAttributes[0] === ";");
       unparsedAttributes = unparsedAttributes.slice(1);
       let cookieAv = "";
       if (unparsedAttributes.includes(";")) {
@@ -38167,7 +38212,7 @@ var require_tree = __commonJS({
 var require_util11 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/core/util.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { kDestroyed, kBodyUsed, kListeners, kBody } = require_symbols6();
     var { IncomingMessage } = __require("node:http");
     var stream = __require("node:stream");
@@ -38185,7 +38230,7 @@ var require_util11 = __commonJS({
         this[kBodyUsed] = false;
       }
       async *[Symbol.asyncIterator]() {
-        assert2(!this[kBodyUsed], "disturbed");
+        assert3(!this[kBodyUsed], "disturbed");
         this[kBodyUsed] = true;
         yield* this[kBody];
       }
@@ -38196,7 +38241,7 @@ var require_util11 = __commonJS({
       if (isStream(body)) {
         if (bodyLength(body) === 0) {
           body.on("data", function() {
-            assert2(false);
+            assert3(false);
           });
         }
         if (typeof body.readableDidRead !== "boolean") {
@@ -38305,7 +38350,7 @@ var require_util11 = __commonJS({
     function getHostname(host) {
       if (host[0] === "[") {
         const idx2 = host.indexOf("]");
-        assert2(idx2 !== -1);
+        assert3(idx2 !== -1);
         return host.substring(1, idx2);
       }
       const idx = host.indexOf(":");
@@ -38316,7 +38361,7 @@ var require_util11 = __commonJS({
       if (!host) {
         return null;
       }
-      assert2(typeof host === "string");
+      assert3(typeof host === "string");
       const servername = getHostname(host);
       if (net.isIP(servername)) {
         return "";
@@ -38594,7 +38639,7 @@ var require_util11 = __commonJS({
     function errorRequest(client, request2, err) {
       try {
         request2.onError(err);
-        assert2(request2.aborted);
+        assert3(request2.aborted);
       } catch (err2) {
         client.emit("error", err2);
       }
@@ -38971,7 +39016,7 @@ var require_request3 = __commonJS({
       InvalidArgumentError,
       NotSupportedError
     } = require_errors2();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var {
       isValidHTTPToken,
       isValidHeaderValue,
@@ -39148,8 +39193,8 @@ var require_request3 = __commonJS({
         }
       }
       onConnect(abort) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         if (this.error) {
           abort(this.error);
         } else {
@@ -39161,8 +39206,8 @@ var require_request3 = __commonJS({
         return this[kHandler].onResponseStarted?.();
       }
       onHeaders(statusCode, headers, resume, statusText) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         if (channels.headers.hasSubscribers) {
           channels.headers.publish({ request: this, response: { statusCode, headers, statusText } });
         }
@@ -39173,8 +39218,8 @@ var require_request3 = __commonJS({
         }
       }
       onData(chunk) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         if (channels.bodyChunkReceived.hasSubscribers) {
           channels.bodyChunkReceived.publish({ request: this, chunk });
         }
@@ -39186,14 +39231,14 @@ var require_request3 = __commonJS({
         }
       }
       onUpgrade(statusCode, headers, socket) {
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         return this[kHandler].onUpgrade(statusCode, headers, socket);
       }
       onComplete(trailers) {
         this.onFinally();
-        assert2(!this.aborted);
-        assert2(!this.completed);
+        assert3(!this.aborted);
+        assert3(!this.completed);
         this.completed = true;
         if (channels.trailers.hasSubscribers) {
           channels.trailers.publish({ request: this, trailers });
@@ -39645,7 +39690,7 @@ var require_connect2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/core/connect.js"(exports, module) {
     "use strict";
     var net = __require("node:net");
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var util3 = require_util11();
     var { InvalidArgumentError } = require_errors2();
     var tls;
@@ -39691,7 +39736,7 @@ var require_connect2 = __commonJS({
           }
           servername = servername || options.servername || util3.getServerName(host) || null;
           const sessionKey = servername || hostname2;
-          assert2(sessionKey);
+          assert3(sessionKey);
           const session = customSession || sessionCache.get(sessionKey) || null;
           port = port || 443;
           socket = tls.connect({
@@ -39711,7 +39756,7 @@ var require_connect2 = __commonJS({
             sessionCache.set(sessionKey, session2);
           });
         } else {
-          assert2(!httpSocket, "httpSocket can only be sent on TLS update");
+          assert3(!httpSocket, "httpSocket can only be sent on TLS update");
           port = port || 80;
           socket = net.connect({
             highWaterMark: 64 * 1024,
@@ -40682,14 +40727,14 @@ var require_global3 = __commonJS({
 var require_data_url = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/web/fetch/data-url.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var encoder = new TextEncoder();
     var HTTP_TOKEN_CODEPOINTS = /^[!#$%&'*+\-.^_|~A-Za-z0-9]+$/;
     var HTTP_WHITESPACE_REGEX = /[\u000A\u000D\u0009\u0020]/;
     var ASCII_WHITESPACE_REPLACE_REGEX = /[\u0009\u000A\u000C\u000D\u0020]/g;
     var HTTP_QUOTED_STRING_TOKENS = /^[\u0009\u0020-\u007E\u0080-\u00FF]+$/;
     function dataURLProcessor(dataURL) {
-      assert2(dataURL.protocol === "data:");
+      assert3(dataURL.protocol === "data:");
       let input = URLSerializer(dataURL, true);
       input = input.slice(5);
       const position = { position: 0 };
@@ -40890,7 +40935,7 @@ var require_data_url = __commonJS({
     function collectAnHTTPQuotedString(input, position, extractValue = false) {
       const positionStart = position.position;
       let value2 = "";
-      assert2(input[position.position] === '"');
+      assert3(input[position.position] === '"');
       position.position++;
       while (true) {
         value2 += collectASequenceOfCodePoints(
@@ -40911,7 +40956,7 @@ var require_data_url = __commonJS({
           value2 += input[position.position];
           position.position++;
         } else {
-          assert2(quoteOrBackslash === '"');
+          assert3(quoteOrBackslash === '"');
           break;
         }
       }
@@ -40921,7 +40966,7 @@ var require_data_url = __commonJS({
       return input.slice(positionStart, position.position);
     }
     function serializeAMimeType(mimeType) {
-      assert2(mimeType !== "failure");
+      assert3(mimeType !== "failure");
       const { parameters, essence } = mimeType;
       let serialization = essence;
       for (let [name, value2] of parameters.entries()) {
@@ -41620,7 +41665,7 @@ var require_util12 = __commonJS({
     var { collectASequenceOfCodePoints, collectAnHTTPQuotedString, removeChars, parseMIMEType } = require_data_url();
     var { performance: performance2 } = __require("node:perf_hooks");
     var { ReadableStreamFrom, isValidHTTPToken, normalizedMethodRecordsBase } = require_util11();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { isUint8Array } = __require("node:util/types");
     var { webidl } = require_webidl2();
     function responseURL(response) {
@@ -41801,7 +41846,7 @@ var require_util12 = __commonJS({
     }
     function determineRequestsReferrer(request2) {
       const policy = request2.referrerPolicy;
-      assert2(policy);
+      assert3(policy);
       let referrerSource = null;
       if (request2.referrer === "client") {
         const globalOrigin = getGlobalOrigin();
@@ -41864,7 +41909,7 @@ var require_util12 = __commonJS({
       }
     }
     function stripURLForReferrer(url2, originOnly = false) {
-      assert2(webidl.is.URL(url2));
+      assert3(webidl.is.URL(url2));
       url2 = new URL(url2);
       if (urlIsLocal(url2)) {
         return "no-referrer";
@@ -41947,7 +41992,7 @@ var require_util12 = __commonJS({
       if (result === void 0) {
         throw new TypeError("Value is not JSON serializable");
       }
-      assert2(typeof result === "string");
+      assert3(typeof result === "string");
       return result;
     }
     var esIteratorPrototype = Object.getPrototypeOf(Object.getPrototypeOf([][Symbol.iterator]()));
@@ -42099,7 +42144,7 @@ var require_util12 = __commonJS({
     }
     var invalidIsomorphicEncodeValueRegex = /[^\x00-\xFF]/;
     function isomorphicEncode(input) {
-      assert2(!invalidIsomorphicEncodeValueRegex.test(input));
+      assert3(!invalidIsomorphicEncodeValueRegex.test(input));
       return input;
     }
     async function readAllBytes(reader, successSteps, failureSteps) {
@@ -42124,7 +42169,7 @@ var require_util12 = __commonJS({
       }
     }
     function urlIsLocal(url2) {
-      assert2("protocol" in url2);
+      assert3("protocol" in url2);
       const protocol = url2.protocol;
       return protocol === "about:" || protocol === "blob:" || protocol === "data:";
     }
@@ -42132,7 +42177,7 @@ var require_util12 = __commonJS({
       return typeof url2 === "string" && url2[5] === ":" && url2[0] === "h" && url2[1] === "t" && url2[2] === "t" && url2[3] === "p" && url2[4] === "s" || url2.protocol === "https:";
     }
     function urlIsHttpHttpsScheme(url2) {
-      assert2("protocol" in url2);
+      assert3("protocol" in url2);
       const protocol = url2.protocol;
       return protocol === "http:" || protocol === "https:";
     }
@@ -42297,7 +42342,7 @@ var require_util12 = __commonJS({
               continue;
             }
           } else {
-            assert2(input.charCodeAt(position.position) === 44);
+            assert3(input.charCodeAt(position.position) === 44);
             position.position++;
           }
         }
@@ -42561,7 +42606,7 @@ var require_formdata_parser = __commonJS({
     var { HTTP_TOKEN_CODEPOINTS, isomorphicDecode } = require_data_url();
     var { makeEntry } = require_formdata2();
     var { webidl } = require_webidl2();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var formDataNameBuffer = Buffer.from('form-data; name="');
     var filenameBuffer = Buffer.from("filename");
     var dd = Buffer.from("--");
@@ -42588,7 +42633,7 @@ var require_formdata_parser = __commonJS({
       return true;
     }
     function multipartFormDataParser(input, mimeType) {
-      assert2(mimeType !== "failure" && mimeType.essence === "multipart/form-data");
+      assert3(mimeType !== "failure" && mimeType.essence === "multipart/form-data");
       const boundaryString = mimeType.parameters.get("boundary");
       if (boundaryString === void 0) {
         throw parsingError("missing boundary in content-type header");
@@ -42649,8 +42694,8 @@ var require_formdata_parser = __commonJS({
         } else {
           value2 = utf8DecodeBytes(Buffer.from(body));
         }
-        assert2(webidl.is.USVString(name));
-        assert2(typeof value2 === "string" && webidl.is.USVString(value2) || webidl.is.File(value2));
+        assert3(webidl.is.USVString(name));
+        assert3(typeof value2 === "string" && webidl.is.USVString(value2) || webidl.is.File(value2));
         entryList.push(makeEntry(name, value2, filename));
       }
     }
@@ -42767,7 +42812,7 @@ var require_formdata_parser = __commonJS({
       }
     }
     function parseMultipartFormDataName(input, position) {
-      assert2(input[position.position - 1] === 34);
+      assert3(input[position.position - 1] === 34);
       let name = collectASequenceOfBytes(
         (char) => char !== 10 && char !== 13 && char !== 34,
         input,
@@ -42853,7 +42898,7 @@ var require_body2 = __commonJS({
     } = require_util12();
     var { FormData: FormData2, setFormDataState } = require_formdata2();
     var { webidl } = require_webidl2();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { isErrored, isDisturbed } = __require("node:stream");
     var { isArrayBuffer } = __require("node:util/types");
     var { serializeAMimeType } = require_data_url();
@@ -42895,7 +42940,7 @@ var require_body2 = __commonJS({
           type: "bytes"
         });
       }
-      assert2(webidl.is.ReadableStream(stream));
+      assert3(webidl.is.ReadableStream(stream));
       let action = null;
       let source = null;
       let length = null;
@@ -43011,8 +43056,8 @@ Content-Type: ${value2.type || "application/octet-stream"}\r
     }
     function safelyExtractBody(object2, keepalive = false) {
       if (webidl.is.ReadableStream(object2)) {
-        assert2(!util3.isDisturbed(object2), "The body has already been consumed.");
-        assert2(!object2.locked, "The stream is locked.");
+        assert3(!util3.isDisturbed(object2), "The body has already been consumed.");
+        assert3(!object2.locked, "The stream is locked.");
       }
       return extractBody(object2, keepalive);
     }
@@ -43145,7 +43190,7 @@ Content-Type: ${value2.type || "application/octet-stream"}\r
 var require_client_h1 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/dispatcher/client-h1.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var util3 = require_util11();
     var { channels } = require_diagnostics();
     var timers = require_timers2();
@@ -43236,7 +43281,7 @@ var require_client_h1 = __commonJS({
            * @returns {number}
            */
           wasm_on_status: (p, at, len) => {
-            assert2(currentParser.ptr === p);
+            assert3(currentParser.ptr === p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onStatus(new FastBuffer(currentBufferRef.buffer, start, len));
           },
@@ -43245,7 +43290,7 @@ var require_client_h1 = __commonJS({
            * @returns {number}
            */
           wasm_on_message_begin: (p) => {
-            assert2(currentParser.ptr === p);
+            assert3(currentParser.ptr === p);
             return currentParser.onMessageBegin();
           },
           /**
@@ -43255,7 +43300,7 @@ var require_client_h1 = __commonJS({
            * @returns {number}
            */
           wasm_on_header_field: (p, at, len) => {
-            assert2(currentParser.ptr === p);
+            assert3(currentParser.ptr === p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onHeaderField(new FastBuffer(currentBufferRef.buffer, start, len));
           },
@@ -43266,7 +43311,7 @@ var require_client_h1 = __commonJS({
            * @returns {number}
            */
           wasm_on_header_value: (p, at, len) => {
-            assert2(currentParser.ptr === p);
+            assert3(currentParser.ptr === p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onHeaderValue(new FastBuffer(currentBufferRef.buffer, start, len));
           },
@@ -43278,7 +43323,7 @@ var require_client_h1 = __commonJS({
            * @returns {number}
            */
           wasm_on_headers_complete: (p, statusCode, upgrade, shouldKeepAlive) => {
-            assert2(currentParser.ptr === p);
+            assert3(currentParser.ptr === p);
             return currentParser.onHeadersComplete(statusCode, upgrade === 1, shouldKeepAlive === 1);
           },
           /**
@@ -43288,7 +43333,7 @@ var require_client_h1 = __commonJS({
            * @returns {number}
            */
           wasm_on_body: (p, at, len) => {
-            assert2(currentParser.ptr === p);
+            assert3(currentParser.ptr === p);
             const start = at - currentBufferPtr + currentBufferRef.byteOffset;
             return currentParser.onBody(new FastBuffer(currentBufferRef.buffer, start, len));
           },
@@ -43297,7 +43342,7 @@ var require_client_h1 = __commonJS({
            * @returns {number}
            */
           wasm_on_message_complete: (p) => {
-            assert2(currentParser.ptr === p);
+            assert3(currentParser.ptr === p);
             return currentParser.onMessageComplete();
           }
         }
@@ -43368,10 +43413,10 @@ var require_client_h1 = __commonJS({
         if (this.socket.destroyed || !this.paused) {
           return;
         }
-        assert2(this.ptr != null);
-        assert2(currentParser === null);
+        assert3(this.ptr != null);
+        assert3(currentParser === null);
         this.llhttp.llhttp_resume(this.ptr);
-        assert2(this.timeoutType === TIMEOUT_BODY);
+        assert3(this.timeoutType === TIMEOUT_BODY);
         if (this.timeout) {
           if (this.timeout.refresh) {
             this.timeout.refresh();
@@ -43394,9 +43439,9 @@ var require_client_h1 = __commonJS({
        * @param {Buffer} chunk
        */
       execute(chunk) {
-        assert2(currentParser === null);
-        assert2(this.ptr != null);
-        assert2(!this.paused);
+        assert3(currentParser === null);
+        assert3(this.ptr != null);
+        assert3(!this.paused);
         const { socket, llhttp } = this;
         if (chunk.length > currentBufferSize) {
           if (currentBufferPtr) {
@@ -43438,8 +43483,8 @@ var require_client_h1 = __commonJS({
         }
       }
       destroy() {
-        assert2(currentParser === null);
-        assert2(this.ptr != null);
+        assert3(currentParser === null);
+        assert3(this.ptr != null);
         this.llhttp.llhttp_free(this.ptr);
         this.ptr = null;
         this.timeout && timers.clearTimeout(this.timeout);
@@ -43525,14 +43570,14 @@ var require_client_h1 = __commonJS({
        */
       onUpgrade(head) {
         const { upgrade, client, socket, headers, statusCode } = this;
-        assert2(upgrade);
-        assert2(client[kSocket] === socket);
-        assert2(!socket.destroyed);
-        assert2(!this.paused);
-        assert2((headers.length & 1) === 0);
+        assert3(upgrade);
+        assert3(client[kSocket] === socket);
+        assert3(!socket.destroyed);
+        assert3(!this.paused);
+        assert3((headers.length & 1) === 0);
         const request2 = client[kQueue][client[kRunningIdx]];
-        assert2(request2);
-        assert2(request2.upgrade || request2.method === "CONNECT");
+        assert3(request2);
+        assert3(request2.upgrade || request2.method === "CONNECT");
         this.statusCode = 0;
         this.statusText = "";
         this.shouldKeepAlive = false;
@@ -43570,8 +43615,8 @@ var require_client_h1 = __commonJS({
         if (!request2) {
           return -1;
         }
-        assert2(!this.upgrade);
-        assert2(this.statusCode < 200);
+        assert3(!this.upgrade);
+        assert3(this.statusCode < 200);
         if (statusCode === 100) {
           util3.destroy(socket, new SocketError("bad response", util3.getSocketInfo(socket)));
           return -1;
@@ -43580,7 +43625,7 @@ var require_client_h1 = __commonJS({
           util3.destroy(socket, new SocketError("bad upgrade", util3.getSocketInfo(socket)));
           return -1;
         }
-        assert2(this.timeoutType === TIMEOUT_HEADERS);
+        assert3(this.timeoutType === TIMEOUT_HEADERS);
         this.statusCode = statusCode;
         this.shouldKeepAlive = shouldKeepAlive || // Override llhttp value which does not allow keepAlive for HEAD.
         request2.method === "HEAD" && !socket[kReset] && this.connection.toLowerCase() === "keep-alive";
@@ -43593,16 +43638,16 @@ var require_client_h1 = __commonJS({
           }
         }
         if (request2.method === "CONNECT") {
-          assert2(client[kRunning] === 1);
+          assert3(client[kRunning] === 1);
           this.upgrade = true;
           return 2;
         }
         if (upgrade) {
-          assert2(client[kRunning] === 1);
+          assert3(client[kRunning] === 1);
           this.upgrade = true;
           return 2;
         }
-        assert2((this.headers.length & 1) === 0);
+        assert3((this.headers.length & 1) === 0);
         this.headers = [];
         this.headersSize = 0;
         if (this.shouldKeepAlive && client[kPipelining]) {
@@ -43649,14 +43694,14 @@ var require_client_h1 = __commonJS({
           return -1;
         }
         const request2 = client[kQueue][client[kRunningIdx]];
-        assert2(request2);
-        assert2(this.timeoutType === TIMEOUT_BODY);
+        assert3(request2);
+        assert3(this.timeoutType === TIMEOUT_BODY);
         if (this.timeout) {
           if (this.timeout.refresh) {
             this.timeout.refresh();
           }
         }
-        assert2(statusCode >= 200);
+        assert3(statusCode >= 200);
         if (maxResponseSize > -1 && this.bytesRead + buf.length > maxResponseSize) {
           util3.destroy(socket, new ResponseExceededMaxSizeError());
           return -1;
@@ -43678,10 +43723,10 @@ var require_client_h1 = __commonJS({
         if (upgrade) {
           return 0;
         }
-        assert2(statusCode >= 100);
-        assert2((this.headers.length & 1) === 0);
+        assert3(statusCode >= 100);
+        assert3((this.headers.length & 1) === 0);
         const request2 = client[kQueue][client[kRunningIdx]];
-        assert2(request2);
+        assert3(request2);
         this.statusCode = 0;
         this.statusText = "";
         this.bytesRead = 0;
@@ -43700,7 +43745,7 @@ var require_client_h1 = __commonJS({
         request2.onComplete(headers);
         client[kQueue][client[kRunningIdx]++] = null;
         if (socket[kWriting]) {
-          assert2(client[kRunning] === 0);
+          assert3(client[kRunning] === 0);
           util3.destroy(socket, new InformationalError("reset"));
           return constants.ERROR.PAUSED;
         } else if (!shouldKeepAlive) {
@@ -43721,7 +43766,7 @@ var require_client_h1 = __commonJS({
       const { socket, timeoutType, client, paused } = parser.deref();
       if (timeoutType === TIMEOUT_HEADERS) {
         if (!socket[kWriting] || socket.writableNeedDrain || client[kRunning] > 1) {
-          assert2(!paused, "cannot be paused while waiting for headers");
+          assert3(!paused, "cannot be paused while waiting for headers");
           util3.destroy(socket, new HeadersTimeoutError());
         }
       } else if (timeoutType === TIMEOUT_BODY) {
@@ -43729,7 +43774,7 @@ var require_client_h1 = __commonJS({
           util3.destroy(socket, new BodyTimeoutError());
         }
       } else if (timeoutType === TIMEOUT_KEEP_ALIVE) {
-        assert2(client[kRunning] === 0 && client[kKeepAliveTimeoutValue]);
+        assert3(client[kRunning] === 0 && client[kKeepAliveTimeoutValue]);
         util3.destroy(socket, new InformationalError("socket idle timeout"));
       }
     }
@@ -43806,7 +43851,7 @@ var require_client_h1 = __commonJS({
       };
     }
     function onHttpSocketError(err) {
-      assert2(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
+      assert3(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
       const parser = this[kParser];
       if (err.code === "ECONNRESET" && parser.statusCode && !parser.shouldKeepAlive) {
         parser.onMessageComplete();
@@ -43840,7 +43885,7 @@ var require_client_h1 = __commonJS({
       client[kSocket] = null;
       client[kHTTPContext] = null;
       if (client.destroyed) {
-        assert2(client[kPending] === 0);
+        assert3(client[kPending] === 0);
         const requests = client[kQueue].splice(client[kRunningIdx]);
         for (let i = 0; i < requests.length; i++) {
           const request2 = requests[i];
@@ -43852,7 +43897,7 @@ var require_client_h1 = __commonJS({
         util3.errorRequest(client, request2, err);
       }
       client[kPendingIdx] = client[kRunningIdx];
-      assert2(client[kRunning] === 0);
+      assert3(client[kRunning] === 0);
       client.emit("disconnect", client[kUrl], [client], err);
       client[kResume]();
     }
@@ -44004,12 +44049,12 @@ upgrade: ${upgrade}\r
       } else if (util3.isIterable(body)) {
         writeIterable(abort, body, client, request2, socket, contentLength, header, expectsPayload);
       } else {
-        assert2(false);
+        assert3(false);
       }
       return true;
     }
     function writeStream(abort, body, client, request2, socket, contentLength, header, expectsPayload) {
-      assert2(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined");
+      assert3(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined");
       let finished = false;
       const writer = new AsyncWriter({ abort, socket, request: request2, contentLength, client, expectsPayload, header });
       const onData = function(chunk) {
@@ -44046,7 +44091,7 @@ upgrade: ${upgrade}\r
           return;
         }
         finished = true;
-        assert2(socket.destroyed || socket[kWriting] && client[kRunning] <= 1);
+        assert3(socket.destroyed || socket[kWriting] && client[kRunning] <= 1);
         socket.off("drain", onDrain).off("error", onFinished);
         body.removeListener("data", onData).removeListener("end", onFinished).removeListener("close", onClose);
         if (!err) {
@@ -44085,12 +44130,12 @@ upgrade: ${upgrade}\r
 \r
 `, "latin1");
           } else {
-            assert2(contentLength === null, "no body must not have content length");
+            assert3(contentLength === null, "no body must not have content length");
             socket.write(`${header}\r
 `, "latin1");
           }
         } else if (util3.isBuffer(body)) {
-          assert2(contentLength === body.byteLength, "buffer body must have content length");
+          assert3(contentLength === body.byteLength, "buffer body must have content length");
           socket.cork();
           socket.write(`${header}content-length: ${contentLength}\r
 \r
@@ -44109,7 +44154,7 @@ upgrade: ${upgrade}\r
       }
     }
     async function writeBlob(abort, body, client, request2, socket, contentLength, header, expectsPayload) {
-      assert2(contentLength === body.size, "blob body must have content length");
+      assert3(contentLength === body.size, "blob body must have content length");
       try {
         if (contentLength != null && contentLength !== body.size) {
           throw new RequestContentLengthMismatchError();
@@ -44132,7 +44177,7 @@ upgrade: ${upgrade}\r
       }
     }
     async function writeIterable(abort, body, client, request2, socket, contentLength, header, expectsPayload) {
-      assert2(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
+      assert3(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
       let callback = null;
       function onDrain() {
         if (callback) {
@@ -44142,7 +44187,7 @@ upgrade: ${upgrade}\r
         }
       }
       const waitForDrain = () => new Promise((resolve, reject) => {
-        assert2(callback === null);
+        assert3(callback === null);
         if (socket[kError]) {
           reject(socket[kError]);
         } else {
@@ -44291,7 +44336,7 @@ ${len.toString(16)}\r
         const { socket, client, abort } = this;
         socket[kWriting] = false;
         if (err) {
-          assert2(client[kRunning] <= 1, "pipeline should only contain this request");
+          assert3(client[kRunning] <= 1, "pipeline should only contain this request");
           abort(err);
         }
       }
@@ -44304,7 +44349,7 @@ ${len.toString(16)}\r
 var require_client_h2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/dispatcher/client-h2.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { pipeline: pipeline2 } = __require("node:stream");
     var util3 = require_util11();
     var {
@@ -44431,7 +44476,7 @@ var require_client_h2 = __commonJS({
       }
     }
     function onHttp2SessionError(err) {
-      assert2(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
+      assert3(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
       this[kSocket][kError] = err;
       this[kClient][kOnError](err);
     }
@@ -44461,7 +44506,7 @@ var require_client_h2 = __commonJS({
         util3.errorRequest(client, request2, err);
         client[kPendingIdx] = client[kRunningIdx];
       }
-      assert2(client[kRunning] === 0);
+      assert3(client[kRunning] === 0);
       client.emit("disconnect", client[kUrl], [client], err);
       client.emit("connectionError", client[kUrl], [client], err);
       client[kResume]();
@@ -44473,7 +44518,7 @@ var require_client_h2 = __commonJS({
       client[kSocket] = null;
       client[kHTTPContext] = null;
       if (client.destroyed) {
-        assert2(client[kPending] === 0);
+        assert3(client[kPending] === 0);
         const requests = client[kQueue].splice(client[kRunningIdx]);
         for (let i = 0; i < requests.length; i++) {
           const request2 = requests[i];
@@ -44490,12 +44535,12 @@ var require_client_h2 = __commonJS({
         this[kHTTP2Session].destroy(err);
       }
       client[kPendingIdx] = client[kRunningIdx];
-      assert2(client[kRunning] === 0);
+      assert3(client[kRunning] === 0);
       client.emit("disconnect", client[kUrl], [client], err);
       client[kResume]();
     }
     function onHttp2SocketError(err) {
-      assert2(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
+      assert3(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
       this[kError] = err;
       this[kClient][kOnError](err);
     }
@@ -44618,7 +44663,7 @@ var require_client_h2 = __commonJS({
         process.emitWarning(new RequestContentLengthMismatchError());
       }
       if (contentLength != null) {
-        assert2(body, "no body must not have content length");
+        assert3(body, "no body must not have content length");
         headers[HTTP2_HEADER_CONTENT_LENGTH] = `${contentLength}`;
       }
       session.ref();
@@ -44783,14 +44828,14 @@ var require_client_h2 = __commonJS({
             expectsPayload
           );
         } else {
-          assert2(false);
+          assert3(false);
         }
       }
     }
     function writeBuffer(abort, h2stream, body, client, request2, socket, contentLength, expectsPayload) {
       try {
         if (body != null && util3.isBuffer(body)) {
-          assert2(contentLength === body.byteLength, "buffer body must have content length");
+          assert3(contentLength === body.byteLength, "buffer body must have content length");
           h2stream.cork();
           h2stream.write(body);
           h2stream.uncork();
@@ -44807,7 +44852,7 @@ var require_client_h2 = __commonJS({
       }
     }
     function writeStream(abort, socket, expectsPayload, h2stream, body, client, request2, contentLength) {
-      assert2(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined");
+      assert3(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined");
       const pipe = pipeline2(
         body,
         h2stream,
@@ -44831,7 +44876,7 @@ var require_client_h2 = __commonJS({
       }
     }
     async function writeBlob(abort, h2stream, body, client, request2, socket, contentLength, expectsPayload) {
-      assert2(contentLength === body.size, "blob body must have content length");
+      assert3(contentLength === body.size, "blob body must have content length");
       try {
         if (contentLength != null && contentLength !== body.size) {
           throw new RequestContentLengthMismatchError();
@@ -44852,7 +44897,7 @@ var require_client_h2 = __commonJS({
       }
     }
     async function writeIterable(abort, h2stream, body, client, request2, socket, contentLength, expectsPayload) {
-      assert2(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
+      assert3(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
       let callback = null;
       function onDrain() {
         if (callback) {
@@ -44862,7 +44907,7 @@ var require_client_h2 = __commonJS({
         }
       }
       const waitForDrain = () => new Promise((resolve, reject) => {
-        assert2(callback === null);
+        assert3(callback === null);
         if (socket[kError]) {
           reject(socket[kError]);
         } else {
@@ -44901,7 +44946,7 @@ var require_client_h2 = __commonJS({
 var require_client2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/dispatcher/client.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var net = __require("node:net");
     var http2 = __require("node:http");
     var util3 = require_util11();
@@ -45186,24 +45231,24 @@ var require_client2 = __commonJS({
     };
     function onError(client, err) {
       if (client[kRunning] === 0 && err.code !== "UND_ERR_INFO" && err.code !== "UND_ERR_SOCKET") {
-        assert2(client[kPendingIdx] === client[kRunningIdx]);
+        assert3(client[kPendingIdx] === client[kRunningIdx]);
         const requests = client[kQueue].splice(client[kRunningIdx]);
         for (let i = 0; i < requests.length; i++) {
           const request2 = requests[i];
           util3.errorRequest(client, request2, err);
         }
-        assert2(client[kSize] === 0);
+        assert3(client[kSize] === 0);
       }
     }
     function connect(client) {
-      assert2(!client[kConnecting]);
-      assert2(!client[kHTTPContext]);
+      assert3(!client[kConnecting]);
+      assert3(!client[kHTTPContext]);
       let { host, hostname: hostname2, protocol, port } = client[kUrl];
       if (hostname2[0] === "[") {
         const idx = hostname2.indexOf("]");
-        assert2(idx !== -1);
+        assert3(idx !== -1);
         const ip2 = hostname2.substring(1, idx);
-        assert2(net.isIPv6(ip2));
+        assert3(net.isIPv6(ip2));
         hostname2 = ip2;
       }
       client[kConnecting] = true;
@@ -45239,7 +45284,7 @@ var require_client2 = __commonJS({
           client[kResume]();
           return;
         }
-        assert2(socket);
+        assert3(socket);
         try {
           client[kHTTPContext] = socket.alpnProtocol === "h2" ? connectH2(client, socket) : connectH1(client, socket);
         } catch (err2) {
@@ -45293,7 +45338,7 @@ var require_client2 = __commonJS({
         });
       }
       if (err.code === "ERR_TLS_CERT_ALTNAME_INVALID") {
-        assert2(client[kRunning] === 0);
+        assert3(client[kRunning] === 0);
         while (client[kPending] > 0 && client[kQueue][client[kPendingIdx]].servername === client[kServerName]) {
           const request2 = client[kQueue][client[kPendingIdx]++];
           util3.errorRequest(client, request2, err);
@@ -45323,7 +45368,7 @@ var require_client2 = __commonJS({
     function _resume(client, sync) {
       while (true) {
         if (client.destroyed) {
-          assert2(client[kPending] === 0);
+          assert3(client[kPending] === 0);
           return;
         }
         if (client[kClosedResolve] && !client[kSize]) {
@@ -46358,7 +46403,7 @@ var require_env_http_proxy_agent = __commonJS({
 var require_retry_handler = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/handler/retry-handler.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { kRetryHandlerDefaultRetry } = require_symbols6();
     var { RequestRetryError } = require_errors2();
     var WrapHandler = require_wrap_handler();
@@ -46541,8 +46586,8 @@ var require_retry_handler = __commonJS({
             });
           }
           const { start, size, end = size ? size - 1 : null } = contentRange;
-          assert2(this.start === start, "content-range mismatch");
-          assert2(this.end == null || this.end === end, "content-range mismatch");
+          assert3(this.start === start, "content-range mismatch");
+          assert3(this.end == null || this.end === end, "content-range mismatch");
           return;
         }
         if (this.end == null) {
@@ -46559,11 +46604,11 @@ var require_retry_handler = __commonJS({
               return;
             }
             const { start, size, end = size ? size - 1 : null } = range2;
-            assert2(
+            assert3(
               start != null && Number.isFinite(start),
               "content-range mismatch"
             );
-            assert2(end != null && Number.isFinite(end), "invalid content-length");
+            assert3(end != null && Number.isFinite(end), "invalid content-length");
             this.start = start;
             this.end = end;
           }
@@ -46571,8 +46616,8 @@ var require_retry_handler = __commonJS({
             const contentLength = headers["content-length"];
             this.end = contentLength != null ? Number(contentLength) - 1 : null;
           }
-          assert2(Number.isFinite(this.start));
-          assert2(
+          assert3(Number.isFinite(this.start));
+          assert3(
             this.end == null || Number.isFinite(this.end),
             "invalid content-length"
           );
@@ -46798,7 +46843,7 @@ var require_h2c_client = __commonJS({
 var require_readable2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/api/readable.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { Readable } = __require("node:stream");
     var { RequestAbortedError, NotSupportedError, InvalidArgumentError, AbortError: AbortError2 } = require_errors2();
     var util3 = require_util11();
@@ -46992,7 +47037,7 @@ var require_readable2 = __commonJS({
           this[kBody] = ReadableStreamFrom(this);
           if (this[kConsume]) {
             this[kBody].getReader();
-            assert2(this[kBody].locked);
+            assert3(this[kBody].locked);
           }
         }
         return this[kBody];
@@ -47061,7 +47106,7 @@ var require_readable2 = __commonJS({
       return util3.isDisturbed(bodyReadable) || isLocked(bodyReadable);
     }
     function consume(stream, type2) {
-      assert2(!stream[kConsume]);
+      assert3(!stream[kConsume]);
       return new Promise((resolve, reject) => {
         if (isUnusable(stream)) {
           const rState = stream._readableState;
@@ -47200,7 +47245,7 @@ var require_readable2 = __commonJS({
 var require_api_request2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/api/api-request.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { AsyncResource } = __require("node:async_hooks");
     var { Readable } = require_readable2();
     var { InvalidArgumentError, RequestAbortedError } = require_errors2();
@@ -47267,7 +47312,7 @@ var require_api_request2 = __commonJS({
           abort(this.reason);
           return;
         }
-        assert2(this.callback);
+        assert3(this.callback);
         this.abort = abort;
         this.context = context;
       }
@@ -47429,7 +47474,7 @@ var require_abort_signal2 = __commonJS({
 var require_api_stream2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/api/api-stream.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { finished } = __require("node:stream");
     var { AsyncResource } = __require("node:async_hooks");
     var { InvalidArgumentError, InvalidReturnValueError } = require_errors2();
@@ -47488,7 +47533,7 @@ var require_api_stream2 = __commonJS({
           abort(this.reason);
           return;
         }
-        assert2(this.callback);
+        assert3(this.callback);
         this.abort = abort;
         this.context = context;
       }
@@ -47595,7 +47640,7 @@ var require_api_pipeline2 = __commonJS({
       Duplex,
       PassThrough
     } = __require("node:stream");
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { AsyncResource } = __require("node:async_hooks");
     var {
       InvalidArgumentError,
@@ -47709,7 +47754,7 @@ var require_api_pipeline2 = __commonJS({
           abort(this.reason);
           return;
         }
-        assert2(!res, "pipeline cannot be retried");
+        assert3(!res, "pipeline cannot be retried");
         this.abort = abort;
         this.context = context;
       }
@@ -47793,7 +47838,7 @@ var require_api_upgrade2 = __commonJS({
     "use strict";
     var { InvalidArgumentError, SocketError } = require_errors2();
     var { AsyncResource } = __require("node:async_hooks");
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var util3 = require_util11();
     var { addSignal, removeSignal } = require_abort_signal2();
     var UpgradeHandler = class extends AsyncResource {
@@ -47821,7 +47866,7 @@ var require_api_upgrade2 = __commonJS({
           abort(this.reason);
           return;
         }
-        assert2(this.callback);
+        assert3(this.callback);
         this.abort = abort;
         this.context = null;
       }
@@ -47829,7 +47874,7 @@ var require_api_upgrade2 = __commonJS({
         throw new SocketError("bad upgrade", null);
       }
       onUpgrade(statusCode, rawHeaders, socket) {
-        assert2(statusCode === 101);
+        assert3(statusCode === 101);
         const { callback, opaque, context } = this;
         removeSignal(this);
         this.callback = null;
@@ -47884,7 +47929,7 @@ var require_api_upgrade2 = __commonJS({
 var require_api_connect2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/api/api-connect.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { AsyncResource } = __require("node:async_hooks");
     var { InvalidArgumentError, SocketError } = require_errors2();
     var util3 = require_util11();
@@ -47913,7 +47958,7 @@ var require_api_connect2 = __commonJS({
           abort(this.reason);
           return;
         }
-        assert2(this.callback);
+        assert3(this.callback);
         this.abort = abort;
         this.context = context;
       }
@@ -49894,7 +49939,7 @@ var require_global4 = __commonJS({
 var require_decorator_handler = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/handler/decorator-handler.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var WrapHandler = require_wrap_handler();
     module.exports = class DecoratorHandler {
       #handler;
@@ -49911,25 +49956,25 @@ var require_decorator_handler = __commonJS({
         this.#handler.onRequestStart?.(...args3);
       }
       onRequestUpgrade(...args3) {
-        assert2(!this.#onCompleteCalled);
-        assert2(!this.#onErrorCalled);
+        assert3(!this.#onCompleteCalled);
+        assert3(!this.#onErrorCalled);
         return this.#handler.onRequestUpgrade?.(...args3);
       }
       onResponseStart(...args3) {
-        assert2(!this.#onCompleteCalled);
-        assert2(!this.#onErrorCalled);
-        assert2(!this.#onResponseStartCalled);
+        assert3(!this.#onCompleteCalled);
+        assert3(!this.#onErrorCalled);
+        assert3(!this.#onResponseStartCalled);
         this.#onResponseStartCalled = true;
         return this.#handler.onResponseStart?.(...args3);
       }
       onResponseData(...args3) {
-        assert2(!this.#onCompleteCalled);
-        assert2(!this.#onErrorCalled);
+        assert3(!this.#onCompleteCalled);
+        assert3(!this.#onErrorCalled);
         return this.#handler.onResponseData?.(...args3);
       }
       onResponseEnd(...args3) {
-        assert2(!this.#onCompleteCalled);
-        assert2(!this.#onErrorCalled);
+        assert3(!this.#onCompleteCalled);
+        assert3(!this.#onErrorCalled);
         this.#onCompleteCalled = true;
         return this.#handler.onResponseEnd?.(...args3);
       }
@@ -49952,7 +49997,7 @@ var require_redirect_handler = __commonJS({
     "use strict";
     var util3 = require_util11();
     var { kBodyUsed } = require_symbols6();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { InvalidArgumentError } = require_errors2();
     var EE = __require("node:events");
     var redirectableStatusCodes = [300, 301, 302, 303, 307, 308];
@@ -49965,7 +50010,7 @@ var require_redirect_handler = __commonJS({
         this[kBodyUsed] = false;
       }
       async *[Symbol.asyncIterator]() {
-        assert2(!this[kBodyUsed], "disturbed");
+        assert3(!this[kBodyUsed], "disturbed");
         this[kBodyUsed] = true;
         yield* this[kBody];
       }
@@ -49992,7 +50037,7 @@ var require_redirect_handler = __commonJS({
         if (util3.isStream(this.opts.body)) {
           if (util3.bodyLength(this.opts.body) === 0) {
             this.opts.body.on("data", function() {
-              assert2(false);
+              assert3(false);
             });
           }
           if (typeof this.opts.body.readableDidRead !== "boolean") {
@@ -50098,7 +50143,7 @@ var require_redirect_handler = __commonJS({
           }
         }
       } else {
-        assert2(headers == null, "headers must be an object or an array");
+        assert3(headers == null, "headers must be an object or an array");
       }
       return ret;
     }
@@ -51894,7 +51939,7 @@ var require_memory_cache_store = __commonJS({
 var require_cache_revalidation_handler = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/handler/cache-revalidation-handler.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var CacheRevalidationHandler = class {
       #successful = false;
       /**
@@ -51931,7 +51976,7 @@ var require_cache_revalidation_handler = __commonJS({
         this.#handler.onRequestUpgrade?.(controller, statusCode, headers, socket);
       }
       onResponseStart(controller, statusCode, headers, statusMessage) {
-        assert2(this.#callback != null);
+        assert3(this.#callback != null);
         this.#successful = statusCode === 304 || this.#allowErrorStatusCodes && statusCode >= 500 && statusCode <= 504;
         this.#callback(this.#successful, this.#context);
         this.#callback = null;
@@ -51981,7 +52026,7 @@ var require_cache_revalidation_handler = __commonJS({
 var require_cache6 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/interceptor/cache.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { Readable } = __require("node:stream");
     var util3 = require_util11();
     var CacheHandler = require_cache_handler();
@@ -52053,8 +52098,8 @@ var require_cache6 = __commonJS({
     }
     function sendCachedValue(handler2, opts, result, age, context, isStale) {
       const stream = util3.isStream(result.body) ? result.body : Readable.from(result.body ?? []);
-      assert2(!stream.destroyed, "stream should not be destroyed");
-      assert2(!stream.readableDidRead, "stream should not be readableDidRead");
+      assert3(!stream.destroyed, "stream should not be destroyed");
+      assert3(!stream.readableDidRead, "stream should not be readableDidRead");
       const controller = {
         resume() {
           stream.resume();
@@ -52856,7 +52901,7 @@ var require_headers2 = __commonJS({
       isValidHeaderValue
     } = require_util12();
     var { webidl } = require_webidl2();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var util3 = __require("node:util");
     function isHTTPWhiteSpaceCharCode(code) {
       return code === 10 || code === 13 || code === 9 || code === 32;
@@ -53072,11 +53117,11 @@ var require_headers2 = __commonJS({
           const iterator2 = this.headersMap[Symbol.iterator]();
           const firstValue = iterator2.next().value;
           array[0] = [firstValue[0], firstValue[1].value];
-          assert2(firstValue[1].value !== null);
+          assert3(firstValue[1].value !== null);
           for (let i = 1, j = 0, right = 0, left = 0, pivot = 0, x, value2; i < size; ++i) {
             value2 = iterator2.next().value;
             x = array[i] = [value2[0], value2[1].value];
-            assert2(x[1] !== null);
+            assert3(x[1] !== null);
             left = 0;
             right = i;
             while (left < right) {
@@ -53103,7 +53148,7 @@ var require_headers2 = __commonJS({
           let i = 0;
           for (const { 0: name, 1: { value: value2 } } of this.headersMap) {
             array[i++] = [name, value2];
-            assert2(value2 !== null);
+            assert3(value2 !== null);
           }
           return array.sort(compareHeaderName);
         }
@@ -53330,7 +53375,7 @@ var require_response2 = __commonJS({
     var { webidl } = require_webidl2();
     var { URLSerializer } = require_data_url();
     var { kConstruct } = require_symbols6();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var textEncoder = new TextEncoder("utf-8");
     var Response2 = class _Response {
       /** @type {Headers} */
@@ -53586,7 +53631,7 @@ var require_response2 = __commonJS({
           return p in state ? state[p] : target[p];
         },
         set(target, p, value2) {
-          assert2(!(p in state));
+          assert3(!(p in state));
           target[p] = value2;
           return true;
         }
@@ -53620,11 +53665,11 @@ var require_response2 = __commonJS({
           body: null
         });
       } else {
-        assert2(false);
+        assert3(false);
       }
     }
     function makeAppropriateNetworkError(fetchParams, err = null) {
-      assert2(isCancelled(fetchParams));
+      assert3(isCancelled(fetchParams));
       return isAborted4(fetchParams) ? makeNetworkError(Object.assign(new DOMException("The operation was aborted.", "AbortError"), { cause: err })) : makeNetworkError(Object.assign(new DOMException("Request was cancelled."), { cause: err }));
     }
     function initializeResponse(response, init, body) {
@@ -53755,7 +53800,7 @@ var require_request4 = __commonJS({
     var { webidl } = require_webidl2();
     var { URLSerializer } = require_data_url();
     var { kConstruct } = require_symbols6();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { getMaxListeners, setMaxListeners: setMaxListeners2, defaultMaxListeners } = __require("node:events");
     var kAbortController = Symbol("abortController");
     var requestFinalizer = new FinalizationRegistry(({ signal, abort }) => {
@@ -53831,7 +53876,7 @@ var require_request4 = __commonJS({
           request2 = makeRequest({ urlList: [parsedURL] });
           fallbackMode = "cors";
         } else {
-          assert2(webidl.is.Request(input));
+          assert3(webidl.is.Request(input));
           request2 = input.#state;
           signal = input.#signal;
           this.#dispatcher = init.dispatcher || input.#dispatcher;
@@ -54480,7 +54525,7 @@ var require_request4 = __commonJS({
 var require_subresource_integrity = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/web/subresource-integrity/subresource-integrity.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var validSRIHashAlgorithmTokenSet = /* @__PURE__ */ new Map([["sha256", 0], ["sha384", 1], ["sha512", 2]]);
     var crypto2;
     try {
@@ -54527,7 +54572,7 @@ var require_subresource_integrity = __commonJS({
       const result = [];
       let strongest = null;
       for (const item of metadataList) {
-        assert2(isValidSRIHashAlgorithm(item.alg), "Invalid SRI hash algorithm token");
+        assert3(isValidSRIHashAlgorithm(item.alg), "Invalid SRI hash algorithm token");
         if (result.length === 0) {
           result.push(item);
           strongest = item;
@@ -54661,7 +54706,7 @@ var require_fetch2 = __commonJS({
       createInflate,
       extractMimeType
     } = require_util12();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { safelyExtractBody, extractBody } = require_body2();
     var {
       redirectStatusSet,
@@ -54742,7 +54787,7 @@ var require_fetch2 = __commonJS({
         requestObject.signal,
         () => {
           locallyAborted = true;
-          assert2(controller != null);
+          assert3(controller != null);
           controller.abort(requestObject.signal.reason);
           const realResponse = responseObject?.deref();
           abortFetch(p, request2, realResponse, requestObject.signal.reason);
@@ -54845,7 +54890,7 @@ var require_fetch2 = __commonJS({
       dispatcher = getGlobalDispatcher()
       // undici
     }) {
-      assert2(dispatcher);
+      assert3(dispatcher);
       let taskDestination = null;
       let crossOriginIsolatedCapability = false;
       if (request2.client != null) {
@@ -54868,7 +54913,7 @@ var require_fetch2 = __commonJS({
         taskDestination,
         crossOriginIsolatedCapability
       };
-      assert2(!request2.body || request2.body.stream);
+      assert3(!request2.body || request2.body.stream);
       if (request2.window === "client") {
         request2.window = request2.client?.globalObject?.constructor?.name === "Window" ? request2.client : "no-window";
       }
@@ -54957,7 +55002,7 @@ var require_fetch2 = __commonJS({
           } else if (request2.responseTainting === "opaque") {
             response = filterResponse(response, "opaque");
           } else {
-            assert2(false);
+            assert3(false);
           }
         }
         let internalResponse = response.status === 0 ? response : response.internalResponse;
@@ -55187,7 +55232,7 @@ var require_fetch2 = __commonJS({
         } else if (request2.redirect === "follow") {
           response = await httpRedirectFetch(fetchParams, response);
         } else {
-          assert2(false);
+          assert3(false);
         }
       }
       response.timingInfo = timingInfo;
@@ -55240,7 +55285,7 @@ var require_fetch2 = __commonJS({
         request2.headersList.delete("host", true);
       }
       if (request2.body != null) {
-        assert2(request2.body.source != null);
+        assert3(request2.body.source != null);
         request2.body = safelyExtractBody(request2.body.source)[0];
       }
       const timingInfo = fetchParams.timingInfo;
@@ -55373,7 +55418,7 @@ var require_fetch2 = __commonJS({
       return response;
     }
     async function httpNetworkFetch(fetchParams, includeCredentials = false, forceNewConnection = false) {
-      assert2(!fetchParams.controller.connection || fetchParams.controller.connection.destroyed);
+      assert3(!fetchParams.controller.connection || fetchParams.controller.connection.destroyed);
       fetchParams.controller.connection = {
         abort: null,
         destroyed: false,
@@ -55680,7 +55725,7 @@ var require_fetch2 = __commonJS({
 var require_util13 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/web/cache/util.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { URLSerializer } = require_data_url();
     var { isValidHeaderName } = require_util12();
     function urlEquals(A, B, excludeFragment = false) {
@@ -55689,7 +55734,7 @@ var require_util13 = __commonJS({
       return serializedA === serializedB;
     }
     function getFieldValues(header) {
-      assert2(header !== null);
+      assert3(header !== null);
       const values = [];
       for (let value2 of header.split(",")) {
         value2 = value2.trim();
@@ -55710,7 +55755,7 @@ var require_util13 = __commonJS({
 var require_cache7 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/web/cache/cache.js"(exports, module) {
     "use strict";
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { kConstruct } = require_symbols6();
     var { urlEquals, getFieldValues } = require_util13();
     var { kEnumerableProperty, isDisturbed } = require_util11();
@@ -55960,7 +56005,7 @@ var require_cache7 = __commonJS({
             return false;
           }
         } else {
-          assert2(typeof request2 === "string");
+          assert3(typeof request2 === "string");
           r = getRequestState(new Request2(request2));
         }
         const operations = [];
@@ -56071,7 +56116,7 @@ var require_cache7 = __commonJS({
               }
               for (const requestResponse of requestResponses) {
                 const idx = cache.indexOf(requestResponse);
-                assert2(idx !== -1);
+                assert3(idx !== -1);
                 cache.splice(idx, 1);
               }
             } else if (operation.type === "put") {
@@ -56103,7 +56148,7 @@ var require_cache7 = __commonJS({
               requestResponses = this.#queryCache(operation.request);
               for (const requestResponse of requestResponses) {
                 const idx = cache.indexOf(requestResponse);
-                assert2(idx !== -1);
+                assert3(idx !== -1);
                 cache.splice(idx, 1);
               }
               cache.push([operation.request, operation.response]);
@@ -56555,7 +56600,7 @@ var require_parse2 = __commonJS({
     var { maxNameValuePairSize, maxAttributeValueSize } = require_constants9();
     var { isCTLExcludingHtab } = require_util14();
     var { collectASequenceOfCodePointsFast } = require_data_url();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { unescape: qsUnescape } = __require("node:querystring");
     function parseSetCookie(header) {
       if (isCTLExcludingHtab(header)) {
@@ -56598,7 +56643,7 @@ var require_parse2 = __commonJS({
       if (unparsedAttributes.length === 0) {
         return cookieAttributeList;
       }
-      assert2(unparsedAttributes[0] === ";");
+      assert3(unparsedAttributes[0] === ";");
       unparsedAttributes = unparsedAttributes.slice(1);
       let cookieAv = "";
       if (unparsedAttributes.includes(";")) {
@@ -57443,7 +57488,7 @@ var require_connection2 = __commonJS({
     var { Headers: Headers2, getHeadersList } = require_headers2();
     var { getDecodeSplit } = require_util12();
     var { WebsocketFrameSend } = require_frame2();
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var crypto2;
     try {
       crypto2 = __require("node:crypto");
@@ -57543,7 +57588,7 @@ var require_connection2 = __commonJS({
         if (reason.length !== 0 && code === null) {
           code = 1e3;
         }
-        assert2(code === null || Number.isInteger(code));
+        assert3(code === null || Number.isInteger(code));
         if (code === null && reason.length === 0) {
           frame.frameData = emptyBuffer;
         } else if (code !== null && reason === null) {
@@ -57642,7 +57687,7 @@ var require_receiver2 = __commonJS({
   "node_modules/.pnpm/undici@7.16.0/node_modules/undici/lib/web/websocket/receiver.js"(exports, module) {
     "use strict";
     var { Writable } = __require("node:stream");
-    var assert2 = __require("node:assert");
+    var assert3 = __require("node:assert");
     var { parserStates, opcodes, states, emptyBuffer, sentCloseFrameState } = require_constants10();
     var {
       isValidStatusCode,
@@ -57879,7 +57924,7 @@ var require_receiver2 = __commonJS({
         return output;
       }
       parseCloseBody(data) {
-        assert2(data.length !== 1);
+        assert3(data.length !== 1);
         let code;
         if (data.length >= 2) {
           code = data.readUInt16BE(0);
@@ -60223,7 +60268,7 @@ __export(util_exports, {
   NUMBER_FORMAT_RANGES: () => NUMBER_FORMAT_RANGES,
   aborted: () => aborted,
   allowsEval: () => allowsEval,
-  assert: () => assert,
+  assert: () => assert2,
   assertEqual: () => assertEqual,
   assertIs: () => assertIs,
   assertNever: () => assertNever,
@@ -60279,7 +60324,7 @@ function assertIs(_arg) {
 function assertNever(_x) {
   throw new Error();
 }
-function assert(_) {
+function assert2(_) {
 }
 function getEnumValues(entries) {
   const numericValues = Object.values(entries).filter((v) => typeof v === "number");
@@ -97792,6 +97837,7 @@ var Octokit2 = Octokit.plugin(requestLog, legacyRestEndpointMethods, paginateRes
 );
 
 // utils/github.ts
+import assert from "node:assert/strict";
 import { createSign } from "node:crypto";
 
 // utils/retry.ts
@@ -97963,23 +98009,23 @@ async function acquireNewToken() {
 }
 var githubInstallationToken;
 async function setupGitHubInstallationToken() {
+  assert(!githubInstallationToken, "GitHub installation token is already set.");
   const acquiredToken = await acquireNewToken();
   core2.setSecret(acquiredToken);
   githubInstallationToken = acquiredToken;
-  return acquiredToken;
+  return {
+    token: acquiredToken,
+    [Symbol.asyncDispose]() {
+      githubInstallationToken = void 0;
+      return revokeGitHubInstallationToken(acquiredToken);
+    }
+  };
 }
 function getGitHubInstallationToken() {
-  if (!githubInstallationToken) {
-    throw new Error("GitHub installation token not set. Call setupGitHubInstallationToken first.");
-  }
+  assert(githubInstallationToken, "GitHub installation token not set. Call setupGitHubInstallationToken first.");
   return githubInstallationToken;
 }
-async function revokeGitHubInstallationToken() {
-  if (!githubInstallationToken) {
-    return;
-  }
-  const token = githubInstallationToken;
-  githubInstallationToken = void 0;
+async function revokeGitHubInstallationToken(token) {
   const apiUrl = process.env.GITHUB_API_URL || "https://api.github.com";
   try {
     await fetch(`${apiUrl}/installation/token`, {
@@ -122843,12 +122889,12 @@ function inspectableError(err) {
     timeStamp: err.timeStamp
   };
 }
-var __typeError = (msg) => {
+var __typeError2 = (msg) => {
   throw TypeError(msg);
 };
-var __accessCheck = (obj, member, msg) => member.has(obj) || __typeError("Cannot " + msg);
+var __accessCheck = (obj, member, msg) => member.has(obj) || __typeError2("Cannot " + msg);
 var __privateGet = (obj, member, getter) => (__accessCheck(obj, member, "read from private field"), getter ? getter.call(obj) : member.get(obj));
-var __privateAdd = (obj, member, value2) => member.has(obj) ? __typeError("Cannot add the same private member more than once") : member instanceof WeakSet ? member.add(obj) : member.set(obj, value2);
+var __privateAdd = (obj, member, value2) => member.has(obj) ? __typeError2("Cannot add the same private member more than once") : member instanceof WeakSet ? member.add(obj) : member.set(obj, value2);
 var __privateSet = (obj, member, value2, setter) => (__accessCheck(obj, member, "write to private field"), member.set(obj, value2), value2);
 var __privateMethod = (obj, member, method) => (__accessCheck(obj, member, "access private method"), method);
 var _readyState;
@@ -126510,138 +126556,146 @@ var Inputs = type({
   ...keyInputDefs
 });
 async function main(inputs) {
-  let mcpServerClose;
-  let payload;
+  var _stack = [];
   try {
     const timer = new Timer();
-    payload = parsePayload(inputs);
-    Inputs.assert(inputs);
-    setupGitConfig();
-    const [githubSetup, sharedTempDir] = await Promise.all([
-      initializeGitHub(),
-      createTempDirectory()
-    ]);
-    timer.checkpoint("githubSetup");
-    const agent2 = resolveAgent({
-      inputs,
-      payload,
-      repoSettings: githubSetup.repoSettings
-    });
-    const resolvedPayload = { ...payload, agent: agent2.name };
-    const apiKeySetup = validateApiKey({
-      agent: agent2,
-      inputs,
-      owner: githubSetup.owner,
-      name: githubSetup.name
-    });
-    if (!apiKeySetup.success) {
-      await reportErrorToComment({ error: apiKeySetup.error });
-      return { success: false, error: apiKeySetup.error };
-    }
-    const toolState = {};
-    const [cliPath] = await Promise.all([
-      installAgentCli({ agent: agent2, token: githubSetup.token }),
-      setupGitAuth({
-        token: githubSetup.token,
+    const installationToken = __using(_stack, await setupGitHubInstallationToken(), true);
+    let mcpServerClose;
+    let payload;
+    try {
+      payload = parsePayload(inputs);
+      Inputs.assert(inputs);
+      setupGitConfig();
+      const [githubSetup, sharedTempDir] = await Promise.all([
+        initializeGitHub(installationToken.token),
+        createTempDirectory()
+      ]);
+      timer.checkpoint("githubSetup");
+      const agent2 = resolveAgent({
+        inputs,
+        payload,
+        repoSettings: githubSetup.repoSettings
+      });
+      const resolvedPayload = { ...payload, agent: agent2.name };
+      const apiKeySetup = validateApiKey({
+        agent: agent2,
+        inputs,
+        owner: githubSetup.owner,
+        name: githubSetup.name
+      });
+      if (!apiKeySetup.success) {
+        await reportErrorToComment({ error: apiKeySetup.error });
+        return { success: false, error: apiKeySetup.error };
+      }
+      const toolState = {};
+      const [cliPath] = await Promise.all([
+        installAgentCli({ agent: agent2, token: installationToken.token }),
+        setupGitAuth({
+          token: installationToken.token,
+          owner: githubSetup.owner,
+          name: githubSetup.name,
+          payload: resolvedPayload,
+          octokit: githubSetup.octokit,
+          toolState
+        })
+      ]);
+      timer.checkpoint("agentSetup+gitAuth");
+      const computedModes = [
+        ...getModes({
+          disableProgressComment: resolvedPayload.disableProgressComment
+        }),
+        ...resolvedPayload.modes || []
+      ];
+      const runId = process.env.GITHUB_RUN_ID || "";
+      if (runId) {
+        const workflowRunInfo = await fetchWorkflowRunInfo(runId);
+        if (workflowRunInfo.progressCommentId) {
+          process.env.PULLFROG_PROGRESS_COMMENT_ID = workflowRunInfo.progressCommentId;
+          log.info(`\u{1F4DD} Using pre-created progress comment: ${workflowRunInfo.progressCommentId}`);
+        }
+      }
+      let jobId;
+      const jobName = process.env.GITHUB_JOB;
+      if (jobName && runId) {
+        const jobs = await githubSetup.octokit.rest.actions.listJobsForWorkflowRun({
+          owner: githubSetup.owner,
+          repo: githubSetup.name,
+          run_id: parseInt(runId, 10)
+        });
+        const matchingJob = jobs.data.jobs.find((job) => job.name === jobName);
+        if (matchingJob) {
+          jobId = String(matchingJob.id);
+          log.info(`\u{1F4CB} Found job ID: ${jobId}`);
+        }
+      }
+      const toolContext = {
         owner: githubSetup.owner,
         name: githubSetup.name,
-        payload: resolvedPayload,
+        githubInstallationToken: installationToken.token,
         octokit: githubSetup.octokit,
-        toolState
-      })
-    ]);
-    timer.checkpoint("agentSetup+gitAuth");
-    const computedModes = [
-      ...getModes({
-        disableProgressComment: resolvedPayload.disableProgressComment
-      }),
-      ...resolvedPayload.modes || []
-    ];
-    const runId = process.env.GITHUB_RUN_ID || "";
-    if (runId) {
-      const workflowRunInfo = await fetchWorkflowRunInfo(runId);
-      if (workflowRunInfo.progressCommentId) {
-        process.env.PULLFROG_PROGRESS_COMMENT_ID = workflowRunInfo.progressCommentId;
-        log.info(`\u{1F4DD} Using pre-created progress comment: ${workflowRunInfo.progressCommentId}`);
-      }
-    }
-    let jobId;
-    const jobName = process.env.GITHUB_JOB;
-    if (jobName && runId) {
-      const jobs = await githubSetup.octokit.rest.actions.listJobsForWorkflowRun({
-        owner: githubSetup.owner,
-        repo: githubSetup.name,
-        run_id: parseInt(runId, 10)
-      });
-      const matchingJob = jobs.data.jobs.find((job) => job.name === jobName);
-      if (matchingJob) {
-        jobId = String(matchingJob.id);
-        log.info(`\u{1F4CB} Found job ID: ${jobId}`);
-      }
-    }
-    const toolContext = {
-      owner: githubSetup.owner,
-      name: githubSetup.name,
-      githubInstallationToken: githubSetup.token,
-      octokit: githubSetup.octokit,
-      payload: resolvedPayload,
-      repo: githubSetup.repo,
-      repoSettings: githubSetup.repoSettings,
-      modes: computedModes,
-      toolState,
-      agent: agent2,
-      sharedTempDir,
-      runId,
-      jobId
-    };
-    const { url: mcpServerUrl, close: mcpServerCloseFunc } = await startMcpHttpServer(toolContext);
-    mcpServerClose = mcpServerCloseFunc;
-    log.info(`\u{1F680} MCP server started at ${mcpServerUrl}`);
-    const mcpServers = createMcpConfigs(mcpServerUrl);
-    log.debug(`\u{1F4CB} MCP Config: ${JSON.stringify(mcpServers, null, 2)}`);
-    timer.checkpoint("mcpServer");
-    const ctx = {
-      ...toolContext,
-      inputs,
-      mcpServerUrl,
-      mcpServerClose: mcpServerCloseFunc,
-      mcpServers,
-      cliPath,
-      apiKey: apiKeySetup.apiKey,
-      apiKeys: apiKeySetup.apiKeys
-    };
-    if (ctx.payload.event.trigger === "fix_review" && Array.isArray(ctx.payload.event.comment_ids) && ctx.payload.event.comment_ids.length === 0) {
-      const noThumbsMessage = `\u{1F44D} **No approved comments found**
+        payload: resolvedPayload,
+        repo: githubSetup.repo,
+        repoSettings: githubSetup.repoSettings,
+        modes: computedModes,
+        toolState,
+        agent: agent2,
+        sharedTempDir,
+        runId,
+        jobId
+      };
+      const { url: mcpServerUrl, close: mcpServerCloseFunc } = await startMcpHttpServer(toolContext);
+      mcpServerClose = mcpServerCloseFunc;
+      log.info(`\u{1F680} MCP server started at ${mcpServerUrl}`);
+      const mcpServers = createMcpConfigs(mcpServerUrl);
+      log.debug(`\u{1F4CB} MCP Config: ${JSON.stringify(mcpServers, null, 2)}`);
+      timer.checkpoint("mcpServer");
+      const ctx = {
+        ...toolContext,
+        inputs,
+        mcpServerUrl,
+        mcpServerClose: mcpServerCloseFunc,
+        mcpServers,
+        cliPath,
+        apiKey: apiKeySetup.apiKey,
+        apiKeys: apiKeySetup.apiKeys
+      };
+      if (ctx.payload.event.trigger === "fix_review" && Array.isArray(ctx.payload.event.comment_ids) && ctx.payload.event.comment_ids.length === 0) {
+        const noThumbsMessage = `\u{1F44D} **No approved comments found**
 
 To use "Fix \u{1F44D}s", add a \u{1F44D} reaction to one or more inline review comments you want fixed.`;
-      log.error(noThumbsMessage);
-      await reportProgress(ctx, { body: noThumbsMessage });
-      return { success: true };
+        log.error(noThumbsMessage);
+        await reportProgress(ctx, { body: noThumbsMessage });
+        return { success: true };
+      }
+      const result = await runAgent(ctx);
+      const mainResult = await handleAgentResult(result);
+      return mainResult;
+    } catch (error41) {
+      const errorMessage = error41 instanceof Error ? error41.message : "Unknown error occurred";
+      log.error(errorMessage);
+      try {
+        await reportErrorToComment({ error: errorMessage });
+      } catch {
+      }
+      await log.writeSummary();
+      return {
+        success: false,
+        error: errorMessage
+      };
+    } finally {
+      try {
+        await ensureProgressCommentUpdated(payload);
+      } catch {
+      }
+      if (mcpServerClose) {
+        await mcpServerClose();
+      }
     }
-    const result = await runAgent(ctx);
-    const mainResult = await handleAgentResult(result);
-    return mainResult;
-  } catch (error41) {
-    const errorMessage = error41 instanceof Error ? error41.message : "Unknown error occurred";
-    log.error(errorMessage);
-    try {
-      await reportErrorToComment({ error: errorMessage });
-    } catch {
-    }
-    await log.writeSummary();
-    return {
-      success: false,
-      error: errorMessage
-    };
+  } catch (_) {
+    var _error = _, _hasError = true;
   } finally {
-    try {
-      await ensureProgressCommentUpdated(payload);
-    } catch {
-    }
-    if (mcpServerClose) {
-      await mcpServerClose();
-    }
-    await revokeGitHubInstallationToken();
+    var _promise2 = __callDispose(_stack, _error, _hasError);
+    _promise2 && await _promise2;
   }
 }
 function agentHasApiKeys(agent2, inputs) {
@@ -126690,9 +126744,8 @@ To fix this, add the required secret to your GitHub repository:
 
 Alternatively, configure Pullfrog to use a different agent at ${settingsUrl}`;
 }
-async function initializeGitHub() {
+async function initializeGitHub(token) {
   log.info(`\u{1F438} Running pullfrog/action@${package_default.version}...`);
-  const token = await setupGitHubInstallationToken();
   const { owner, name } = parseRepoContext();
   const octokit = createOctokit(token);
   const [repoResponse, repoSettings] = await Promise.all([
@@ -126700,7 +126753,6 @@ async function initializeGitHub() {
     fetchRepoSettings({ token, repoContext: { owner, name } })
   ]);
   return {
-    token,
     owner,
     name,
     octokit,
diff --git a/esbuild.config.js b/esbuild.config.js
index 6bfdc89..01e4889 100644
--- a/esbuild.config.js
+++ b/esbuild.config.js
@@ -19,7 +19,7 @@ const stripShebangPlugin = {
         try {
           const content = readFileSync(outputFile, "utf8");
           // Remove shebang line from the beginning if present
-          const withoutShebang = content.startsWith("#!") 
+          const withoutShebang = content.startsWith("#!")
             ? content.slice(content.indexOf("\n") + 1)
             : content;
           writeFileSync(outputFile, withoutShebang);
@@ -38,7 +38,7 @@ const sharedConfig = {
   bundle: true,
   format: "esm",
   platform: "node",
-  target: "node20",
+  target: "node24",
   minify: false,
   sourcemap: false,
   // Bundle all dependencies - GitHub Actions doesn't have node_modules
diff --git a/main.ts b/main.ts
index e4ceb97..1ab0c00 100644
--- a/main.ts
+++ b/main.ts
@@ -21,7 +21,6 @@ import { reportErrorToComment } from "./utils/errorReport.ts";
 import {
   createOctokit,
   parseRepoContext,
-  revokeGitHubInstallationToken,
   setupGitHubInstallationToken,
 } from "./utils/github.ts";
 import { setupGitAuth, setupGitConfig } from "./utils/setup.ts";
@@ -54,7 +53,6 @@ export interface MainResult {
 
 // intermediate result types for deterministic context building
 interface GitHubSetup {
-  token: string;
   owner: string;
   name: string;
   octokit: Octokit;
@@ -67,12 +65,12 @@ type ApiKeySetup =
   | { success: false; error: string };
 
 export async function main(inputs: Inputs): Promise<MainResult> {
+  const timer = new Timer();
+  await using installationToken = await setupGitHubInstallationToken();
   let mcpServerClose: (() => Promise<void>) | undefined;
   let payload: Payload | undefined;
 
   try {
-    const timer = new Timer();
-
     // phase 1: parse and validate inputs
     payload = parsePayload(inputs);
     Inputs.assert(inputs);
@@ -80,7 +78,7 @@ export async function main(inputs: Inputs): Promise<MainResult> {
 
     // phase 2: fast setup (github + temp dir)
     const [githubSetup, sharedTempDir] = await Promise.all([
-      initializeGitHub(),
+      initializeGitHub(installationToken.token),
       createTempDirectory(),
     ]);
     timer.checkpoint("githubSetup");
@@ -108,9 +106,9 @@ export async function main(inputs: Inputs): Promise<MainResult> {
     // phase 5: parallel long-running operations (agent install + git auth)
     const toolState: ToolState = {};
     const [cliPath] = await Promise.all([
-      installAgentCli({ agent, token: githubSetup.token }),
+      installAgentCli({ agent, token: installationToken.token }),
       setupGitAuth({
-        token: githubSetup.token,
+        token: installationToken.token,
         owner: githubSetup.owner,
         name: githubSetup.name,
         payload: resolvedPayload,
@@ -157,7 +155,7 @@ export async function main(inputs: Inputs): Promise<MainResult> {
     const toolContext: ToolContext = {
       owner: githubSetup.owner,
       name: githubSetup.name,
-      githubInstallationToken: githubSetup.token,
+      githubInstallationToken: installationToken.token,
       octokit: githubSetup.octokit,
       payload: resolvedPayload,
       repo: githubSetup.repo,
@@ -230,7 +228,6 @@ export async function main(inputs: Inputs): Promise<MainResult> {
     if (mcpServerClose) {
       await mcpServerClose();
     }
-    await revokeGitHubInstallationToken();
   }
 }
 
@@ -349,10 +346,9 @@ export interface ToolState {
 /**
  * Initialize GitHub connection: token, octokit, repo data, settings
  */
-async function initializeGitHub(): Promise<GitHubSetup> {
+async function initializeGitHub(token: string): Promise<GitHubSetup> {
   log.info(`🐸 Running pullfrog/action@${packageJson.version}...`);
 
-  const token = await setupGitHubInstallationToken();
   const { owner, name } = parseRepoContext();
 
   const octokit = createOctokit(token);
@@ -364,7 +360,6 @@ async function initializeGitHub(): Promise<GitHubSetup> {
   ]);
 
   return {
-    token,
     owner,
     name,
     octokit,
diff --git a/utils/github.ts b/utils/github.ts
index e09deba..4c603f7 100644
--- a/utils/github.ts
+++ b/utils/github.ts
@@ -1,6 +1,7 @@
 import * as core from "@actions/core";
 import { throttling } from "@octokit/plugin-throttling";
 import { Octokit } from "@octokit/rest";
+import assert from "node:assert/strict";
 import { createSign } from "node:crypto";
 import { log } from "./cli.ts";
 import { retry } from "./retry.ts";
@@ -248,31 +249,29 @@ let githubInstallationToken: string | undefined;
 /**
  * Setup GitHub installation token for the action
  */
-export async function setupGitHubInstallationToken(): Promise<string> {
+export async function setupGitHubInstallationToken() {
+  assert(!githubInstallationToken, "GitHub installation token is already set.");
   const acquiredToken = await acquireNewToken();
   core.setSecret(acquiredToken);
   githubInstallationToken = acquiredToken;
-  return acquiredToken;
+  return {
+    token: acquiredToken,
+    [Symbol.asyncDispose]() {
+      githubInstallationToken = undefined;
+      return revokeGitHubInstallationToken(acquiredToken);
+    },
+  };
 }
 
 /**
  * Get the GitHub installation token from memory
  */
 export function getGitHubInstallationToken(): string {
-  if (!githubInstallationToken) {
-    throw new Error("GitHub installation token not set. Call setupGitHubInstallationToken first.");
-  }
+  assert(githubInstallationToken, "GitHub installation token not set. Call setupGitHubInstallationToken first.");
   return githubInstallationToken;
 }
 
-export async function revokeGitHubInstallationToken(): Promise<void> {
-  if (!githubInstallationToken) {
-    return;
-  }
-
-  const token = githubInstallationToken;
-  githubInstallationToken = undefined;
-
+async function revokeGitHubInstallationToken(token: string): Promise<void> {
   const apiUrl = process.env.GITHUB_API_URL || "https://api.github.com";
 
   try {