1 files changed, 73 insertions, 0 deletions
diff --git a/packages/bun-release/src/fetch.ts b/packages/bun-release/src/fetch.ts
new file mode 100644
index 000000000..d9c85a5f3
--- /dev/null
+++ b/packages/bun-release/src/fetch.ts
@@ -0,0 +1,73 @@
+import { debug, isDebug } from "./console";
+
+export const fetch = "fetch" in globalThis ? webFetch : nodeFetch;
+
+type Options = RequestInit & { assert?: boolean };
+
+async function webFetch(url: string, options: Options = {}): Promise<Response> {
+  debug("fetch request", url, options);
+  const response = await globalThis.fetch(url, options, { verbose: isDebug });
+  debug("fetch response", response);
+  if (options?.assert !== false && !isOk(response.status)) {
+    try {
+      debug(await response.text());
+    } catch {}
+    throw new Error(`${response.status}: ${url}`);
+  }
+  return response;
+}
+
+async function nodeFetch(
+  url: string,
+  options: Options = {},
+): Promise<Response> {
+  const { get } = await import("node:http");
+  return new Promise((resolve, reject) => {
+    get(url, (response) => {
+      debug("http.get", url, response.statusCode);
+      const status = response.statusCode ?? 501;
+      if (response.headers.location && isRedirect(status)) {
+        return nodeFetch(url).then(resolve, reject);
+      }
+      if (options?.assert !== false && !isOk(status)) {
+        return reject(new Error(`${status}: ${url}`));
+      }
+      const body: Buffer[] = [];
+      response.on("data", (chunk) => {
+        body.push(chunk);
+      });
+      response.on("end", () => {
+        resolve({
+          ok: isOk(status),
+          status,
+          async arrayBuffer() {
+            return Buffer.concat(body).buffer as ArrayBuffer;
+          },
+          async text() {
+            return Buffer.concat(body).toString("utf-8");
+          },
+          async json() {
+            const text = Buffer.concat(body).toString("utf-8");
+            return JSON.parse(text);
+          },
+        } as Response);
+      });
+    }).on("error", reject);
+  });
+}
+
+function isOk(status: number): boolean {
+  return status >= 200 && status <= 204;
+}
+
+function isRedirect(status: number): boolean {
+  switch (status) {
+    case 301: // Moved Permanently
+    case 308: // Permanent Redirect
+    case 302: // Found
+    case 307: // Temporary Redirect
+    case 303: // See Other
+      return true;
+  }
+  return false;
+}