fix: add condition for if portRequired then port must not be empty or undefined

Author: ndk123-web

middleserver/controllers/middlemanController.mjs

@@ -72,11 +72,16 @@ const MiddlemanController = async (req, res) => {
     }
 
     const { host, port, method, params, protocol, portRequired  } = jsonresponse.data || {};
-    if (!host || !port) {
+    if (!host) {
         logError("Registry returned invalid server info", jsonresponse);
         return res.status(500).json(new ApiResponse(500, "Invalid server info from registry"));
     }
 
+    if (portRequired && !port){
+        logError("Port Required but not provided by registry", jsonresponse);
+        return res.status(500).json(new ApiResponse(500, "Port required but not provided by registry"));
+    }
+
     if (showLog) {
         logInfo("Sending request to Server", { host, port, method, params });
     }
@@ -100,7 +105,7 @@ const MiddlemanController = async (req, res) => {
             jsonresponsee = await serverResponse.json();
 
         } else {
-            serverResponse = await fetch(`${protocol}://${host}/api/v1/${method}`, {
+            serverResponse = await fetch(`${protocol}://${host}/api/v1/ndk-load-balancer/forward-requests`, {
                 method: "POST",
                 headers: { "Content-Type": "application/json" },
                 body: JSON.stringify({ method, params }),

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ndk-rpc-cluster",
-  "version": "1.0.8",
+  "version": "2.0.0",
   "description": "Enterprise-grade RPC cluster system with load balancing, fault tolerance, service discovery and automatic failover support",
   "type": "module",
   "main": "./index.mjs",