portal-BE/src/main/java/org/onap/portal/controller/MicroserviceProxyController.java

   1 /*-
   2  * ============LICENSE_START==========================================
   3  * ONAP Portal
   4  * ===================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ===================================================================
   7  *
   8  * Unless otherwise specified, all software contained herein is licensed
   9  * under the Apache License, Version 2.0 (the "License");
  10  * you may not use this software except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *             http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  * Unless otherwise specified, all documentation contained herein is licensed
  22  * under the Creative Commons License, Attribution 4.0 Intl. (the "License");
  23  * you may not use this documentation except in compliance with the License.
  24  * You may obtain a copy of the License at
  25  *
  26  *             https://creativecommons.org/licenses/by/4.0/
  27  *
  28  * Unless required by applicable law or agreed to in writing, documentation
  29  * distributed under the License is distributed on an "AS IS" BASIS,
  30  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  31  * See the License for the specific language governing permissions and
  32  * limitations under the License.
  33  *
  34  * ============LICENSE_END============================================
  35  *
  36  *
  37  */
  38 package org.onap.portal.controller;
  39
  40 import com.fasterxml.jackson.databind.ObjectMapper;
  41 import java.io.IOException;
  42 import java.security.Principal;
  43 import javax.servlet.http.HttpServletRequest;
  44 import javax.servlet.http.HttpServletResponse;
  45 import org.onap.portal.domain.db.fn.FnUser;
  46 import org.onap.portal.service.MicroserviceProxyService;
  47 import org.onap.portal.service.user.FnUserService;
  48 import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate;
  49 import org.springframework.beans.factory.annotation.Autowired;
  50 import org.springframework.context.annotation.Configuration;
  51 import org.springframework.context.annotation.EnableAspectJAutoProxy;
  52 import org.springframework.web.bind.annotation.PathVariable;
  53 import org.springframework.web.bind.annotation.RequestMapping;
  54 import org.springframework.web.bind.annotation.RequestMethod;
  55 import org.springframework.web.bind.annotation.RestController;
  56 import org.springframework.web.client.HttpClientErrorException;
  57
  58 @RestController
  59 @Configuration
  60 @EnableAspectJAutoProxy
  61 public class MicroserviceProxyController {
  62
  63     private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(MicroserviceProxyController.class);
  64
  65     private final MicroserviceProxyService microserviceProxyService;
  66     private final FnUserService fnUserService;
  67
  68     @Autowired
  69     public MicroserviceProxyController(MicroserviceProxyService microserviceProxyService,
  70         FnUserService fnUserService) {
  71         this.microserviceProxyService = microserviceProxyService;
  72         this.fnUserService = fnUserService;
  73     }
  74
  75     @RequestMapping(value = {"/portalApi/microservice/proxy/{serviceId}"}, method = {
  76         RequestMethod.GET}, produces = "application/json")
  77     public String getMicroserviceProxy(Principal principal, HttpServletRequest request, HttpServletResponse response,
  78         @PathVariable("serviceId") long serviceId) throws Exception {
  79         FnUser user = fnUserService.loadUserByUsername(principal.getName());
  80         String answer = "";
  81         try {
  82             answer = microserviceProxyService.proxyToDestination(serviceId, user, request);
  83         } catch (HttpClientErrorException e) {
  84             answer = e.getResponseBodyAsString();
  85         }
  86         return isValidJSON(answer) ? answer
  87             : "{\"error\":\"" + answer.replace(System.getProperty("line.separator"), "") + "\"}";
  88     }
  89
  90     @RequestMapping(value = {"/portalApi/microservice/proxy/parameter/{widgetId}"}, method = {
  91         RequestMethod.GET}, produces = "application/json")
  92     public String getMicroserviceProxyByWidgetId(Principal principal, HttpServletRequest request,
  93         HttpServletResponse response,
  94         @PathVariable("widgetId") long widgetId) throws Exception {
  95         FnUser user = fnUserService.loadUserByUsername(principal.getName());
  96         String answer = "";
  97         try {
  98             answer = microserviceProxyService.proxyToDestinationByWidgetId(widgetId, user, request);
  99         } catch (HttpClientErrorException e) {
 100             answer = e.getResponseBodyAsString();
 101         }
 102         return isValidJSON(answer) ? answer
 103             : "{\"error\":\"" + answer.replace(System.getProperty("line.separator"), "") + "\"}";
 104     }
 105
 106     private boolean isValidJSON(String response) {
 107         try {
 108             final ObjectMapper mapper = new ObjectMapper();
 109             mapper.readTree(response);
 110             return true;
 111         } catch (IOException e) {
 112             logger.debug(EELFLoggerDelegate.debugLogger, "isValidJSON failed", e);
 113             return false;
 114         }
 115     }
 116 }