save

src/index.ts

@@ -3,7 +3,6 @@ import { Handler } from "hono";
 import https from "https";
 import http from "http";
 import { createBunWebSocket } from "hono/bun";
-import fetch from "node-fetch";
 
 import dotenv from "dotenv";
 
@@ -50,71 +49,37 @@ function basicProxy(proxy_url = ""): Handler {
       headers[key] = value;
     });
 
-    const httpModule = url.startsWith("https") ? https : http;
+    const blob = await c.req.blob();
 
-    const agent = new httpModule.Agent({
-      rejectUnauthorized: false,
+    const response = await fetch(url, {
+      method: c.req.raw.method,
+      headers: headers,
+      body: blob.size > 0 ? blob : undefined,
     });
 
-    // Construct options for the https.request
-    const requestOptions = {
-      method: c.req.raw.method,
-      headers,
-      rejectUnauthorized: false,
-      agent: agent,
-    };
+    // response
 
-    console.log("Request options", requestOptions);
+    console.log("Response", response.status, response.statusText);
 
-    const res = await fetch(url, {
-      agent: agent,
-    });
+    // Compress the response based on the Content-Encoding
 
-    console.log("Response TEST", res.status, res.statusText, res.headers);
-
-    // Perform the request using https.request
-    return new Promise(async (resolve, reject) => {
-      console.log("Requesting", url, requestOptions);
-      const req = httpModule.request(url, requestOptions, (res) => {
-        const chunks = [];
-        res.on("data", (chunk) => {
-          chunks.push(chunk);
-        });
-        res.on("end", () => {
-          const responseBody = Buffer.concat(chunks);
-
-          console.log(
-            "Response",
-            res.statusCode,
-            res.statusMessage,
-            res.headers
-          );
-
-          // Return the response
-          resolve(
-            new Response(responseBody, {
-              status: res.statusCode,
-              statusText: res.statusMessage,
-              headers: res.headers,
-            })
-          );
-        });
-      });
+    const contentEncoding = response.headers.get("Content-Encoding");
 
-      // Handle request errors
-      req.on("error", (err) => {
-        console.error("Error making request:", err);
-        reject(err);
-      });
+    let compressed: Uint8Array = new Uint8Array();
 
-      // Write request body if present
-      const buff = await c.req.arrayBuffer();
-      if (buff.byteLength > 0) {
-        // To Uint8Array
-        req.write(Buffer.from(buff));
-      }
+    if (contentEncoding === "deflate") {
+      const buffer = await response.arrayBuffer();
+      compressed = Bun.deflateSync(buffer);
+    } else if (contentEncoding === "gzip") {
+      const buffer = await response.arrayBuffer();
+      compressed = Bun.gzipSync(buffer);
+    } else {
+    }
 
-      req.end();
+    return new Response(compressed, {
+      status: response.status,
+      statusText: response.statusText,
+      headers: response.headers,
     });
   };
 }