Multicluster support changes and cluster origin added

Author: brijeshgajjarfynd

express/api_routes.js

@@ -11,7 +11,8 @@ function setupProxyRoutes(extension) {
 
     applicationProxyRoutes.use(["/:cluster_id", "/"],async (req, res, next) => {
         try {
-            const clusterId = req.params.cluster_id;
+            const clusterId = req.params.cluster_id || req.query.cluster_origin;
+            console.log(clusterId, "Cluster Id of the Extension");
             if (clusterId) {
                 extension = ExtensionFactory.getExtension(clusterId)
             }

express/extension_factory.js

@@ -8,7 +8,7 @@ class ExtensionFactory {
     static getExtension(clusterId) {
         const clusterExt = ExtensionFactory._extensionMap[clusterId]
         if (clusterId !== null && !clusterExt) {
-            throw FdkInvalidCluster(`Extension instance not found for clusterId ${clusterId}`);
+            throw new FdkInvalidCluster(`Extension instance not found for clusterId ${clusterId}`);
         }
         return clusterExt;
     }

express/routes.js

@@ -15,7 +15,7 @@ function setupRoutes(ext) {
     FdkRoutes.get(["/:cluster_id/fp/install", "/fp/install"], async (req, res, next) => {
         // ?company_id=1&client_id=123313112122
         try {
-            const cluster_id = req.params.cluster_id;
+            const cluster_id = req.query.cluster_url || req.params.cluster_id;
             if (cluster_id) {
                 ext = ExtensionFactory.getExtension(cluster_id)
             }

express/webhook.js

@@ -291,7 +291,7 @@ class WebhookRegistry {
         }
         try {
             const { body } = req;
-            const clusterId = req.params.cluster_id;
+            const clusterId = body.referer || req.params.cluster_id;
             if (body.event.name === TEST_WEBHOOK_EVENT_NAME) {
                 return;
             }