Support dynamic client providers

core/src/main/java/org/apache/airavata/mft/core/AuthZToken.java

@@ -0,0 +1,46 @@
+package org.apache.airavata.mft.core;
+
+public class AuthZToken {
+
+    private String mftAuthorizationToken;
+    private String agentId;
+    private String agentSecret;
+
+    public AuthZToken(String mftAuthorizationToken, String agentId, String agentSecret) {
+        this.mftAuthorizationToken = mftAuthorizationToken;
+        this.agentId = agentId;
+        this.agentSecret = agentSecret;
+    }
+
+    public AuthZToken(String mftAuthorizationToken) {
+        this.mftAuthorizationToken = mftAuthorizationToken;
+    }
+
+    public AuthZToken(){
+
+    }
+
+    public String getMftAuthorizationToken() {
+        return mftAuthorizationToken;
+    }
+
+    public void setMftAuthorizationToken(String mftAuthorizationToken) {
+        this.mftAuthorizationToken = mftAuthorizationToken;
+    }
+
+    public String getAgentId() {
+        return agentId;
+    }
+
+    public void setAgentId(String agentId) {
+        this.agentId = agentId;
+    }
+
+    public String getAgentSecret() {
+        return agentSecret;
+    }
+
+    public void setAgentSecret(String agentSecret) {
+        this.agentSecret = agentSecret;
+    }
+}

services/secret-service/server/src/main/java/org/apache/airavata/mft/secret/server/AppConfig.java

@@ -17,6 +17,7 @@
 
 package org.apache.airavata.mft.secret.server;
 
+import org.apache.airavata.mft.secret.server.backend.custos.CustosClientsFactory;
 import org.apache.airavata.mft.secret.server.backend.custos.auth.AgentAuthenticationHandler;
 import org.apache.custos.clients.CustosClientProvider;
 import org.springframework.beans.factory.annotation.Value;
@@ -42,16 +43,13 @@ public class AppConfig {
     private String custosSecret;
 
     @Bean
-    public CustosClientProvider custosClientProvider() {
-        return new CustosClientProvider.Builder().setServerHost(custosHost)
-                .setServerPort(custosPort)
-                .setClientId(custosId)
-                .setClientSec(custosSecret).build();
+    public CustosClientsFactory custosClientsFactory() {
+        return new CustosClientsFactory(custosHost, custosPort, custosId, custosSecret);
     }
 
     @Bean
     public AgentAuthenticationHandler agentAuthenticationHandler() throws IOException {
-        return new AgentAuthenticationHandler(custosId, custosClientProvider());
+        return new AgentAuthenticationHandler(custosId, custosSecret, custosClientsFactory());
     }
 
 

services/secret-service/server/src/main/java/org/apache/airavata/mft/secret/server/backend/custos/CustosClientsFactory.java

@@ -0,0 +1,54 @@
+package org.apache.airavata.mft.secret.server.backend.custos;
+
+import org.apache.custos.clients.CustosClientProvider;
+
+import java.util.Map;
+import java.util.Optional;
+import java.util.concurrent.ConcurrentHashMap;
+
+public class CustosClientsFactory {
+
+    private String custosHost;
+
+    private int custosPort;
+
+    private Map<String, CustosClientProvider> custosClientProviderMap = new ConcurrentHashMap<>();
+
+    public CustosClientsFactory(String custosHost, int custosPort, String custosId, String custosSecret) {
+        this.custosHost = custosHost;
+        this.custosPort = custosPort;
+        CustosClientProvider custosClientProvider = new CustosClientProvider.Builder().setServerHost(custosHost)
+                .setServerPort(custosPort)
+                .setClientId(custosId)
+                .setClientSec(custosSecret).build();
+        custosClientProviderMap.put(custosId, custosClientProvider);
+
+    }
+
+
+    public CustosClientProvider getCustosClientProvider(String custosId, String custosSecret) {
+
+        if (custosClientProviderMap.containsKey(custosId)) {
+            return custosClientProviderMap.get(custosId);
+        }
+
+        CustosClientProvider custosClientProvider = new CustosClientProvider.Builder().setServerHost(custosHost)
+                .setServerPort(custosPort)
+                .setClientId(custosId)
+                .setClientSec(custosSecret).build();
+        custosClientProviderMap.put(custosId, custosClientProvider);
+        return custosClientProvider;
+
+    }
+
+    public Optional<CustosClientProvider> getCustosClientProvider(String custosId) {
+
+        if (custosClientProviderMap.containsKey(custosId)) {
+            return Optional.of(custosClientProviderMap.get(custosId));
+        }
+        return Optional.empty();
+
+    }
+
+
+}