diff options
Diffstat (limited to 'ms/neng/src/main/java')
15 files changed, 1227 insertions, 0 deletions
diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/JerseyConfiguration.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/JerseyConfiguration.java new file mode 100644 index 00000000..4905e6eb --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/JerseyConfiguration.java @@ -0,0 +1,62 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core; + +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.databind.DeserializationFeature; +import com.fasterxml.jackson.databind.MapperFeature; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.SerializationFeature; +import javax.ws.rs.ApplicationPath; +import org.glassfish.jersey.server.ResourceConfig; +import org.glassfish.jersey.servlet.ServletProperties; +import org.onap.ccsdk.apps.ms.neng.core.service.rs.RestServiceImpl; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Primary; +import org.springframework.stereotype.Component; + +/** + * Configuration of the REST framework. + */ +@Component +@ApplicationPath("/") +public class JerseyConfiguration extends ResourceConfig { + /** + * Builds the bean configuring Jackson for JSON serialization. + */ + @Bean + @Primary + public ObjectMapper objectMapper() { + ObjectMapper objectMapper = new ObjectMapper(); + objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL); + objectMapper.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false); + objectMapper.enable(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES); + objectMapper.enable(DeserializationFeature.READ_ENUMS_USING_TO_STRING); + return objectMapper; + } + + @Autowired + public JerseyConfiguration() { + register(RestServiceImpl.class); + property(ServletProperties.FILTER_FORWARD_ON_404, true); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/WebConfiguration.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/WebConfiguration.java new file mode 100644 index 00000000..ca918eb9 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/WebConfiguration.java @@ -0,0 +1,69 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core; + +import org.onap.ccsdk.apps.ms.neng.core.rs.interceptors.AaiAuthorizationInterceptor; +import org.onap.ccsdk.apps.ms.neng.core.rs.interceptors.PolicyManagerAuthorizationInterceptor; +import org.springframework.boot.web.client.RestTemplateBuilder; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.web.servlet.config.annotation.ViewControllerRegistry; +import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter; + +/** + * Configuration for the API part of the micro-service. + */ +@Configuration +public class WebConfiguration { + /** + * Creates the bean for configuring swagger. + */ + @Bean + public WebMvcConfigurerAdapter forwardToIndex() { + return new WebMvcConfigurerAdapter() { + @Override + public void addViewControllers(ViewControllerRegistry registry) { + registry.addViewController("/swagger").setViewName("redirect:/swagger/index.html"); + registry.addViewController("/swagger/").setViewName("redirect:/swagger/index.html"); + registry.addViewController("/docs").setViewName("redirect:/docs/html/index.html"); + registry.addViewController("/docs/").setViewName("redirect:/docs/html/index.html"); + } + }; + } + + /** + * Creates the bean for configuring policy manager interceptor. + */ + @Bean + public RestTemplateBuilder policyMgrRestTempBuilder(PolicyManagerAuthorizationInterceptor auth) { + RestTemplateBuilder restTemplateBuiler = new RestTemplateBuilder(); + return restTemplateBuiler.additionalInterceptors(auth); + } + + /** + * Creates the bean for configuring A&AI interceptor. + */ + @Bean + public RestTemplateBuilder aaiRestTempBuilder(AaiAuthorizationInterceptor auth) { + RestTemplateBuilder restTemplateBuiler = new RestTemplateBuilder(); + return restTemplateBuiler.additionalInterceptors(auth); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/GetConfigRequest.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/GetConfigRequest.java new file mode 100644 index 00000000..e8bc555d --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/GetConfigRequest.java @@ -0,0 +1,77 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.resource.model; + +import java.io.Serializable; +import java.util.Map; + +/** + * POJO representing policy manager get-config request. + */ +public class GetConfigRequest implements Serializable { + private static final long serialVersionUID = -8039686696076337053L; + + Map<String, Object> configAttributes; + String configName; + String ecompName; + String policyName; + boolean unique; + + public Map<String, Object> getConfigAttributes() { + return configAttributes; + } + + public void setConfigAttributes(Map<String, Object> configAttributes) { + this.configAttributes = configAttributes; + } + + public String getConfigName() { + return configName; + } + + public void setConfigName(String configName) { + this.configName = configName; + } + + public String getEcompName() { + return ecompName; + } + + public void setEcompName(String ecompName) { + this.ecompName = ecompName; + } + + public String getPolicyName() { + return policyName; + } + + public void setPolicyName(String policyName) { + this.policyName = policyName; + } + + public boolean isUnique() { + return unique; + } + + public void setUnique(boolean unique) { + this.unique = unique; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/GetConfigResponse.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/GetConfigResponse.java new file mode 100644 index 00000000..9fe567f1 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/GetConfigResponse.java @@ -0,0 +1,39 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.resource.model; + +import java.io.Serializable; + +/** + * POJO representing policy manager get-config response. + */ +public class GetConfigResponse implements Serializable { + private static final long serialVersionUID = -8039686696076337053L; + Object response; + + public Object getResponse() { + return response; + } + + public void setResponse(Object response) { + this.response = response; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/HelloWorld.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/HelloWorld.java new file mode 100644 index 00000000..19de4e33 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/HelloWorld.java @@ -0,0 +1,51 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.resource.model; + +/** + * POJO representing the hello/ping/heart-beat operation request. + */ +public class HelloWorld { + String message; + + public HelloWorld() { + } + + public HelloWorld(String message) { + this.message = message; + } + + public String getMessage() { + return message; + } + + public void setMessage(String message) { + this.message = message; + } + + /** + * Gives a readable representation of this object. + */ + @Override + public String toString() { + return "message = " + getMessage(); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/NameGenRequest.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/NameGenRequest.java new file mode 100644 index 00000000..9fa91410 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/NameGenRequest.java @@ -0,0 +1,60 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.resource.model; + +import java.io.Serializable; +import java.util.List; +import java.util.Map; + +/** + * POJO representing the request from the client. + */ +public class NameGenRequest implements Serializable { + private static final long serialVersionUID = -8039686696076337053L; + + List<Map<String, String>> elements; + Boolean useDb; + + public List<Map<String, String>> getElements() { + return elements; + } + + public void setElements(List<Map<String, String>> elements) { + this.elements = elements; + } + + public Boolean getUseDb() { + return useDb; + } + + public void setUseDb(Boolean useDb) { + this.useDb = useDb; + } + + /** + * Gives a readable representation of this object. + */ + public String toString() { + StringBuffer buf = new StringBuffer(); + buf.append("elements: " + this.elements); + return buf.toString(); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/NameGenResponse.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/NameGenResponse.java new file mode 100644 index 00000000..c4ac7fcb --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/resource/model/NameGenResponse.java @@ -0,0 +1,41 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.resource.model; + +import java.io.Serializable; +import java.util.List; +import java.util.Map; + +/** + * POJO representing the response back to the client. + */ +public class NameGenResponse implements Serializable { + private static final long serialVersionUID = -8039686696076337053L; + List<Map<String, String>> elements; + + public List<Map<String, String>> getElements() { + return elements; + } + + public void setElements(List<Map<String, String>> elements) { + this.elements = elements; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/rs/interceptors/PolicyManagerAuthorizationInterceptor.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/rs/interceptors/PolicyManagerAuthorizationInterceptor.java new file mode 100644 index 00000000..c0a28f13 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/rs/interceptors/PolicyManagerAuthorizationInterceptor.java @@ -0,0 +1,52 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.rs.interceptors; + +import java.io.IOException; +import org.onap.ccsdk.apps.ms.neng.extinf.props.PolicyManagerProps; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.HttpRequest; +import org.springframework.http.client.ClientHttpRequestExecution; +import org.springframework.http.client.ClientHttpRequestInterceptor; +import org.springframework.http.client.ClientHttpResponse; +import org.springframework.stereotype.Component; + +/** + * Interceptor for adding authorization headers in the request to policy manager. + */ +@Component +public class PolicyManagerAuthorizationInterceptor implements ClientHttpRequestInterceptor { + @Autowired + PolicyManagerProps props; + + /** + * Intercepts the given request and adds additional headers, mainly for authorization. + */ + @Override + public ClientHttpResponse intercept(HttpRequest httpRequest, byte[] body, + ClientHttpRequestExecution executionChain) throws IOException { + httpRequest.getHeaders().add("ClientAuth", props.getClientAuth()); + httpRequest.getHeaders().add("Environment", props.getEnvironment()); + httpRequest.getHeaders().add("X-ECOMP-RequestID", props.getEcompRequestId()); + httpRequest.getHeaders().add("Authorization", props.getBasicAuth()); + return executionChain.execute(httpRequest, body); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/SpringService.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/SpringService.java new file mode 100644 index 00000000..1cdd61e1 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/SpringService.java @@ -0,0 +1,62 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.service; + +import org.onap.ccsdk.apps.ms.neng.core.resource.model.HelloWorld; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenRequest; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenResponse; +import org.onap.ccsdk.apps.ms.neng.persistence.entity.PolicyDetails; + +/** + * Specification for the implementation of the APIs exposed by this micro-service. + */ +public interface SpringService { + /** + * Name generation API. + */ + public NameGenResponse genNetworkElementName(NameGenRequest request) throws Exception; + + /** + * Name removal API. + */ + public NameGenResponse releaseNetworkElementName(NameGenRequest request) throws Exception; + + /** + * API to return naming policy cached in this micro-service. + * + * <p/>This is not used by clients -- it is here to help with diagnostics. + */ + public PolicyDetails getPolicyDetails(String policyName); + + /** + * API to add a naming policy to the database cache in this micro-service. + * + * <p/>This is not used by clients -- it is here to help with diagnostics. + */ + public void addPolicy(Object request) throws Exception; + + /** + * Heart-beat/ping API. + * + * <p/>This is not used by clients -- it is here to help with diagnostics. + */ + public HelloWorld getQuickHello(String name); +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/SpringServiceImpl.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/SpringServiceImpl.java new file mode 100644 index 00000000..72aee461 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/SpringServiceImpl.java @@ -0,0 +1,228 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import java.sql.Timestamp; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Set; +import java.util.logging.Logger; +import java.util.stream.Collectors; +import javax.transaction.Transactional; +import org.onap.ccsdk.apps.ms.neng.core.exceptions.NengException; +import org.onap.ccsdk.apps.ms.neng.core.gen.NameGenerator; +import org.onap.ccsdk.apps.ms.neng.core.persistence.NamePersister; +import org.onap.ccsdk.apps.ms.neng.core.policy.PolicyFinder; +import org.onap.ccsdk.apps.ms.neng.core.policy.PolicyParameters; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.HelloWorld; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenRequest; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenResponse; +import org.onap.ccsdk.apps.ms.neng.core.seq.SequenceGenerator; +import org.onap.ccsdk.apps.ms.neng.core.validator.AaiNameValidator; +import org.onap.ccsdk.apps.ms.neng.core.validator.DbNameValidator; +import org.onap.ccsdk.apps.ms.neng.core.validator.ExternalKeyValidator; +import org.onap.ccsdk.apps.ms.neng.persistence.entity.GeneratedName; +import org.onap.ccsdk.apps.ms.neng.persistence.entity.PolicyDetails; +import org.onap.ccsdk.apps.ms.neng.persistence.entity.ServiceParameter; +import org.onap.ccsdk.apps.ms.neng.persistence.repository.GeneratedNameRespository; +import org.onap.ccsdk.apps.ms.neng.persistence.repository.PolicyDetailsRepository; +import org.onap.ccsdk.apps.ms.neng.persistence.repository.ServiceParameterRepository; +import org.onap.ccsdk.apps.ms.neng.service.extinf.impl.AaiServiceImpl; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; +import org.springframework.stereotype.Service; + +/** + * Implementation of the APIs exposed by this micro-service. + */ +@Service +public class SpringServiceImpl implements SpringService { + private static Logger log = Logger.getLogger(SpringServiceImpl.class.getName()); + + @Autowired AaiServiceImpl aaiService; + @Autowired ExternalKeyValidator externalKeyValidator; + @Autowired @Qualifier("policyFinderServiceImpl") PolicyFinder policyFinder; + @Autowired @Qualifier("policyFinderServiceDBImpl") PolicyFinder policyFinderDbImpl; + @Autowired PolicyParameters policyParameters; + @Autowired SequenceGenerator sequenceGenerator; + @Autowired DbNameValidator dbNameValidator; + @Autowired PolicyDetailsRepository policyDetailsRepository; + @Autowired AaiNameValidator aaiNameValidator; + @Autowired NamePersister namePersister; + @Autowired ServiceParameterRepository serviceParamRepo; + @Autowired GeneratedNameRespository generatedNameRepository; + + /** + * Heart-beat/ping API. + */ + @Override + public HelloWorld getQuickHello(String name) { + if (name == null || name.isEmpty()) { + name = "world"; + } + String message = "Hello " + name + "!"; + log.info(message); + HelloWorld hello = new HelloWorld(message); + log.info(hello.toString()); + return hello; + } + + /** + * Name generation API. + */ + @Transactional(rollbackOn = Exception.class) + public NameGenResponse genNetworkElementName(NameGenRequest request) throws Exception { + try { + Map<String, Map<String, String>> earlierNames = new HashMap<String, Map<String, String>>(); + List<Map<String, String>> allElements = new ArrayList<Map<String, String>>(); + Map<String, Map<String, ?>> policyCache = new HashMap<String, Map<String, ?>>(); + List<Map<String, String>> generatedNames = new ArrayList<Map<String, String>>(); + validateRequest(request); + if (request.getElements() != null && request.getElements().size() > 0) { + allElements.addAll(request.getElements()); + } + PolicyFinder policyFinderImpl = findPolicyFinderImpl(request); + for (Map<String, String> requestElement : allElements) { + log.info("Processing " + requestElement.toString()); + NameGenerator nameGen = new NameGenerator(policyFinderImpl, policyParameters, sequenceGenerator, + dbNameValidator, aaiNameValidator, namePersister, requestElement, allElements, + earlierNames, policyCache); + generatedNames.add(nameGen.generate()); + } + NameGenResponse resp = new NameGenResponse(); + resp.setElements(generatedNames); + return resp; + } catch (Exception e) { + if (e instanceof NengException) { + throw e; + } else { + e.printStackTrace(); + throw new Exception("Internal error occurred while processing the request"); + } + } + } + + /** + * Name removal API. + */ + @Transactional(rollbackOn = Exception.class) + public NameGenResponse releaseNetworkElementName(NameGenRequest request) throws Exception { + NameGenResponse response = new NameGenResponse(); + Timestamp curTime = new Timestamp(System.currentTimeMillis()); + try { + for (Map<String, String> requestElement : request.getElements()) { + String key = requestElement.get("external-key"); + List<GeneratedName> generatedNames = generatedNameRepository.findByExternalId(key); + for (GeneratedName generatedName : generatedNames) { + generatedName.setIsReleased("Y"); + generatedName.setLastUpdatedTime(curTime); + } + buildUnAssignResponse(generatedNames, response); + } + return response; + } catch (Exception e) { + if (e instanceof NengException) { + throw e; + } else { + e.printStackTrace(); + throw new Exception("Internal error occurred while processing the request"); + } + } + } + + /** + * API to return naming policy cached in this micro-service. + */ + @Override + public PolicyDetails getPolicyDetails(String policyName) { + try { + return policyDetailsRepository.findPolicyResponseByName(policyName); + } catch (Exception e) { + return new PolicyDetails(); + } + } + + /** + * API to add a naming policy to the database cache in this micro-service. + */ + @Override + public void addPolicy(Object request) throws Exception { + try { + @SuppressWarnings("unchecked") + Map<String, Object> policyData = (Map<String, Object>)request; + PolicyDetails pd = new PolicyDetails(); + pd.setPolicyName((String) policyData.get("policyName")); + ObjectMapper objectmapper = new ObjectMapper(); + log.info(objectmapper.writeValueAsString(policyData.get("policyValue"))); + pd.setPolicyResponse(objectmapper.writeValueAsString(policyData.get("policyValue"))); + policyDetailsRepository.save(pd); + } catch (Exception e) { + log.warning(e.getMessage()); + } + } + + void buildUnAssignResponse(List<GeneratedName> generatedNames, NameGenResponse response) { + if (response.getElements() == null) { + response.setElements(new ArrayList<Map<String, String>>()); + } + for (GeneratedName generatedName : generatedNames) { + Map<String, String> element = new HashMap<>(); + element.put("external-key", generatedName.getExternalId()); + element.put("resource-name", generatedName.getElementType()); + element.put("resource-value", generatedName.getName()); + response.getElements().add(element); + } + } + + void validateRequest(NameGenRequest request) throws Exception { + List<Map<String, String>> elems = request.getElements(); + if (elems != null && elems.size() > 0) { + boolean error = false; + Set<String> externalKeySet = elems.stream().map(s -> s.get("external-key")).collect(Collectors.toSet()); + if (externalKeySet.size() != request.getElements().size()) { + error = true; + } + for (String externalKey : externalKeySet) { + if (externalKey == null || externalKeyValidator.isPresent(externalKey)) { + error = true; + } + } + if (error) { + throw new NengException("External Key is required and must be unique"); + } + } + } + + private PolicyFinder findPolicyFinderImpl(NameGenRequest request) { + if (request.getUseDb() != null && !request.getUseDb()) { + return this.policyFinder; + } + ServiceParameter param = serviceParamRepo.findByName("use_db_policy"); + if ((request.getUseDb() != null && request.getUseDb().booleanValue()) + || (param != null && "Y".equals(param.getValue()))) { + return policyFinderDbImpl; + } + return this.policyFinder; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/rs/RestService.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/rs/RestService.java new file mode 100644 index 00000000..f8da1eee --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/rs/RestService.java @@ -0,0 +1,102 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.service.rs; + +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiResponse; +import io.swagger.annotations.ApiResponses; +import java.util.List; +import java.util.Map; +import javax.validation.Valid; +import javax.ws.rs.DELETE; +import javax.ws.rs.GET; +import javax.ws.rs.POST; +import javax.ws.rs.Path; +import javax.ws.rs.Produces; +import javax.ws.rs.QueryParam; +import javax.ws.rs.core.MediaType; +import javax.ws.rs.core.Response; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenRequest; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenResponse; +import org.springframework.web.bind.annotation.RequestBody; + + +/** + * Specifies the properties of the REST-style interface/API to this micro-service. + */ +@Api +@Path("/service") +@Produces({MediaType.APPLICATION_JSON}) +public interface RestService { + /** + * Name generation API. + */ + @POST + @Path("/v1/genNetworkElementName") + @Produces({MediaType.APPLICATION_JSON}) + @ApiOperation(value = "Generates network element names, based on naming policies", + response = NameGenResponse.class) + @ApiResponses(value = {@ApiResponse(code = 404, message = "Service not available"), + @ApiResponse(code = 500, message = "Unexpected Runtime error")}) + public Response generateNetworkElementName(@RequestBody @Valid NameGenRequest request); + + /** + * Name removal API. + */ + @DELETE + @Path("/v1/genNetworkElementName") + @Produces({MediaType.APPLICATION_JSON}) + @ApiOperation(value = "Releases network element names", response = NameGenResponse.class) + @ApiResponses(value = {@ApiResponse(code = 404, message = "Service not available"), + @ApiResponse(code = 500, message = "Unexpected Runtime error")}) + public Response releaseNetworkElementName(@RequestBody @Valid NameGenRequest request); + + /** + * API to return naming policy cached in this micro-service. + * + * <p/>This is not used by clients -- it is here to help with diagnostics. + */ + @GET + @Path("/v1/getpolicyresponse/{policyName}") + @Produces({MediaType.APPLICATION_JSON}) + public List<Map<String, Object>> getPolicyResponse(@QueryParam("policyName") String policyName) throws Exception; + + /** + * API to add a naming policy to the database cache in this micro-service. + * + * <p/>This is not used by clients -- it is here to help with diagnostics. + */ + @POST + @Path("/v1/addPolicy") + @Produces({MediaType.APPLICATION_JSON}) + public Map<String, Object> addPolicyToDb(Object request) throws Exception; + + /** + * Heart-beat/ping API. + * + * <p/>This is not used by clients -- it is here to help with diagnostics. + */ + @GET + @Path("/hello") + @Produces({MediaType.APPLICATION_JSON}) + public Response getQuickHello(@QueryParam("name") String name); +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/rs/RestServiceImpl.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/rs/RestServiceImpl.java new file mode 100644 index 00000000..ed5723b6 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/rs/RestServiceImpl.java @@ -0,0 +1,116 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.service.rs; + +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.ObjectMapper; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.logging.Logger; +import javax.validation.Valid; +import javax.ws.rs.core.Response; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.HelloWorld; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenRequest; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenResponse; +import org.onap.ccsdk.apps.ms.neng.core.service.SpringService; +import org.onap.ccsdk.apps.ms.neng.persistence.entity.PolicyDetails; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; +import org.springframework.web.bind.annotation.RequestBody; + +/** + * Implementation of the REST-style interface/API to this micro-service. + */ +@Component +public class RestServiceImpl implements RestService { + private static Logger log = Logger.getLogger(RestServiceImpl.class.getName()); + + @Autowired SpringService service; + + /** + * Heart-beat/ping API. + */ + @Override + public Response getQuickHello(String name) { + log.info(name); + HelloWorld hw = service.getQuickHello(name); + return Response.ok().entity(hw).build(); + } + + /** + * Name generation API. + */ + @Override + public Response generateNetworkElementName(@RequestBody @Valid NameGenRequest request) { + log.info("Received request: " + request.toString()); + try { + NameGenResponse resp = service.genNetworkElementName(request); + return Response.ok().entity(resp).build(); + } catch (Exception e) { + log.warning(e.getMessage()); + return Response.status(500).entity("{ \"error\": \"" + e.getMessage() + "\" }").build(); + } + } + + /** + * Name removal API. + */ + @Override + public Response releaseNetworkElementName(NameGenRequest request) { + NameGenResponse resp; + try { + resp = service.releaseNetworkElementName(request); + return Response.ok().entity(resp).build(); + } catch (Exception e) { + log.warning(e.getMessage()); + return Response.status(500).entity("{ \"error\": \"" + e.getMessage() + "\" }").build(); + } + } + + /** + * API to return naming policy cached in this micro-service. + */ + @Override + public List<Map<String, Object>> getPolicyResponse(String policyName) throws Exception { + PolicyDetails policyDetails = service.getPolicyDetails(policyName); + List<Map<String, Object>> policyResponse = null; + ObjectMapper mapper = new ObjectMapper(); + policyResponse = mapper.readValue(policyDetails.getPolicyResponse(), + new TypeReference<List<Map<String, Object>>>() {}); + return policyResponse; + } + + /** + * API to add a naming policy to the database cache in this micro-service. + */ + @Override + public Map<String, Object> addPolicyToDb(Object request) throws Exception { + Map<String, Object> respMap = new HashMap<>(); + try { + service.addPolicy(request); + respMap.put("status", "Policy added successfully"); + } catch (Exception e) { + respMap.put("status", "Failed"); + } + return respMap; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/validator/ExternalKeyValidator.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/validator/ExternalKeyValidator.java new file mode 100644 index 00000000..28dde566 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/validator/ExternalKeyValidator.java @@ -0,0 +1,44 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.core.validator; + +import org.onap.ccsdk.apps.ms.neng.persistence.repository.GeneratedNameRespository; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * Checks if the external key in the request is already there in the DB or not. + */ +@Component +public class ExternalKeyValidator { + @Autowired + GeneratedNameRespository genNameRepo; + + /** + * Tells if the given external ID is present in the DB. + */ + public boolean isPresent(String externalId) { + if (genNameRepo.findByExternalId(externalId).size() > 0) { + return true; + } + return false; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/service/extinf/impl/PolicyFinderServiceDbImpl.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/service/extinf/impl/PolicyFinderServiceDbImpl.java new file mode 100644 index 00000000..d283b362 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/service/extinf/impl/PolicyFinderServiceDbImpl.java @@ -0,0 +1,59 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.service.extinf.impl; + +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.DeserializationFeature; +import com.fasterxml.jackson.databind.ObjectMapper; +import java.util.List; +import java.util.Map; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.GetConfigResponse; +import org.onap.ccsdk.apps.ms.neng.persistence.entity.PolicyDetails; +import org.onap.ccsdk.apps.ms.neng.persistence.repository.PolicyDetailsRepository; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; +import org.springframework.stereotype.Component; + +/** + * Finds policies from the database. + */ +@Component +@Qualifier("PolicyFinderDbImpl") +public class PolicyFinderServiceDbImpl extends PolicyFinderServiceImpl { + @Autowired + PolicyDetailsRepository policyDetailsRepo; + + /** + * Finds the policy with the given name from the DB. + */ + @Override + public GetConfigResponse getConfig(String policyName) throws Exception { + ObjectMapper objectmapper = new ObjectMapper(); + objectmapper.enable(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT); + PolicyDetails policyDetails = policyDetailsRepo.findPolicyResponseByName(policyName); + List<Map<Object, Object>> respObj = objectmapper.readValue(policyDetails.getPolicyResponse(), + new TypeReference<List<Map<Object, Object>>>() {}); + transformConfigObject(objectmapper, respObj); + GetConfigResponse configResp = new GetConfigResponse(); + configResp.setResponse(respObj); + return configResp; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/service/extinf/impl/PolicyFinderServiceImpl.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/service/extinf/impl/PolicyFinderServiceImpl.java new file mode 100644 index 00000000..a19c9153 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/service/extinf/impl/PolicyFinderServiceImpl.java @@ -0,0 +1,165 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.ccsdk.apps.ms.neng.service.extinf.impl; + +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.ObjectMapper; +import java.net.URI; +import java.security.cert.X509Certificate; +import java.util.List; +import java.util.Map; +import java.util.logging.Logger; +import javax.net.ssl.SSLContext; +import org.apache.http.conn.ssl.SSLConnectionSocketFactory; +import org.apache.http.conn.ssl.TrustStrategy; +import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.impl.client.HttpClients; +import org.onap.ccsdk.apps.ms.neng.core.exceptions.NengException; +import org.onap.ccsdk.apps.ms.neng.core.policy.PolicyFinder; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.GetConfigRequest; +import org.onap.ccsdk.apps.ms.neng.core.resource.model.GetConfigResponse; +import org.onap.ccsdk.apps.ms.neng.core.rs.interceptors.PolicyManagerAuthorizationInterceptor; +import org.onap.ccsdk.apps.ms.neng.extinf.props.PolicyManagerProps; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; +import org.springframework.boot.web.client.RestTemplateBuilder; +import org.springframework.http.HttpStatus; +import org.springframework.http.MediaType; +import org.springframework.http.RequestEntity; +import org.springframework.http.ResponseEntity; +import org.springframework.http.client.HttpComponentsClientHttpRequestFactory; +import org.springframework.stereotype.Component; +import org.springframework.web.client.HttpStatusCodeException; +import org.springframework.web.client.RestTemplate; + +/** + * Finds policies from policy manager. + */ +@Component +@Qualifier("PolicyFinderServiceImpl") +public class PolicyFinderServiceImpl implements PolicyFinder { + private static Logger log = Logger.getLogger(PolicyFinderServiceImpl.class.getName()); + + @Autowired PolicyManagerProps policManProps; + @Autowired + @Qualifier("policyMgrRestTempBuilder") + RestTemplateBuilder policyMgrRestTempBuilder; + @Autowired PolicyManagerAuthorizationInterceptor authInt; + RestTemplate restTemplate; + + /** + * Find policy with the given name from policy manager. + */ + @Override + public Map<String, Object> findPolicy(String policyName) throws Exception { + Object response = getConfig(policyName).getResponse(); + if (response instanceof List) { + @SuppressWarnings("unchecked") + List<Map<String, Object>> policyList = (List<Map<String, Object>>)response; + return ((policyList != null && policyList.size() > 0) ? policyList.get(0) : null); + } else { + return null; + } + } + + GetConfigResponse getConfig(String policyName) throws Exception { + GetConfigRequest getConfigRequest = new GetConfigRequest(); + getConfigRequest.setPolicyName(policyName); + GetConfigResponse getConfigResponse = makeOutboundCall(getConfigRequest, GetConfigResponse.class); + return getConfigResponse; + } + + <T, R> GetConfigResponse makeOutboundCall(T request, Class<R> response) throws Exception { + log.info("Policy Manager - " + policManProps.getUrl()); + RequestEntity<T> re = RequestEntity.post(new URI(policManProps.getUrl())) + .accept(MediaType.APPLICATION_JSON).contentType(MediaType.APPLICATION_JSON).body(request); + try { + ResponseEntity<Object> resp = getRestTemplate().exchange(re, Object.class); + if (HttpStatus.OK.equals(resp.getStatusCode())) { + ObjectMapper objectmapper = new ObjectMapper(); + System.out.println(objectmapper.writeValueAsString(resp.getBody())); + List<Map<Object, Object>> respObj = objectmapper.readValue( + objectmapper.writeValueAsString(resp.getBody()), + new TypeReference<List<Map<Object, Object>>>() {}); + transformConfigObject(objectmapper, respObj); + GetConfigResponse getConfigResp = new GetConfigResponse(); + getConfigResp.setResponse(respObj); + return getConfigResp; + } + } catch (HttpStatusCodeException e) { + handleError(e); + } + throw new NengException("Error while retrieving policy from policy manager."); + } + + void handleError(HttpStatusCodeException e) throws Exception { + String respString = e.getResponseBodyAsString(); + log.info(respString); + if (HttpStatus.NOT_FOUND.equals(e.getStatusCode()) && (respString != null && respString.contains(""))) { + throw new NengException("Policy not found in policy manager."); + } + throw new NengException("Error while retrieving policy from policy manager."); + } + + /** + * Transforms the 'config' element (which is received as a JSON string) to a map like a JSON object. + */ + void transformConfigObject(ObjectMapper objectmapper, List<Map<Object, Object>> respObj) throws Exception { + Object configElement = respObj.get(0).get("config"); + if (configElement instanceof String) { + Map<Object, Object> obj = objectmapper.readValue(configElement.toString(), + new TypeReference<Map<Object, Object>>() {}); + respObj.get(0).put("config", obj); + } + } + + RestTemplate getRestTemplate() throws Exception { + if (restTemplate != null) { + return restTemplate; + } + TrustStrategy acceptingTrustStrategy = (X509Certificate[] chain, String authType) -> true; + SSLContext sslContext = org.apache.http.ssl.SSLContexts.custom() + .loadTrustMaterial(null, acceptingTrustStrategy).build(); + SSLConnectionSocketFactory csf = new SSLConnectionSocketFactory(sslContext); + CloseableHttpClient httpClient = HttpClients.custom().setSSLSocketFactory(csf).build(); + HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory(); + requestFactory.setHttpClient(httpClient); + restTemplate = new RestTemplate(requestFactory); + restTemplate.getInterceptors().add(getAuthInt()); + return restTemplate; + } + + RestTemplateBuilder getPolicyMgrRestTempBuilder() { + return policyMgrRestTempBuilder; + } + + void setPolicyMgrRestTempBuilder(RestTemplateBuilder policyMgrRestTempBuilder) { + this.policyMgrRestTempBuilder = policyMgrRestTempBuilder; + } + + PolicyManagerAuthorizationInterceptor getAuthInt() { + return authInt; + } + + void setAuthInt(PolicyManagerAuthorizationInterceptor authInt) { + this.authInt = authInt; + } +} |