feat: parse port from onConnect handler

src/components/proxy-middleware/middlewares/logger_middleware.js

@@ -1,6 +1,7 @@
+
 // import { cloneDeep } from "lodash";
 // import HTTPSnippet from "httpsnippet";
-import { get_success_actions_from_action_results } from "../rule_action_processor/utils";
+import { get_success_actions_from_action_results, getHost } from "../rule_action_processor/utils";
 import { createHar } from "../helpers/harObectCreator";
 // const url = require("url");
 
@@ -15,6 +16,7 @@ class LoggerMiddleware {
       return "";
     }
     let requestCurl = "";
+
     // try {
     //   const harObject = cloneDeep(requestHarObject);
     //   requestCurl = new HTTPSnippet(harObject).convert("shell", "curl", {
@@ -79,7 +81,7 @@ class LoggerMiddleware {
         ctx.rq.final_request.headers,
         ctx.rq.final_request.method,
         protocol,
-        ctx.rq.final_request.host,
+        getHost(ctx),
         ctx.rq.final_request.path,
         ctx.rq.final_request.body,
         ctx.rq.final_response.status_code,

src/components/proxy-middleware/rule_action_processor/utils.js

@@ -43,6 +43,20 @@ export const get_success_actions_from_action_results = (
   return success_action_results_objs.map((obj) => obj.action);
 };
 
+export const getHost = (ctx) => {
+  const finalHost = ctx.rq.final_request.host;
+  const port = ctx.rq.final_request.port;
+  const protocol = ctx.isSSL ? "https" : "http";
+  const standardPort = protocol === "https" ? 443 : 80;
+
+  // Only append port if it's non-standard and not already in the host
+  if (port && port !== standardPort && !finalHost.includes(':')) {
+    return `${finalHost}:${port}`;
+  }
+
+  return finalHost;
+}
+
 export const get_file_contents = (file_path) => {
   return fs.readFileSync(file_path, "utf-8");
 }