blob: 2880f30247dcf4515b2018985c8e986ebad8cc4a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/*-
* ============LICENSE_START=======================================================
* ONAP : CCSDK.apps
* ================================================================================
* Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Modifications Copyright (C) 2018 IBM.
* ================================================================================
* 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.databind.ObjectMapper;
import java.net.URI;
import java.util.logging.Logger;
import org.apache.http.client.HttpClient;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.impl.client.HttpClientBuilder;
import org.onap.ccsdk.apps.ms.neng.core.exceptions.NengException;
import org.onap.ccsdk.apps.ms.neng.core.resource.model.AaiResponse;
import org.onap.ccsdk.apps.ms.neng.core.rs.interceptors.AaiAuthorizationInterceptor;
import org.onap.ccsdk.apps.ms.neng.extinf.props.AaiProps;
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.RequestEntity;
import org.springframework.http.ResponseEntity;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.stereotype.Service;
import org.springframework.web.client.HttpClientErrorException;
import org.springframework.web.client.RestTemplate;
/**
* Implements interface with A&AI.
*/
@Service
public class AaiServiceImpl {
private static final Logger log = Logger.getLogger(AaiServiceImpl.class.getName());
@Autowired
AaiProps aaiProps;
RestTemplate restTemplate;
@Autowired
AaiAuthorizationInterceptor authInt;
@Autowired
@Qualifier("aaiRestTempBuilder")
RestTemplateBuilder aaiRestTempBuilder;
/**
* Validates the given network element name against A&AI, using the given URL.
*
* @param url the URL for A&AI
* @param name a generated network element name
* @return true if the element name is valid
*/
public boolean validate(String url, String name) throws Exception {
AaiResponse resp = makeOutboundCall(url, name);
return !resp.isRecFound();
}
public void setAaiRestTempBuilder(RestTemplateBuilder aaiRestTempBuilder) {
this.aaiRestTempBuilder = aaiRestTempBuilder;
}
public void setRestTemplate(RestTemplate restTemplate) {
this.restTemplate = restTemplate;
}
AaiResponse makeOutboundCall(String url, String name) throws Exception {
String uri = aaiProps.getUriBase() + url + name;
log.info("AAI URI - " + uri);
ResponseEntity<Object> resp = null;
try {
RequestEntity<Void> re = RequestEntity.get(new URI(uri)).build();
resp = getRestTemplate().exchange(re, Object.class);
if (HttpStatus.OK.equals(resp.getStatusCode())) {
ObjectMapper objectmapper = new ObjectMapper();
log.info(objectmapper.writeValueAsString(resp.getBody()));
return buildResponse(true);
} else if (HttpStatus.NOT_FOUND.equals(resp.getStatusCode())) {
log.warning(resp.toString());
return buildResponse(false);
} else {
log.warning(resp.toString());
throw new NengException("Error while validating name with A&AI");
}
} catch (HttpClientErrorException e) {
log.warning(e.getStatusCode() + " -- " + e.getResponseBodyAsString());
if (HttpStatus.NOT_FOUND.equals(e.getStatusCode())) {
return buildResponse(false);
}
throw new NengException("Error while validating name with AAI");
}
}
AaiResponse buildResponse(boolean found) {
AaiResponse aaiResp = new AaiResponse();
aaiResp.setRecFound(found);
return aaiResp;
}
RestTemplate getRestTemplate() {
if (this.restTemplate == null) {
System.setProperty("javax.net.ssl.trustStore", aaiProps.getCert());
System.setProperty("javax.net.ssl.trustStorePassword", aaiProps.getCertPassword());
RestTemplateBuilder restBld = aaiRestTempBuilder.additionalInterceptors(authInt);
HttpClient client = HttpClientBuilder.create()
.setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE)
.build();
//this.restTemplate = restBld.requestFactory(new HttpComponentsClientHttpRequestFactory(client)).build();
}
return this.restTemplate;
}
public void setAaiProps(AaiProps aaiProps) {
this.aaiProps = aaiProps;
}
}
|
