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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
|
/*-
* ================================================================================
* eCOMP Portal SDK
* ================================================================================
* Copyright (C) 2017 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.openecomp.portalsdk.core.restful.client;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import javax.servlet.http.HttpServletResponse;
import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.openecomp.portalsdk.core.domain.App;
import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
import org.openecomp.portalsdk.core.onboarding.crossapi.PortalApiConstants;
import org.openecomp.portalsdk.core.onboarding.crossapi.PortalApiProperties;
import org.openecomp.portalsdk.core.service.AppService;
import org.openecomp.portalsdk.core.util.CipherUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* Provides a basic client to access a REST endpoint at the Portal via get or
* post. Usage caveats:
* <OL>
* <LI>Must be auto-wired by Spring, because this in turn auto-wires a
* data-access service to read application credentials from the FN_APP table.
* <LI>If HTTP access is used and the server uses a self-signed certificate, the
* local trust store must be extended appropriately. The HTTP client throws
* exceptions if the JVM cannot validate the server certificate.
* </OL>
*/
@Component
public class PortalRestClientBase {
EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(PortalRestClientBase.class);
@Autowired
AppService appService;
/**
* Constructs and sends a GET request for the URI, with REST application
* credentials in the header as the Portal expects.
*
* @param uri
* URI of the service
* @return Result of the get; null if an error happens
* @throws URISyntaxException
* @throws IOException
* @throws ClientProtocolException
*/
public HttpStatusAndResponse getRestWithCredentials(final URI uri) throws Exception {
String uebKey = PortalApiProperties.getProperty(PortalApiConstants.UEB_APP_KEY);
App app = appService.getDefaultApp();
if (uebKey == null || app == null || app.getUsername() == null || app.getAppPassword() == null)
throw new Exception("Missing one or more required properties and/or database entries");
String decryptedPassword = CipherUtil.decrypt(app.getAppPassword());
CloseableHttpClient httpClient = HttpClients.createDefault();
HttpGet httpGet = new HttpGet(uri);
httpGet.setHeader("uebkey", uebKey);
httpGet.setHeader("username", app.getUsername());
httpGet.setHeader("password", decryptedPassword);
String responseJson = null;
CloseableHttpResponse response = null;
try {
logger.info(EELFLoggerDelegate.debugLogger, "GET from " + uri);
response = httpClient.execute(httpGet);
logger.info(EELFLoggerDelegate.debugLogger, "Status is " + response.getStatusLine());
if (response.getStatusLine().getStatusCode() != HttpServletResponse.SC_OK)
logger.info(EELFLoggerDelegate.debugLogger, "Status is " + response.getStatusLine().toString());
HttpEntity entity = response.getEntity();
if (entity == null) {
logger.info(EELFLoggerDelegate.debugLogger, "Entity is null!");
} else {
// entity content length is never set.
// this naively tries to read everything.
responseJson = EntityUtils.toString(entity);
logger.info(EELFLoggerDelegate.debugLogger, responseJson);
EntityUtils.consume(entity);
}
} finally {
if (response != null)
response.close();
}
if (response == null)
return null;
return new HttpStatusAndResponse(response.getStatusLine().getStatusCode(), responseJson);
}
/**
* Constructs and sends a POST request using the specified body, with REST
* application credentials in the header as the Portal expects.
*
* @param uri
* REST endpoint
* @param json
* Content to post
* @return Result of the post; null if an error happens
* @throws Exception
*/
public HttpStatusAndResponse postRestWithCredentials(final URI uri, final String json) throws Exception {
String uebKey = PortalApiProperties.getProperty(PortalApiConstants.UEB_APP_KEY);
App app = appService.getDefaultApp();
if (uebKey == null || app == null || app.getUsername() == null || app.getAppPassword() == null)
throw new Exception("Missing one or more required properties and/or database entries");
CloseableHttpClient httpClient = HttpClients.createDefault();
HttpPost httpPost = new HttpPost(uri);
httpPost.setHeader("uebkey", uebKey);
httpPost.setHeader("username", app.getUsername());
httpPost.setHeader("password", app.getAppPassword());
StringEntity postEntity = new StringEntity(json, ContentType.create("application/json", Consts.UTF_8));
httpPost.setEntity(postEntity);
String responseJson = null;
CloseableHttpResponse response = null;
try {
logger.info(EELFLoggerDelegate.debugLogger, "POST to " + uri);
response = httpClient.execute(httpPost);
logger.info(EELFLoggerDelegate.debugLogger, "Status is " + response.getStatusLine());
if (response.getStatusLine().getStatusCode() != HttpServletResponse.SC_OK)
throw new Exception("Status is " + response.getStatusLine().toString());
HttpEntity entity = response.getEntity();
if (entity == null) {
logger.info(EELFLoggerDelegate.debugLogger, "Entity is null!");
} else {
// entity content length is never set.
// this naively tries to read everything.
responseJson = EntityUtils.toString(entity);
logger.info(EELFLoggerDelegate.debugLogger, responseJson);
EntityUtils.consume(entity);
}
} finally {
if (response != null)
response.close();
}
return new HttpStatusAndResponse(response.getStatusLine().getStatusCode(), responseJson);
}
}
|
