2 * ================================================================================
\r
4 * ================================================================================
\r
5 * Copyright (C) 2017 AT&T Intellectual Property
\r
6 * ================================================================================
\r
7 * Licensed under the Apache License, Version 2.0 (the "License");
\r
8 * you may not use this file except in compliance with the License.
\r
9 * You may obtain a copy of the License at
\r
11 * http://www.apache.org/licenses/LICENSE-2.0
\r
13 * Unless required by applicable law or agreed to in writing, software
\r
14 * distributed under the License is distributed on an "AS IS" BASIS,
\r
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
16 * See the License for the specific language governing permissions and
\r
17 * limitations under the License.
\r
18 * ================================================================================
\r
20 package org.openecomp.portalapp.portal.controller;
\r
22 import java.io.File;
\r
23 import java.io.FileInputStream;
\r
24 import java.io.FileOutputStream;
\r
25 import java.io.IOException;
\r
26 import java.io.OutputStream;
\r
27 import java.util.ArrayList;
\r
28 import java.util.List;
\r
30 import javax.servlet.ServletContext;
\r
31 import javax.servlet.http.HttpServletRequest;
\r
32 import javax.servlet.http.HttpServletResponse;
\r
34 import org.openecomp.portalapp.controller.EPRestrictedBaseController;
\r
35 import org.openecomp.portalapp.portal.domain.EPUser;
\r
36 import org.openecomp.portalapp.portal.domain.MicroserviceData;
\r
37 import org.openecomp.portalapp.portal.domain.MicroserviceParameter;
\r
38 import org.openecomp.portalapp.portal.domain.WidgetCatalog;
\r
39 import org.openecomp.portalapp.portal.domain.WidgetCatalogParameter;
\r
40 import org.openecomp.portalapp.portal.domain.WidgetParameterResult;
\r
41 import org.openecomp.portalapp.portal.domain.WidgetServiceHeaders;
\r
42 import org.openecomp.portalapp.portal.ecomp.model.PortalRestResponse;
\r
43 import org.openecomp.portalapp.portal.ecomp.model.PortalRestStatusEnum;
\r
44 import org.openecomp.portalapp.portal.logging.aop.EPAuditLog;
\r
45 import org.openecomp.portalapp.portal.service.ConsulHealthService;
\r
46 import org.openecomp.portalapp.portal.service.MicroserviceService;
\r
47 import org.openecomp.portalapp.portal.service.WidgetParameterService;
\r
48 import org.openecomp.portalapp.util.EPUserUtils;
\r
49 import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
\r
50 import org.springframework.beans.factory.annotation.Autowired;
\r
51 import org.springframework.context.annotation.Bean;
\r
52 import org.springframework.context.annotation.EnableAspectJAutoProxy;
\r
53 import org.springframework.core.io.FileSystemResource;
\r
54 import org.springframework.http.HttpEntity;
\r
55 import org.springframework.http.HttpHeaders;
\r
56 import org.springframework.http.HttpMethod;
\r
57 import org.springframework.http.MediaType;
\r
58 import org.springframework.http.ResponseEntity;
\r
59 import org.springframework.util.LinkedMultiValueMap;
\r
60 import org.springframework.util.MultiValueMap;
\r
61 import org.springframework.web.bind.annotation.PathVariable;
\r
62 import org.springframework.web.bind.annotation.RequestBody;
\r
63 import org.springframework.web.bind.annotation.RequestMapping;
\r
64 import org.springframework.web.bind.annotation.RequestMethod;
\r
65 import org.springframework.web.bind.annotation.RestController;
\r
66 import org.springframework.web.client.RestClientException;
\r
67 import org.springframework.web.client.RestTemplate;
\r
68 import org.springframework.web.multipart.MultipartFile;
\r
69 import org.springframework.web.multipart.MultipartHttpServletRequest;
\r
70 import org.springframework.web.multipart.commons.CommonsMultipartResolver;
\r
72 @SuppressWarnings("unchecked")
\r
74 @org.springframework.context.annotation.Configuration
\r
75 @EnableAspectJAutoProxy
\r
77 public class WidgetsCatalogController extends EPRestrictedBaseController {
\r
79 private static final String HTTPS = "https://";
\r
81 EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(WidgetsCatalogController.class);
\r
82 RestTemplate template = new RestTemplate();
\r
83 String whatService = "widgets-service";
\r
86 private ConsulHealthService consulHealthService;
\r
89 private MicroserviceService microserviceService;
\r
92 private WidgetParameterService widgetParameterService;
\r
95 public CommonsMultipartResolver multipartResolver() {
\r
96 return new CommonsMultipartResolver();
\r
100 // for localhost testing only
\r
101 javax.net.ssl.HttpsURLConnection.setDefaultHostnameVerifier(new javax.net.ssl.HostnameVerifier() {
\r
103 public boolean verify(String hostname, javax.net.ssl.SSLSession sslSession) {
\r
104 if (hostname.equals("localhost")) {
\r
112 @RequestMapping(value = { "/portalApi/microservices/widgetCatalog/{loginName}" }, method = RequestMethod.GET)
\r
113 public List<WidgetCatalog> getUserWidgetCatalog(HttpServletRequest request, HttpServletResponse response,
\r
114 @PathVariable("loginName") String loginName) throws RestClientException, Exception {
\r
115 List<WidgetCatalog> widgets = new ArrayList<>();
\r
117 ResponseEntity<ArrayList> ans = template.exchange(
\r
118 HTTPS + consulHealthService.getServiceLocation(whatService)
\r
119 + "/widget/microservices/widgetCatalog/" + loginName,
\r
120 HttpMethod.GET, new HttpEntity(WidgetServiceHeaders.getInstance()), ArrayList.class);
\r
121 widgets = ans.getBody();
\r
122 } catch (Exception e) {
\r
123 logger.error(EELFLoggerDelegate.errorLogger, "getUserWidgetCatalog failed", e);
\r
124 // returning null because null help check on the UI if there was a
\r
125 // communication problem with Microservice.
\r
131 @RequestMapping(value = { "/portalApi/microservices/widgetCatalog" }, method = RequestMethod.GET)
\r
132 public List<WidgetCatalog> getWidgetCatalog(HttpServletRequest request, HttpServletResponse response)
\r
133 throws RestClientException, Exception {
\r
134 List<WidgetCatalog> widgets = new ArrayList<>();
\r
136 ResponseEntity<ArrayList> ans = template.exchange(
\r
137 HTTPS + consulHealthService.getServiceLocation(whatService)
\r
138 + "/widget/microservices/widgetCatalog",
\r
139 HttpMethod.GET, new HttpEntity(WidgetServiceHeaders.getInstance()), ArrayList.class);
\r
140 widgets = ans.getBody();
\r
141 } catch (Exception e) {
\r
142 logger.error(EELFLoggerDelegate.errorLogger, "getWidgetCatalog failed", e);
\r
143 // returning null because null help check on the UI if there was a
\r
144 // communication problem with Microservice.
\r
150 @RequestMapping(value = {
\r
151 "/portalApi/microservices/widgetCatalog/{widgetId}" }, method = RequestMethod.PUT, produces = "application/json")
\r
152 public void updateWidgetCatalog(HttpServletRequest request, HttpServletResponse response,
\r
153 @RequestBody WidgetCatalog newWidgetCatalog, @PathVariable("widgetId") long widgetId)
\r
154 throws RestClientException, Exception {
\r
156 HTTPS + consulHealthService.getServiceLocation(whatService)
\r
157 + "/widget/microservices/widgetCatalog/" + widgetId,
\r
158 HttpMethod.PUT, new HttpEntity(newWidgetCatalog, WidgetServiceHeaders.getInstance()), String.class);
\r
161 @RequestMapping(value = { "/portalApi/microservices/widgetCatalog/{widgetId}" }, method = RequestMethod.DELETE)
\r
162 public void deleteOnboardingWidget(HttpServletRequest request, HttpServletResponse response,
\r
163 @PathVariable("widgetId") long widgetId) throws RestClientException, Exception {
\r
165 HTTPS + consulHealthService.getServiceLocation(whatService)
\r
166 + "/widget/microservices/widgetCatalog/" + widgetId,
\r
167 HttpMethod.DELETE, new HttpEntity(WidgetServiceHeaders.getInstance()), String.class);
\r
170 @RequestMapping(value = { "/portalApi/microservices/widgetCatalog/{widgetId}" }, method = RequestMethod.POST)
\r
171 public String updateWidgetCatalogWithFiles(HttpServletRequest request, HttpServletResponse response,
\r
172 @PathVariable("widgetId") long widgetId) throws RestClientException, Exception {
\r
173 MultipartHttpServletRequest mRequest;
\r
174 MultiValueMap<String, Object> multipartRequest = new LinkedMultiValueMap<>();
\r
176 String tmp_folder = "/tmp/";
\r
177 String respond = null;
\r
178 FileOutputStream fo = null;
\r
180 mRequest = (MultipartHttpServletRequest) request;
\r
181 MultipartFile mFile = mRequest.getFile("file");
\r
182 fileName = mFile.getOriginalFilename();
\r
183 fo = new FileOutputStream(tmp_folder + fileName);
\r
184 fo.write(mFile.getBytes());
\r
186 HttpHeaders header = new HttpHeaders();
\r
187 header.setContentType(MediaType.MULTIPART_FORM_DATA);
\r
188 multipartRequest.add("file", new FileSystemResource(tmp_folder + fileName));
\r
189 multipartRequest.add("widget", request.getParameter("newWidget"));
\r
190 respond = template.postForObject(
\r
191 HTTPS + consulHealthService.getServiceLocation(whatService)
\r
192 + "/widget/microservices/widgetCatalog/" + widgetId,
\r
193 new HttpEntity<>(multipartRequest, WidgetServiceHeaders.getInstance()), String.class);
\r
194 File f = new File(tmp_folder + fileName);
\r
196 } catch (Exception e) {
\r
197 logger.error(EELFLoggerDelegate.errorLogger, "updateWidgetCatalogWithFiles failed", e);
\r
202 } catch (IOException e) {
\r
203 logger.error(EELFLoggerDelegate.errorLogger, "updateWidgetCatalogWithFiles failed 2", e);
\r
209 @RequestMapping(value = { "/portalApi/microservices/widgetCatalog" }, method = RequestMethod.POST)
\r
210 public String createWidgetCatalog(HttpServletRequest request, HttpServletResponse response)
\r
211 throws RestClientException, Exception {
\r
212 MultipartHttpServletRequest mRequest;
\r
213 MultiValueMap<String, Object> multipartRequest = new LinkedMultiValueMap<>();
\r
215 String tmp_folder = "/tmp/";
\r
216 String respond = null;
\r
217 FileOutputStream fo = null;
\r
219 mRequest = (MultipartHttpServletRequest) request;
\r
220 MultipartFile mFile = mRequest.getFile("file");
\r
221 fileName = mFile.getOriginalFilename();
\r
222 fo = new FileOutputStream(tmp_folder + fileName);
\r
223 fo.write(mFile.getBytes());
\r
225 HttpHeaders header = new HttpHeaders();
\r
226 header.setContentType(MediaType.MULTIPART_FORM_DATA);
\r
227 multipartRequest.add("file", new FileSystemResource(tmp_folder + fileName));
\r
228 multipartRequest.add("widget", request.getParameter("newWidget"));
\r
230 respond = template.postForObject(
\r
231 HTTPS + consulHealthService.getServiceLocation(whatService)
\r
232 + "/widget/microservices/widgetCatalog",
\r
233 new HttpEntity<>(multipartRequest, WidgetServiceHeaders.getInstance()), String.class);
\r
234 File f = new File(tmp_folder + fileName);
\r
236 } catch (Exception e) {
\r
237 logger.error(EELFLoggerDelegate.errorLogger, "createWidgetCatalog failed", e);
\r
242 } catch (IOException e) {
\r
243 logger.error(EELFLoggerDelegate.errorLogger, "createWidgetCatalog failed 2", e);
\r
249 @RequestMapping(value = "/portalApi/microservices/{widgetId}/framework.js", method = RequestMethod.GET)
\r
250 public String getWidgetFramework(HttpServletRequest request, HttpServletResponse response,
\r
251 @PathVariable("widgetId") long widgetId) throws RestClientException, Exception {
\r
252 return template.getForObject(HTTPS + consulHealthService.getServiceLocation(whatService)
\r
253 + "/widget/microservices/" + widgetId + "/framework.js", String.class,
\r
254 WidgetServiceHeaders.getInstance());
\r
257 @RequestMapping(value = "/portalApi/microservices/{widgetId}/controller.js", method = RequestMethod.GET)
\r
258 public String getWidgetController(HttpServletRequest request, HttpServletResponse response,
\r
259 @PathVariable("widgetId") long widgetId) throws RestClientException, Exception {
\r
260 return template.getForObject(HTTPS + consulHealthService.getServiceLocation(whatService)
\r
261 + "/widget/microservices/" + widgetId + "/controller.js", String.class,
\r
262 WidgetServiceHeaders.getInstance());
\r
265 @RequestMapping(value = "/portalApi/microservices/{widgetId}/style.css", method = RequestMethod.GET)
\r
266 public String getWidgetCSS(HttpServletRequest request, HttpServletResponse response,
\r
267 @PathVariable("widgetId") long widgetId) throws RestClientException, Exception {
\r
268 return template.getForObject(HTTPS + consulHealthService.getServiceLocation(whatService)
\r
269 + "/widget/microservices/" + widgetId + "/styles.css", String.class,
\r
270 WidgetServiceHeaders.getInstance());
\r
273 @RequestMapping(value = { "/portalApi/microservices/parameters/{widgetId}" }, method = RequestMethod.GET)
\r
274 public PortalRestResponse<List<WidgetParameterResult>> getWidgetParameterResult(HttpServletRequest request,
\r
275 HttpServletResponse response, @PathVariable("widgetId") long widgetId) throws Exception {
\r
276 EPUser user = EPUserUtils.getUserSession(request);
\r
278 List<WidgetParameterResult> list = new ArrayList<>();
\r
279 Long serviceId = template.exchange(
\r
280 HTTPS + consulHealthService.getServiceLocation(whatService)
\r
281 + "/widget/microservices/widgetCatalog/parameters/" + widgetId,
\r
282 HttpMethod.GET, new HttpEntity(WidgetServiceHeaders.getInstance()), Long.class).getBody();
\r
283 if (serviceId == null) {
\r
284 // return ok/sucess and no service parameter for this widget
\r
285 return new PortalRestResponse<List<WidgetParameterResult>>(PortalRestStatusEnum.WARN,
\r
286 "No service parameters for this widget", list);
\r
288 List<MicroserviceParameter> defaultParam = microserviceService.getParametersById(serviceId);
\r
289 for (MicroserviceParameter param : defaultParam) {
\r
290 WidgetParameterResult user_result = new WidgetParameterResult();
\r
291 user_result.setParam_id(param.getId());
\r
292 user_result.setDefault_value(param.getPara_value());
\r
293 user_result.setParam_key(param.getPara_key());
\r
294 WidgetCatalogParameter userValue = widgetParameterService.getUserParamById(widgetId, user.getId(),
\r
296 if (userValue == null)
\r
297 user_result.setUser_value(param.getPara_value());
\r
299 user_result.setUser_value(userValue.getUser_value());
\r
301 list.add(user_result);
\r
304 return new PortalRestResponse<List<WidgetParameterResult>>(PortalRestStatusEnum.OK, "SUCCESS", list);
\r
307 @RequestMapping(value = { "/portalApi/microservices/services/{paramId}" }, method = RequestMethod.GET)
\r
308 public List<WidgetCatalogParameter> getUserParameterById(HttpServletRequest request, HttpServletResponse response,
\r
309 @PathVariable("paramId") long paramId) throws Exception {
\r
310 List<WidgetCatalogParameter> list = widgetParameterService.getUserParameterById(paramId);
\r
314 @RequestMapping(value = { "/portalApi/microservices/services/{paramId}" }, method = RequestMethod.DELETE)
\r
315 public void deleteUserParameterById(HttpServletRequest request, HttpServletResponse response,
\r
316 @PathVariable("paramId") long paramId) throws Exception {
\r
317 widgetParameterService.deleteUserParameterById(paramId);
\r
320 @RequestMapping(value = { "/portalApi/microservices/download/{widgetId}" }, method = RequestMethod.GET)
\r
321 public void doDownload(HttpServletRequest request, HttpServletResponse response,
\r
322 @PathVariable("widgetId") long widgetId) throws RestClientException, Exception {
\r
324 ServletContext context = request.getServletContext();
\r
325 byte[] byteFile = template.exchange(HTTPS + consulHealthService.getServiceLocation(whatService) + "/widget/microservices/download/" + widgetId,
\r
326 HttpMethod.GET, new HttpEntity(WidgetServiceHeaders.getInstance()), byte[].class).getBody();
\r
327 String fileLocation = widgetId + ".zip";
\r
328 FileOutputStream stream = new FileOutputStream(fileLocation);
\r
329 stream.write(byteFile);
\r
332 File downloadFile = new File(fileLocation);
\r
333 FileInputStream inputStream = new FileInputStream(downloadFile);
\r
334 String mimeType = context.getMimeType(downloadFile.getPath());
\r
335 if (mimeType == null) {
\r
336 mimeType = "application/octet-stream";
\r
339 response.setContentType(mimeType);
\r
340 response.setContentLength((int) downloadFile.length());
\r
341 String headerKey = "Content-Disposition";
\r
342 String headerValue = String.format("attachment; filename=\"%s\"", downloadFile.getName());
\r
343 downloadFile.delete();
\r
344 response.setHeader(headerKey, headerValue);
\r
346 OutputStream outStream = response.getOutputStream();
\r
347 byte[] buffer = new byte[32 * 1024];
\r
348 int bytesRead = -1;
\r
349 while ((bytesRead = inputStream.read(buffer)) != -1) {
\r
350 outStream.write(buffer, 0, bytesRead);
\r
353 inputStream.close();
\r
357 @RequestMapping(value = { "/portalApi/microservices/parameters" }, method = RequestMethod.POST)
\r
358 public PortalRestResponse<String> saveWidgetParameter(HttpServletRequest request, HttpServletResponse response,
\r
359 @RequestBody WidgetCatalogParameter widgetParameters) throws Exception {
\r
360 EPUser user = EPUserUtils.getUserSession(request);
\r
361 widgetParameters.setUserId(user.getId());
\r
363 WidgetCatalogParameter oldParam = widgetParameterService.getUserParamById(widgetParameters.getWidgetId(),
\r
364 widgetParameters.getUserId(), widgetParameters.getParamId());
\r
365 if (oldParam != null) {
\r
366 widgetParameters.setId(oldParam.getId());
\r
368 widgetParameterService.saveUserParameter(widgetParameters);
\r
370 } catch (Exception e) {
\r
371 return new PortalRestResponse<String>(PortalRestStatusEnum.ERROR, "FAILURE", e.getMessage());
\r
373 return new PortalRestResponse<String>(PortalRestStatusEnum.OK, "SUCCESS", "");
\r