1 files changed, 127 insertions, 0 deletions
diff --git a/blueprints-processor/adaptors/rest-adaptor-provider/src/main/java/org/onap/ccsdk/config/rest/adaptor/service/SSLRestClientAdapterImpl.java b/blueprints-processor/adaptors/rest-adaptor-provider/src/main/java/org/onap/ccsdk/config/rest/adaptor/service/SSLRestClientAdapterImpl.java
new file mode 100644
index 000000000..7d31b812e
--- /dev/null
+++ b/blueprints-processor/adaptors/rest-adaptor-provider/src/main/java/org/onap/ccsdk/config/rest/adaptor/service/SSLRestClientAdapterImpl.java
@@ -0,0 +1,127 @@
+/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package org.onap.ccsdk.config.rest.adaptor.service;
+
+import java.util.Map;
+import java.util.UUID;
+import org.onap.ccsdk.config.rest.adaptor.ConfigRestAdaptorConstants;
+import org.onap.ccsdk.config.rest.adaptor.ConfigRestAdaptorException;
+import org.onap.ccsdk.config.rest.adaptor.data.RestResponse;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+public class SSLRestClientAdapterImpl extends AbstractConfigRestClientAdapter {
+    
+    private static EELFLogger logger = EELFManager.getInstance().getLogger(SSLRestClientAdapterImpl.class);
+    private String baseUrl = "";
+    private String application = "";
+    
+    public SSLRestClientAdapterImpl(Map<String, String> properties, String serviceSelector)
+            throws ConfigRestAdaptorException {
+        super(properties, serviceSelector);
+        init(serviceSelector);
+    }
+    
+    private void init(String serviceSelector) throws ConfigRestAdaptorException {
+        try {
+            if (isSSLServiceAdapaterEnabled) {
+                
+                logger.info("Initializing SSL client for selector ({}), properties ({})", serviceSelector, properties);
+                
+                String baseUrlProp = ConfigRestAdaptorConstants.REST_ADAPTOR_BASE_PROPERTY + serviceSelector
+                        + ConfigRestAdaptorConstants.SSL_SERVICE_BASEURL;
+                String applicationProp = ConfigRestAdaptorConstants.REST_ADAPTOR_BASE_PROPERTY + serviceSelector
+                        + ConfigRestAdaptorConstants.SSL_SERVICE_APP;
+                String keyStorePathProp = ConfigRestAdaptorConstants.REST_ADAPTOR_BASE_PROPERTY + serviceSelector
+                        + ConfigRestAdaptorConstants.SSL_SERVICE_KEY;
+                String keyStorePassProp = ConfigRestAdaptorConstants.REST_ADAPTOR_BASE_PROPERTY + serviceSelector
+                        + ConfigRestAdaptorConstants.SSL_SERVICE_KEY_PSSWD;
+                String trustStorePathProp = ConfigRestAdaptorConstants.REST_ADAPTOR_BASE_PROPERTY + serviceSelector
+                        + ConfigRestAdaptorConstants.SSL_SERVICE_TRUST;
+                String trustStorePassProp = ConfigRestAdaptorConstants.REST_ADAPTOR_BASE_PROPERTY + serviceSelector
+                        + ConfigRestAdaptorConstants.SSL_SERVICE_TRUST_PSSWD;
+                
+                baseUrl = properties.get(baseUrlProp);
+                application = properties.get(applicationProp);
+                
+                String keyStorePath = properties.get(keyStorePathProp);
+                String trustStorePath = properties.get(trustStorePathProp);
+                String keyStorePass = properties.get(keyStorePassProp);
+                String trustStorePass = properties.get(trustStorePassProp);
+                
+                initialiseSSL(keyStorePath, trustStorePath, keyStorePass, trustStorePass);
+                logger.info("Initialised SSL Client Service adaptor service for selector ({})", serviceSelector);
+                if (restTemplate == null) {
+                    throw new ConfigRestAdaptorException(
+                            "couldn't initialise SSL Client selector (" + serviceSelector + ")");
+                }
+            } else {
+                throw new ConfigRestAdaptorException("SSL Client selector (" + serviceSelector + ") is not enabled");
+            }
+            
+        } catch (Exception e) {
+            throw new ConfigRestAdaptorException("SSLRestClientAdapterImpl : " + e.getMessage(), e);
+        }
+    }
+    
+    @Override
+    public <T> T getResource(String path, Class<T> responseType) throws ConfigRestAdaptorException {
+        return super.getResource(formHttpHeaders(), constructUrl(baseUrl, path), responseType);
+    }
+    
+    @Override
+    public <T> T postResource(String path, Object request, Class<T> responseType) throws ConfigRestAdaptorException {
+        return super.postResource(formHttpHeaders(), constructUrl(baseUrl, path), request, responseType);
+    }
+    
+    @Override
+    public <T> T exchangeResource(String path, Object request, Class<T> responseType, String method)
+            throws ConfigRestAdaptorException {
+        return super.exchangeResource(formHttpHeaders(), constructUrl(baseUrl, path), request, responseType, method);
+    }
+    
+    @Override
+    public RestResponse getResource(String path) throws ConfigRestAdaptorException {
+        return super.getResource(formHttpHeaders(), constructUrl(baseUrl, path));
+    }
+    
+    @Override
+    public RestResponse postResource(String path, Object request) throws ConfigRestAdaptorException {
+        return super.postResource(formHttpHeaders(), constructUrl(baseUrl, path), request);
+    }
+    
+    @Override
+    public RestResponse exchangeResource(String path, Object request, String method) throws ConfigRestAdaptorException {
+        return super.exchangeResource(formHttpHeaders(), constructUrl(baseUrl, path), request, method);
+    }
+    
+    private HttpHeaders formHttpHeaders() {
+        
+        HttpHeaders headers = new HttpHeaders();
+        
+        headers.setContentType(MediaType.APPLICATION_JSON);
+        headers.add("Accept", MediaType.APPLICATION_JSON_VALUE);
+        headers.add("X-FromAppId", application);
+        headers.add("X-TransactionId", generateUUID());
+        
+        return headers;
+    }
+    
+    private synchronized String generateUUID() {
+        return UUID.randomUUID().toString();
+    }
+}